3.基于DWR推送技术Demo

分类：Ajax作者：编程之家用户
前面 我装载了两篇文章，第一篇 是对服务器推送技术的大体认识

http://www.jb51.cc/article/p-borfdzaf-mh.html

第二篇：另一种推送技术

http://www.jb51.cc/article/p-qtuisjoe-mh.html

有了这么推送技术的认识，那么 我们再来认识下DWR的推送技术

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

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

我下面的Demo是基于DWR 3.0.对于2.0 对于推送对象的寻找和scriptSession的管理 都有不同，有时间的朋友可以去对比下版本的不同

1. 我们去DWR 官网 下载3.0的jar包 地址：https://java.net/downloads/dwr/DWR_3.x/3.0_RC2/dwr.jar

不知道，使用DWR推送技术的朋友对DWR的认识和配置有多少的了解，对于DWR的认识我就不多说了，我下面尽量写的详细点，配置也弄详细点

2. 在项目WEB-INF文件夹下新建一个dwr.xml文件

dwr.xml配置文件中详解（转）：http://www.jb51.cc/article/p-eoarpasf-ts.html

<strong><span style="font-size:14px;"><?xml</span><span style="font-size:14px;"> version="1.0" encoding="UTF-8"?>  
<!DOCTYPE dwr PUBLIC "-//GetAhead Limited//DTD Direct Web Remoting 3.0//EN" "http://getahead.org/dwr/dwr30.dtd">
<dwr>
   <allow>
        <create creator="new" javascript="MessagePush">
         
          	<param name="class" value="com.zte.its.online.dwrserver.ReverseMsgCenter"/>
           </create>
   </allow>
</dwr>

对于上面的代码，javascript="messagePush" ，messagePush这个可以理解成别名，到时候页面中引用

param中的value对应的代码文件 是自己定义的java类

3.配置Web.xml文件

