利用的是一种默认的配置。
User和Message是2个Javabean，封装用户及消息数据。
ChatLogon负责登录后跳转到聊天页面。
Chat聊天的主类。
如下是具体代码：
User.java:
package com.dwr.chat.demo;
public class User {
private String userId;
private String area;
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getArea() {
return area;
}
public void setArea(String area) {
this.area = area;
}
}
Message.java:
package com.dwr.chat.demo;
public class Message {
private String from;
private String to;
private String msg;
private String area;
public String getFrom() {
return from;
}
public void setFrom(String from) {
this.from = from;
}
public String getTo() {
return to;
}
public void setTo(String to) {
this.to = to;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
public String getArea() {
return area;
}
public void setArea(String area) {
this.area = area;
}
}
ChatLogon.java:
package com.dwr.chat.demo;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
/**
* Servlet implementation class ChatLogon
*/
public class ChatLogon extends HttpServlet {
private static final long serialVersionUID = 1L;
/**
* @see HttpServlet#HttpServlet()
*/
public ChatLogon() {
super();
// TODO Auto-generated constructor stub
}
/**
* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
*/
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
this.doPost(request, response);
}
/**
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
*/
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
String userId = request.getParameter("userId");
String area = request.getParameter("area");
if (userId == null || "".equals(userId) || area == null || "".equals(area)) {
response.sendRedirect("/chat/jsp/logon.jsp");
}
else {
HttpSession session = request.getSession();
User user = new User();
user.setArea(area);
user.setUserId(userId);
session.setAttribute("user", user);
request.getRequestDispatcher("/chat/jsp/chat.jsp").forward(request, response);
}
}
}
Chat.java:
package com.dwr.chat.demo;
import java.util.Collection;
import javax.servlet.http.HttpSession;
import org.directwebremoting.ScriptBuffer;
import org.directwebremoting.ScriptSession;
import org.directwebremoting.WebContext;
import org.directwebremoting.WebContextFactory;
public class Chat {
public void sendMsg(String msg, String to) {
WebContext context = WebContextFactory.get();
HttpSession session = context.getSession();
ScriptSession ss = context.getScriptSession();
Collection<ScriptSession> sess = context.getAllScriptSessions();
System.out.println("sess length:" + sess.size());
if (msg == null || "".equals(msg)) {
return;
}
session.setAttribute("flag", session.hashCode());
ss.setAttribute("flag", session.hashCode());
User user = (User) session.getAttribute("user");
if (ss.getAttribute("user") == null) {
ss.setAttribute("user", user);
}
Message message = new Message();
message.setFrom(user.getUserId());
message.setMsg(msg);
message.setTo("".equals(to) ? "所有人" : to);
message.setArea(user.getArea());
ScriptBuffer sbf = new ScriptBuffer();
sbf.appendScript("Chat.recvMsg(");
sbf.appendData(message);
sbf.appendScript(");");
// 是否有这个人
boolean hasThisPerson = true;
// 是否可以私聊
boolean isPPOk = false;
// 是否在同一区域。
boolean isInSameArea = true;
ScriptSession ssTo = null;
// 是否是与自己聊天
boolean isWithSlef = false;
for (ScriptSession ssr : sess) {
if (ssr != null) {
User user2 = (User) ssr.getAttribute("user");
if (user2 != null) {
if ("".equals(to)) {
// 发送信息给所有人。
ssr.addScript(sbf);
System.out.println("发送给所有人。");
} else {
if (user2.getArea().equals(user.getArea())) {
if (user2.getUserId().equals(to)) {
// 如果是自己，则不能进行私聊
if (user2.getUserId().equals(user.getUserId())) {
isWithSlef = true;
break;
}
else {
ssTo = ssr; // 私聊
isPPOk = true;
break;
}
} else { // 没有这个人呢。
hasThisPerson = false;
break;
}
} else {
isInSameArea = false; // 用户与您不在同一区域
break;
}
}
}
}
}
if (!hasThisPerson) {// 没有这个人。
ss.addScript(new ScriptBuffer(// 不能return
"alert('对不起，没有这个人！');"));
System.out.println("对不起，没有这个人！");
}
if (!isInSameArea) {
ss.addScript(new ScriptBuffer("alert('" + to
+ "与您不在同一区域！');"));
System.out.println("不再同一个区域。。。");
}
if (isPPOk)
{
// 私聊
ssTo.addScript(sbf);
// 同时，发给自己
ss.addScript(sbf);
System.out.println("私聊。"); // 不能return
ssTo = null;
}
if (isWithSlef) {
ss.addScript(new ScriptBuffer("alert('自己不能跟自己聊天！');"));
System.out.println("自己不能跟自己聊天。");// 不能return
}
}
public void exitPage() {
WebContext context = WebContextFactory.get();
HttpSession ses = context.getSession();
if (ses.getAttribute("flag") != null) {
int flag = (Integer) ses.getAttribute("flag");
Collection<ScriptSession> colls = context.getAllScriptSessions();
for (ScriptSession ss : colls) {
if (ss != null) {
if ((Integer) ss.getAttribute("flag") == flag) {
ss.invalidate();
return;
}
}
}
}
}
}
Chat.js:
var Chat = new function() {
this.sendMsg = function(){
var msg = document.getElementById("msg").value;
var pp = document.getElementById("pps");
if (pp.checked) {
// 如果选中复选框，说明是私聊。
pp = document.getElementById("pp").value;
}
else {
pp = "";
}
if (msg !== "") {
ChatServer.sendMsg(msg,pp);
document.getElementById("msg").value = "";
}
else {
alert("发送的消息不能为空！");
return;
}
};
this.recvMsg = function(data) {
var dd = document.getElementById("msgCenter");
if (data !== null) {
var tr = document.createElement("tr");
var td1 = document.createElement("td");
var td2 = document.createElement("td");
var td3 = document.createElement("td");
var td4 = document.createElement("td");
td1.innerText = dd.rows.length;
td2.innerText = data.from;
td3.innerText = data.to;
td4.innerText = data.msg;
tr.appendChild(td1);
tr.appendChild(td2);
tr.appendChild(td3);
tr.appendChild(td4);
dd.appendChild(tr);
}
};
this.keySendMsg = function(e) {
e = e || event;
if (e.keyCode == 10) {
sendMsg();
}
};
// 在选中私聊复选框时，显示
this.showOrHidePP = function(oItem) {
var pp = document.getElementById("pp");
if (oItem.checked) {
pp.style.display = "block";
}
else {
pp.style.display = "none";
}
};
};
Login.jsp:
<%@ page language="java" contentType="text/html; charset=gb18030" pageEncoding="gb18030"%> <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=gb18030"> <title>logon</title> <link href="../css/global.css"></link> </head> <body> <fieldset style="width: 600px;"> <legend>用户登录</legend> <form action="/dwr/chat/logon.action" method="post"> <table width="500px" cellpadding="0" cellspacing="0"> <tr> <td>用户ID：</td> <td><input type="text" name="userId"> </td> </tr> <tr> <td>区域：</td> <td><input type="radio" name="area" value="etc01" checked="checked">电信一区 <input type="radio" name="area" value="etc02">电信二区</td> </tr> <tr align="center"> <td colspan="2"><input type="submit" value="登录系统"> </td> </tr> </table> </form> </fieldset> </body> </html>
chat.jsp:
<%@ page language="java" contentType="text/html; charset=gb18030"
pageEncoding="gb18030"%>
<%@page import="com.dwr.chat.demo.User"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=gb18030">
<title>chat</title>
<link href="../css/global.css"></link>
<script type="text/javascript" src="/dwr/dwr/engine.js"></script>
<script type="text/javascript" src="/dwr/dwr/util.js"></script>
<script type="text/javascript" src="/dwr/dwr/interface/ChatServer.js"></script>
<script type="text/javascript" src="/dwr/chat/js/chat.js"></script>
<script type="text/javascript">
window.onunload = ChatServer.exitPage();
document.onunload = ChatServer.exitPage();
</script>
</head>
<body onload="dwr.engine.setActiveReverseAjax(true);ChatServer.sendMsg('','');">
<div>
<%
User user = (User)session.getAttribute("user");
%>
<span style="color:red;font-size:15px;">欢迎<%=user==null?"":user.getUserId() %></span>
</div>
<div style="width:500px;">
<fieldset>
<legend>输入内容</legend>
<input type="checkbox" id="pps" onclick="Chat.showOrHidePP(this);">私聊<input type="text" id="pp" style="display:none;">
<table width="500px" cellpadding="0" cellspacing="0">
<tr>
<td>输入消息：</td>
<td><textarea rows="8" cols="55" id="msg" name="msg"></textarea>
</td>
</tr>
<tr align="center">
<td colspan="2"><input type="button" value="发送" onclick="Chat.sendMsg();">
</td>
</tr>
</table>
</fieldset>
</div>
<div style="width:500px;">
<fieldset>
<legend>消息中心：</legend>
<table width="500px" cellpadding="0" cellspacing="0" id="msgCenter" border="1">
<tr>
<td>编号</td>
<td>发信人</td>
<td>收信人</td>
<td>消息内容</td>
</tr>
</table>
</fieldset>
</div>
</body>
</html>
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" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" 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>dwr</display-name>
<welcome-file-list>
<welcome-file>index.html</welcome-file>
<welcome-file>index.htm</welcome-file>
<welcome-file>index.jsp</welcome-file>
<welcome-file>default.html</welcome-file>
<welcome-file>default.htm</welcome-file>
<welcome-file>default.jsp</welcome-file>
</welcome-file-list>
<servlet>
<servlet-name>dwr-invoker</servlet-name>
<servlet-class>org.directwebremoting.servlet.DwrServlet</servlet-class>
<init-param>
<param-name>activeReverseAjaxEnabled</param-name>
<param-value>true</param-value>
</init-param>
<init-param>
<param-name>debug</param-name>
<param-value>true</param-value>
</init-param>
<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>
</servlet>
<servlet-mapping>
<servlet-name>dwr-invoker</servlet-name>
<url-pattern>/dwr/*</url-pattern>
</servlet-mapping>
<servlet>
<description></description>
<display-name>ChatLogon</display-name>
<servlet-name>ChatLogon</servlet-name>
<servlet-class>com.dwr.chat.demo.ChatLogon</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>ChatLogon</servlet-name>
<url-pattern>/chat/logon.action</url-pattern>
</servlet-mapping>
</web-app>
dwr.xml:
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE dwr PUBLIC "-//GetAhead Limited//DTD Direct Web Remoting 2.0//EN" "http://www.getahead.ltd.uk/dwr/dwr20.dtd"> <dwr> <allow> <create creator="new" javascript="ChatServer"> <param name="class" value="com.dwr.chat.demo.Chat"></param> </create> <convert converter="bean" match="com.dwr.chat.demo.User"></convert> <convert converter="bean" match="com.dwr.chat.demo.Message"></convert> </allow> </dwr>
相关推荐
spring3 dwr3 聊天 dwr server push spring3+dwr3实现聊天功能 使用DWR SERVER PUSH 实现聊天功能
DWR在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能 java jsp页面
DWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rarDWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rarDWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rarDWR 在线...
现在DWR的反转AJAX功能.允许我们从服务器端来控制客服端.而不需要客户端来请求.服务器可以自动把消息发给指定的客户端! 我不能把公司的代码贴出来,所以我自己写了一个DEMO,已经实现了对指定用户发送消息的功能,...
所有技术:;j2ee dwr servlet js 实现在线聊天功能，无刷新，逆推信息。
用JSP实现 时时聊天功能 用DWR 用JSP实现 时时聊天功能 用DWR
myeclipse 工程 简单的实例 点对点聊天功能的实现
spring整合dwr 完成无刷新的ajax聊天室功能 利用comet技术
dwr和spring的整合做下整理，以及对网页版的聊天功能做了一个简单的Demo，用了注解的方式，使用dwr框架来把Java代码，通过Javascript方式调用。功能虽不全，但集成是从网络上获取的，加以修改。希望对网友有用。
dwr服务器推技术 整合struts2，实现多人同一个界面聊天，可以看到信登陆的用户，可以私人聊天和群聊功能
基于DWR的webIM系统，利用反向ajax（comet）技术和dwr框架实现了聊天室和点对点聊天的功能，项目运行起来后打开页面，输入用户名即可登录，登录后用户会显示在左侧用户框中，若想与用户私聊，在用户框中点击用户，在...
如果你还是停留在原来的ajax层面的话，这次绝对...DWR出2.0版了,其中最大的亮点就是Reverse Ajax技术!传统的浏览器发起请求服务器返回响应,而现在通过反向ajax可以由服务器向浏览器发响应但是不需要浏览器提供请求。...
使用DWR服务器推送技术实现聊天功能，在线的所有用户以及用户发送的消息都有服务器“推”给客户端进行显示。
实现一个简单的Web版的聊天功能,Java使用开源框架最新版本的dwr3,包括相应的JSP页面的实现。
用ajax技术实现聊天室功能，主要采用DWR框架，参考《基于J2EE的Ajax宝典》
没事的时候自己写的一个聊天室，用了SSH框架整合DWR推反转AJAX技术，可能有一些不合理的地方，但实现了聊天室的基本功能，希望给大家一些帮助。需要大家根据spring配置文件，配置下Mysql数据库，建一张用户表就可以...
这个程序是模仿QQ实现的群聊功能,基本类似聊天室.聊天记录每5条保存到数据库,具体请各位朋友细看. 技术:ExtJS 3.2 DWR 3.0 Struts 2.16 Spring 2.0 Hibernate 3.2 MySql 5.0 原文地址: ...
基于dwr的聊天室，也可实现消息的推送，类似与websocket失效消息发送推送功能
服务器推送技术，在同一个界面实现多用户聊天和私聊功能
ext + ibatis + spring + struts2 + dwr实现，数据库自己建一个，改spring的配置文件就行，表名：users，字段只有三个：id（int），name，password 这个版本是我做的测试版本，登录界面是我随便从其他系统整过来的...