DWR实现服务器端向客户端推送消息

原文

1.简介

DWR（Direct Web Remoting）是一个用于改善web页面与java类交互的远程服务器端Ajax开源框架，可以帮助开发人员开发包含AJAX技术的网站。它可以允许在浏览器里的代码使用运行在WEB服务器上的JAVA函数，就像它就在浏览器里一样。

它包含两个主要的部分:允许 JavaScript从 WEB服务器上一个遵循了 AJAX原则的 Servlet中获取数据.另外一方面一个JavaScript库可以帮助 网站开发人员轻松地利用获取的数据来动态改变网页的内容.
DWR采取了一个类似AJAX的新方法来动态生成基于java类的JavaScript代码。这样WEB开发人员就可以在JavaScript里使用Java代码，就像它们是 浏览器的 本地代码( 客户端代码)一样；但是Java代码运行在WEB服务器端而且可以自由访问WEB 服务器的资源。出于安全的理由，WEB开发者必须适当地配置哪些java类可以安全的被外部使用。 [1]
这个从JAVA到JavaScript的远程功能方法给DWR的用户带来非常像传统的RPC机制,就像RMI或者SOAP一样,而且拥有运行在WEB上但是不需要 浏览器插件的好处.
DWR不认为浏览器/WEB服务器协议是重要的,而更乐于保证 编程界面的简单自然.对此最大的挑战就是把AJAX的异步特性和正常JAVA方法调用的同步特性相结合.在异步模式下,结果数据在开始调用之后的一段时间之后才可以被异步访问获取到.DWR允许WEB开发人员传递一个 回调函数,来 异步处理Java 函数调用过程.
以上是百度百科中copy的废话,下面来看步骤

2.前提条件:

2.1 dwr.jar 此包可以到官网下载:http://directwebremoting.org/dwr/downloads/index.htm(必须)

2.2 commons-logging-xxxx.jar(官网说需要)

3.eclipse中new >> Dynamic Web Project 复制dwr.jar到lib目录下会自动build path

4.打开web.xml编辑:

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns="http://java.sun.com/xml/ns/javaee"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
	id="WebApp_ID" version="2.5">
	<display-name>dwrDemo</display-name>
	<welcome-file-list>
	<welcome-file>login.jsp</welcome-file>
		<welcome-file>index.jsp</welcome-file>
	</welcome-file-list>
	<servlet>
		<display-name>LoginServlet</display-name>
		<servlet-name>LoginServlet</servlet-name>
		<servlet-class>com.yun.study.servlet.LoginServlet</servlet-class>
	</servlet>
	<servlet-mapping>
		<servlet-name>LoginServlet</servlet-name>
		<url-pattern>/loginServlet</url-pattern>
	</servlet-mapping>

	<servlet>
		<servlet-name>dwr-invoker</servlet-name>
		<servlet-class>org.directwebremoting.servlet.DwrServlet</servlet-class>
		<init-param>
			<param-name>crossDomainSessionSecurity</param-name>
			<param-value>false</param-value>
		</init-param>
		<init-param>
			<param-name>allowScriptTagRemoting</param-name>
			<param-value>true</param-value>
		</init-param>
		<init-param>
			<param-name>classes</param-name>
			<param-value>java.lang.Object</param-value>
		</init-param>
		<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>
		<init-param>
			<param-name>maxWaitAfterWrite</param-name>
			<param-value>3000</param-value>
		</init-param>
		<init-param>
			<param-name>debug</param-name>
			<param-value>true</param-value>
		</init-param>
		<init-param>
			<param-name>logLevel</param-name>
			<param-value>WARN</param-value>
		</init-param>
	</servlet>
