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

admin

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

, P, H+ R/ `( J9 m8 w, n, R

1. package services;
   0 [3 O4 O2 v7 l. r( N
2. 
   
3. import java.util.ArrayList;
   0 M# L% O. e, W% A6 U
4. import java.util.Collection;
   
5. import java.util.List;
   ; t' Z6 I0 {& W
6. 
   
7. import javax.servlet.http.HttpServletRequest;
   + M4 M$ s  `! {; _5 |" m
8. import javax.servlet.http.HttpSession;
   
9. 
   , O% \$ X: f8 p% J( }- ]
10. import org.directwebremoting.ScriptSession;
    ' Z$ G+ b) [4 e* S( X
11. import org.directwebremoting.WebContext;
    " N' D! m2 \7 W3 @
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    / N( u* ^5 D  X4 j; F( i( F7 P
14. 
    ' ~- }: o5 L7 ?6 v* v. j" _
15. import pojo.MessageInfo;
    
16. import pojo.UserInfo;
    
17. 
    
18. public class ChatManager {
    - U9 e1 i* P8 Q5 C3 J6 @- Y
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>();
    6 s+ c# M- `  T+ n5 x7 N5 I: R
22.         public ChatManager(){
    1 V! L. c( |5 N/ x
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    
24.                 sendUserList.add(userInfo);
    
25.         }
    
26.        
    
27.         public String updateOnlineUsers(String userName,boolean flag) {
    * s% j+ n# G; ~& W
28.                 UserInfo userInfo=null;
    
29.                 WebContext context=WebContextFactory.get();
    : u2 Q# v! C* T4 ^9 q
30.                 HttpSession session = context.getSession();
    5 _( h6 E6 F" D! i9 d6 j* P% e
31.                 if (flag) {
    9 w! P8 ]  S! e" P5 A: o
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    % V3 C4 B* l  n5 D7 E$ p
34.                         sendUserList.add(userInfo);
    
35.                         this.setScriptSessionFlag(userInfo);
    
36.                 }
    
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
39.                 Util allPageUtil = new Util(sessionsByPage);
    - k1 Z' S8 Z" r- x4 b" a
40.                 allPageUtil.removeAllOptions("onlineList");
    & ~9 ]; P* |& v0 m7 ]0 U: A
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
      u( L) u( g( L; R
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    ( X/ o* {8 ]: j! p' ?1 _# c
44.                 if (!flag) {
    - {$ _5 p" z7 w  s
45.                         return null;
    
46.                 }
    
47.                 return userInfo.getUserId();
    
48.         }
    
49.        
    7 c9 A$ [/ e3 [2 L
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    % F% t4 b; J% |& h" H# h6 |" |9 X$ B
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    / V! R6 t7 \; x: d+ a
53.        
    ; M, Y4 M+ |5 t0 u. S
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    - D# ^# Y3 v% q6 h$ I
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    
57.                 WebContext context = WebContextFactory.get();
    
58.                 String currentPage = "/chat/index.jsp";
    ( v+ N* y6 E% \. X' n
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    ( W+ ^( F1 @- j' U) j6 Y3 P# X
60.                 sessions.addAll(sessionsByPage);
    2 ~2 x; |2 w! \. E/ D6 o2 y
61.                 if ("0".equals(userId)) {
    2 o, |% x1 R2 B$ Y1 G3 m
62.                         list=sessions;
      \6 N" N/ {# _$ |
63.                 }else{
    2 S0 h9 l5 b2 E1 {
64.                         for (ScriptSession session : sessions) {
    / ?! v! c: F5 t/ a  {1 s
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    
68.                                         break;
    
69.                                 }
    0 T3 F% k. M7 X" x6 r" q# \5 {; b
70.                         }
    6 m# v2 ?0 Z; {8 o- Q4 H7 |9 l
71.                 }
    ) ~( c# _/ W. y" F) j
72.                 return list;
    
73.         }
    
74.        
    
75.         public void sendMessage(String sender,String receiverId,String msg) {
    " U: f+ t, q+ U+ I
76.                 Collection<ScriptSession> scriptSessionFlag = this.getScriptSessionFlag(receiverId);
    
77.                 MessageInfo messageInfo = new MessageInfo(sender,receiverId,msg);
    
78.                 messageList.add(messageInfo);
    , b$ p- h5 r( Y' l# ^: K" T
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    ; A4 s7 D: N/ E" _: r* W0 I: t
80.                 receiverUtil.removeAllOptions("messageList");
    
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    + V0 A" z1 p' }- U- P1 ~+ [
82.         }
    
83. }
    / P5 J5 @( c) a% r2 |

复制代码

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

+ K, I9 K) D% @& H$ y

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了

woniu

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