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

admin

在下根据网上的相关资料，摸索着写了一个DWR框架推模式的小聊天室，可实现私聊功能。
! K$ ~* e1 N$ x% y: x3 w功能基本正常，但是偶尔会出现信息显示不同步的问题，现将源码奉上，希望各位高手能指点一二。ChatManager.java
4 c7 A; ?- O& Q( S% `: N* U

1. package services;
   . y+ e" C7 a' H" k+ E; w% R
2. 
   
3. import java.util.ArrayList;
   9 |% b: w/ |. N- e  A) Y
4. import java.util.Collection;
   " I* F; X' l. e* p7 o
5. import java.util.List;
   $ U0 X/ ^) O) y+ U! }8 s% u
6. 
   9 d9 z8 G. J* F; K3 ]
7. import javax.servlet.http.HttpServletRequest;
   & \6 a4 V2 C. `! }8 r" Y( ?) _1 U
8. import javax.servlet.http.HttpSession;
   . S$ J- s3 Q2 w6 A7 t- d+ r
9. 
   % j; |6 @: o9 I1 z
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    
12. import org.directwebremoting.WebContextFactory;
    # Z, s2 I+ j7 p- |" f9 U
13. import org.directwebremoting.proxy.dwr.Util;
    0 u( A' A2 f/ m3 Y
14. 
    
15. import pojo.MessageInfo;
    
16. import pojo.UserInfo;
    7 H" r9 Z7 X8 w) [5 M/ P! b% s
17. 
    2 l4 m3 X6 b: s9 \0 B0 L) L* V
18. public class ChatManager {
    
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(){
    " f% d2 O7 T) C/ O' u: c( i9 H1 [. x
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    ) W* g* T" ~1 {/ e
24.                 sendUserList.add(userInfo);
    % Z1 f: a, |$ n( N! h
25.         }
    
26.        
    
27.         public String updateOnlineUsers(String userName,boolean flag) {
    
28.                 UserInfo userInfo=null;
    ( h3 t7 Y' L( p: C! K
29.                 WebContext context=WebContextFactory.get();
    
30.                 HttpSession session = context.getSession();
    
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    
35.                         this.setScriptSessionFlag(userInfo);
    + T- ?+ u3 g" T3 ?. G; U
36.                 }
    5 r. Z1 c8 V. R  h
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    + M) j' A; e6 J( S. H5 n' D
39.                 Util allPageUtil = new Util(sessionsByPage);
    
40.                 allPageUtil.removeAllOptions("onlineList");
    
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    
44.                 if (!flag) {
    5 A5 u8 P$ N6 X6 `8 D6 P+ `
45.                         return null;
    
46.                 }
    ' t0 Z' O0 N: z1 \4 U0 i
47.                 return userInfo.getUserId();
    
48.         }
    
49.        
    ) n# d2 q8 ?8 `: A
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
      y/ i8 H4 A/ Z5 Q) c$ G2 Y
52.         }
    ! w# U* {+ S' B1 C; P! |
53.        
    2 ?  q8 Q7 ~- a
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    - ]2 H1 ~9 x5 \+ x/ H) B4 j
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    9 `6 E; V: o, N' G$ Q0 Y* E
57.                 WebContext context = WebContextFactory.get();
    ! L( A( n9 P/ Y5 ^
58.                 String currentPage = "/chat/index.jsp";
    
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    ; _2 w$ m5 q1 z0 v+ E2 Q
60.                 sessions.addAll(sessionsByPage);
    
61.                 if ("0".equals(userId)) {
    - ]% x8 _. R; s% b
62.                         list=sessions;
    
63.                 }else{
    " F+ A# P( E- z+ {* W( a
64.                         for (ScriptSession session : sessions) {
    ( J) T* F' C. y  F0 o$ H! w
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    . J0 y9 E" b! a5 C9 m8 w2 S
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    
68.                                         break;
    + u+ H& ]3 [; Q0 L$ A3 d3 @, D; }7 T: c
69.                                 }
    % U0 |+ Q7 [- ?& U, c/ n8 ^% F
70.                         }
    
71.                 }
    
72.                 return list;
    
73.         }
    3 n& R+ D  O* p' ~8 P
74.        
    
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);
    " X9 r9 i: _) y2 z  H4 Q
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    
80.                 receiverUtil.removeAllOptions("messageList");
    & x7 e) p8 i- z9 _% E# T
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    % _  o1 h" E4 A& D
82.         }
    7 s+ I$ K% D% ]- t) d3 o
83. }
    , `  i4 I+ I" X) ?4 W

复制代码

8 ~; ]+ k* L, @- j2 t项目源码下载地址：点击下载

9 X8 O' b3 M' |4 T; [

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了
) f& Z5 _9 G' d5 u4 }2 d# |

woniu

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