DWR的逆向Ajax主要包括两种模式：主动模式和被动模式。其中主动模式包括polling和comet两种，被动模式只有piggyback这一种

 <!-- Dwr 推技术 -->
  <!--  Start  -->
	  <servlet>  
	      <servlet-name>dwr-invoke</servlet-name>  
	      <servlet-class>uk.ltd.getahead.dwr.DWRServlet</servlet-class>  
	     <init-param>  
	         <param-name>debug</param-name>  
	         <param-value>true</param-value>   
	     </init-param>  
	      <!-- DWR默认采用piggyback方式 --> 
	      
	    <!-- 使用polling和comet的方式 --> 
	     <!--
	    <init-param> 
	        <param-name>pollAndCometEnabled</param-name> 
	        <param-value>true</param-value> 
	    </init-param> 
	    --> 
	    <!-- comet方式 -->  
	     <init-param>  
	         <param-name>activeReverseAjaxEnabled</param-name>  
	         <param-value>true</param-value>  
	     </init-param>
	     <init-param>  
           <param-name>initApplicationScopeCreatorsAtStartup</param-name>  
           <param-value>true</param-value>  
        </init-param> 
	     <!-- polling方式：在comet方式的基础之上，再配置以下参数 --> 
	    <!--   
	    <init-param> 
	        <param-name>org.directwebremoting.extend.ServerLoadMonitor</param-name> 
	        <param-value>org.directwebremoting.impl.PollingServerLoadMonitor</param-value> 
	    </init-param> 
	     -->  
	      <!-- polling方式：毫秒数。页面默认的请求间隔时间是5秒 --> 
	    <!--   
	    <init-param> 
	        <param-name>disconnectedTime</param-name> 
	        <param-value>60000</param-value>   
	    </init-param> 
	     -->    
	      <load-on-startup>2</load-on-startup>
	  </servlet>  
	  
	  <servlet-mapping>  
	     <servlet-name>dwr-invoke</servlet-name>  
	     <url-pattern>/dwr/*</url-pattern>  
	  </servlet-mapping>  
  <!--  End  -->

好了..大部分的工作我们都已经处理完了，我们改实现页面和后台代码了..

4.页面引用

4.1 首先页面引用3个js

	<script type="text/javascript" src="<%=path%>/dwr/engine.js"></script>
	<script type="text/javascript" src="<%=path%>/dwr/util.js"></script>
	<script type="text/javascript" src="<%=path%>/dwr/interface/MessagePush.js"></script>

engine.js 文件 是dwr的引擎文件，如果你原来就熟悉dwr的反向ajax就应该理解作用是干嘛的，如果你第一次接触dwr也没关系， 我简单的和你说下，当你的项目启动起来，你访问http://你本地ip: 端口/项目名/dwr/engine.js 你就能看到 你在dwr.xml文件中配置的方法

util.js 是dwr自带的工具js,具体的我也没使用过，可以搜索下

关键的来了..你的MessagePush.js 就是你在dwr.xml文件中配置的javaScript:的别名，前面的dwr/interface 这个路径是固定的

还哆嗦下，第一次接触dwr的朋友，不要担心engine.js 和util.js 和自定义的js 该去哪找？ 这个你不要担心，不需要找，你引用的dwr.jar启动后 就会有..那么具体怎么做到的，我猜想应该是生成一个js到部署的服务器环境中...

4.2 在body页面的onload事件中加载几个javascript方法

<body onload="dwr.engine.setActiveReverseAjax(true);dwr.engine.setNotifyServerOnPageUnload(true,true);onPageLoad();dwr.engine.setErrorHandler(function(){});">

我来解释下 onload自动加载的javascript方法的作用

dwr.engine.setActiveReverseAjax(true); 启动该页面的ReverseAjax功能

dwr.engine.setNotifyServerOnPageUnload(true,true); 这个就是当页面加载时，后台listen监听器去除失效的scriptSession，再创建新的scriptSession

onPageLoad(); 自定义的javascript函数，下面说明

dwr.engine.setErrorHandler(function(){});" 这个方法 防止项目已经关闭，客户页面还未关闭，页面会谈Error的问题

4.3书写自己的页面调用后台方法

               MessagePush.pageLoad();

MessagePush 是dwr.xml文件中定义的别名， pageLoad是我们在自定义后台java代码中自定义的java方法

关于参数：可以传多个，还有 就是关于中文的问题， 大家不要转码、编码了，参数通过dwr方式传入后台是不会乱码的

5.对应的推送java代码

重点来了....

推送消息的后台代码

5.1 scriptsession的管理

这里Dwr2.0与Dwr3.0 的是有区别的，Dwr3.0的 ScriptSession 都通过ScriptSessionListener来监听

import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.ServletException;

import org.directwebremoting.Browser;
import org.directwebremoting.Container;
import org.directwebremoting.ScriptSession;
import org.directwebremoting.ServerContextFactory;
import org.directwebremoting.event.ScriptSessionEvent;
import org.directwebremoting.event.ScriptSessionListener;
import org.directwebremoting.extend.ScriptSessionManager;
import org.directwebremoting.servlet.DwrServlet;

public class ConnectManagerCenter extends DwrServlet {

	private static final long serialVersionUID = -7504612622407420071L;

	// 维护一个Map key为session的Id， value为ScriptSession对象（供管理scriptSession使用）
	public static final Map<String,ScriptSession> scriptSessionMap = new HashMap<String,ScriptSession>();

	public void init() throws ServletException {

		Container container = ServerContextFactory.get().getContainer();

		ScriptSessionManager manager = container
				.getBean(ScriptSessionManager.class);

		ScriptSessionListener listener = new ScriptSessionListener() {

			/**
			 * 添加客户端session
			 * 
			 * 			 * 
			 */
			@Override
			public void sessionCreated(ScriptSessionEvent ev) {

				ScriptSession scriptSession = ev.getSession();

				scriptSessionMap.put(scriptSession.getId(),scriptSession);

				System.out
						.println("a ScriptSession iscreated \n \t scriptSessionId = "
								+ scriptSession.getId());
			}

			/**
			 * 由页面关闭，或时间超时引起的 连接关闭
			 */
			@Override
			public void sessionDestroyed(ScriptSessionEvent ev) {

				ScriptSession scriptSession = ev.getSession();

				scriptSessionMap.remove(scriptSession.getId()); // 移除scriptSession
				System.out
						.println("a ScriptSession is distroyed \n \t scriptSessionId = "
								+ scriptSession.getId());

			}

		};

		manager.addScriptSessionListener(listener);

	}


这里，我有两点 需要说明：

1. 第一次页面加载 是不会进入sessionCreated这个内部类的，第二次刷新才会触发

2. 关于sessionDestroyed的调用， 页面关闭后会自动调用， 但是 火狐浏览器好像有点迟缓.. 最重要的问题是，每次destroy ScriptSession的时候，这个放好会调用无数次（就是当前活跃的ScriptSession的个数次） ，我不知道这是为什么，官网的资料太少...所以 如果需要在创建和卸载时处理业务，请提前处理...

