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

admin

在下根据网上的相关资料，摸索着写了一个DWR框架推模式的小聊天室，可实现私聊功能。
2 D6 x( F) {; p功能基本正常，但是偶尔会出现信息显示不同步的问题，现将源码奉上，希望各位高手能指点一二。ChatManager.java
4 j# E( V8 ~( Z2 ^0 {5 h
7 A" T" [- K$ \) f3 h6 ~; h

1. package services;
   
2. 
   - b7 H; Z: k) K4 ^& r( y" S
3. import java.util.ArrayList;
   0 Z3 c8 `% h6 f) _/ o' q1 `
4. import java.util.Collection;
   
5. import java.util.List;
   
6. 
   
7. import javax.servlet.http.HttpServletRequest;
   
8. import javax.servlet.http.HttpSession;
   
9. 
   5 u& ]' V6 I* |: U, z
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;
    , B/ {. a+ n5 L# I
17. 
    ( V3 s3 z: r& w8 Y3 S  c
18. public class ChatManager {
    
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    ' Y+ s) x, B# x5 B$ E# v
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    - m, z; {8 P5 i4 G/ o* k
22.         public ChatManager(){
    5 ^) I# r$ @' [% h7 d7 O
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    
24.                 sendUserList.add(userInfo);
    
25.         }
    
26.        
    7 E- ]- x& X9 m
27.         public String updateOnlineUsers(String userName,boolean flag) {
    1 @4 Y* ], m) X9 V( M; C
28.                 UserInfo userInfo=null;
    ! \( ~' y# P' c4 W* ^+ n# G
29.                 WebContext context=WebContextFactory.get();
    
30.                 HttpSession session = context.getSession();
    , B4 {3 }2 y. C/ X/ B+ j0 a- p# W
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    - h% ?  Q! S1 o6 n
35.                         this.setScriptSessionFlag(userInfo);
    
36.                 }
    ( h. w5 u* v* A! E: G3 k+ O
37.                 String currentPage = "/chat/index.jsp";
    6 p; E/ v, ~, p6 }8 N/ k
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    : {  H% [- y  ]% J0 d) q( V
39.                 Util allPageUtil = new Util(sessionsByPage);
    2 I/ l- @5 S: X, i8 a
40.                 allPageUtil.removeAllOptions("onlineList");
    , [1 L3 {: m6 I9 p* ?& V2 G& X
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    & l0 W) G+ v) N0 e+ a# a( c
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    6 R4 n9 x8 l  v1 w7 R3 y
44.                 if (!flag) {
    ; {# E/ Q5 j; |$ r
45.                         return null;
    
46.                 }
    
47.                 return userInfo.getUserId();
    4 D7 X" r0 G5 x
48.         }
    
49.        
    
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    + G5 Z. ~3 e; k  I& C$ h
53.        
    + J5 y/ W! I* Z' Z+ q) z
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    ' h: U# M$ t6 h+ `
57.                 WebContext context = WebContextFactory.get();
    
58.                 String currentPage = "/chat/index.jsp";
    & a& |/ G. q0 i1 t2 L/ ]8 Y! \2 o
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    . f% w6 _0 N; E! N& E4 F: I
60.                 sessions.addAll(sessionsByPage);
    
61.                 if ("0".equals(userId)) {
    
62.                         list=sessions;
    
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    
66.                                 if (userId.equals(userInfo.getUserId())) {
    7 |$ M) [1 ?  \
67.                                         list.add(session);
    
68.                                         break;
    & ]5 ^) ?7 l. c) I
69.                                 }
    
70.                         }
    $ A4 ]5 a- ?# @, Z1 Y
71.                 }
    ; W4 E$ X& J" p  @1 m) {
72.                 return list;
    4 L. f8 N, {5 X- f1 n/ V
73.         }
    0 ^3 ~1 n4 r+ [+ f
74.        
    ' q' q5 J( c. H" |* ]
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);
    
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    
80.                 receiverUtil.removeAllOptions("messageList");
    . I! L$ w5 v, v) S7 T  T  x
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    7 y8 K1 i- A# h& n% z
82.         }
    
83. }
    6 Q9 H  @" W0 L  M2 ^, A

复制代码

项目源码下载地址：点击下载
- b+ S, T4 d! }

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了
/ A# c3 U1 x9 L3 b) \( u

woniu

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