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

admin

在下根据网上的相关资料，摸索着写了一个DWR框架推模式的小聊天室，可实现私聊功能。
功能基本正常，但是偶尔会出现信息显示不同步的问题，现将源码奉上，希望各位高手能指点一二。ChatManager.java
7 U1 |: s) p1 w. j+ |! V8 Y) @
6 u, ^3 H; u5 Q4 Z) P8 d% A

1. package services;
   
2. 
   
3. import java.util.ArrayList;
   
4. import java.util.Collection;
   & Z$ G9 l, i; U8 o- L6 R9 O0 p  k$ G
5. import java.util.List;
   . y, H, |) `$ Y( ]- M+ I9 E& v
6. 
   
7. import javax.servlet.http.HttpServletRequest;
   0 K3 [" ?3 t+ a! K4 E
8. import javax.servlet.http.HttpSession;
   + J2 s2 y" R: Y
9. 
   8 q- |6 S5 d. t0 }( r, I
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    
14. 
    . J: G( z6 i, w: x4 Z0 Q
15. import pojo.MessageInfo;
    ! o1 q& H) D# \/ q  g: w
16. import pojo.UserInfo;
    : U- c" t+ r( e1 w# S
17. 
    
18. public class ChatManager {
    
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    5 v4 g. J9 O+ F/ g8 ]3 }
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    0 M6 Y5 \4 ?4 q( w- B$ c$ m
22.         public ChatManager(){
    4 F  H# C5 Q, J
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    
24.                 sendUserList.add(userInfo);
    
25.         }
    - \9 F. Q6 S+ A# [3 [
26.        
    
27.         public String updateOnlineUsers(String userName,boolean flag) {
    3 `. U) }$ u+ o4 n  x( r, r: g
28.                 UserInfo userInfo=null;
    
29.                 WebContext context=WebContextFactory.get();
    $ d/ l' j4 Q, w* x' E: [- U5 b
30.                 HttpSession session = context.getSession();
    * N! i9 G4 e8 D2 L$ J& ?
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    
35.                         this.setScriptSessionFlag(userInfo);
    
36.                 }
    
37.                 String currentPage = "/chat/index.jsp";
      t1 g' k6 e+ }  }: P
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    / r  `. x/ D& n1 O+ N
39.                 Util allPageUtil = new Util(sessionsByPage);
    . ?) x9 L, J( S  U' l+ s
40.                 allPageUtil.removeAllOptions("onlineList");
    . p2 [- f: W  T) `. a6 R
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    1 Y" G* N- ]6 V
42.                 allPageUtil.removeAllOptions("userList");
    3 O: t. |  X* N8 ]* c
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    - ?% ]/ Z% Q9 F/ ~
44.                 if (!flag) {
    
45.                         return null;
    8 X$ ~2 Q1 s4 J  g5 o. I! e
46.                 }
    
47.                 return userInfo.getUserId();
    
48.         }
    
49.        
    , E) ]0 W6 g- Y
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    - d" i; j, G" A( ~5 v6 [
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    
53.        
      B+ ]7 o2 h; L/ V) }* N
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    0 e5 J# Y6 y9 y9 ~5 p2 F# e
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    
57.                 WebContext context = WebContextFactory.get();
    
58.                 String currentPage = "/chat/index.jsp";
    7 {# C" N  x4 @+ q% N/ O  z
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    1 p5 |! z% t8 Q5 ^! p' N1 N4 \
60.                 sessions.addAll(sessionsByPage);
      h* A# O+ R  a
61.                 if ("0".equals(userId)) {
    , Q; j, j; c: _& U  _# s
62.                         list=sessions;
    5 y+ G/ g! K) ?
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    * U" A/ `, A& d& ^% G7 m
68.                                         break;
    3 [% k8 V. Y* N3 {6 v# |
69.                                 }
    - v! o0 R/ |' T; w9 q
70.                         }
    
71.                 }
    ) V9 a) {  ^8 l0 k) B4 ?# j
72.                 return list;
    2 N) r- b0 i2 c8 F+ ^
73.         }
    4 Z  t; w" H! H( A  }
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);
    , u( J0 V  S/ G
78.                 messageList.add(messageInfo);
    ' n+ w0 {; R$ s. Y4 E
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    
80.                 receiverUtil.removeAllOptions("messageList");
    , e2 j5 B' Z7 t9 b( y9 n  z( s) u  D
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    
82.         }
    ) _! Z& Z# }+ T+ X  N& h
83. }
    , b0 |3 y: b. K. W  N

复制代码

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

! Y+ V; L8 Z/ y7 ]# y3 U' N

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了

woniu

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