http長(zhǎng)連接使用Pushlet來(lái)實(shí)現(xiàn)服務(wù)器端向客戶端推送信息.doc

使用Pushlet來(lái)實(shí)現(xiàn)服務(wù)器端向客戶端推送信息1. 實(shí)現(xiàn)方式：有兩種實(shí)現(xiàn)方式：1. 通過(guò)配置文件來(lái)實(shí)現(xiàn)定時(shí)的從服務(wù)器端向客戶端推送信息2. 通過(guò)API主動(dòng)向另外一端推送信息以下分別給予介紹。2. 特別注意在開(kāi)始測(cè)試之前，有兩點(diǎn)非常重要，需要實(shí)現(xiàn)講明，否則程序?qū)?huì)無(wú)法正常運(yùn)行：2.1. JSP頁(yè)面上的設(shè)定JSP頁(yè)面上必須添加以下代碼以確保Pushlet能夠正確的獲得后臺(tái)服務(wù)的地址：base href=2.2. Pushlet的JS文件的Bug修改需要修改被引用的JS文件ajax-pushlet-client.js的內(nèi)容，找到PL.pushletURL = PL._getWebRoot() + pushlet.srv;將其修改為PL.pushletURL = pushlet.srv;修改的原因是Pushlet進(jìn)行地址解析的方法在某些應(yīng)用中會(huì)解析錯(cuò)誤，導(dǎo)致請(qǐng)求的路徑是nullpushlet.srv?，最終導(dǎo)致無(wú)法正確的請(qǐng)求到服務(wù)器的信息。2.3. 中文問(wèn)題一般情況下，如果不做特殊處理，中文問(wèn)題將會(huì)導(dǎo)致Pushlet的客戶端停止響應(yīng)，解決辦法是，在使用Pushlet的客戶端代碼發(fā)送消息之前，將其進(jìn)行轉(zhuǎn)碼，代碼為encodeURIComponent( msg)3. 正式開(kāi)始以上準(zhǔn)備工作完畢，就可以正式的開(kāi)發(fā)測(cè)試樣例了。3.1. 定時(shí)的從后臺(tái)向前臺(tái)push信息(1) 在eclipse中創(chuàng)建一個(gè)動(dòng)態(tài)的web工程(2) 配置及庫(kù)文件文件：從/ 下載最新的pushlet的開(kāi)發(fā)包，將其中的以下文件按照描述進(jìn)行設(shè)定序號(hào)文件名源位置目標(biāo)位置備注1.pushlet.jarpushlet-2.0.4lib項(xiàng)目類路徑如果使用的是applet的話，還需要將pushletclient.jar設(shè)置到項(xiàng)目的類路徑中去2.pertiespushlet-2.0.4webappspushletWEB-INFclasses項(xiàng)目的src根路徑注意稍后需要修改perties，其他兩個(gè)文件的內(nèi)容不需要修改3.ajax-pushlet-client.jspushlet-2.0.4webappspushletlib項(xiàng)目的webrootlib需要按照之前的描述修改其中的內(nèi)容(3) 修改web.xml，將pushlet的自啟動(dòng)servlet添加進(jìn)去 pushlet nl.justobjects.pushlet.servlet.Pushlet 1 pushlet /pushlet.srv (4) 創(chuàng)建服務(wù)器端代碼，特別注意類和內(nèi)部靜態(tài)類的名字/* * */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;/* * author QIAGUO * */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);/* * (non-Javadoc) * * see nl.justobjects.pushlet.core.EventPullSource#getSleepTime() */Overrideprotected long getSleepTime() return 1000;/每一秒鐘自動(dòng)執(zhí)行一次/* * (non-Javadoc) * * see nl.justobjects.pushlet.core.EventPullSource#pullEvent() */Overrideprotected Event pullEvent() /注意，一下是設(shè)定消息的主題/guoguo/helloworld，號(hào)稱主題是可以繼承的 /但是筆者的測(cè)試是失敗的，也許方法不對(duì)，呵呵Event event = Event.createDataEvent(/guoguo/helloworld);String data= hello,world 郭強(qiáng) +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) 注冊(cè)服務(wù)器端代碼為事件源，在perties文件中，添加以下行source7=com.guoguo.HelloWorldPushlet$HWPushlet以上方式適用于有內(nèi)部類的情況，如果沒(méi)有內(nèi)部類的話，使用以下的方式進(jìn)行注冊(cè)(這時(shí)外部類必須繼承父類EventPullSource)source7=com.guoguo.HelloWorldPushlet(6) 頁(yè)面（可以參考頁(yè)面內(nèi)注釋信息）Pushlet Test base href= /初始化pushlet客戶端PL._init(); /設(shè)定運(yùn)行時(shí)顯示調(diào)試信息，不需要時(shí)，直接刪掉即可PL.setDebug(true); /設(shè)定監(jiān)聽(tīng)主題：/guoguo/helloworld，與服務(wù)器端的主題完全一致PL.joinListen(/guoguo/helloworld); /接收到事件后，顯示服務(wù)器信息function onData(event) guoguo.innerText=(event.get(hw);Pushlet Test(7) 啟動(dòng)服務(wù)器，即可看到頁(yè)面上的信息每秒鐘一次，進(jìn)行定時(shí)的更新3.2. 主動(dòng)控制發(fā)送消息3.2.1. 有刷新的提交信息（服務(wù)器端主動(dòng)發(fā)送消息）(1) 創(chuàng)建一個(gè)servlet，并且注冊(cè)到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;/* * Servlet implementation class ChatServlet */public class ChatServlet extends HttpServlet private static final long serialVersionUID = 1L;/* * see HttpServlet#HttpServlet() */public ChatServlet() super();/* * see HttpServlet#service(HttpServletRequest request, HttpServletResponse * response) */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); / 向ID為piero的用戶推送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 ChatServlet ChatServlet com.guoguo.ChatServlet ChatServlet /ChatServlet (2) 頁(yè)面端代碼發(fā)送端base href=form action=/ChatServlet接收端base href=PL._init();PL.joinListen(/guoguo/myevent1);function onData(event) guoguo.innerText = (event.get(key1);啟動(dòng)服務(wù)器，從發(fā)送端提交信息，內(nèi)容會(huì)在接收端顯示出來(lái)3.2.2. 無(wú)刷新的提交信息（從客戶端發(fā)送消息）發(fā)送端base hr