<!--此处必须要有 不然前端js不能自动引入-->
	<servlet-mapping>
      <servlet-name>dwr-invoker</servlet-name>
      <url-pattern>/dwr/*</url-pattern>
   </servlet-mapping>
</web-app>
以上具体的 init-param可以到官网查查文档什么的搞定

5.在web.xml同级目录下新建一个文件 dwr.xml

<?xml 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.yun.study.service.MessagePush" />
		</create>
		<create creator="new" javascript="TestPush">
			<param name="class" value="com.yun.study.service.Test" />
		</create>
	</allow>
</dwr>
以上可以看出 我的class有两个 
com.yun.study.service.MessagePush
com.yun.study.service.Test
属性javascript的值表示是在js中用到该类的时候引用的名字

6.新建的java类如下:

bean:

package com.yun.study.model;

public class User {
	private String userId;

	public String getUserId() {
		return userId;
	}

	public void setUserId(String userId) {
		this.userId = userId;
	}
}
package com.yun.study.servlet;

import javax.servlet.servletexception;
import javax.servlet.http.HttpSession;

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

import com.yun.study.model.User;

public class DwrScriptSessionManagerUtil extends DwrServlet {
	private static final long serialVersionUID = 109326676726848212L;

	public void init() throws servletexception {

		try {
			Container container = ServerContextFactory.get().getContainer();
			ScriptSessionManager manager = container
					.getBean(ScriptSessionManager.class);
			ScriptSessionListener listener = new ScriptSessionListener() {
				public void sessionCreated(ScriptSessionEvent ev) {
					HttpSession session = WebContextFactory.get().getSession();
					String userId = ((User) session.getAttribute("userinfo"))
							.getUserId() + "";
					System.out.println("======>>>a ScriptSession is created,userId="+userId);
					ev.getSession().setAttribute("userId",userId);
				}

				public void sessionDestroyed(ScriptSessionEvent ev) {
					String userId = (String) ev.getSession().getAttribute("userId");
					System.out.println("======>>>userId="+userId+" ScriptSession is distroyed");
				}
			};
			manager.addScriptSessionListener(listener);
		} catch (Exception e) {
			e.printstacktrace();
		}
	}
}


package com.yun.study.service;

import javax.servlet.servletexception;

import org.directwebremoting.ScriptSession;
import org.directwebremoting.WebContextFactory;

import com.yun.study.servlet.DwrScriptSessionManagerUtil;

public class MessagePush {
	public void onPageLoad(String userId) {
		System.out.println("=====>>>>MessagePush onPageLoad invoke begin!");
		ScriptSession scriptSession = WebContextFactory.get().getScriptSession();

		scriptSession.setAttribute("userId",userId);

		DwrScriptSessionManagerUtil dwrScriptSessionManagerUtil = new DwrScriptSessionManagerUtil();

		try {

			dwrScriptSessionManagerUtil.init();
			System.out.println("=====>>>>MessagePush onPageLoad invoke end!");

		} catch (servletexception e) {

			e.printstacktrace();

		}

	}

}

package com.yun.study.service;

import java.text.SimpleDateFormat;
import java.util.Collection;
import java.util.Date;

import org.directwebremoting.browser;
import org.directwebremoting.ScriptBuffer;
import org.directwebremoting.ScriptSession;
import org.directwebremoting.ScriptSessionFilter;

public class Test {
	SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
	public void sendMessageAuto(String userid) {
		System.out.println("======>>>sendMessageAuto invoke begin!");
		final String userId = userid;
		final String sendMessage = "长江长江,我是黄河,收到请回答!当前时间是:"+sdf.format(new Date());
		browser.withAllSessionsFiltered(new ScriptSessionFilter() {
			public boolean match(ScriptSession session) {
				if (session.getAttribute("userId") == null)
					return false;
				else
					return (session.getAttribute("userId")).equals(userId);
			}
		},new Runnable() {

			private ScriptBuffer script = new ScriptBuffer();

			public void run() {
				System.out.println("====>>>invoke client browser task run.......");
				script.appendCall("showMessage",sendMessage);

				Collection<ScriptSession> sessions = browser.getTargetSessions();

				for (ScriptSession scriptSession : sessions) {
					System.out.println("===>>>loop execute sessions userId:"+scriptSession.getAttribute("userId"));
					scriptSession.addScript(script);
				}
			}
		});
		System.out.println("======>>>sendMessageAuto invoke end!");
	}
}

package com.yun.study.servlet;

import java.io.IOException;

import javax.servlet.servletexception;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.yun.study.model.User;

/**
 * Servlet implementation class ServerPushMessageServlet
 */
