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

admin

在下根据网上的相关资料，摸索着写了一个DWR框架推模式的小聊天室，可实现私聊功能。
: j: y" r; v1 l功能基本正常，但是偶尔会出现信息显示不同步的问题，现将源码奉上，希望各位高手能指点一二。ChatManager.java
; c5 }4 ]6 o! c6 J: G( Z

1. package services;
   
2. 
   
3. import java.util.ArrayList;
   : e! m) M; Z% |7 e9 _# D$ A
4. import java.util.Collection;
   
5. import java.util.List;
   
6. 
   # i, A. o3 @* n( ~
7. import javax.servlet.http.HttpServletRequest;
   : |/ S( Q8 s$ I  i# k
8. import javax.servlet.http.HttpSession;
   ) Z& T4 q8 X/ S4 s
9. 
     G& Y# f$ h! R: P6 W4 }
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
      f, k+ {" n  l' r5 y, e% \# b
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    2 M* S) {. p6 p' k2 z1 k
14. 
    3 K( D7 U9 h2 u$ K2 |5 m
15. import pojo.MessageInfo;
    
16. import pojo.UserInfo;
    
17. 
    5 s4 K9 x9 a& {5 a6 g
18. public class ChatManager {
    : `/ H' p, `; ]8 R
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(){
    5 a0 b) g3 }0 \* Q8 G
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    
24.                 sendUserList.add(userInfo);
    # V$ I* J2 d- m& z0 y6 Z6 T, w9 [
25.         }
    : ]# Z7 E% t8 Z: c$ t! D
26.        
    
27.         public String updateOnlineUsers(String userName,boolean flag) {
    
28.                 UserInfo userInfo=null;
    " a  ~  U" y6 F5 |, F, Z' Z
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);
    1 R7 m$ f0 A+ F) Y5 C4 o
36.                 }
    9 @( V4 U$ G* f" Y7 F+ }( `, s
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    2 v2 _) I5 N1 F
39.                 Util allPageUtil = new Util(sessionsByPage);
    ; b( c! ~1 g7 x2 ~7 v
40.                 allPageUtil.removeAllOptions("onlineList");
    " K0 q+ u' A2 ^% [: q
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    
44.                 if (!flag) {
    $ k' T. s3 M( x$ u- ^8 t
45.                         return null;
    ) e1 s' h, Q; }+ ~
46.                 }
    3 ~! s8 c$ |, b) O. |
47.                 return userInfo.getUserId();
    + O5 G3 p$ |  _  e
48.         }
    % ?% ~5 a/ s. O4 N; c
49.        
    
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    0 u7 ^' V- Y, F- J- d: R1 P+ W
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    2 Z0 X/ x. P+ d! A& d9 V2 b
53.        
    
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    ' N+ t! }" e$ j, ~( S! x) k, o/ Q' E
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    $ V8 L. r/ G# }% k9 s) W0 i
57.                 WebContext context = WebContextFactory.get();
    
58.                 String currentPage = "/chat/index.jsp";
    4 r+ F5 g0 L. i
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    8 ^' z. F* B$ R+ ?
60.                 sessions.addAll(sessionsByPage);
    & e4 o* ]/ k6 u/ _& J7 w
61.                 if ("0".equals(userId)) {
    : i' [1 C% f6 Z
62.                         list=sessions;
    ; R% L" a3 a) H! w
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    
66.                                 if (userId.equals(userInfo.getUserId())) {
    : X- o& Z7 [' H% t2 f: h% |/ R
67.                                         list.add(session);
    , |5 x/ R; ]% ~" B: ^% q; M( V
68.                                         break;
    
69.                                 }
    
70.                         }
    
71.                 }
    % c/ W% \: T# g
72.                 return list;
    ( v% n9 m: T; u, x- b
73.         }
    
74.        
    / Z% y5 I. A  V6 }
75.         public void sendMessage(String sender,String receiverId,String msg) {
    
76.                 Collection<ScriptSession> scriptSessionFlag = this.getScriptSessionFlag(receiverId);
    & W9 }* m. q( h. J* L( Z' p8 T
77.                 MessageInfo messageInfo = new MessageInfo(sender,receiverId,msg);
    
78.                 messageList.add(messageInfo);
    
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    $ H2 y' b7 X: I) a, H
80.                 receiverUtil.removeAllOptions("messageList");
    # j+ V5 Z- k5 @! ]* Z- C4 j* k
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    
82.         }
    
83. }
    

复制代码

项目源码下载地址：点击下载
& b3 u6 K9 O$ P) L, X; p! _( a9 Q5 A1 d

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了

woniu

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