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

admin

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

1. package services;
   % ]6 b! c1 o* U! v4 h! s! A) E6 u
2. 
   , G# `$ U7 R6 \& q4 b* U: w8 k
3. import java.util.ArrayList;
   & U' x6 F$ g* o+ @: _7 h6 D+ ]
4. import java.util.Collection;
   
5. import java.util.List;
   6 M$ V! w1 w$ @* L
6. 
   
7. import javax.servlet.http.HttpServletRequest;
   ; A0 T1 |$ q5 N$ E- U
8. import javax.servlet.http.HttpSession;
   
9. 
   * {: I5 Y4 s! y  p
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    
12. import org.directwebremoting.WebContextFactory;
    
13. import org.directwebremoting.proxy.dwr.Util;
    ( Z1 F0 q: A7 V- @& @% H
14. 
    - Y0 L0 F$ d5 b
15. import pojo.MessageInfo;
    . i- e2 H% ?8 x2 J# m2 A
16. import pojo.UserInfo;
    
17. 
    , w- l% j) w0 L7 l0 P% ?. Q
18. public class ChatManager {
    
19.         public static List<UserInfo> onlineUsersList=new ArrayList<UserInfo>();
    
20.         public static List<UserInfo> sendUserList=new ArrayList<UserInfo>();
    4 I2 C- F+ A6 |$ f; A& X
21.         public static List<MessageInfo> messageList=new ArrayList<MessageInfo>();
    % S# C, Y2 i5 ], \/ n
22.         public ChatManager(){
    % v& v& b9 v9 l
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    $ w2 o8 B$ u% P6 \! ]8 u
24.                 sendUserList.add(userInfo);
    2 }2 Z) S4 u. s9 ~1 }; p
25.         }
    & d, m8 V7 [% {1 i0 a$ I* q
26.        
    
27.         public String updateOnlineUsers(String userName,boolean flag) {
    5 B% D7 k$ A6 }$ s9 F  h* |" C
28.                 UserInfo userInfo=null;
    
29.                 WebContext context=WebContextFactory.get();
    
30.                 HttpSession session = context.getSession();
    
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
    
33.                         onlineUsersList.add(userInfo);
    + b) G6 ?: E2 {* f. l
34.                         sendUserList.add(userInfo);
    4 d/ F9 J  X: G( h
35.                         this.setScriptSessionFlag(userInfo);
    $ }5 Y9 S5 I8 Q8 q! G  l& k+ y
36.                 }
    # F6 M6 k' ^. u% a, ?6 S7 I$ r
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
39.                 Util allPageUtil = new Util(sessionsByPage);
      x; i  y2 f5 k& M
40.                 allPageUtil.removeAllOptions("onlineList");
    
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    0 n3 E" |2 r8 u. b* t) C% V
42.                 allPageUtil.removeAllOptions("userList");
    
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    
44.                 if (!flag) {
    
45.                         return null;
    
46.                 }
    ! L! {9 O; i" ^9 m1 c5 [# S7 _
47.                 return userInfo.getUserId();
    
48.         }
    
49.        
    + G' r( Y7 [  ?; x, y6 D2 e  B: w
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    ! ^$ r- ~( u8 X7 ~0 ?( m2 |( m
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    , P8 H) [, r7 E
52.         }
    : Y) T. Z/ ?/ b: l$ |  X( Q
53.        
    4 X! e1 D: v4 N5 G
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    . l$ z! T! j# W+ v( ^) w
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    
57.                 WebContext context = WebContextFactory.get();
    6 U9 d# t7 `/ n+ v, f9 w
58.                 String currentPage = "/chat/index.jsp";
    % y+ b& m* T2 q! D4 X4 c
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    
60.                 sessions.addAll(sessionsByPage);
    2 k, R. @, G. Q3 r
61.                 if ("0".equals(userId)) {
    
62.                         list=sessions;
    
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    6 U# `: r/ o/ h# z5 Y* r* A
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    2 z5 M+ T4 j2 H+ `
66.                                 if (userId.equals(userInfo.getUserId())) {
    
67.                                         list.add(session);
    
68.                                         break;
    ! i4 l) }9 Y- G0 E" s
69.                                 }
    5 P: v; `' D2 z! M' r9 D/ R7 a
70.                         }
    
71.                 }
    $ r! B3 i8 H! n/ Z1 A# ]3 T
72.                 return list;
    , h) [5 y$ ?9 A# @0 V) F
73.         }
    / A# b6 w3 Y( U* c4 e5 j; i% F. l
74.        
    3 ^4 i4 A( z5 t0 n3 ?$ }! Z3 T' T
75.         public void sendMessage(String sender,String receiverId,String msg) {
    8 ?  Q* w. u: Z3 G; }7 O
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);
    5 P. ]) ^- I+ ~
80.                 receiverUtil.removeAllOptions("messageList");
    * G& e& O' K4 y8 m7 A5 h
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    4 Y* Q; d( I$ B% P2 \
82.         }
    3 T9 k" u6 h! Q0 p# [5 v: ~& Z3 P
83. }
    

复制代码

/ }, j  {+ `  @( e6 `% e项目源码下载地址：点击下载
8 I7 E+ }3 R( _* `
0 `1 L: X1 l- B- F

woniu

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

wwlg5292

呃,楼主分享链接失效了

wwlg5292

谢谢楼主分享