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

admin

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

8 V2 v5 M1 [3 b' A

1. package services;
   
2. 
   2 O1 j6 u( w" ^( {
3. import java.util.ArrayList;
   
4. import java.util.Collection;
   
5. import java.util.List;
   % n1 O! D( H+ W1 `! Y, E9 C
6. 
   ! ?& G& f# f4 x9 |1 I" y
7. import javax.servlet.http.HttpServletRequest;
   
8. import javax.servlet.http.HttpSession;
   
9. 
   
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    $ I4 b3 D9 h5 K6 n% Y
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    
14. 
    
15. import pojo.MessageInfo;
    
16. import pojo.UserInfo;
    2 s$ T! `9 j6 z
17. 
    3 P( ], K/ ]$ N5 ?
18. public class ChatManager {
    8 r. Q' N* C1 }' E7 e9 `2 Q
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    * {. t% x* a$ \5 D& y
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    
22.         public ChatManager(){
    
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    : R# K) T( J' j: c; r& q
24.                 sendUserList.add(userInfo);
    
25.         }
    0 E% N, Y4 U7 ?  c( p$ Y9 N
26.        
    , I& l. J& m) a" R4 U/ M: \
27.         public String updateOnlineUsers(String userName,boolean flag) {
    
28.                 UserInfo userInfo=null;
    
29.                 WebContext context=WebContextFactory.get();
    . H- S2 B& }7 ^( C8 F
30.                 HttpSession session = context.getSession();
    5 X. c5 c0 S/ ~
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    
35.                         this.setScriptSessionFlag(userInfo);
    ( a1 B( n. Q4 B- ]. `& I
36.                 }
      m. O0 ?9 N( Q. L# f+ r9 M
37.                 String currentPage = "/chat/index.jsp";
    ' P0 o0 P" m& z) V+ N0 l
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
39.                 Util allPageUtil = new Util(sessionsByPage);
    
40.                 allPageUtil.removeAllOptions("onlineList");
    
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    
44.                 if (!flag) {
    
45.                         return null;
    
46.                 }
    2 _$ g. d; b- B' p
47.                 return userInfo.getUserId();
    
48.         }
    
49.        
    
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    5 |5 J3 F) r! [& b6 V$ x
53.        
    2 B6 `. ?3 X% v$ J4 a1 o8 u; h/ O  l
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    $ c  `+ ]- `- c0 R3 K, W
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    " ^* U* L: W' r0 O+ v
57.                 WebContext context = WebContextFactory.get();
    + g3 l: }1 v" w. I4 Y7 h1 i
58.                 String currentPage = "/chat/index.jsp";
    
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    - d7 E- x+ ?, h! F2 K
60.                 sessions.addAll(sessionsByPage);
    3 w+ f. x5 ~- g1 \
61.                 if ("0".equals(userId)) {
    
62.                         list=sessions;
    
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    8 O& \6 ?- Q) |1 ~6 b
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    " L+ y8 I5 M/ Y3 j" Z5 \
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    
68.                                         break;
    
69.                                 }
    8 f* M* V: m' T2 b/ D/ ~
70.                         }
    : g, Y1 r- Q3 ~8 G8 V! e
71.                 }
    ; T  {  D3 ?% Q; @
72.                 return list;
    
73.         }
    . q# M& J7 o6 g3 Z; r, B
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);
    3 S! J( v' z6 m9 E, n
78.                 messageList.add(messageInfo);
    ) o# E) `8 U- G# L; W6 _9 L& ]
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    7 ~! }6 o8 \0 L( k1 ^
80.                 receiverUtil.removeAllOptions("messageList");
    
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    ; }( w  `2 ~3 G3 m
82.         }
      o& S2 }% |6 I& v6 x6 d
83. }
    

复制代码

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

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了
7 H; Y4 M8 ^) q7 @; [

woniu

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