public class LoginServlet extends HttpServlet {
	private static final long serialVersionUID = 1L;
       
    /**
     * @see HttpServlet#HttpServlet()
     */
    public LoginServlet() {
        super();
        // Todo Auto-generated constructor stub
    }

	/**
	 * @see HttpServlet#doGet(HttpServletRequest request,HttpServletResponse response)
	 */
	protected void doGet(HttpServletRequest request,HttpServletResponse response) throws servletexception,IOException {
		doPost(request,response);
	}

	/**
	 * @see HttpServlet#doPost(HttpServletRequest request,HttpServletResponse response)
	 */
	protected void doPost(HttpServletRequest request,IOException {
		String pageName = request.getParameter("pageName");
		String sessionId = request.getSession().getId();
		User u = new User();
		u.setUserId(sessionId);
		request.getSession().setAttribute("userinfo",u);
		response.sendRedirect(pageName);
	}

}

以下是界面:

登录:login.jsp

<?xml version="1.0" encoding="UTF-8" ?>
<%@ page language="java" contentType="text/html; charset=UTF-8"
	pageEncoding="UTF-8"%>
<%
	String path = request.getcontextpath();
	String basePath = request.getScheme() + "://"
			+ request.getServerName() + ":" + request.getServerPort()
			+ path + "/";
%>

<!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%>"></base>
<Meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
<title>dwr test</title>

</head>
<body>

<form action="<%=basePath%>/loginServlet" method="post">
<p>请点击以下button 将会模拟登录得到一个sessionKey设置到你的session中用于表示您的身份,</p>
<p style="color: red;">界面将跳转到一个客户端页面(用于接收服务器推送消息的)!</p>
	<br/><input type="hidden" name="pageName" value="index.jsp"/>
	<input type="submit" value="跳转到客户端"/>
</form>
<br/><br/><br/>
<hr/>
<form action="<%=basePath%>/loginServlet" method="post">
	<p>请点击以下button 将会模拟登录得到一个sessionKey设置到你的session中用于表示您的身份,</p>
	<p style="color: red;">界面将跳转到一个触发服务端推送消息的界面(用于通知服务器推送消息给客户端的)!</p><br/>
	<input type="hidden" name="pageName" value="clientPush.jsp"/>
	<input type="submit" value="跳转到通知服务发送界面"/>
</form>
	
</body>
</html>

:index.jsp: 

<?xml version="1.0" encoding="UTF-8" ?>
<%@ page language="java" contentType="text/html; charset=UTF-8"
	pageEncoding="UTF-8"%>
<%
	String path = request.getcontextpath();
	String basePath = request.getScheme() + "://"
			+ request.getServerName() + ":" + request.getServerPort()
			+ path + "/";
%>

<!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%>"></base>
<Meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
<title>dwr client test</title>
<script type="text/javascript" src="<%=basePath%>/js/jquery-1.7.2.min.js"></script>
<script type="text/javascript" src="dwr/engine.js"></script>
<script type="text/javascript" src="dwr/util.js"></script>
<script type="text/javascript"
	src="<%=basePath%>/dwr/interface/MessagePush.js"></script>

<script type="text/javascript">
	//通过该方法与后台交互，确保推送时能找到指定用户  
	function onPageLoad() {
		var userId = '${userinfo.userId}';
		MessagePush.onPageLoad(userId);
	}
	//服务器向客户端推送信息的方法 
	function showMessage(autoMessage) {
		$("#serverSay").html(autoMessage);
	}
</script>
</head>
<body
	onload="onPageLoad();dwr.engine.setActiveReverseAjax(true);dwr.engine.setNotifyServerOnPageUnload(true);;">
	This is my DWR DEOM page.please copy this userId <span style="color: red;">${userinfo.userId}</span>
	to clientPush.jsp page to trigger a event,server will send message to client......
	<hr/><br/>
	<div id="DemoDiv">demo</div>
	<h2 style="color: red;" id="serverSay"></h2>
</body>
</html>

clientPush.jsp: 

<?xml version="1.0" encoding="UTF-8" ?>
<%@ page language="java" contentType="text/html; charset=UTF-8"
	pageEncoding="UTF-8"%>
<%
	String path = request.getcontextpath();
	String basePath = request.getScheme() + "://"
			+ request.getServerName() + ":" + request.getServerPort()
			+ path + "/";
%>

<!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%>"></base>
<Meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
<title>server push message trigger</title>
<script type="text/javascript" src="<%=basePath%>/js/jquery-1.7.2.min.js"></script>
<script type='text/javascript' src='dwr/engine.js'></script>
<script type='text/javascript' src='dwr/util.js'></script>
<script type='text/javascript' src='dwr/interface/TestPush.js'></script>

<script type="text/javascript">
	function test() {
		var userId = $("#userId").val();
		TestPush.sendMessageAuto(userId);
	}
</script>
</head>

<body>
	client userId<input type="text" name="userId" id="userId" />
	<br />
	<input type="button" value="Send" onclick="test()" />
</body>
</html>

ok!

注意:以上测试 客户端和通知服务端的页面请使用两个不同的浏览器测试,以免session存在覆盖的问题

DWR实现服务器端向客户端推送消息的更多相关文章

