微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

DWR3实现服务器端向客户端精确推送消息

分类：Ajax作者：编程之家

研究了一天半，终于模拟出了这个功能，网上DWR的资料不少，但是真正实现客户端向服务器端精确推送消息的只有两篇文章。但是代码都只有一部分，向我这种刚开始学习DWR的人来说要看懂真的蛮难。不过即便如此，http://www.blogjava.net/stevenjohn/archive/2012/07/07/382447.html这片文章还是给了我很大帮助，再次表示感谢，下面我将这两天的研究详细记录下来备忘，也希望能帮助到像我一样的人。只写过程，不写原理（不是不写，而是有些地方我也不太懂），下面开始：

第一、在项目中引入dwr.jar，然后在web.xml中进行配置，配置如下：

Java代码
  1. <servlet>
  3. <servlet-name>dwr-invoker</servlet-name>
  4. <servlet-class>
  5. org.directwebremoting.servlet.DwrServlet
  6. </servlet-class>
  7. <init-param>
  8. <param-name>crossDomainSessionSecurity</param-name>
  9. <param-value>false</param-value>
  10. </init-param>
  11. <param-name>allowScriptTagRemoting</param-name>
  12. <param-value>true</param-value>
  13. <param-name>classes</param-name>
  14. <param-value>java.lang.Object</param-value>
  15. <param-name>activeReverseAjaxEnabled</param-name>
  16. <param-name>initApplicationScopeCreatorsAtStartup</param-name>
  17. <param-name>maxWaitAfterWrite</param-name>
  18. <param-value>3000</param-value>
  19. <param-name>debug</param-name>
  20. <param-name>logLevel</param-name>
  21. <param-value>WARN</param-value>
  22. </servlet>

第二：在web.xml的同级目录下新建dwr.xml文件，内容如下

