dwr消息推送和tomcat集群

发布时间：2020-12-16 00:52:45 所属栏目：百科来源：网络整理

导读：网友的提问：项目中用到了dwr消息推送。而服务端是通过一个http请求后触发dwr中的推送方法。而单个tomcat中。服务器发送的http请求和用户都在一个tomcat服务器中。这样就能精准推送到每个客户端用户中。现在配置了apache集群后，通过负载均衡，apache把服

网友的提问：

项目中用到了dwr消息推送。而服务端是通过一个http请求后触发dwr中的推送方法。而单个tomcat中。服务器发送的http请求和用户都在一个tomcat服务器中。这样就能精准推送到每个客户端用户中。现在配置了apache集群后，通过负载均衡，apache把服务器的这个http请求也给分配给一个tomcat容器中。这样的话，在别的tomcat容器中的用户就接受不要消息了。有什么好的办法让这个请求分配给每个tomcat容器。

提取到的知识点是

dwr消息推送、apache集群、负载均衡

http://tonl.iteye.com/blog/1399027

使用DWR反转实现信息推送（一）

除了利用Pushlet实现信息推送外，DWR反转同样可以实现推送。

DWR的简单配置方法已经在以前的博客中写过。所以这里直接贴代码：

新建web工程，这里命名为DwrEg，包结构如下：

web.xml代码如下：

    Xml代码 
    
  
 <?xmlversion="1.0"encoding="UTF-8"?>
<web-appversion="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">
servletservlet-name>dwr-invoke</servlet-class>uk.ltd.getahead.dwr.DWRServletinit-paramparam-name>debugparam-value>true>activeReverseAjaxEnabled <!--
>classes>java.lang.Object>-- 
servlet-mappingurl-pattern>/dwr/*welcome-file-listwelcome-file>client.htmlweb-app>

dwr.xml代码如下：

<!DOCTYPEdwrPUBLIC"-//GetAheadLimited//DTDDirectWebRemoting2.0//EN""http://getahead.org/dwr//dwr20.dtd"dwrallowcreatejavascript="myrevsrse"creator="new"paramname="class"value="com.src.MyReverse"/>create MyReverse.java代码如下：

    Java代码 
    
  
packagecom.src;importjava.util.Collection;
importorg.directwebremoting.ScriptBuffer;
importorg.directwebremoting.ScriptSession;
importorg.directwebremoting.ServerContext;
importorg.directwebremoting.ServerContextFactory;
importorg.directwebremoting.WebContext;
importorg.directwebremoting.WebContextFactory;
importorg.directwebremoting.proxy.dwr.Util;
publicclassMyReverse{
voidsendMes(Stringmes){
 System.out.println("kaoshisibestllll...");
 send("系统消息："+mes);
 }
voidsend(finalStringoutput){
 org.directwebremoting.WebContextweb=WebContextFactory.get();
 Stringpage=web.getServletContext().getContextPath()+"/client.html";
 Collectionsessions=web.getScriptSessionsByPage(page);
 System.out.println("size=="+sessions.size());
 UtilutilAll=newUtil(sessions);
 utilAll.addFunctionCall("callBack",output);//callBack是client.jsp里面的javascript函数，output是传递过去的参数
 //utilAll.setValue("news_id",output,false);
//这种方法也可以，直接将client.html里id为news_id的textarea的值设置为output的值
voidnoticeNewOrder(intid){
 WebContextwctx=WebContextFactory.get();
 ScriptBufferscript=newScriptBuffer();
 script.appendScript("receiveMessages(")
 .appendData(id)
 .appendScript(");");
 ServerContextsctx=ServerContextFactory.get(wctx.getServletContext());
 Collection<ScriptSession>pages=sctx.getScriptSessionsByPage("/DwrEg/client.html");
for(ScriptSessionsession:pages){
 session.addScript(script);
 }
 client.html代码如下：

    Html代码 
   htmlscripttype="text/javascript"src="dwr/engine.js">scriptscripttype="text/javascript"src="dwr/util.js"headscripttype="text/javascript" functioncallBack(data){
 alert(data);
 functionreceiveMessages(id){
 $('orderNotice').innerHTML="收到id为"+id+"的新订单!";
 $('orderNotice').show();
bodyonload="dwr.engine.setActiveReverseAjax(true);"textarearows="20"cols="20"id="news_id"textareabrdivid="orderNotice"divbody 推送界面dopush.html的代码如下：
scripttype="text/javascript"src="dwr/interface/myrevsrse.js"metahttp-equiv="Content-Type"content="text/html;charset=utf-8"title>Inserttitlehere functionsendnews(){
 varnew_content=dwr.util.getValue("newcontent");
 myrevsrse.sendMes(new_content);
 functionsendinfo(){
 myrevsrse.noticeNewOrder(12);
inputtype="text"name="newcontent"inputtype="button"value="发消息"onclick="sendnews()"inputtype="button"value="send2"onclick="sendinfo()" 同样，这里的问题也是怎么实现点对点的信息推送，这儿只是实现了向所有的clent.html页面推送信息，以后接着总结。。。。


 
tomcat集群http://www.52php.cn/article/p-dnqaqzvd-gc.html
（编辑：李大同）
【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!