  1. 基于JavaScript编写一个图片转PDF转换器

    本文为大家介绍了一个简单的 JavaScript 项目，可以将图片转换为 PDF 文件。你可以从本地选择任何一张图片，只需点击一下即可将其转换为 PDF 文件，感兴趣的可以动手尝试一下

  2. HTML5数字输入仅接受整数的实现代码

    这篇文章主要介绍了HTML5数字输入仅接受整数的实现代码,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

  3. amaze ui 的使用详细教程

    这篇文章主要介绍了amaze ui 的使用详细教程,本文通过多种方法给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

  4. html5简介_动力节点Java学院整理

    这篇文章主要介绍了html5简介,用于指定构建网页的元素，这些元素中的大多数都用于描述网页内容，有兴趣的可以了解一下

  5. 有没有办法知道购买哪个iTunes帐户？ – iOS

    我的应用程序提供应用内购买非消耗类型.该应用程序具有登录功能.是否可以根据登录用户购买我的应用程序？

  6. ios 8 Homescreen webapp,关闭和打开iPad停止javascript

    我有一个适用于iPad的全屏HTML5网络应用程序,并且刚刚安装了IOS8来试用它,它一切正常,直到你关闭并重新启动iPad.一旦web应用程序重新启动javascript就会停止并加载新页面不会重新启动它.在iPad上的Safari中打开同一页面时,关闭和打开iPad会继续按预期工作.其他人注意到了这个或想出了一个解决方案吗？解决方法这似乎是我在iOS8.1.1更新中解决的.

  7. ios – Apple应用程序内购买收据 – 在服务器端验证

    我想验证它,并确保这是独一无二的.我担心的是：如果有人会收到一张有效收据,他就可以破解我们的服务器端API,并使用相同的有效收据进行无限数量的应用内购买.我应该以某种方式解密并检查transaction_id的“原始”收据,即我发送给Apple进行验证的收据？

  8. iOS 6 javascript与object.defineProperty的间歇性问题

    当访问使用较新的Object.defineProperty语法定义属性的对象的属性时,有没有其他人注意到新iOS6javascript引擎中的间歇性错误/问题？https://developer.mozilla.org/en-US/docs/JavaScript/Reference/Global_Objects/Object/defineProperty我正在看到javascript失败的情况,说

  9. ios – 如何使用JSExport导出内部类的方法

    解决方法似乎没有办法将内部类函数导出到javascript.我将内部类移出并创建了独立的类,它起作用了.

  10. 静音iOS推送通知与React Native应用程序在后台