Java代码 <!DOCTYPEdwrPUBLIC
  • "-//GetAheadLimited//DTDDirectWebRemoting3.0//EN"
  • "http://getahead.org/dwr/dwr30.dtd">
  • <dwr>
  • <alow>
  • <createcreator="new"javascript="MessagePush">
  • <paramname="class"value="com.huatech.messageremind.service.MessagePush"/>
  • </create>
  • <createcreator="new"javascript="TestPush">
  • <paramname="class"value="com.huatech.messageremind.service.Test"/>
  • </alow>
  • </dwr>

    • 这个是dwr的基本配置，MessagePush在页面的javascript中使用，这个是对被推送页面开放的java类，Test是对推送页面开放的java类。场景：管理员后台登陆，发布一条消息，通过Test推送到后台，后台通过MessagePush推送给指定的用户，当然，至于怎么找到指定的用户，下面会说。

    第三，被推送的页面代码

    Java代码 <%@pagelanguage="java"import="java.util.*"pageEncoding="utf-8"%>
  • <%
  • Stringpath=request.getContextPath();
  • StringbasePath=request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
  • %>
  • <!DOCTYPEHTMLPUBLIC"-//W3C//DTDHTML4.01Transitional//EN">
  • <html>
  • <head>
  • <basehref="<%=basePath%>">
  • <title>DWRDEMO</title>
  • <metahttp-equiv="pragma"content="no-cache">
  • <metahttp-equiv="cache-control"content="no-cache">
  • <metahttp-equiv="expires"content="0">
  • <metahttp-equiv="keywords"content="keyword1,keyword2,keyword3">
  • <metahttp-equiv="description"content="Thisismypage">
  • </head>
  • <scripttype='text/javascript'src='dwr/engine.js'></script>
  • <scripttype='text/javascript'src='dwr/util.js'></script>
  • <scripttype="text/javascript"src="dwr/interface/MessagePush.js"></script>
  • <scripttype="text/javascript">
  • //通过该方法与后台交互，确保推送时能找到指定用户
  • functiononPageLoad(){
  • varuserId='${userinfo.humanid}';
  • MessagePush.onPageLoad(userId);
  • }
  • //推送信息
  • functionshowMessage(autoMessage){
  • alert(autoMessage);
  • </script>
  • <bodyonload="onPageLoad();dwr.engine.setActiveReverseAjax(true);dwr.engine.setNotifyServerOnPageUnload(true);;">
  • ThisismyDWRDEOMpage.<hr>
  • <br>
  • <divid="DemoDiv">demo</div>
  • </body>
  • </html>

    • 以上代码的简单解释：

    页面页面onload的3个函数都是必须的，后两个是dwr的，第一个是将登录用户的userid与对应 的scriptSession进行处理，以便精确推送的时候能找到推送对象

    第四 MessagePush类中实现的方法如下：

    Java代码 publicvoidonPageLoad(StringuserId){
  • ScriptSessionscriptSession=WebContextFactory.get().getScriptSession();
  • scriptSession.setAttribute(userId,userId);
  • DwrScriptSessionManagerUtildwrScriptSessionManagerUtil=newDwrScriptSessionManagerUtil();
  • try{
  • dwrScriptSessionManagerUtil.init();
  • System.out.println("cacaca");
  • }catch(ServletExceptione){
  • e.printStackTrace();
  • }

    • 里面对应的DwrScriptSessionManagerUtil 对应如下：

    Java代码 importjavax.servlet.ServletException;
  • importjavax.servlet.http.HttpSession;
  • importorg.directwebremoting.Container;
  • importorg.directwebremoting.ServerContextFactory;
  • importorg.directwebremoting.WebContextFactory;
  • importorg.directwebremoting.event.ScriptSessionEvent;
  • importorg.directwebremoting.event.ScriptSessionListener;
  • importorg.directwebremoting.extend.ScriptSessionManager;
  • importorg.directwebremoting.servlet.DwrServlet;
  • publicclassDwrScriptSessionManagerUtilextendsDwrServlet{
  • privatestaticfinallongserialVersionUID=-7504612622407420071L;
  • publicvoidinit()throwsServletException{
  • Containercontainer=ServerContextFactory.get().getContainer();
  • ScriptSessionManagermanager=container.getBean(ScriptSessionManager.class);
  • ScriptSessionListenerlistener=newScriptSessionListener(){
  • publicvoidsessionCreated(ScriptSessionEventev){
  • HttpSessionsession=WebContextFactory.get().getSession();
  • StringuserId=((User)session.getAttribute("userinfo")).getHumanid()+"";
  • System.out.println("aScriptSessioniscreated!");
  • ev.getSession().setAttribute("userId",userId);
  • publicvoidsessionDestroyed(ScriptSessionEventev){
  • System.out.println("aScriptSessionisdistroyed");
  • };
  • manager.addScriptSessionListener(listener);
  • }

    • 第五 推送页面代码：

    Java代码 <%@pagelanguage="java"import="java.util.*"pageEncoding="UTF-8"%>
  • <title>MyJSP'MyJsp.jsp'startingpage</title>
  • <scripttype="text/javascript"src="<%=request.getContextPath()%>/js/jquery-1.5.1.js"></script>
  • <scripttype='text/javascript'src='dwr/interface/TestPush.js'></script>
  • functiontest(){
  • varmsg=document.getElementById("msgId").value;
  • //msg={msgId:'1',context:$("#msgContext").val()};
  • TestPush.sendMessageAuto(msg,"哈哈哈");
  • <body>
  • id&nbsp;&nbsp;&nbsp;&nbsp;:<inputtype="text"name="msgId"id="msgId"/><br/>
  • <inputtype="button"value="Send"onclick="test()"/>
  • </html>

    • 第六：精确推送要实现的代码：

    Java代码 publicclassTest{
  • publicvoidsendMessageAuto(Stringuserid,Stringmessage){
  • finalStringuserId=userid;
  • finalStringautoMessage=message;
  • Browser.withAllSessionsFiltered(newScriptSessionFilter(){
  • publicbooleanmatch(ScriptSessionsession){
  • if(session.getAttribute("userId")==null)
  • returnfalse;
  • else
  • return(session.getAttribute("userId")).equals(userId);
  • },newRunnable(){
  • privateScriptBufferscript=newScriptBuffer();
  • publicvoidrun(){
  • script.appendCall("showMessage",autoMessage);
  • Collection<ScriptSession>sessions=Browser
  • .getTargetSessions();
  • for(ScriptSessionscriptSession:sessions){
  • scriptSession.addScript(script);
  • });
  • }

    • 至此 这个例子的代码都已经贴出来了，应该是可以跑通的，有问题的话可以给我留言。当然，要自己写个登录，然后把userId放到session里面，这个比较简单，就不贴代码了，有问题可以在http://download.csdn.net/detail/luojia_wang/5275588上下载原项目。我只是简单的做了一个能实现功能的例子，还有很多地方要研究，比如跟spring整合，还可能有很多优化，等我继续学习一下再说.

    原文地址：https://www.jb51.cc/ajax/162054.html

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

    相关推荐

    ajax 上传文件项目下载
    IE6是一个非常老旧的网页浏览器，虽然现在很少人再使用它，但是在某些特殊情况下，我们可能还需要使用IE6来访问网页。而在IE6中，我们通常会使用JavaScript来提交表单，来看一下具体操作。
    ajax .post()
    PHP中的count()函数是用来计算数组或容器中元素的个数。这个函数十分方便，在编写代码时使用频率也非常高。无论你是要统计数组的长度、统计字符串中字符出现的次数还是统计对象中属性的个数，count()都可以帮助你轻松
    ajax 不返回值 写法
    使用 AJAX（Asynchronous JavaScript and XML）技术可以在不刷新整个页面的情况下，向服务器发送请求并接收响应。通常来说，我们使用 AJAX 请求是为了获取后台数据，并将其展示在前端页面上。然而，有时候我们只需要
    ajax 下载文件 blob
    Ajax（Asynchronous JavaScript and XML）是一种用于改进网页用户体验的技术，通过与服务器进行异步通信，实现在网页上局部刷新数据而不必整个页面刷新的功能。在实际开发中，我们经常需要从服务器端下载文件，而传统
    ajax 下载excel文件流
    本文将介绍如何通过AJAX下载Excel文件流。通过AJAX，我们可以在不刷新整个页面的情况下，向服务器发送请求并获取响应数据。在某些场景下，我们需要通过AJAX下载Excel文件流，以便于在前端使用或保存到本地。本文将详
    ajax .get .post
    Ajax是一种用于客户端和服务器之间的异步通信技术。通过Ajax，我们可以在不刷新整个页面的情况下向服务器发送请求并获得响应数据。而在Ajax的基础上，.get和.post是两种常用的请求方法，它们分别用于发送GET和POST请
    ajax 上传 excel
    AJAX（Asynchronous JavaScript and XML）是一种在网页上实现异步数据传输的技术。通过AJAX，网页可以在不刷新整个页面的情况下与服务器进行数据交互，提升用户体验和页面性能。在实际应用中，AJAX广泛用于表单提交、
    ajax 下拉 360取不到值
    在使用Ajax下拉加载数据的过程中，有时候会出现无法取到360度的问题。这个问题可能是由于代码逻辑的问题导致的，也有可能是网络延迟引起的。为了解决这个问题，我们需要对代码进行仔细排查，并且在合适的地方添加适当
    ajax 与 .post 区别
    本文将介绍Ajax和.post之间的区别。Ajax是一种用于在网页上进行异步通信的技术，能够在不刷新整个页面的情况下更新部分页面内容。.post是jQuery中的一个方法，用于向服务器发送POST请求。虽然它们都可以用于发送异步
    ajax 上传文件 目录权限
    AJAX（Asynchronous JavaScript and XML）是一种在Web页面上进行异步数据请求和交互的技术。它的出现使得页面在后台与服务器进行数据交互的同时，不需要重新加载整个页面。在网页开发中，常常需要实现文件上传功能，
    苹果市值2025年有望达4万亿美元
    pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot