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

admin

在下根据网上的相关资料，摸索着写了一个DWR框架推模式的小聊天室，可实现私聊功能。
- o3 D9 S3 A4 X3 s) y' j功能基本正常，但是偶尔会出现信息显示不同步的问题，现将源码奉上，希望各位高手能指点一二。ChatManager.java

" |  |/ S( \' I4 _% i9 N

1. package services;
   $ R6 I2 ~' m9 O7 W3 p
2. 
   8 K: P. H; }& p, g3 ~( ?' `
3. import java.util.ArrayList;
   * E; |* J# A) a
4. import java.util.Collection;
   
5. import java.util.List;
   
6. 
   4 k4 j+ C" D) c, w$ |+ M, X
7. import javax.servlet.http.HttpServletRequest;
   + ?. D2 V% |/ ^" C8 N
8. import javax.servlet.http.HttpSession;
   ! d+ l" O5 k* \! n5 c/ y
9. 
   6 @  ^2 S% f$ }6 h- k
10. import org.directwebremoting.ScriptSession;
      `+ f: N; }  I: a
11. import org.directwebremoting.WebContext;
    
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    
14. 
    0 n& u6 N9 k' N- n
15. import pojo.MessageInfo;
    
16. import pojo.UserInfo;
    7 ?& H) h; K! v* M- U  ]; F% T
17. 
    
18. public class ChatManager {
    
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    ) v1 |* Z4 z% U3 j6 y1 [/ c5 u
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    
22.         public ChatManager(){
    
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    2 H# q) m5 j) S) [1 V& S
24.                 sendUserList.add(userInfo);
    
25.         }
    
26.        
    
27.         public String updateOnlineUsers(String userName,boolean flag) {
    
28.                 UserInfo userInfo=null;
    
29.                 WebContext context=WebContextFactory.get();
    - }$ z- ]/ V! {( G% u1 z
30.                 HttpSession session = context.getSession();
    
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
    4 }2 B3 K# ]: s9 u" ]# O  |) g
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    7 N9 t7 `8 j9 T" [
35.                         this.setScriptSessionFlag(userInfo);
    , x, F$ L& q& T& s
36.                 }
    
37.                 String currentPage = "/chat/index.jsp";
    : \. \5 a* l8 t5 p0 f" G3 t* B
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    3 w9 h6 H( X& C  R
39.                 Util allPageUtil = new Util(sessionsByPage);
    , |$ K) @" Y7 F( i  \
40.                 allPageUtil.removeAllOptions("onlineList");
    
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    9 d3 l$ e) }& C" P2 T$ D% V
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    
44.                 if (!flag) {
    + ^  t- T8 D' k
45.                         return null;
    
46.                 }
    + w! l( x; ~# e+ l# z
47.                 return userInfo.getUserId();
    / ^* n9 w8 q! v+ @' X. v+ D
48.         }
    
49.        
    
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    
53.        
    
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    2 T7 A# Y- L% Q: H# o4 }+ C  G" u9 x+ u
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    4 R6 b) E# a$ d$ Z4 y8 {/ }
57.                 WebContext context = WebContextFactory.get();
    
58.                 String currentPage = "/chat/index.jsp";
    
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
60.                 sessions.addAll(sessionsByPage);
    
61.                 if ("0".equals(userId)) {
    & B4 @, D0 k* G
62.                         list=sessions;
    ! H# }/ G6 X4 I! ~
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    , {( N0 o6 Z- j+ V: K
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    9 p- @! H. t. m0 Q" K8 r. K; A
66.                                 if (userId.equals(userInfo.getUserId())) {
    7 V$ r( G: }/ T6 w9 j* R: x
67.                                         list.add(session);
    9 c4 R* o7 ^) `% ]$ Q
68.                                         break;
    
69.                                 }
    
70.                         }
    ) c( j. h. k$ t2 X% S/ I) |) A& A3 L
71.                 }
    
72.                 return list;
    + W( H" C3 s, K' l6 e/ Q- V6 A
73.         }
    ; y" p2 y& h0 z5 Q
74.        
    " G! t$ I- ~, R9 R9 L/ w
75.         public void sendMessage(String sender,String receiverId,String msg) {
    % |0 ~+ m1 B& f. j
76.                 Collection<ScriptSession> scriptSessionFlag = this.getScriptSessionFlag(receiverId);
    
77.                 MessageInfo messageInfo = new MessageInfo(sender,receiverId,msg);
    1 e" v+ u" j( `. Y* C) h. Y$ D
78.                 messageList.add(messageInfo);
    + N' T- J  t+ O6 ]" R+ T2 ^- ?
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    1 `; _) d; w6 Y
80.                 receiverUtil.removeAllOptions("messageList");
    # I) Y3 }# H& X( M
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    
82.         }
    2 y4 l4 `3 e2 u8 x" ^+ B4 ~
83. }
    

复制代码

2 r0 p% ]# P: [" M0 C; f项目源码下载地址：点击下载

$ X8 f" y7 F3 r" w$ O+ ^7 Z6 ^7 `

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了
, O; b) p3 A! B8 W6 m

woniu

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