Web端server推送技术原理分析及dwr框架简单的使用

[align=left]1 背景[/align]
“server推送技术”（ServerPushing）是近期Web技术中最热门的一个流行术语。它是继“Ajax”之后又一个倍受追捧的Web技术。“server推送技术”近期的流行跟“Ajax ”有着密切的关系。

随着 Ajax技术的兴起，让广大开发者重新看到了使用浏览器来替代桌面应用的机会，而且这次机会很大。Ajax将整个页面的刷新变成页面局部的刷新，而且数据的传送是以异步方式进行，这使得网络延迟带来的视觉差异将会消失。

可是，在浏览器中的 Ajax应用中存在一个致命的缺陷无法满足传统桌面系统的需求。那就是“server发起的消息传递”（Server-Initiated Message Delivery）。在非常多的应用其中，server软件须要向client主动发送消息或信息。由于server掌握着系统的主要资源，可以最先获得系统的状态变化和事件的发生。当这些变化发生的时候，server须要主动的向client实时的发送消息。比如股票的变化。在传统的桌面系统这样的需求没有不论什么问题，由于client和server之间通常存在着持久的连接，这个连接可以双向传递各种数据。而基于HTTP协议的 Web应用却不行。

2 client得到通知的方式

图1 传统web 訪问机制

我们知道， Web的訪问机制天生是设计用来 pull数据的，如图 1，也就是仅仅同意 Browser端主动发起请求，server是被动的响应，不同意Server向 Browser发出一个 connection请求，也就是说没有为server向 Browser
push数据提供设计实现.尽管没有直接的实现方法,却能够使用一些变通的方式完毕类似的功能。

2.1 传统轮询

在 Web早期，这一点常使用meta刷新实现。这将自己主动指示浏览器在指定秒数之后又一次装载页面，从而支持简陋的轮询（polling）。比如在HTML文件里增加
<META HTTP-RQUIV="Refresh" CONTENT=12>，实际上就是 HTTP 头标告知浏览器每 12 秒更新一次文档。

长处 ：不须要server端的配置。

缺点 ：

a) 糟糕的用户体验

b) 对server的压力非常大，而且造成带宽的极大浪费。

2.2 Ajax 轮询

Ajax隔一段时间（通常使用JavaScript的setTimeout函数）就去server查询是否有改变，从而进行增量式的更新。可是间隔多长时间去查询成了问题，由于性能和即时性造成了严重的反比关系。间隔太短，连续不断的请求会冲垮server，间隔太长，务器上的新数据就须要越多的时间才干到达客户机。

长处：

a) 不须要太多server端的配置。

b) 减少带宽的负荷（由于server返回的不是完整页面）。

缺点：

a) 对server的压力并不会有明显的降低。

b) 实时性差，有一定的延迟。

应用： 这是一项很常见的技术，比如，大多数 webmail应用程序就是通过这样的技术在电子邮件到达时显示电子邮件的。

2.3 Comet

Comet方式通俗的说就是一种长连接机制(long lived http)。相同是由Browser端主动发起请求，可是Server端以一种似乎非常慢的响应方式给出回答。这样在这个期间内，服务器端能够使用同一个connection把要更新的数据主动发送给Browser。因此请求可能等待较长的时间，期间没有不论什么数据返回，可是一旦有了新的数据，它将马上被发送到客户机。Comet又有非常多种实现方式，可是总的来说对Server端的负载都会有添加.尽管对于单位操作来说，每次仅仅须要建议一次connection,可是因为connection是保持较长时间的,对于 server端的资源的占用要有所添加。

长处： 实时性好（消息延时小）；性能好（能支持大量用户）

缺点： 长期占用连接，丧失了无状态高并发的特点。

应用： 股票系统、实时通讯。

2.4 Flash XML Socket

这样的方案实现的基础是：一、Flash提供了 XMLSocket类。二、 JavaScript 和 Flash的紧密结合：在 JavaScript能够直接调用 Flash程序提供的接口。

缺点：

