`
xiaoliang330
  • 浏览: 115306 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

小玩dwr实现服务器推送

 
阅读更多
最近项目有需要用到‘推’,就是服务器端自动把消息推给客户端,就做了个不像样的dwr实现的服务器推送demo,玩玩...

首先少不了dwr的jar包。
然后是在项目中建个dwr.xml的配置文件,当然,同时需要在web.xml中配置。

贴上代码:
web.xml
<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee 
	http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
	<servlet>
		<servlet-name>DwrServlet</servlet-name>
		<servlet-class>org.directwebremoting.servlet.DwrServlet</servlet-class>
		<init-param>
			<param-name>debug</param-name>
			<param-value>true</param-value>
		</init-param>
		<init-param>
			<param-name>pollAndCometEnabled</param-name>
			<param-value>true</param-value>
		</init-param>
		<load-on-startup>12</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>DwrServlet</servlet-name>
		<url-pattern>/dwr/*</url-pattern>
	</servlet-mapping>


	<welcome-file-list>
		<welcome-file>index.jsp</welcome-file>
	</welcome-file-list>

</web-app>



配置也没什么好解释的,
然后在工程中创建了两个类:

package dwr.reverseAjax;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import javax.servlet.http.HttpSession;

import org.directwebremoting.WebContext;
import org.directwebremoting.WebContextFactory;
import org.directwebremoting.proxy.dwr.Util;
import org.directwebremoting.util.Logger;

import dwr.reverse.StocksPusher;

public class DWRAjaxReverse implements Runnable {
	public static List<DWRAjaxReverse> store = new ArrayList<DWRAjaxReverse>();
	WebContext wctx = null;
	public String currentPage = "";
	private static final Logger log = Logger.getLogger(DWRAjaxReverse .class);

	@SuppressWarnings("unchecked")
	public DWRAjaxReverse() {
		ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(
				1);
		executor.scheduleAtFixedRate(this, 1, 7000, TimeUnit.MILLISECONDS);

		wctx = WebContextFactory.get();
		HttpSession session = wctx.getSession();
		List<DWRAjaxReverse> list = (List<DWRAjaxReverse>) session
				.getAttribute("DWRHelper");
		if (list == null)
			list = new ArrayList<DWRAjaxReverse>();
		list.add(this);
		store.add(this);
	}

	@SuppressWarnings("unchecked")
	public void addMessage(String text) {
		LinkedList messages = new LinkedList();
		if (text != null && text.trim().length() > 0) {
			messages.addFirst(new Message(text));
			while (messages.size() > 10) {
				messages.removeLast();
			}
		}
		wctx = WebContextFactory.get();
		currentPage = wctx.getCurrentPage();

		Util utilThis = new Util(wctx.getScriptSession());
		utilThis.setValue("text", "");

		Collection sessions = wctx.getScriptSessionsByPage(currentPage);
		Util utilAll = new Util(sessions);

		utilAll.removeAllOptions("chatlog");
		// utilAll.addOptions("chatlog", messages, "text");
		utilAll.addFunctionCall("reverseAjax", text);
	}

	@SuppressWarnings("unchecked")
	@Override
	public void run() {
		if (true) {
			log.info("run...");
			Collection sessions = wctx.getScriptSessionsByPage(currentPage);
			Util utilAll = new Util(sessions);
			Date date = new Date();
			LinkedList lst = new LinkedList();
			lst.add(new Message(date.toString()));
			// utilAll.setValue("text", date.toString());
			//utilAll.removeAllOptions("chatlog");
			//utilAll.addOptions("chatlog", lst, "text");
			utilAll.addFunctionCall("reverseAjax", date.toString());
			log.info("current time is : "+date.toString());
		}
	}

}






package dwr.reverseAjax;

import org.directwebremoting.Security;

public class Message {
	private String text;
	private long id = System.currentTimeMillis();
	
	public Message(String newText){
		text = newText;
		if(text.length()>256){
			text = text.substring(0,256);
		}
		text = Security.replaceXmlCharacters(text);
	}

	public String getText() {
		return text;
	}

	public void setText(String text) {
		this.text = text;
	}

	public void setId(long id) {
		this.id = id;
	}

	public long getId() {
		return id;
	}
}





主要操作都在DWRAjaxReverse类中。

然后就是在dwr.xml中配置了,
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE dwr PUBLIC "-//GetAhead Limited//DTD Direct Web Remoting 2.0//EN" "http://getahead.org/dwr/dwr20.dtd">
<dwr>
	<allow>
	
		<create creator="new" javascript="DWRAjaxReverse">
			<param name="class" value="dwr.reverseAjax.DWRAjaxReverse" />
			<include method="addMessage" />
		</create>
		<convert converter="bean" match="dwr.reverseAjax.Message">
			<param name="include" value="id,text" />
		</convert>


	</allow>
</dwr>


用过dwr的人这个配置你懂的!


现在写个简单的jsp,

<h1>
	DWR AjaxReverse
</h1>
    <meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
	<script type='text/javascript' src='/stock/dwr/engine.js'></script>
	<script type='text/javascript' src='/stock/dwr/util.js'></script>
	<script type='text/javascript' src='/stock/dwr/interface/DWRAjaxReverse.js'></script>
	
	<body onload="dwr.engine.setActiveReverseAjax(true);init()">
	
	<script type="text/javascript">
	
	function reverseAjax(messages){
		document.getElementById('time_text').innerHTML= messages;
	}

	function init() {
		DWRAjaxReverse.addMessage("you are welcome!");
	}
</script>
	<hr />
	<ul id="chatlog" style="list-style-type: none;" >
	</ul>
	<span id='time_text' ></span>
	
</body>



不要问我/stock/dwr/engine.js 这样在工程中看不到的js在哪,玩dwr这个是要懂的(其实我也不懂,只知道dwr会自己虚拟的创建)

dwr.engine.setActiveReverseAjax(true) 这句在你的前台页面是不能少的

其中,reverseAjax这个function就是给后台调用的,后台调用前台
到此,这么个demo也算像个样子了

分享到:
评论
1 楼 lihong11 2013-01-05  
大哥,加加注释好不?看不懂唉

相关推荐

    MongoDB分片集群搭建教程:副本集创建与数据分片

    内容概要:本文提供了详细的MongoDB分片集群的搭建指导,涵盖了从环境准备、配置文件编写、副本集的建立、主节点的选择、配置服务器和数据分片服务器的配置到最后的路由节点的搭建与操作整个流程,以及对数据库的哈希与范围两种分片策略的应用介绍和具体命令执行。 适合人群:熟悉NoSQL数据库概念并对MongoDB有一定了解的技术人员,尤其是在大型数据管理和分布式数据库架构设计中有需求的开发者。 使用场景及目标:帮助技术人员掌握构建高效能、高可用性的MongoDB分片集群的方法,适用于处理大规模、实时性强的数据存储与读取场景。 其他说明:文中通过实例演示了每个步骤的具体操作方法,便于跟随文档实操,同时也介绍了可能遇到的问题及其解决方案,如在没有正确配置的情况下试图写入数据时出现错误等情况的处理。

    CPPC++_嵌入式硬件的物联网解决方案blinker库与Arduino ESP8266 ESP32一起工作.zip

    CPPC++_嵌入式硬件的物联网解决方案blinker库与Arduino ESP8266 ESP32一起工作

    CPPC++_逆向调用QQ Mojo IPC与WeChat XPlugin.zip

    CPPC++_逆向调用QQ Mojo IPC与WeChat XPlugin

    CPPC++_现代活动指标.zip

    CPPC++_现代活动指标

    CPPC++_Xournal是一款手写笔记软件,支持PDF注释,使用C语言编写,支持GTK3,支持Linux,如Ubu.zip

    CPPC++_Xournal是一款手写笔记软件,支持PDF注释,使用C语言编写,支持GTK3,支持Linux,如Ubu

    基于SSM学生实习管理系统前台小程序与后台管理系统开发实践

    资源概述: 本资源提供了一套完整的学生实习管理系统解决方案,涵盖了前台小程序页面与后台管理系统两大模块。前台小程序页面设计简洁直观,用户可根据不同身份(学生或企业)进行登录。学生用户能够方便地浏览并投递感兴趣的实习岗位,而企业用户则能轻松发布实习信息,吸引优秀人才。后台管理系统功能全面,包括个人中心、首页、学生管理、教师管理、企业管理、招聘管理、评分管理以及实习管理等多个方面,为管理员提供了强大的数据管理和操作工具。 技术栈亮点: SSM框架:系统后台采用Spring、Spring MVC和MyBatis Plus(简称SSM)作为核心开发框架,确保了系统的稳定性、可扩展性和可维护性。Spring作为控制反转(IoC)和面向切面编程(AOP)的容器,为系统提供了强大的业务逻辑处理能力;Spring MVC则负责处理Web请求和响应,实现了前后端的分离;MyBatis Plus作为持久层框架,简化了数据库操作,提高了开发效率。 MySQL数据库:系统采用MySQL作为数据库存储解决方案,支持大数据量的存储和高效查询。 如有侵权请联系我删除,谢谢

    微服务闪聚支付项目.zip

    微服务闪聚支付项目

    Rust 与 Java 互调实战示例

    博客链接 https://blog.csdn.net/weixin_47560078/article/details/143714557 文章从原理介绍出发,实现了 Rust 与 Java 的互调。利用 JNI 技术,可以充分发挥 Rust 的性能优势,同时保持 Java 的跨平台特性。这种技术组合适用于对性能要求较高的应用场景,如图像处理、数据分析和系统级编程等。

    CPPC++_这是我翻译的艾根中文文档.zip

    cppc++

    Matlab实现斑马优化算法ZOA-TCN-Multihead-Attention多输入单输出回归预测算法研究.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。 替换数据可以直接使用,注释清楚,适合新手

    Matlab实现雪融优化算法SAO-TCN-Multihead-Attention多输入单输出回归预测算法研究.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。 替换数据可以直接使用,注释清楚,适合新手

    分布式事务lcn.zip

    分布式事务lcn

    基于Simulink的正弦波PWM技术和三次谐波注入PWM技术研究.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。

    【风电功率预测】基于BiTCN的风电功率多变量输入预测研究附Matlab代码.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。

    CPPC++_这是由一块迷你带OV2640双DRV8833驱动TypeC接口PSRAM的ESP32PicoD4开发板驱.zip

    cppc++

    JAVA安卓手机与电脑的socket通信源码数据库 其他源码类型 WinForm

    安卓手机与电脑的socket通信源码

    Anaconda:JupyterNotebook使用教程.docx

    Anaconda:JupyterNotebook使用教程.docx

    Amazon S3:S3静态网站托管教程.docx

    Amazon S3:S3静态网站托管教程.docx

    Python商品销售数据分析可视化项目源码(期末大作业).zip

    Python商品销售数据分析可视化项目源码(期末大作业).zip,个人经导师指导并认可通过的98分大作业设计项目。主要针对计算机相关专业的正在做期末大作业设计的学生和需要项目实战练习的学习者,可作为课程设计、期末大作业,代码资料完整下载可用。 Python商品销售数据分析可视化项目源码(期末大作业).zip,个人经导师指导并认可通过的98分大作业设计项目。主要针对计算机相关专业的正在做期末大作业设计的学生和需要项目实战练习的学习者,可作为课程设计、期末大作业,代码资料完整下载可用。Python商品销售数据分析可视化项目源码(期末大作业).zip,个人经导师指导并认可通过的98分大作业设计项目。主要针对计算机相关专业的正在做期末大作业设计的学生和需要项目实战练习的学习者,可作为课程设计、期末大作业,代码资料完整下载可用。Python商品销售数据分析可视化项目源码(期末大作业).zip,个人经导师指导并认可通过的98分大作业设计项目。主要针对计算机相关专业的正在做期末大作业设计的学生和需要项目实战练习的学习者,可作为课程设计、期末大作业,代码资料完整下载可用。Python商品销售数据分析

    CPPC++_wechathookWeChatApi微信Api微信hook微信接口python微信接口java微信Ap.zip

    CPPC++_wechathookWeChatApi微信Api微信hook微信接口python微信接口java微信Ap

Global site tag (gtag.js) - Google Analytics