服务器推技术研究Comet

服务器推技术

最近参与的一个关于股票的项目，有这样一个需求。服务器需要主动推送给客户端消息。这和传统的Web模式不同。传统的Web系统，客户端和服务器的交互是这样的：

客户端先和服务器建立一个TCP连接，然后客户端开始发送数据，服务器端接受数据，并且根据请求去反馈相应的信息，然后服务器终止TCP连接。

现在的HTTP1.1版本都默认Connection:keep-alive 。就是所谓的长连接，在服务器返回客户端信息之后，服务器端不会立刻断开连接，而是保持连接，直到服务器设定Timeout时间限制为止。当然keep-alive 要长期占用服务器的一个TCP 通道，占用服务器的资源。

而对与一些HTTP1.0版本是不识别keep-alive的，所以设置了keep-alive是没有用的。在实际使用中，HTTP头部有了Keep-Alive这个值并不代表一定会使用长连接。

那么如何使服务器和客户端保持长连接，让服务器接受到数据之后就立刻发送给客户端呢？

一，使用ajax长轮询，与服务器保持长连接。

二，使用iframe标签，后台不断输出代码到前端。

三，webSocket方法。

我总结了一下，大体上可以分为上面三类：

1.ajax长轮询：

实际上就是前端，不停连续的发送请求给后端，这样就可以保持前端和后端的连接了。当然，这种暴力的方式也分好和坏。如果你在前端里，写一个while循环，向后端发送ajax请求，那就是这样的情况，前一个请求，后端还没有处理完，另一个请求就发送过来了，请求不断的发送，有很多请求就被搁置，然后阻塞在那里直到自动关闭。这样是最消耗服务器资源的。当然我们可以改善一下：

$.ajax({

url:'mydata',
dataType: 'json',
method:'post',
success:function(data){
//alert(data);

$("#hi").append("姓名："+data.name+"  性别："+data.sex);
conn1();

},
error:function(e){
conn1();

}
});

这样的请求就变成，前端发送了请求，直到有数据从后端传送过来，我才继续发送请求。或者我的请求一直在搁置，或者发生错误了，我再发送请求。这样的话就大大减少了前端向后端发送请求的次数，比暴力循环优化了很多。

2.iframe 长连接。

其实iframe标签，可以理解为文档中的文档，就是在html页面中，iframe来执行后端传过来的代码，相当于在html中嵌入一段需要执行的代码。那么利用iframe这个标签，我们可以这样实现长连接。

前端发送一个请求到后端，后端然后开一个循环，不断的向前端的iframe中输出代码，然后iframe执行这段代码，来输出信息。

这里就不想写代码了。

其实这两种方式，前者是让前端死循环，后者是让后端死循环。后端的话，当然可以去开一个线程执行死循环。

3.webSocket

是一种新技术，在客户端和服务器端建立Socket连接，这样前端需要安装flash去执行Socket。这样的方式，前后端可以随心所欲传送数据。网页游戏就是这种方式。

接下来重点介绍Pushlet 框架。

Pushlet框架，百度上说，用了ajax轮询和iframe隐藏帧两种方式实现了服务器推技术。

https://github.com/SilentCC/MyProgramming/blob/master/README.md

我的Git中的WebComet中有源码。下面来看下如何使用。



可以看到目录结构是这样的

我们需要pushlet.jar log4j.properties pushlet.properties sources.properties 和aja-pushlet-client.js 这四个文件，在源代码包里都有。

我们需要再web.xml中配置文件

<servlet>
<servlet-name>pushlet</servlet-name>
<servlet-class>nl.justobjects.pushlet.servlet.Pushlet</servlet-class>
<load-on-startup>3</load-on-startup>
</servlet>

<servlet-mapping>
<servlet-name>pushlet</servlet-name>
<url-pattern>/pushlet.srv</url-pattern>
</servlet-mapping>

然后开始写pushlet的核心类

package com;

import java.io.Serializable;
import java.io.UnsupportedEncodingException;
import sun.rmi.runtime.Log;
import nl.justobjects.pushlet.core.Dispatcher;
import nl.justobjects.pushlet.core.Event;
import nl.justobjects.pushlet.core.EventPullSource;
import nl.justobjects.pushlet.*;
import nl.justobjects.pushlet.core.EventSource;

public class HelloWorldPushlet implements Serializable{

static public class HwPlushlet extends EventPullSource{

protected long getSleepTime(){

return 3000;
}

public Event pullEvent(){

Event event = Event.createDataEvent("/cuige/he");
event.setField("mess", "hello,world!Plushlet!");
//System.out.println("ok");
return event;
}

}

static public class HsPlushlet implements EventSource{

public void pullEvent(String message){

Event event = Event.createDataEvent("/suige/he");
event.setField("mess", message);
Dispatcher.getInstance().multicast(event);
}

public void activate() {
// TODO Auto-generated method stub

}

public void passivate() {
// TODO Auto-generated method stub

}

public void stop() {
// TODO Auto-generated method stub

}

}

static public class HsPlushlet2 implements EventSource{

public void pullEvent(String message){

Event event = Event.createDataEvent("/cuige/he");
event.setField("mes", message);
Dispatcher.getInstance().multicast(event);
}

public void activate() {
// TODO Auto-generated method stub

}

public void passivate() {
// TODO Auto-generated method stub

}

public void stop() {
// TODO Auto-generated method stub

}

}

}

上面这个类是我们自己写的pushlet 的核心类。

在类中，我们有两种方式可以向前端发送信息：

1.继承EventPullSource 类，

在子类中，我们可以设置getSleepTime() 来设置服务器每隔多长时间发送一组数据到前端。

pullEvent是传播数据的方法，在子类中不能有参数

2.实现EventSouce 接口。

pullEvent可以传入参数。实现EventSouce的类，可以在服务器端任何需要的地方去使用~，这样的话我们可以在需要的时候传入需要的参数，然后再发送数据到前端

创建event

Event event = Event.createDataEvent("/cuige/he");
event.setField("mes", message);

广播event

Dispatcher.getInstance().multicast(event);

这样在需要的地方定义类对象，再调用就好了

在前端的话我们可以：

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

function conn2(){

PL._init();

PL.joinListen('/suige/he');
alert("ok");
}

function onData(event){

alert("ok");
var data =JSON.parse(event.get("mess"));

$("#hi2").append("姓名："+data.name+"性别："+data.sex);

}

</script>

PL._init() 是初始化客户端，
PL.joinListen('/suige/he') 是告诉高科端监听哪个event.

function onData(event){} 就是接受数据的函数。

这里我们还要配置数据源，根据我们写的主类，在sources.properties 中设置

source1=com.HelloWorldPushlet$HsPlushlet
source2=com.HelloWorldPushlet$HsPlushlet2

这样的话，我们在一个界面只能监听一个全局的消息。怎么在一个界面的两个地方接受不同的数据源呢？