a) 由于XMLSocket没有HTTP隧道功能，XMLSocket类不能自己主动穿过防火墙；

b) 由于是使用套接口，须要设置一个通信port，防火墙、代理server也可能对非HTTP通道port进行限制；

应用： 网络聊天室，网络互动游戏。

2.5 Java Applet 套接口

在client使用 Java Applet，通过 java.net.Socket或java.net.DatagramSocket或java.net.MulticastSocket 建立与server端的套接口连接，从而实现“server推送 ”。

缺点： 须要client安装 JAVA虚拟机。

3 Comet 介绍

Comet 有时也称反向 Ajax或server端推技术（server-side push）。其思想非常easy：将数据直接从server推到浏览器，而不必等到浏览器请求数据。听起来简单，可是假设熟悉Web 应用程序，尤其是HTTP协议，那么您就会知道，这绝不简单。实现Comet风格的 Web应用程序，同一时候保证在浏览器和server上的可伸缩性，这仅仅是在近期几年才成为可能。眼下一些主流站点都有类似的原理，比如：webQQ、开心网、校内等等，它们中消息动态都是採用类似的技术，仅仅是详细实现方式不一样。

COMET的精髓就在于用server与javascript来维持浏览器的长连接，同一时候完毕server端事件的浏览器端响应。这种事件广播机制是跨网络的，同一时候也是实时的。

採用了 Comet技术的server在客户机做出一个请求后，和客户机建立一个永久的连接，然后server会依据客户机的请求不断把数据包推向客户，这个推的过程是不间断的。由server推向客户机的数据在客户机的浏览器上会不断产生新的内容，并且不会产生Client
pull那样的HTML文档头，从而大大降低了延迟的时间，向（server响应--客户机请求）同步迈进了一步。

server推送通常效率要比client拖曳效率高，由于它不必为兴许数据建立新的连接。由于始终保持连接，即使没有传输数据时也是这样，因此server必须愿意分配这些TCP/IPport，对于TCP/IPport数有限的server这将是一个严重的问题。

client拖曳效率低，由于这必须每次为传送数据建立新的连接。可是它不必始终保持连接。在实际情况中，建立HTTP连接通常须要花费相当多的时间，多达一秒甚至很多其它。因此从性能上考虑，server推送对于终于用户更有吸引力，特别是对于须要常常更新信息的情况下。

server推送相对client拖曳的还有一点优势是，server推送相对照较easy控制。比如，server每一次推送时都保持一个连接，但它又随时能够关闭当中的不论什么连接，而不须要在server上设置特殊的算法。而client拖曳在相同的情况下要麻烦很多，它每次要与server建立连接，server为了处理将client拖曳请求与特定的终于用户匹配等情况，须要使用相当麻烦的算法。

如上所述，在server推送中，多个响应中连接始终保持，使server可在不论什么时间发送很多其它的数据。一个明显的优点是server全然可以控制更新数据的时间和频率。另外，这样的方法效率高，由于始终保持连接。缺点是保持连接状态会浪费server端的资源。server推送还比較easy中断。

4 Comet 实现（Java语言）

4.1 死循环法

最简单的自然是死循环法，假设使用观察者模式则能够进一步提高性能。

可是这样的做法的缺点在于client请求了这个 servlet后， web server会开启一个线程运行 servlet 的代码，而 servlet 由迟迟不肯结束，造成该线程也无法被释放。于是乎，一个client一个线程，当client数量添加时，server依旧会承受非常大的负担。

4.2 改写webserver

眼下的趋势是从 web server内部入手，用 nio （ JDK 1.4 提出的 java.nio 包）改写 request/response 的实现，再利用线程池增强server的资源利用率，从而解决问题，眼下支持这一非 J2EE 官方技术的server有 Glassfish 和 Jetty 。

JDK 1.4 版本号 ( 包含之后的版本号 ) 最显著的新特性就是添加了 NIO(New IO) ，可以以非堵塞的方式处理网络的请求，这就使得在 Java 中仅仅须要少量的线程就能处理大量的并发请求了。

