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

admin

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

6 K7 j5 c- j  q3 L+ X) ]

1. package services;
   
2. 
   - m. d8 ], M$ W2 ^3 @
3. import java.util.ArrayList;
   ) B8 u7 O$ H: E& a& p
4. import java.util.Collection;
   / k5 v5 u: M7 l" ^
5. import java.util.List;
   ' F% L' W" S% _, b. N, b! ~
6. 
   ) l% r+ P$ k" c8 h% |3 G
7. import javax.servlet.http.HttpServletRequest;
   
8. import javax.servlet.http.HttpSession;
   
9. 
   % |7 g0 y  y1 X  ]
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    
14. 
    
15. import pojo.MessageInfo;
    
16. import pojo.UserInfo;
    
17. 
    
18. public class ChatManager {
    
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    ( V" h7 X) R& l
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    , q6 n7 t1 y( y; S7 `
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
      C0 N' n2 L7 ]
22.         public ChatManager(){
    
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    
24.                 sendUserList.add(userInfo);
    - ?2 o, }: ?# Y$ F) s% b: l4 s
25.         }
    2 F, R2 C$ h" s4 r6 L8 f; @
26.        
    . s. T5 P9 T. N5 P
27.         public String updateOnlineUsers(String userName,boolean flag) {
    
28.                 UserInfo userInfo=null;
    
29.                 WebContext context=WebContextFactory.get();
    
30.                 HttpSession session = context.getSession();
    
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    ; |: q+ P8 d$ |6 d& A2 ]
34.                         sendUserList.add(userInfo);
    
35.                         this.setScriptSessionFlag(userInfo);
    
36.                 }
    + ?7 ^# X/ z+ S1 @! q' X
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    * `; b( b: M$ s  ?( [0 h/ n
39.                 Util allPageUtil = new Util(sessionsByPage);
    ! n2 |  M4 @/ Y, Z( `
40.                 allPageUtil.removeAllOptions("onlineList");
    + H% g/ P5 ~, A6 a1 ~0 @. I
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    
44.                 if (!flag) {
    
45.                         return null;
    
46.                 }
      u) J( ]) q9 T' @' T
47.                 return userInfo.getUserId();
    
48.         }
    
49.        
    
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    5 ]4 A# z" `6 b7 o0 c) N  ~
52.         }
    
53.        
    - N+ r7 D3 z* F9 j+ t) z: N
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    * n4 Y1 ]7 M) J, Y" p, V
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    ) W; |" g& c" F' t4 L: n! J
57.                 WebContext context = WebContextFactory.get();
    
58.                 String currentPage = "/chat/index.jsp";
    7 i! l$ J/ D3 z1 o0 D" L
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
60.                 sessions.addAll(sessionsByPage);
    * N- \. d, B$ u2 }! C3 O+ S
61.                 if ("0".equals(userId)) {
    
62.                         list=sessions;
    
63.                 }else{
    " P5 `0 r/ z6 ?
64.                         for (ScriptSession session : sessions) {
    
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    7 ]( h2 |: n/ r* c! H$ q
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    ; N& {' t( j8 `) \0 ^; B: s
68.                                         break;
    
69.                                 }
    , P" A. X5 ^3 D" c7 J" d
70.                         }
    8 p  ]  {2 N6 Y7 e( C: O4 y
71.                 }
    ' B* M0 B' _# `
72.                 return list;
    
73.         }
    ; ~, j+ J: u- G1 N% w
74.        
    
75.         public void sendMessage(String sender,String receiverId,String msg) {
    ; m  s/ Y; k& D8 v
76.                 Collection<ScriptSession> scriptSessionFlag = this.getScriptSessionFlag(receiverId);
    
77.                 MessageInfo messageInfo = new MessageInfo(sender,receiverId,msg);
    
78.                 messageList.add(messageInfo);
    $ U: d; v9 K, Z$ m
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    # h+ F8 N9 N1 p2 P
80.                 receiverUtil.removeAllOptions("messageList");
    
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    ; ^4 y: ]7 |. F  I/ T1 r& E/ k8 w
82.         }
    
83. }
    / S, O7 Q# m4 i! Q/ I2 ?

复制代码

/ T# q- [6 o" |; _" q) S0 p项目源码下载地址：点击下载

( R3 O" m, ]/ X

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了

woniu

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