javaWeb聊天室简单例子（可私聊）

admin

在下根据网上的相关资料，摸索着写了一个DWR框架推模式的小聊天室，可实现私聊功能。
功能基本正常，但是偶尔会出现信息显示不同步的问题，现将源码奉上，希望各位高手能指点一二。ChatManager.java

1. package services;
   ' G1 S4 E6 K4 j# p; n/ t6 f) e2 m
2. 
   - S2 z% P4 r0 k0 O/ k" Z
3. import java.util.ArrayList;
   ' F% K- X( ~5 o' }% o8 c: Y: T2 y
4. import java.util.Collection;
   
5. import java.util.List;
   . r% o+ x& \9 X4 O5 N: A% l
6. 
   , v2 t* g- y8 g" r" j4 E+ l0 N
7. import javax.servlet.http.HttpServletRequest;
   
8. import javax.servlet.http.HttpSession;
   3 o2 X+ d6 S9 j/ @
9. 
   
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    $ S* g# P$ N' @+ a
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    
14. 
      x$ }: r7 _# }; Y& [
15. import pojo.MessageInfo;
    3 G' f1 ~* ^  g+ v; N
16. import pojo.UserInfo;
    
17. 
    % {2 H6 F1 I. I: w) ?9 I) [
18. public class ChatManager {
    0 e: L0 [8 c3 `$ H& P9 m' i
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    
22.         public ChatManager(){
    2 o& g& c/ V* f* G! y
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    
24.                 sendUserList.add(userInfo);
    ' C- V! w: N/ \& S2 k7 _4 n+ m& O3 ]/ b
25.         }
    0 }+ [5 _7 ]; `/ O0 V8 L
26.        
    8 }  P9 ?5 x1 Y' u) H/ o
27.         public String updateOnlineUsers(String userName,boolean flag) {
    % c) F" u- V) z+ v
28.                 UserInfo userInfo=null;
    - P& I$ p2 H! e7 u
29.                 WebContext context=WebContextFactory.get();
    
30.                 HttpSession session = context.getSession();
    
31.                 if (flag) {
    7 d7 D6 l8 h8 Q7 I% H9 k1 E; X9 V
32.                         userInfo = new UserInfo(session.getId(),userName);
    6 q- o9 y% G: n
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    6 j: ]( A0 D+ z5 ?8 c7 v9 @
35.                         this.setScriptSessionFlag(userInfo);
    0 v  w1 I1 x( E) L1 V3 f
36.                 }
    
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
39.                 Util allPageUtil = new Util(sessionsByPage);
    3 h& d7 R' {/ T( Y- N1 a1 K: _
40.                 allPageUtil.removeAllOptions("onlineList");
    
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    
44.                 if (!flag) {
    
45.                         return null;
    
46.                 }
    
47.                 return userInfo.getUserId();
    
48.         }
    
49.        
    
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    / Y, T$ @/ F1 j3 }# r% [
53.        
    
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    . E7 U0 F2 x: z* n- u; N3 A2 M/ s
57.                 WebContext context = WebContextFactory.get();
    
58.                 String currentPage = "/chat/index.jsp";
    
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    ; T& T* X5 z% |1 u' `/ I. {" z
60.                 sessions.addAll(sessionsByPage);
    
61.                 if ("0".equals(userId)) {
    3 w% y0 F$ b7 g/ B# e
62.                         list=sessions;
    
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    0 {+ z/ W9 m# S" V0 @
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    
68.                                         break;
    
69.                                 }
    . {/ b# R% j9 d) x3 q
70.                         }
    
71.                 }
    " {5 q- F" \- n8 x7 @" m2 [$ M0 j
72.                 return list;
    
73.         }
    , q$ I5 g( v* b
74.        
    - i6 {+ P  b0 a+ r) N6 @# _
75.         public void sendMessage(String sender,String receiverId,String msg) {
    
76.                 Collection<ScriptSession> scriptSessionFlag = this.getScriptSessionFlag(receiverId);
    
77.                 MessageInfo messageInfo = new MessageInfo(sender,receiverId,msg);
    
78.                 messageList.add(messageInfo);
    
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    6 y( L# h8 i9 W! R
80.                 receiverUtil.removeAllOptions("messageList");
    
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    9 a  ^2 f4 G$ _) S* O+ d/ F
82.         }
    ! b5 k3 T$ @( ]% z
83. }
    ( S# X( s5 \8 i" N3 a9 l# T6 g

复制代码

项目源码下载地址：点击下载
0 L4 H! _2 d5 f# o
9 K7 D% @* }& z! E% k- s

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了
# D" {' T! k% U9 D- J

woniu

这个项目太棒勒！下下来学习下！