服务器推技术
最近参与的一个关于股票的项目，有这样一个需求。服务器需要主动推送给客户端消息。这和传统的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
这样的话，我们在一个界面只能监听一个全局的消息。怎么在一个界面的两个地方接受不同的数据源呢？