    我有一个ReactNative应用程序,我试图获得一个发送到JavaScript处理程序的静默iOS推送通知.我看到的行为是AppDelegate中的didReceiveRemoteNotification函数被调用,但是我的JavaScript中的处理程序不会被调用,除非应用程序在前台,或者最近才被关闭.我很困惑的事情显然是应用程序正在被唤醒,并且它的didReceiveRemoteNotifi

随机推荐

  1. xe-ajax-mock 前端虚拟服务

    最新版本见Github，点击查看历史版本基于XEAjax扩展的Mock虚拟服务插件；对于前后端分离的开发模式，ajax+mock使前端不再依赖后端接口开发效率更高。CDN使用script方式安装，XEAjaxMock会定义为全局变量生产环境请使用xe-ajax-mock.min.js，更小的压缩版本，可以带来更快的速度体验。

  2. vue 使用 xe-ajax

    安装完成后自动挂载在vue实例this.$ajaxCDN安装使用script方式安装，VXEAjax会定义为全局变量生产环境请使用vxe-ajax.min.js，更小的压缩版本，可以带来更快的速度体验。cdnjs获取最新版本点击浏览已发布的所有npm包源码unpkg获取最新版本点击浏览已发布的所有npm包源码AMD安装require.js安装示例ES6Module安装通过Vue.use()来全局安装示例./Home.vue

  3. AJAX POST数据中文乱码解决

    前端使用encodeURI进行编码后台java.net.URLDecoder进行解码编解码工具

  4. Koa2框架利用CORS完成跨域ajax请求

    实现跨域ajax请求的方式有很多，其中一个是利用CORS，而这个方法关键是在服务器端进行配置。本文仅对能够完成正常跨域ajax响应的，最基本的配置进行说明。这样OPTIONS请求就能够通过了。至此为止，相当于仅仅完成了预检，还没发送真正的请求呢。

  5. form提交时，ajax上传文件并更新到&lt;input&gt;中的value字段

  6. ajax的cache作用

    filePath="+escape;},error:{alert;}});解决方案：1.加cache:false2.url加随机数正常代码：网上高人解读：cache的作用就是第一次请求完毕之后，如果再次去请求，可以直接从缓存里面读取而不是再到服务器端读取。

  7. 浅谈ajax上传文件属性contentType = false

    默认值为contentType="application/x-www-form-urlencoded".在默认情况下，内容编码类型满足大多数情况。在这里，我们主要谈谈contentType=false.在使用ajax上传文件时：在其中先封装了一个formData对象，然后使用post方法将文件传给服务器。说到这，我们发现在JQueryajax()方法中我们使contentType=false,这不是冲突了吗？这就是因为当我们在form标签中设置了enctype=“multipart/form-data”,

  8. 909422229_ajaxFileUpload上传文件

    ajaxFileUpload.js很多同名的，因为做出来一个很容易。我上github搜AjaxFileUpload出来很多类似js。ajaxFileUpload是一个异步上传文件的jQuery插件传一个不知道什么版本的上来，以后不用到处找了。语法：$.ajaxFileUploadoptions参数说明：1、url上传处理程序地址。2，fileElementId需要上传的文件域的ID，即的ID。3，secureuri是否启用安全提交，默认为false。4，dataType服务器返回的数据类型。6，error

  9. AJAX-Cache：一款好用的Ajax缓存插件

    原文链接AJAX-Cache是什么Ajax是前端开发必不可少的数据获取手段，在频繁的异步请求业务中，我们往往需要利用“缓存”提升界面响应速度，减少网络资源占用。AJAX-Cache是一款jQuery缓存插件，可以为$.ajax()方法扩展缓存功能。

  10. jsf – Ajax update/render在已渲染属性的组件上不起作用

    我试图ajax更新一个有条件渲染的组件。我可以确保#{user}实际上是可用的。这是怎么引起的，我该如何解决呢？必须始终在ajax可以重新呈现之前呈现组件。Ajax正在使用JavaScriptdocument.getElementById()来查找需要更新的组件。但是如果JSF没有将组件放在第一位，那么JavaScript找不到要更新的内容。解决方案是简单地引用总是渲染的父组件。

返回
顶部