Jetty 6设计来处理大量并发连接，它使用Java语言的不阻塞 I/O(java.nio)库而且使用优化的输出缓冲架构。Jetty也有一个处理长连接的杀手锏:一个称为 Continuations的特性。

Grizzly 作为 GlassFish 中很重要的一个项目，就是用 NIO 的技术来实现应用server中的高性能纯 Java 的 HTTP 引擎。 Grizzly 还是一个独立于 GlassFish 的框架结构，能够单独用来扩展和构建自己的server软件。

特点： 使用 NIO 不是一件简单的技术，它的一些特点使得编程的模型比原来堵塞的方式更为复杂。

4.3 使用框架

基于 Java 的成熟的server推送框架有 DWR 。

DWR是一个开放源代码的使用Apache许可协议的解决方式，它包括server端Java库、一个 DWR
servlet以及 JavaScript库。尽管 DWR不是 Java平台上唯一可用的Ajax-RPC 工具包，可是它是最成熟的，并且提供了很多实用的功能。从最简单的角度来说，DWR是一个引擎，能够把server端Java对象的方法公开给JavaScript 代码。使用DWR 能够有效地从应用程序代码中把Ajax的所有请求 -响应循环消除掉。这意味着client代码再也不须要直接处理XMLHttpRequest对象或者server的响应。不再须要编写对象的序列化代码或者使用第三方工具才干把对象变成XML。甚至不再须要编写servlet代码把 Ajax请求调整成对 Java域对象的调用。

DWR 从 2.0開始添加了 push 功能 , 也就是在异步传输的情况下能够从 Web-Server 端发送数据到 Browser

一个简单的dwr推送程序

第一步 将dwr相关的jar包导入到project

第二步 配置web.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"> <servlet>
<servlet-name>dwr-invoker</servlet-name>
<servlet-class>org.directwebremoting.servlet.DwrServlet</servlet-class>
<!-- 设置是否同意使用dwr推送技术 -->
<init-param>
<param-name>activeReverseAjaxEnabled</param-name>
<param-value>true</param-value>
</init-param>
<init-param>
<param-name>maxWaitAfterWrite</param-name>
<param-value>-1</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>dwr-invoker</servlet-name>
<url-pattern>/dwr/*</url-pattern>
</servlet-mapping>
</web-app>

第三步编写com.im.service.SendPushService类

[align=left][/align]

public class SendPushService {
//发送消息
public void send(String msg) {
System.out.println("==========调用了send方法==========");
ScriptBuffer scriptBuffer = new ScriptBuffer(); //构造js脚本
WebContext webContext=WebContextFactory.get();
ScriptSession myScSession = webContext.getScriptSession();
scriptBuffer.appendScript("dwrtest(");
scriptBuffer.appendData(msg);
scriptBuffer.appendScript(")");
Util util = new Util(myScSession);
util.addScript(scriptBuffer); //向client推送消息
}
}

第四步 在dwr.xml文件定义向外暴露的接口

<allow>
<create creator="new" javascript="SendPushService">
<param name="class" value="com.im.service.SendPushService"/>
</create>
</allow>

第五步: 编写jsp文件.

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns=" http://www.w3.org/1999/xhtml"> <head>
<base href="${basePath }" />
<script type='text/javascript' src='${basePath}dwr/engine.js'></script>
<script type='text/javascript' src='${basePath}dwr/util.js'></script>
<script type='text/javascript' src='${basePath}dwr/interface/SendPushService.js'></script>
<script type="text/javascript">
function hello(){
SendPushService.send("第一个dwr推程序");
}
/**由dwr在后台调用这种方法**/
function dwrtest(data){
alert(data);
}
</script>
<title>第一个dwr推程序</title>
</head>
<body onload="dwr.engine.setActiveReverseAjax(true);">
<input type="button" value="点击我" onclick="hello();" />
</body>
</html>

DWR聊天样例(源代码)

转载请标明出处 http://blog.csdn.net/shimiso

技术交流群:173711587