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

admin

在下根据网上的相关资料，摸索着写了一个DWR框架推模式的小聊天室，可实现私聊功能。
功能基本正常，但是偶尔会出现信息显示不同步的问题，现将源码奉上，希望各位高手能指点一二。ChatManager.java
3 B2 K/ w% _; t( q
  `8 a0 K+ g" k/ o( V) W

1. package services;
   0 p) \+ [: V2 u, A3 s0 M
2. 
   2 N; u$ K8 L3 Y% s  X0 `1 g4 o
3. import java.util.ArrayList;
   ) o# A- D. B* W9 f& z' d
4. import java.util.Collection;
   + P; c, T- @7 C$ @
5. import java.util.List;
   & y9 O: ?4 o! A
6. 
   + O% @. G1 ?5 ~- f) |/ I0 i
7. import javax.servlet.http.HttpServletRequest;
   ; _) a( v# [0 }3 e4 Y/ Z
8. import javax.servlet.http.HttpSession;
   ! ^" ~, a/ N  c$ b/ g
9. 
   
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    & o* V9 ]9 ?& d0 \# A! D' V& N" `+ ?
14. 
    
15. import pojo.MessageInfo;
    
16. import pojo.UserInfo;
    " [, j6 ^9 S. I/ b  |1 h
17. 
    " h& Y2 J  Q; z4 @9 B6 ^4 _- X
18. public class ChatManager {
    5 p8 t3 T  j' j* x0 x
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    & r2 U& m+ h- l# V3 Z! o0 g$ P
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    . P& U) R( F4 x$ }6 m, B7 U
22.         public ChatManager(){
    1 L/ ?0 @. C) p2 n
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    & @1 Z9 s; M. l
24.                 sendUserList.add(userInfo);
    
25.         }
    
26.        
    2 G+ J, t3 r- u4 H  }; u8 r, ~  F
27.         public String updateOnlineUsers(String userName,boolean flag) {
    
28.                 UserInfo userInfo=null;
    
29.                 WebContext context=WebContextFactory.get();
    1 X- F6 N; l/ W( X/ L+ m: W
30.                 HttpSession session = context.getSession();
    
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    
34.                         sendUserList.add(userInfo);
    7 F- @3 ~: E: f$ [0 v2 o
35.                         this.setScriptSessionFlag(userInfo);
    
36.                 }
    
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    % ~( ^0 D# x( `
39.                 Util allPageUtil = new Util(sessionsByPage);
    9 r5 \) K* ]  V4 h1 H# Y3 Y% X
40.                 allPageUtil.removeAllOptions("onlineList");
    
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    : h, k! c" |2 @3 F. Z
42.                 allPageUtil.removeAllOptions("userList");
    
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    4 p% e2 N) L  D4 s& @8 J2 X* C
44.                 if (!flag) {
    
45.                         return null;
    2 n, ~9 o0 d$ b7 l) n4 E
46.                 }
    " f: h9 v3 b' m, p' I/ s3 F
47.                 return userInfo.getUserId();
    , v- l; g1 a2 m/ @8 H, M
48.         }
    * x7 K5 G& e' f: |* q8 h' K. _% d
49.        
    
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    2 M- ?  T/ @: b8 t- q
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    ) t6 |0 I. F4 h
52.         }
    3 g% l3 E5 H/ K; F- e
53.        
    
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    2 A# ~6 _  g* D( |' f6 N+ @+ }3 G
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    & }/ \' b6 H" v" N' y. H9 n
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    , l) O. c9 K# }# I* U# C/ H
57.                 WebContext context = WebContextFactory.get();
    & `7 @# V( w" F8 w( O
58.                 String currentPage = "/chat/index.jsp";
    ) p9 |7 C8 i, Q  A, J" }$ i# r' S
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    ) M# e% k- l( X- R4 z9 w3 j8 l
60.                 sessions.addAll(sessionsByPage);
    
61.                 if ("0".equals(userId)) {
    9 B% ^. B" O/ ]* o- `
62.                         list=sessions;
    
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    , ?2 l. B: I* k/ w0 f4 l
66.                                 if (userId.equals(userInfo.getUserId())) {
    % ?4 e; g/ x( a7 M3 E2 C
67.                                         list.add(session);
    
68.                                         break;
    
69.                                 }
    
70.                         }
    ( r) L. D+ n; p6 M- \5 f
71.                 }
    / l, y4 u- E1 ^: G
72.                 return list;
    ' f& \- s( [9 `" F* A
73.         }
    
74.        
    
75.         public void sendMessage(String sender,String receiverId,String msg) {
    
76.                 Collection<ScriptSession> scriptSessionFlag = this.getScriptSessionFlag(receiverId);
    - Q% D; n$ O% [  q4 `2 W: Q4 e
77.                 MessageInfo messageInfo = new MessageInfo(sender,receiverId,msg);
    ; i& g+ B: }, s5 p; ~
78.                 messageList.add(messageInfo);
    
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    
80.                 receiverUtil.removeAllOptions("messageList");
    & R- i7 H6 l" }3 L7 d3 K
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    ( S9 }9 h+ Y) m4 {0 b) [, P' E
82.         }
    
83. }
    

复制代码

项目源码下载地址：点击下载
$ E7 {) I, O8 h+ Z  U

woniu

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

wwlg5292

呃,楼主分享链接失效了

wwlg5292

谢谢楼主分享