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

admin

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

9 g! p# X, x8 V6 _, A- D: ~

1. package services;
   
2. 
   
3. import java.util.ArrayList;
   # ]+ e. h1 f! e% j
4. import java.util.Collection;
   
5. import java.util.List;
   
6. 
   
7. import javax.servlet.http.HttpServletRequest;
   " }9 `" V1 s' L; e6 Z
8. import javax.servlet.http.HttpSession;
   
9. 
   ( @+ D: h+ _" T
10. import org.directwebremoting.ScriptSession;
    . [% H' q) [! ]' v
11. import org.directwebremoting.WebContext;
    
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    
14. 
    
15. import pojo.MessageInfo;
    
16. import pojo.UserInfo;
    
17. 
    + @1 x% E/ {' a; ^: J) F
18. public class ChatManager {
    
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    1 @! G$ }) K. M2 n7 P# Q
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    4 G( Z. ]- S# b& ]" R
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    
22.         public ChatManager(){
    
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    . P/ I& L- k% `0 U  ^0 g' f
24.                 sendUserList.add(userInfo);
    
25.         }
    : m8 `- q, a0 q8 s; i, I- I
26.        
    ! G& k4 C% M, K# T
27.         public String updateOnlineUsers(String userName,boolean flag) {
      ~3 Q0 E# G& w9 n$ Z
28.                 UserInfo userInfo=null;
    
29.                 WebContext context=WebContextFactory.get();
    . y1 k$ O% ^: ^9 v- E
30.                 HttpSession session = context.getSession();
    
31.                 if (flag) {
    ; P7 P0 z% v" d+ l
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    3 r8 |+ J% N" X' n, Q, ~/ K) @
35.                         this.setScriptSessionFlag(userInfo);
    . t/ i+ v6 m3 b7 g6 T3 q  C
36.                 }
    3 e6 H8 y6 z" A; j) C$ j
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
39.                 Util allPageUtil = new Util(sessionsByPage);
    
40.                 allPageUtil.removeAllOptions("onlineList");
    " r- }; m2 S9 Z0 @( E6 P9 i! c& |
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    ; i* H6 P  q* s5 Z5 A/ `2 ^
44.                 if (!flag) {
    
45.                         return null;
    
46.                 }
    
47.                 return userInfo.getUserId();
    
48.         }
    
49.        
    3 f* G% ^& [7 z$ _
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    
53.        
    
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    5 C) U7 w, q- b/ s1 K1 \0 V  R  R
57.                 WebContext context = WebContextFactory.get();
    2 l, w, l( Q$ ~9 Z0 S9 \- W" I/ b' M
58.                 String currentPage = "/chat/index.jsp";
    
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
60.                 sessions.addAll(sessionsByPage);
    
61.                 if ("0".equals(userId)) {
    1 V+ c; g! z" l& v
62.                         list=sessions;
    $ E5 n; I$ f; @* e$ g/ _# K: d
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    . i; j4 b, t3 G6 y/ M
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    ; o& m0 K. [7 a, A& v
68.                                         break;
    
69.                                 }
    4 b+ z! V% v1 @- O( p1 l
70.                         }
    
71.                 }
    $ X. r9 M% {" P
72.                 return list;
    
73.         }
    
74.        
    
75.         public void sendMessage(String sender,String receiverId,String msg) {
    6 s* B- y4 _; F
76.                 Collection<ScriptSession> scriptSessionFlag = this.getScriptSessionFlag(receiverId);
    
77.                 MessageInfo messageInfo = new MessageInfo(sender,receiverId,msg);
    
78.                 messageList.add(messageInfo);
    ( R- X' L# Q& O6 Q2 |& \5 q* W
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    
80.                 receiverUtil.removeAllOptions("messageList");
    
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    % {- v% n# j0 H0 r
82.         }
    ( ~* W6 o* O0 X  \# D6 d5 P. V
83. }
    

复制代码

项目源码下载地址：点击下载

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了
2 f  ^2 }2 b' ?

woniu

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