pushlet

pushlet是comet的一种实现，而且是开源，其声 称能支持目前的web 服务器，于是就对其提供的服务器端以及客户端代码进行了一番研究，心得如下： 在要使用push的页面中通过执行p_embed()向当前页面添加用来与server通讯的iframe 。后台通讯的页面叫js_pushlet_js.html页面，在这个页面中包含两个frame：一个负责发送请求，也就是controlFrame，一 个负责接受请求，即listenFrame。

clientAdapter的作用：clientAdapter实际上是对response的一个封装，根据向 response中write不同的数据，可以分为不同的clientAdapter实现，比如BroswerAdapter就是为了处理浏览器发送的请 求。

在每次打开页面之后都要建立与后台的联系，这个一般都是通过js函数join来实现的，join会调用 js_push_client.js中的通用函数(p_join_listen)来做两件事: 第一个就是调用p_join，给用来通讯的iframe赋location.href值，让它去发送请求，接收请求的是 nl.justobjects.pushlet.servlet.Pushlet这个servlet。

并通过p_event=join告诉后台开始建立连接。在发送完请求之后，后台会response回来一段新的js 代码，处理方法是：String nl.justobjects.pushlet.core.BrowserAdapter.event2JavaScript(Event event) throws IOException，里面的返回结果是：" "，后台在处理完join事件之后将结束response。

push()这个函数在 js_pushlet_net.html这个页面中，不过它还会调用js_pushlet_client.js库中的_push()函数，push函数会 根据server传回的参数（这些参数都是一些后台要调用的事件参数），最终我们会根据返回的参数执行相应的回调函数，这些回调函数在事件的应用html 应用页面中实现，比如ping.html页面，回调函数有：onData等。

第二件事就是调用p_listen再次向后台发送请求（由负责与后台通讯的iframe中另外一个子frame来处 理），不过此时需要后台执行的是listen事件，listen跟其他事件不同在于它先找到当前 session对应的订阅者（subscriber），然后调用subscriber的fetchEvent()方法，从订阅者的event queue中取出所有的event对象 ?在js_pushlet_client.js中有一个全局变量：pushletNet这个指的就是用来与后台通信的那个iframe对象，还有一个全局 的变量是pushletURI，这个指的是要请求的servlet url。

后台Event的处理机制：对Event的处理放在EventSource中，EventSource分两种：pull和push，目前主要是pull方 式（似乎有些与pushlet矛盾），EventSource有多个实现，这些实现会在source.properties中注册，然后由 EventSourceManager进行管理，EventSource同时会实现Runnable接口，即会用到多线程，在Servlet初始化的时候 通过启动EventSourceManager来启动多个EventSource线程。

由于pushlet采用的是发布/订阅模式，在将Event发送给客户端前，首先要找到所有的客户端对象，这个通过 一个pushlet自己定义的session（每一个连接到服务器的客户端会在服务器上注册一个 session来保存客户端信息，在每次发送请求的时候会带有一个sessionid来加以识别）来处理，然后从所有连接的客户端找到订阅了该event 的订阅者，这个是在Dispatcher的multicast()方法中进行的，在订阅者中有一个event queue对象，广播的event对象将保存到该queue中。

从queue中抓取event的过程则交给controllor完成。 前台需要连续发送请求？不需要，如果需要拼命的发送请求，就不叫comet了，前台只需要发送两个请求，一个是请求连接的join请求事件，一个是对后台 进行监听的listen事件，如果后台对应的数据发生了变化，则这个变化会反应到订阅者的event队列中，监听事件请求就是不断的读取订阅者的 event队列即可。response需要请求执行完成之后关闭吗？在第一个join事件请求是需要关闭的，listen事件请求则不需要。

如果客户端连接关闭了，后台如何知晓？在向response中write数据的时候抛出异常，后台就会知道可能是客户端已经关闭，这样该输出将结束 ?pushlet中如何与ajax结合使用？如果使用ajax的话，就是将iframe换成了xmlhttp，后台无变化，就是这么简单！

评论

1 楼 shutaodream 2010-12-24  

前台是否可以向后台传参数，因为每个定阅的主题面要求返回的数据不同，根据页面传送的参数而定。

谢谢！
前台定阅主题代码：
p_join_listen('/system/test');

后台处理阅定将代码:
/**
* Produces an event related to the Dispatcher.getInstance(). status.
*/
static public class TestEventPullSource extends EventPullSource {
private int number = 0;

public long getSleepTime() {
return 2000;
}

public Event pullEvent() {
Event event = Event.createDataEvent("/system/test");
// p(Dispatcher.getInstance()..getStatus());
event.setField("nr", "" + (number++));
event.setField("time", "" + System.currentTimeMillis());
return event;
}

  }