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

admin

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

1. package services;
   ' ], L9 G. a$ Q* }4 n. V% L1 P
2. 
   / U9 r( B% I& y3 M9 ?
3. import java.util.ArrayList;
   
4. import java.util.Collection;
   4 N" H/ Y! [* h, E. J
5. import java.util.List;
   3 a- x2 ~+ C# e7 X; J
6. 
   
7. import javax.servlet.http.HttpServletRequest;
   
8. import javax.servlet.http.HttpSession;
   
9. 
   
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    8 A9 B- c* T, @
12. import org.directwebremoting.WebContextFactory;
    " H$ @$ {& I/ S# F  i5 N5 R2 c
13. import org.directwebremoting.proxy.dwr.Util;
    0 M( c" w3 j8 d' D, C. x
14. 
    + W7 _8 u. k; D# e0 d3 w
15. import pojo.MessageInfo;
    0 l9 ?, N$ V$ f( D; i9 z; a* H
16. import pojo.UserInfo;
    : ^0 z0 n9 n8 a, g* Q: T
17. 
    
18. public class ChatManager {
    1 D7 {: R5 b* k: a6 e4 a; r+ v  \
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    % [% T7 z4 ~3 I" U1 R
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    ( B; z8 u; G$ O; ?! N) v
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    
22.         public ChatManager(){
    
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    * t: r7 c# ]1 B( w
24.                 sendUserList.add(userInfo);
    " z! u+ _3 B. {, T
25.         }
      Y3 F3 j: j) Z, H5 o
26.        
    6 ^( g: J! I0 D% S  l" d
27.         public String updateOnlineUsers(String userName,boolean flag) {
    & u4 [! v) I8 K+ w0 \; p: R
28.                 UserInfo userInfo=null;
    6 U" j5 v7 Q3 M2 l% \" K
29.                 WebContext context=WebContextFactory.get();
    ; d& j( A+ X6 {. `' ]
30.                 HttpSession session = context.getSession();
    
31.                 if (flag) {
    ; g7 i' \6 B7 f
32.                         userInfo = new UserInfo(session.getId(),userName);
    & F- s! s' e& @
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    
35.                         this.setScriptSessionFlag(userInfo);
    
36.                 }
    ( S. H# U0 s8 I4 p) [
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
39.                 Util allPageUtil = new Util(sessionsByPage);
    
40.                 allPageUtil.removeAllOptions("onlineList");
    ( E4 y" p7 t1 S7 C' ^! f
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    $ j: h! p* i" ?9 f- m7 \
42.                 allPageUtil.removeAllOptions("userList");
    1 j# {4 J, n/ O9 X/ q  X% u: i! t
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    " q' E7 {8 _; r, j7 t; K
44.                 if (!flag) {
    0 Z2 N# Z4 Y/ V7 ^7 v- f% i
45.                         return null;
    
46.                 }
    
47.                 return userInfo.getUserId();
    - @: z( c# j2 ?
48.         }
    ) x0 U( R; P% L1 ]4 [- n: K; I
49.        
    
50.         public void setScriptSessionFlag(UserInfo userInfo) {
      \. f$ q1 N: o
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    
53.        
    
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    5 h' J# r8 s! F7 b, l
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    7 {' `9 P, r. B/ h: h
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    7 |+ _+ b: F; {  i
57.                 WebContext context = WebContextFactory.get();
    - u, ]' p  Q5 d+ \8 x& @- u
58.                 String currentPage = "/chat/index.jsp";
    * f9 Q6 T2 H6 @4 E# z( p  B( W
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    9 D0 g" h/ B2 M  G. W' u
60.                 sessions.addAll(sessionsByPage);
    
61.                 if ("0".equals(userId)) {
    7 N* e9 v! @+ I' d* G2 t& E. @
62.                         list=sessions;
    
63.                 }else{
    8 F# ^4 E, x0 R2 A
64.                         for (ScriptSession session : sessions) {
    ! ]4 |! \4 C4 W' \+ L
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    2 {5 U9 z: y" g  R- ~  u+ {
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    
68.                                         break;
    4 C* J8 c6 C; K/ ^1 W% {# m
69.                                 }
    ' d# j2 }; S; u) ^# x" O9 R
70.                         }
    ( s. @7 ?4 K' t: G/ I* l; J) R' g
71.                 }
    
72.                 return list;
    
73.         }
    4 c: p: i5 g: {! _+ y9 i8 K8 k/ z, c' Y
74.        
    6 Z9 n( z+ k& f& _
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);
    
80.                 receiverUtil.removeAllOptions("messageList");
    
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    
82.         }
    4 ?$ a. d" D  a* W* f' n
83. }
    

复制代码

- |* i6 A% n3 S  t6 _! B项目源码下载地址：点击下载

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了

woniu

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