`
xiaoliang330
  • 浏览: 115369 次
  • 性别: 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  
大哥,加加注释好不?看不懂唉

相关推荐

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

    5. **处理推送消息**: 在JavaScript事件处理器中,接收并处理由服务器推送过来的消息。可以更新DOM元素,显示新消息,或者执行其他客户端操作。 6. **优化性能和资源管理**: 为了防止过多的连接占用服务器资源,...

    实现 Dwr 服务器推送

    三、DWR服务器推送的实现 1. **配置DWR** - 首先,需要在项目中引入DWR的jar包。 - 在web.xml中配置DWR的ContextListener和Servlet。 - 创建dwr.xml配置文件,定义允许与JavaScript交互的Java类和方法。 2. **...

    dwr实现的服务器推demo

    在这个"**dwr实现的服务器推demo**"中,我们看到一个实例,展示了如何利用DWR的技术来实现实时的、无需刷新的服务器推送功能。 服务器推是一种技术,它允许服务器主动地将数据发送到客户端,而不需要客户端(通常是...

    dwr demo 反向推送 导向推送

    这个"**dwr demo 反向推送 导向推送**"是一个示例项目,展示了如何利用DWR来实现反向推送技术,也称为服务器推送。这种技术允许服务器主动地将数据推送到客户端,而不需要客户端不断地发起请求。 在传统的HTTP协议...

    dwr推技术实现服务器推送数据

    5. **客户端接收**:在JavaScript中,使用DWR提供的API注册回调函数,接收到服务器推送的数据后进行处理和展示。 Java推技术不仅限于DWR,还有其他框架如Comet、Atmosphere等也提供了类似的功能。但DWR因其易用性和...

    DWR服务器推送技术(实时)

    **DWR的服务器推送实现**: DWR使用一种称为Reverse Ajax或Comet的技术来实现服务器推送。它创建了一个持久化的HTTP连接,使得服务器可以在准备好新数据时立即发送,而不需要等待客户端的请求。DWR提供了一种简单的...

    DWR实现服务器推送站内消息

    使用DWR框架实现服务器器消息推送,本例以登录为例供大家参考学习:client与service建立一个长连接,不用client手动request,service会自动response,当有好友在线的时候,会自动把好友的信息加载到select里,点击...

    dwr3实现推送功能

    而推送功能则反其道而行,由服务器主动向客户端发送数据,即服务器推送。这在实时性要求高的应用场景中非常有用,如聊天、股票更新、在线协作等。 3. **配置DWR 3** 要启用DWR 3的推送功能,首先需要在项目的Web-...

    使用dwr+spring实现消息推送

    在IT行业中,消息推送是一项重要的技术,它使得服务器能够实时地向客户端发送数据,而无需客户端不断地轮询请求。在本教程中,我们将探讨如何利用Direct Web Remoting (DWR) 和Spring框架来实现这样的功能。 DWR是...

    dwr实现服务器推技术,兼容低版本IE

    "dwr实现服务器推技术,兼容低版本IE"这一主题,表明我们将讨论如何利用DWR实现在旧版Internet Explorer上的服务器推送功能。 1. **DWR基础原理** DWR的核心在于创建一个JavaScript对象,该对象可以直接调用服务器...

    dwr服务器推送,dwr.jar,推送,服务器ajax,dwr服务推送例子

    在实际应用中,使用DWR服务器推送的例子可能包括实时聊天系统、股票行情更新、在线游戏状态同步等。例如,你可以创建一个Java类,定义一个返回最新消息的方法,然后在dwr.xml中配置该类和方法,使其可以被JavaScript...

    dwr spring服务器主动推送示例代码

    这个类会被DWR自动暴露给JavaScript,以便于服务器推送数据。 ```java public class ServerPushService { public void sendMessage(String message) { // 业务逻辑,获取需要推送的数据 // ... // 调用DWR ...

    dwr3推送消息

    然后,你可以使用`addReverseAjaxListener()`来添加事件监听器,监听`onMessage`事件,当接收到服务器推送的消息时执行相应的处理函数。 在实际应用中,可能还需要考虑多线程和并发问题,因为服务器可能需要同时...

    dwr实现消息精确推送

    ### dwr实现消息精确推送详解 #### 一、前言 Direct Web Remoting(DWR)是一种开源技术,它使得JavaScript可以直接调用服务器端的Java方法成为可能,从而简化了客户端与服务器之间的交互过程。本篇文章将详细介绍...

    springMVC+dwr技术实现消息推送实例

    5. **事件处理:** 当服务器推送消息时,JavaScript会接收到通知,然后根据需求更新页面或者触发其他客户端事件。 6. **安全性和优化:** 考虑到性能和安全性,可能需要限制长连接的数量,进行连接管理和超时处理,...

    DWR服务器推送技术实现WebQQ

    DWR服务器推送实现步骤 - **配置DWR**:首先,我们需要在Web应用中集成DWR库,并在Web-INF目录下创建dwr.xml配置文件,配置允许的Java类和方法供JavaScript调用。 - **创建Java服务端接口**:定义一个Java接口或...

    DWR推送技术大全 dwr推送聊天实例

    总的来说,DWR推送技术通过Comet实现了高效的服务器到客户端的数据推送,简化了实时Web应用的开发。结合提供的源码示例"j-jetty-dwr-comet-src",开发者可以深入理解DWR的工作原理,并学习如何在实际项目中应用这项...

    springMvc + dwr 注解 实现消息推送

    5. **前端页面**:使用JavaScript和DWR API调用服务器端的方法,实现实时消息的推送和显示。 在前端,我们可以利用JavaScript事件监听器来触发DWR调用,当有新的消息时,前端页面会立即更新。此外,DWR还支持异步...

    Java Dwr实现消息精准推送以及js调用后台+demo

    在“Java Dwr实现消息精准推送以及js调用后台+demo”这个主题中,我们将深入探讨如何利用DWR来实现高效的消息推送和JavaScript与后台Java的交互。以下是一些关键知识点: 1. **DWR基础**:DWR的核心功能是提供一种...

    dwr消息推送完整示例

    在前端JavaScript代码中,订阅DWR提供的事件,以便在接收到服务器推送的消息时执行相应的处理函数,如更新页面内容、显示通知等。 3. **错误处理与连接管理** 实现错误处理和连接管理机制,例如在连接断开时尝试...

Global site tag (gtag.js) - Google Analytics