`
k1121
  • 浏览: 179068 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

使用Pushlet将消息从服务器端推送到客户端

 
阅读更多

使用Pushlet来实现服务器端向客户端推送信息

1.   实现方式:

有两种实现方式:

1.         通过配置文件来实现定时的从服务器端向客户端推送信息

2.         通过API主动向另外一端推送信息

 

以下分别给予介绍。

 

2.   特别注意

在开始测试之前,有三点非常重要,需要实现讲明,否则程序将会无法正常运行:

2.1.     JSP页面上的设定

JSP页面上必须添加以下代码以确保Pushlet能够正确的获得后台服务的地址:

<base href="<%=request.getContextPath()%>">

 

2.2.     PushletJS文件的Bug修改

需要修改被引用的JS文件ajax-pushlet-client.js的内容,找到

PL.pushletURL = PL._getWebRoot() + 'pushlet.srv';

将其修改为

PL.pushletURL = 'pushlet.srv';

修改的原因是Pushlet进行地址解析的方法在某些应用中会解析错误,导致请求的路径是nullpushlet.srv?,最终导致无法正确的请求到服务器的信息。

 

2.3.     中文问题

一般情况下,如果不做特殊处理,中文问题将会导致Pushlet的客户端停止响应,解决办法是,在使用Pushlet的客户端代码发送消息之前,将其进行转码,代码为

encodeURIComponent( msg)

3.   正式开始

以上准备工作完毕,就可以正式的开发测试样例了。

 

3.1.     定时的从后台向前台push信息

(1)       eclipse中创建一个动态的web工程

(2)       配置及库文件文件:从http://www.pushlets.com/ 下载最新的pushlet的开发包,将其中的以下文件按照描述进行设定

序号

文件名

源位置

目标位置

备注

1.         

pushlet.jar

{pushlet-2.0.4}\lib

项目类路径

如果使用的是applet的话,还需要将pushletclient.jar设置到项目的类路径中去

2.         

log4j.properties

pushlet.properties

sources.properties

{pushlet-2.0.4}\webapps\pushlet\WEB-INF\classes

项目的src根路径

注意稍后需要修改sources.properties,其他两个文件的内容不需要修改

3.         

ajax-pushlet-client.js

{pushlet-2.0.4}\webapps\pushlet\lib

项目的webroot\lib

需要按照之前的描述修改其中的内容

(3)       修改web.xml,将pushlet的自启动servlet添加进去

  <servlet>

    <servlet-name>pushlet</servlet-name>

    <servlet-class>nl.justobjects.pushlet.servlet.Pushlet</servlet-class>

    <load-on-startup>1</load-on-startup>

  </servlet>

  <servlet-mapping>

    <servlet-name>pushlet</servlet-name>

    <url-pattern>/pushlet.srv</url-pattern>

  </servlet-mapping>

(4)       创建服务器端代码,特别注意类和内部静态类的名字

 

package com.guoguo;

 

import java.io.Serializable;

import java.io.UnsupportedEncodingException;

import sun.rmi.runtime.Log;

import nl.justobjects.pushlet.core.Event;

import nl.justobjects.pushlet.core.EventPullSource;

 

 

public class HelloWorldPushlet implements Serializable {

 

     

      private static final long serialVersionUID = -8940934044114406724L;

 

      public static class HWPushlet extends EventPullSource {

           Log log = Log.getLog(HWPushlet.class.getName(),

                      HWPushlet.class.getName(), true);

 

          

           @Override

           protected long getSleepTime() {

                 return 1000;//每一秒钟自动执行一次

           }

 

          

           @Override

           protected Event pullEvent() {

             //注意,一下是设定消息的主题/guoguo/helloworld,号称主题是可以继承的

            //但是笔者的测试是失败的,也许方法不对,呵呵

                 Event event = Event.createDataEvent("/guoguo/helloworld");

                 String data= "hello,world 郭强 "+System.currentTimeMillis();

                 try {

                      data=new String(data.getBytes("UTF-8"),"ISO-8859-1");

                 } catch (UnsupportedEncodingException e) {

                      e.printStackTrace();

                 }

                 event.setField("hw",data);

                 return event;

           }

 

      }

}

 

(5)       注册服务器端代码为事件源,在sources.properties文件中,添加以下行

source7=com.guoguo.HelloWorldPushlet$HWPushlet

以上方式适用于有内部类的情况,如果没有内部类的话,使用以下的方式进行注册(这时外部类必须继承父类EventPullSource)

source7=com.guoguo.HelloWorldPushlet

(6)       页面(可以参考页面内注释信息)

<%@ page language="java" contentType="text/html; charset=ISO-8859-1"

      pageEncoding="ISO-8859-1"%>

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN""http://www.w3.org/TR/html4/loose.dtd">

<html>

<head>

<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">

<title>Pushlet Test</title>

<meta http-equiv="pragma" content="no-cache"> 

<meta http-equiv="cache-control" content="no-cache">

<base href="<%=request.getContextPath()%>">

</head>

<body>

      <script type="text/javascript" src="lib/ajax-pushlet-client.js"></script>

      <div id="guoguo"></div>

      <script type="text/javascript">

          //初始化pushlet客户端

           PL._init();

        //设定运行时显示调试信息,不需要时,直接删掉即可

           PL.setDebug(true);

        //设定监听主题:/guoguo/helloworld,与服务器端的主题完全一致

           PL.joinListen('/guoguo/helloworld');

        //接收到事件后,显示服务器信息

           function onData(event) {

                 guoguo.innerText=(event.get("hw"));

           }

      </script>

      <p1>Pushlet Test</p1>

</body>

</html>

(7)       启动服务器,即可看到页面上的信息每秒钟一次,进行定时的更新

3.2.     主动控制发送消息

3.2.1.   有刷新的提交信息(服务器端主动发送消息)

(1)       创建一个servlet,并且注册到web.xml

Servlet代码

package com.guoguo;

 

import java.io.IOException;

 

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

 

import nl.justobjects.pushlet.core.Dispatcher;

import nl.justobjects.pushlet.core.Event;

import nl.justobjects.pushlet.core.SessionManager;

 

 

public class ChatServlet extends HttpServlet {

         private static final long serialVersionUID = 1L;

 

        

         public ChatServlet() {

                   super();

         }

 

        

         protected void service(HttpServletRequest request,

                            HttpServletResponse response) throws ServletException, IOException {

                   // myUnicast();

                   myMulticast();

                   // myBroadcast();

                   request.getRequestDispatcher("chat.jsp").forward(request, response);

         }

 

         private void myUnicast() {

 

                   Event event = Event.createDataEvent("/guoguo/myevent1");

                   event.setField("key1", "Unicast msg");

                   Dispatcher.getInstance().unicast(event, "piero"); // IDpiero的用户推送

                   System.out.println("success....");

         }

 

         private void myMulticast() {

                   Event event = Event.createDataEvent("/guoguo/myevent1");

                   //Event event = Event.createDataEvent("/guoguo");

                   event.setField("key1", "Multicast msg");

                   Dispatcher.getInstance().multicast(event); // 向所有和myevent1名称匹配的事件推送

 

                   System.out.println("wa success....");

 

         }

 

         private void myBroadcast() {

                   Event event = Event.createDataEvent("/guoguo/myevent1"); // 向所有的事件推送,不要求和这儿的myevent1名称匹配

                   event.setField("key1", "Broadcast msg");

                   Dispatcher.getInstance().broadcast(event);

 

                   System.out.println("asw success....");

         }

 

}

 

Web.xml

  <servlet>

    <display-name>ChatServlet</display-name>

    <servlet-name>ChatServlet</servlet-name>

    <servlet-class>com.guoguo.ChatServlet</servlet-class>

  </servlet>

  <servlet-mapping>

    <servlet-name>ChatServlet</servlet-name>

    <url-pattern>/ChatServlet</url-pattern>

  </servlet-mapping>

 

(2)       页面端代码

发送端

<base href="<%=request.getContextPath()%>">

<form action="<%=request.getContextPath()%>/ChatServlet">

      <input type="submit">

</form>

接收端

<base href="<%=request.getContextPath()%>">

<script type="text/javascript" src="lib/ajax-pushlet-client.js"></script>

<div id="guoguo"></div>

<script type="text/javascript">

           PL._init();

           PL.joinListen('/guoguo/myevent1');

           function onData(event) {

                 guoguo.innerText = (event.get("key1"));

           }

</script>

 

启动服务器,从发送端提交信息,内容会在接收端显示出来

 

3.2.2.   无刷新的提交信息(从客户端发送消息)

发送端

<base href="<%=request.getContextPath()%>">

<script type="text/javascript" src="lib/ajax-pushlet-client.js"></script>

<script type="text/javascript">

           PL._init();

           function sendnews(msg) {

                 p_publish('/guoguo/myevent1','key1',encodeURIComponent(msg),’key2’,’msg2’);

           }

</script>

<input type="text" name="mymsg">

<input type = "button" value="发消息" onclick="sendnews(mymsg.value)"/>

 

接收端

<base href="<%=request.getContextPath()%>">

<script type="text/javascript" src="lib/ajax-pushlet-client.js"></script>

<div id="guoguo"></div>

<script type="text/javascript">

           PL._init();

           PL.joinListen('/guoguo/myevent1');

           function onData(event) {

                 guoguo.innerText = (event.get("key1"));

           }

</script>

 

启动服务器,从发送端提交信息,内容会在接收端显示出来

 

 

注意:Pushlet目前仅对IE支持良好,经过笔者的测试,FireFox,Chrome均无法实现无刷新的客户端信息提交。

分享到:
评论

相关推荐

    使用Pushlet来实现服务器端向客户端推送信息

    使用Pushlet来实现服务器端向客户端推送信息

    pushlet实现服务器端向客户端推送消息总结

    Pushlet 是一种基于 Java 的实时通信框架,用于实现在服务器端向客户端主动推送消息的功能,而无需客户端不断轮询。这种技术在构建实时应用程序,如聊天室、实时股票更新或在线游戏等场景中非常有用。以下是关于 ...

    基于pushlet实现的jsp网站消息推送

    - 服务器端需要监控数据源,当有新数据时,通过Pushlet API将消息发送给已连接的客户端。 - 客户端接收到推送的消息后,更新网页内容。 4. **优点与挑战** Pushlet的优势在于其简单易用的API和对Java环境的良好...

    服务器推送pushlet讲解

    3. 实现Pushlet服务端:在服务器端,你需要编写Java代码来处理事件,并在事件触发时调用Pushlet API将数据推送给客户端。 4. 测试与优化:测试Pushlet应用的性能和稳定性,根据需求进行必要的优化,如调整连接超时...

    PushLet实例,服务器消息推送

    【标题】"PushLet实例,服务器消息推送"指的是一个基于Java技术实现的服务器端消息推送系统,名为PushLet。在互联网应用中,实时性是非常重要的一个特性,例如在线聊天、股票更新、新闻推送等场景。传统的HTTP协议是...

    pushlet消息推送

    Pushlet系统的核心组件包括Pushlet Server(推送服务器)、Pushlet Client(推送客户端)以及Event Source(事件源)。Pushlet Server是服务端程序,它接收客户端的连接并保持这些连接打开,等待来自Event Source的...

    pushlet定时向前台推送消息

    1. **服务器端组件**:Pushlet服务器端通常会有一个或多个服务,它们负责处理客户端的连接、注册以及数据推送。当服务器端有新数据可用时,它会主动找到已注册的客户端并推送数据。 2. **客户端组件**:客户端需要...

    服务器推送 pushlet

    在Pushlet的实现中,主要有两个关键角色:Pushlet Server(推送服务器)和Pushlet Client(推送客户端)。Pushlet Server负责接收来自客户端的连接,并在有新数据时主动将数据推送到这些连接。Pushlet Client则建立...

    pushlet java 消息实时推送

    这个工程可能包含了Pushlet服务器端的实现代码、客户端的订阅代码、配置文件以及测试用例等。通过分析这个项目源码,我们可以深入理解Pushlet的工作原理,学习如何在Java中实现消息推送,并解决实际应用中的中文字符...

    Pushlet消息推送

    3. **点对点推送**:也称为一对一推送,是指服务器将消息直接推送到特定的客户端。这种推送方式适用于私密性强的信息传递,如私人消息、定制通知等。在这种模式下,服务器需要知道接收者的标识,并且只能向指定的...

    一个基于pushlet推送的小例子

    它基于Servlet和JSP,利用 comet 技术(一种模拟服务器端推送的技术)实现在HTTP长连接下的数据推送。Pushlet的核心思想是创建一个持久的HTTP连接,服务器端可以通过这个连接主动向客户端推送数据,而客户端只需要一...

    Pushlet后台往jsp前台推送消息实例

    - **Pushlet Server**:服务器端,处理来自客户端的连接请求,维护长连接,并负责将消息推送给客户端。 - **Producer**:消息生产者,负责生成需要推送的数据。 - **Consumer**:消息消费者,通常是Web浏览器或...

    pushlet服务器推技术例子

    3. **Event**:Pushlet机制基于事件驱动,当服务器端有新的事件(如新的聊天消息)发生时,会生成一个事件对象,然后通过已建立的连接将这个事件推送到相关的客户端。 4. **Session Management**:Pushlet支持多...

    http长连接(服务器推)使用pushlet教程示例以及jar包源码

    例如,"使用Pushlet来实现服务器端向客户端推送信息.doc"文档会详细解释如何配置和使用Pushlet Server来发送数据;"使用Pushlet实现点对点发送.docx"和"使用Pushlet实现一对多的信息推送.docx"则分别介绍了这两种推...

    服务器推送——PushLet的应用<一>

    服务器将消息放入这个队列,然后通过HTTP响应将消息推送给客户端。 3. **ClientHandler**:处理客户端的HTTP请求,初始化PushSession,并处理来自客户端的消息。 4. **EventDispatcher**:事件分发器,用于处理...

    服务器推送——PushLet的应用<二>

    1. **创建服务器端推送服务** 首先,你需要创建一个Pushlet实例,注册事件处理器,然后启动服务。事件处理器将处理从服务器发送到客户端的消息。 2. **定义事件处理器** 在处理器中,你可以定义处理逻辑,比如从...

    网页推送pushlet的demo

    网页推送技术在现代互联网应用中扮演着重要角色,它能够实时地将服务器端的数据更新推送到客户端,无需用户频繁刷新页面。Pushlet是基于Java的一种早期的推送技术框架,它利用了 comet 技术,实现了服务器到客户端的...

    pushlet 之 Pushlet使用手把手实例

    3. 数据推送:当服务器端有新的匹配订阅的事件时,会主动将数据推送到客户端,而无需客户端轮询请求。 4. 断开连接:当客户端不再需要接收推送时,或者服务器检测到连接异常,会断开连接。 三、Pushlet 实例步骤 1...

    通过推送机制(Tomcat comet,pushlet)实现进度条

    在Pushlet模型中,服务器端有一个Pushlet容器,用于管理与客户端的连接和数据推送。客户端则通过JavaScript或其他前端技术创建持久的HTTP连接,并监听来自服务器的推送事件,从而更新进度条的显示。 **实现进度条的...

Global site tag (gtag.js) - Google Analytics