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

admin

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

1. package services;
   8 ^9 ~$ U" t1 r" |. d9 a
2. 
   $ O- r$ o8 M. v+ u7 X
3. import java.util.ArrayList;
   
4. import java.util.Collection;
   
5. import java.util.List;
     E7 _- Y1 Z9 z# A. m
6. 
   
7. import javax.servlet.http.HttpServletRequest;
   
8. import javax.servlet.http.HttpSession;
   
9. 
   
10. import org.directwebremoting.ScriptSession;
    8 i# m4 q* z8 {+ m
11. import org.directwebremoting.WebContext;
    0 R8 k+ x+ `* G
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    
14. 
    
15. import pojo.MessageInfo;
    1 ^, F  J7 F/ j, M
16. import pojo.UserInfo;
    ' g% ]6 ^, \8 x* O( B2 N, h
17. 
    
18. public class ChatManager {
    
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    
22.         public ChatManager(){
    ( e) q( A, w1 \. t. u6 w  _; H6 i
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    
24.                 sendUserList.add(userInfo);
    
25.         }
    . p+ v8 ~5 H( H% H% h/ ^9 f
26.        
    
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) {
    6 C# k; N! y, G: O$ C
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    ' s* j  ?. d% G+ F( J; x( V
35.                         this.setScriptSessionFlag(userInfo);
    * i. ~4 G" T! B
36.                 }
    7 h( c0 S4 `3 k
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    2 g1 V* ]7 E4 e
39.                 Util allPageUtil = new Util(sessionsByPage);
    
40.                 allPageUtil.removeAllOptions("onlineList");
    9 N! f( _; @3 P
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    
44.                 if (!flag) {
    
45.                         return null;
      t8 b* @$ b8 ?2 C  N
46.                 }
    
47.                 return userInfo.getUserId();
    # V5 \0 }" p' A/ L, {" K; Q7 @
48.         }
    
49.        
    ' Z7 C( r& T" \* N4 c2 P7 ^' n
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    ' J; ^" E: e# k9 a6 }& r
52.         }
    
53.        
    ; ~0 k8 h* V; p
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    5 Y0 ]$ W2 G( P- L' @# G
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    
57.                 WebContext context = WebContextFactory.get();
    & a6 n" Y7 w' K- C; V
58.                 String currentPage = "/chat/index.jsp";
    
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
60.                 sessions.addAll(sessionsByPage);
    4 N' S5 E" a# ?' C
61.                 if ("0".equals(userId)) {
    3 i( f  E$ P* u' h3 h
62.                         list=sessions;
    
63.                 }else{
    " b$ C! f% y4 t% p
64.                         for (ScriptSession session : sessions) {
    4 a6 ~+ t  C, }) K3 u
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    
66.                                 if (userId.equals(userInfo.getUserId())) {
      S9 S/ e6 m' O( B' u9 U4 @
67.                                         list.add(session);
    ; I8 d. ]. ~; v* c
68.                                         break;
    
69.                                 }
    
70.                         }
    
71.                 }
    , u+ h/ S6 I  D& Y! s
72.                 return list;
      l% h1 A5 `4 g. K! n: k$ h8 u
73.         }
    7 c; H5 L! |% @* \# o2 |+ I& `' F
74.        
    
75.         public void sendMessage(String sender,String receiverId,String msg) {
    + [& g, ^5 O' x; F0 D, M
76.                 Collection<ScriptSession> scriptSessionFlag = this.getScriptSessionFlag(receiverId);
    " j/ c" j4 b5 m$ H+ j2 g3 Z3 x
77.                 MessageInfo messageInfo = new MessageInfo(sender,receiverId,msg);
    
78.                 messageList.add(messageInfo);
    $ w$ l/ }6 E! x! H
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    5 u  j3 ]1 p+ S- w
80.                 receiverUtil.removeAllOptions("messageList");
    - y  ~! I; [0 m4 }
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    
82.         }
    * X7 B) A' y4 a* i. T; Y, {
83. }
    

复制代码

$ T, ^" |" N3 ~" |3 W) v项目源码下载地址：点击下载
' W0 J) \, \, G
& r; F2 x9 m7 V, U1 t8 D& M

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了
5 k$ K* Y, G: `% T* J" A

woniu

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