5.2 消息的推送集中处理类

public class ReverseMsgCenter {

	// ScriptSession链接处理类
	private static ConnectManagerCenter connectManagerCenter = new ConnectManagerCenter();

	/***
	 * 咨询者 页面加载时处理函数
	 * @param request
	 */
	public void pageLoad(HttpServletRequest request) {

		ScriptSession scriptSession = connectManagerCenter
				.getScriptSessionDwrFunction();

		scriptSession.setAttribute("scriptSessionId",scriptSession.getId());
		
		try {
			connectManagerCenter.init();
		} catch (ServletException e) {
			e.printStackTrace();
		}
	}
	

	/***
	 * 推送消息
	 * 
	 * 
	 * @param scriptSessionId
	 *           根据scriptSessionId可以获得该页面对象
	 * @param javaScriptFunction
	 *            推送页面的调用方法
	 * @param request
	 * @param pushMsg
	 *            推送的语句 List
	 */
	public void pushMsgMethod(String scriptSessionId,final String javaScriptFunction,HttpServletRequest request,Object... pushmsg) {

		final Object[] pushMsg = pushmsg;

		/**
		 * Browser.withAllSessionsFiltered(filter,runnble)
		 * 过滤器，通过自定义规则在内存中的过滤ScriptSession
		 */
		Browser.withAllSessionsFiltered(new ScriptSessionFilter() {
			public boolean match(ScriptSession session) {
				// 自定义过滤规则
				if (session.getAttribute("scriptSessionId") == null)
					return false;
				else
					return (session.getAttribute("scriptSessionId")).equals(scriptSessionId);
			}
		},new Runnable() {

			private ScriptBuffer script = new ScriptBuffer();

			public void run() {

				script.appendCall(javaScriptFunction,pushMsg);

				Collection<ScriptSession> sessions = Browser

				.getTargetSessions();
				for (ScriptSession scriptSession : sessions) {
					scriptSession.addScript(script);
				}
			}
		});
	}
}

这个类中，有两个方法：

pageLoad（） 这个是让页面调用的加载类 创建ScriptSession 对象

pushMsgMethod（） 这个方法是重点中的重点， 这个就是推送消息的封装方法：这个方法类有

            Browser.withAllSessionsFiltered(filter,run);    //注意这里调用了有filter功能（筛选对象，如果是群发的话，这里可以不判断）的方法 ，run  寻找对应的ScriptSession对应的页面Url ，从而进一步回调方法

scriptSessionId,这个是用来精准找到是把消息推送到页面去的标识

javaScriptFunction,这个是回调页面中的javascript方法，这里是方法名称

request,这个是页面的请求，和一般的request不一样噢。。具体搜索

Object... pushmsg 参数组，用来传输数据至页面，如果只是一个参数，那么页面就直接接受不需要把这个参数当成List对象，如果是多个参数组成的参数组，那么前台接受就是数组形式 ，取值就按照 array[0],array[1]

