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

admin

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

1. package services;
   
2. 
   
3. import java.util.ArrayList;
   3 y9 N  w' i6 y8 u% A
4. import java.util.Collection;
   9 F% M$ r( o' J" m- k. O& m8 @
5. import java.util.List;
   " y: P4 E6 @8 p& v
6. 
   3 C; E* T+ U+ z# V
7. import javax.servlet.http.HttpServletRequest;
   , N) T) n+ O9 I% D* r- e" H8 G. ?
8. import javax.servlet.http.HttpSession;
   & m$ D9 U/ q0 I$ M2 N$ W
9. 
   7 C+ ^4 g! r/ {  t0 @
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    0 b& ]; y, E& |% G5 x# t
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    7 i$ Q8 Q  v  J  ^$ K4 t, O* G  `4 u
14. 
    9 ^. H0 v: m$ P/ \- v  z, q4 h
15. import pojo.MessageInfo;
    
16. import pojo.UserInfo;
    & I7 H+ N: |0 d, Z+ a# o9 H$ u
17. 
    ) i5 o( ]# F' h0 x3 m
18. public class ChatManager {
    5 M: |" s1 d; ]
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    # U( }$ A# y8 ~# W! G! o: h
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    ( a% C) O* }$ G% M6 Y; N* N8 T
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    ; X$ E9 s7 [# q! E
22.         public ChatManager(){
    
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    
24.                 sendUserList.add(userInfo);
    $ u: p( ]$ _4 A% f# l0 A8 E: ^! L
25.         }
    8 i; t& H, J5 m6 p% N: L
26.        
    7 t- ?5 a0 _& s2 R8 b6 d5 F6 z
27.         public String updateOnlineUsers(String userName,boolean flag) {
    ) ~$ c% h; w0 h2 W; p, j) K
28.                 UserInfo userInfo=null;
    # B: ]8 ?0 q, ?) j: ]- F% P+ K8 K
29.                 WebContext context=WebContextFactory.get();
    2 \) E3 u8 N7 d+ w" i
30.                 HttpSession session = context.getSession();
    ( u/ N+ f/ j( U
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
    # w) z2 H+ ~) Y( x' ^$ T; I
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    5 ^3 W6 {2 d+ f8 K0 k% t' L
35.                         this.setScriptSessionFlag(userInfo);
    
36.                 }
    
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
39.                 Util allPageUtil = new Util(sessionsByPage);
    
40.                 allPageUtil.removeAllOptions("onlineList");
    . U9 e6 [+ Z# O/ x- X
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    5 D+ q7 d8 Y5 u7 H
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    % G# m" J+ c1 H" t
44.                 if (!flag) {
    7 Y8 {) G- b" G0 _9 r
45.                         return null;
    " R+ G: p* _+ c0 t, n& W# `& U
46.                 }
    5 I3 s# g- T3 r& K  t" E1 g( R
47.                 return userInfo.getUserId();
    
48.         }
    4 L4 b0 j% S) ^* C7 H4 x# O
49.        
    
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    # J$ u( I1 Y7 ^* }0 f' g
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    ; R* ]" X4 @8 H0 _7 L; d/ W
53.        
    % B" p) m( [  \
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
      e0 m- i$ j) X) i+ u
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    5 W8 ?& Z; m8 x) `
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    4 D% z6 g+ s) m. s2 d
57.                 WebContext context = WebContextFactory.get();
    ' h  ]+ ^' s2 S* |( o; {
58.                 String currentPage = "/chat/index.jsp";
    
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
60.                 sessions.addAll(sessionsByPage);
    , G) x; @1 I/ |4 D
61.                 if ("0".equals(userId)) {
    . f; j2 Z& y6 d! n& P" F# _9 H& O
62.                         list=sessions;
    
63.                 }else{
    , k6 ]7 i; k( V4 P  k
64.                         for (ScriptSession session : sessions) {
    & G4 u8 d6 |5 J/ }8 [4 ~- d6 R
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    : B0 Z4 ~$ |$ }9 u/ ]' |
68.                                         break;
    
69.                                 }
    
70.                         }
    3 V) v) N5 ~: n/ h
71.                 }
    
72.                 return list;
    & Z6 n( G; Y- U, [2 z
73.         }
    ( s$ ^, O9 J  Y8 o' E) h
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);
    ' l- o& {* t7 W
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    9 u! I6 l2 d; R' K; |) _/ d
80.                 receiverUtil.removeAllOptions("messageList");
    
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    
82.         }
    : s6 \2 w- x: J2 p7 Y) a
83. }
    

复制代码

项目源码下载地址：点击下载
: N8 \6 @1 q* b6 g. p

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了
. I* H# H4 h* O# [6 B

woniu

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