下面我举个例子 关于回调接收参数的，

  //后台推送回调function
  function connectSuccessMethodCall(msg){
	if(msg[0] == "T"){ 
				//
	}else{
				
		$('#serviceTokenId').val(msg[1]);
				
		$('#sessionNo').val(msg[2]);
				
	}

大体就这么多啦。。大家可以在页面的onload里面 直接调用初始化的方法，得到当前的ScriptSessionId,在调用pushMsgMethod这个方法...

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

$.AJAX()方法中的PROCESSDATA参数
$.AJAX()方法中的PROCESSDATA参数 在使用jQuery的$.ajax()方法的时候参数processData默认为true(该方法为jQuery独有的) 默认情况下会将发送的数据序列化以适应默认的内容类型application/x-www-form-urlencoded 如果想发送不
form表单提交的几种方式
form表单提交的几种方式 表单提交方式一：直接利用form表单提交 html页面代码： &lt;!DOCTYPE html&gt; &lt;html&gt; &lt;head&gt; &lt;meta charset=&quot;UTF-8&quot; /&gt; &lt;title&gt;Ins
AJAX应用之注册用户即时检测
文章浏览阅读1.3k次。AJAX的无刷新机制使得在注册系统中对于注册名称的检测能即时显示。常见的用户注册是用户输入用户名，后台程序检测数据库中用户名是否重复而做出注册的成功与失败之提示（当用户注册重名时将返回重新注册），或者稍微人性化一点就是在用户名文本框后添加一个检测按钮，让用户检测后再做注册。以上操作，对于用户体验方面来说是比较“差劲”的，一个很好的用户体验就是：当用户输入完注册用户名后，Web系统应能即时检查并即时_用户注册 实时异步检测
详谈基于JSON的高级AJAX开发技术
文章浏览阅读1.2k次。 本文将解释如何使用AJAX和JSON分析器在客户端和服务器之间创建复杂的JSON数据传输层。一、 引言毫无疑问，AJAX已经成为当今Web开发中一种强有力的用户交互技术，但是它的许多可能性应用仍然鲜为人知。在本文中，我们将来共同探讨如何 使用JavaScript对象标志(JSON)和JSON分析器在服务器和客户端AJAX引擎之间创建复杂而强有力的JSON数据传输层。我们将_ajax技术可行性
手写的ajax分页控件
文章浏览阅读2.2k次。/************************** 创建XMLHttpRequest对象 **************************/function CreateRequest(){ var xmlObj = null; try { xmlObj = new XMLHttpRequest(); } catch(e) {
AJAX中同时发送多个请求XMLHttpRequest对象处理方法
文章浏览阅读3.7k次。在ajax应用中，通常一个页面要同时发送多个请求，如果只有一个XMLHttpRequest对象，前面的请求还未完成，后面的就会把前面的覆盖 掉，如果每次都创建一个新的XMLHttpRequest对象，也会造成浪费。解决的办法就是创建一个XMLHttpRequset的对象池，如果池里有 空闲的对象，则使用此对象，否则将创建一个新的对象。下面是我最近写的一个简单的类：* XMLHttpReques_xmlhttprequest发送多个请求
Ajax 同一页面同时执行多个 XMLHTTP
文章浏览阅读3.1k次。Ajax 同一页面如何同时执行多个 XMLHTTP 呢，比如博客页，需要同时利用 Ajax 读取作者信息、文章信息、评论信息……我们的第一反应可能是创建多个全局 XMLHTTP 对象，但这并不现实。其实实现方式非常简单，就是给 onreadystatechange 对应的回调函数加上参数，以下代码是解决方案中一个函数中的一段代码。xmlhttp.open("GET", "ajax_proc_ajax响应多个mxl文件
简单介绍数据岛使用方法
文章浏览阅读1.5k次。数据岛指的是存在Html网页中的xml代码段，它在Html中形成了一个数据的集合，数据岛允许我们在Html网页中集成xml，对xml编写脚本.数据岛有它特有的形式，由标记xml开始，在开始标记中要有一个ID属性，用于指定该指定数据岛的名称。 (当然要以/xml结束).元素xml包含的内容就是xml代码。数据岛也分为2种：1）内嵌的数据岛形式2）外嵌的数据岛形式说了那么多废话，还_数据中岛计算模式
AJAX 框架 用 Asp.net ajax 还是 Jquery ?
文章浏览阅读2.1k次。AJAX 流行之后，总想好好学习一下。但是众多的框架实在难以选择。说明一下 ASP.NET AJAX 并不包括在 AJAX 框架之中。刚开始学了 JQuqery， 众多的 $get(),...等等符号早已把我搞晕了。暂时就放弃了。后来学习 ASP.NET AJAX ，在微软的领导下，逐渐由服务器端转向客户端编程。 激起我客户端编程的兴趣，才想起学习一下了 Jquery. 随着WEB2._jquery ajax asp.net 认证
轻便的XMLHttpRequest应用函数：downloadUrl()
文章浏览阅读1.7k次。前段时间在用google map api的函数库的时候，发现里面的downloadUrl函数非常好用，所以自己写了一个。用腻了那些什么框架什么池，到头来发现越简单的东西越是适合我这种懒人。downloadUrl(url, callback, data);参数说明： url不用说了; callback是回调函数，函数调用的时候会有两个参数：data, responseCode，data就_xmlhttprequest downloadurl
利用XMLHTTP无刷新自动实时更新数据
文章浏览阅读956次。前些时间写了几篇关于XMLHTTP运用的实例.(可以到http://dev.csdn.net/user/wanghr100看之前的几编关于XMLHTTP的介绍.)近来看论坛上经常有人提问关于如何无刷新,自动更新数据.传统上,我们浏览网页,如果加入最新的数据.只能是等我们重新向服务器端请求时才能显示出来.但是,对于一些时效性很强的网站.传统的这种做法是不能满足的.我们可以让程序自动刷新.定时_后端xml怎么实现数据有救新增,没有就更新
AJAX设计模式 XMLHttpRequest调用
文章浏览阅读3.3k次。 XMLHttpRequest调用XMLHttpRequest Call ●●●调用，回调，下载，抓取，实时，查询，远程通信（Remoting），远程通信脚本（RemoteScripting），同步，上传，XMLHttpRequest图6-2：XMLHttpRequest调用 目标故事Reta正在一个批发商网站上购买商品。每次她添加一个商品到购物车时，web站点发出_createxmlhttpre
用javascript动态更改DropDownList下拉项
文章浏览阅读1.3k次。function clearitem(){ var drp1 = document.getElementById("drp1"); while(drp1.options.length>0) { drp1.options.remove(0); } }//动态更改方法（根据城市代码取得该市商业区并添加到DropDownList中_dropdownlist根據動態變化
微調一下 Json.net ，讓他可以序列基本型別
文章浏览阅读1.9k次。因為 Json.net 是有附原始碼的，他也附了單元測試的專案，底下是我額外增加的UnitTest，我的目標就是讓底下的測試可以pass，而且原來的Test 也要都能通過。 ValueTypeTest.csusing System;using NUnit.Framework;namespace Newtonsoft.Json.Test { [TestFixture] public cl_vb 無效的 json 基本型別
利用XMLHTTP无刷新获取数据
文章浏览阅读844次。利用XMLHTTP无刷新获取数据. 客户端和服务器端数据的交互有几种方法.1.提交,通过提交到服务器端.也称"有刷新"吧.2.通过XMLHTTP无刷新提交到服务器端,并返回数据.也称"无刷新"吧.利用XMLHTTP我们可以实现很多很强大的应用.这文章主要介绍它的一些简单的应用.附:因为XMLHTTP是IE5.0+支持的对象.所以你必须要有IE5.0+才能看到效果.client.htm_xmlhttp取源码没有更新
.Net 底下，Json 相關套件的限制
文章浏览阅读1.8k次。Json.Net 無法序列基本型別(string, int)，Asp.Net Ajax 無法正確序列日期，AjaxPro序列出我不想要的_type字串 1. Json.Net 是我最常使用的序列/反序列json套件，標榜速度快，對於一對多關係的object 也都能正常運作, 己能滿足我平日的需要，但前幾天突然有個情況，我要序列的是一個泛型參數，該參數不一定是物object型別，有可能是st_token string in state start
编写组件，使用JavaScript更新UpdatePanel (转载)
文章浏览阅读1.3k次。转载自：http://www.cnblogs.com/JeffreyZhao/archive/2007/01/31/update_the_updatepanels_by_js.html众 所周知，UpdatePanel是通过Trigger来更新的。被设定为Trigger的控件在PostBack之后会被客户端所截获，并且使用 XMLHttpRequest对象发送内容，然后服务器端由ScriptMan_web.ui.updatepanel 和 updatepanel 的区别
无刷新网页——数据岛技术应用
文章浏览阅读1.9k次。有些时候，只是需要更新页面的一个部分甚至只是更新中间的几个数据却需要从服务器DOWN整个页面，导致各种资源的浪费。使用数据岛技术可以很好的解决这个问题：通过定时器或用户事件触发数据岛（XML对象）象服务器获取数据，在数据获取完成后，适时更新相关数据。示例HTML部分：http://localhost/WebService/LoadData/FeaturedService.asmx/GetScore_web数据岛
构建pool管理无刷新页面的xmlhttp对象
文章浏览阅读1k次。在页面上使用ActiveXObject的代价是很大的，如果我们的无刷新页面使用xmlhttp技术，我们或许需要频繁的建立xmlhttp对象，当然 我们也可以使用全局变量来cache一个xmlhttp对象实例。但是这样的方法适合于同步方式xmlhttp通信，而对于异步方式xmlhttp通信将 会出现问题。由于没有了进程的堵塞，用户可能再次调用同一个xmlhttp实例，如果这时前一个通信未完成，那么就
Lightbox JS v2.0
文章浏览阅读998次。 by Lokesh Dhakar 译: croc查看原文概要：Lightbox JS 是一个简单而又谦恭的用来把图片覆盖在当前页面上的脚本. 它能被快速安装并且运作于所有流行的浏览器.最新更新 Version 2.0 图片集: 分组相关的图片并且能轻松的导航它们 视觉特效: 奇特的自适应调整 向后兼容: yes! 点击这里查看实例_on lightbox 2 by lokesh dhakar
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot