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

admin

在下根据网上的相关资料，摸索着写了一个DWR框架推模式的小聊天室，可实现私聊功能。
" {) v9 D) \. R& ^4 @5 V& H功能基本正常，但是偶尔会出现信息显示不同步的问题，现将源码奉上，希望各位高手能指点一二。ChatManager.java

1. package services;
   ! V6 y5 c, H- w" ~! ?$ d
2. 
   
3. import java.util.ArrayList;
   9 Z" M! U# E$ S% |4 M- o
4. import java.util.Collection;
   
5. import java.util.List;
   0 f5 v: r$ b7 P$ m' _4 Z+ r- [
6. 
   
7. import javax.servlet.http.HttpServletRequest;
   ) A. I' R% ^" ]+ {( m9 Q/ S& V
8. import javax.servlet.http.HttpSession;
   
9. 
   
10. import org.directwebremoting.ScriptSession;
    
11. import org.directwebremoting.WebContext;
    % `; U$ D4 K; W8 U
12. import org.directwebremoting.WebContextFactory;
    + d  J- Q4 o# F6 R2 V8 X8 r' L3 ]
13. import org.directwebremoting.proxy.dwr.Util;
    
14. 
    
15. import pojo.MessageInfo;
    ; z  T: F' Y7 s3 _; R
16. import pojo.UserInfo;
    $ ?! }3 S% E; ?3 b$ k! X
17. 
    2 p5 C, K7 D! g0 F/ J1 T
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>();
    ' [5 ?" _; \+ i- s
22.         public ChatManager(){
    - S/ H+ c( k; f7 O
23.                 UserInfo userInfo = new UserInfo("0","所有人");
    
24.                 sendUserList.add(userInfo);
    
25.         }
    $ {# C6 a$ @3 Y6 T, V/ l/ @" J4 J8 @$ p
26.        
      C. A& Y' ?8 Y- j
27.         public String updateOnlineUsers(String userName,boolean flag) {
    
28.                 UserInfo userInfo=null;
    ) q" o# w2 |9 b* O0 A
29.                 WebContext context=WebContextFactory.get();
    # M8 ]: W6 e- t& F' R/ F
30.                 HttpSession session = context.getSession();
    2 ]: O2 A+ Y7 F. Z7 j4 i: h) k+ X+ A
31.                 if (flag) {
    
32.                         userInfo = new UserInfo(session.getId(),userName);
      b5 f9 q( v. P& I7 H$ r
33.                         onlineUsersList.add(userInfo);
    3 X6 P: b2 H7 w5 D/ {/ t
34.                         sendUserList.add(userInfo);
    
35.                         this.setScriptSessionFlag(userInfo);
    
36.                 }
    5 S3 ]; E; {) ]
37.                 String currentPage = "/chat/index.jsp";
    
38.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    3 B7 W6 }0 K9 T) u! G2 O, d
39.                 Util allPageUtil = new Util(sessionsByPage);
    
40.                 allPageUtil.removeAllOptions("onlineList");
    0 j2 G% G3 c5 o' {
41.                 allPageUtil.addOptions("onlineList", onlineUsersList, "userName");
    
42.                 allPageUtil.removeAllOptions("userList");
    % s' t* ^7 I: w; [" [
43.                 allPageUtil.addOptions("userList", sendUserList, "userId", "userName");
    ' J6 F( _. g9 c! l( d" P
44.                 if (!flag) {
    ) T, E# O* E* @. X2 j2 ]' f. g
45.                         return null;
    
46.                 }
    6 H1 X* ?) J" {/ W4 J/ I4 o
47.                 return userInfo.getUserId();
    
48.         }
    
49.        
    4 L. w, z) A/ Q1 \0 k
50.         public void setScriptSessionFlag(UserInfo userInfo) {
    
51.                 WebContextFactory.get().getScriptSession().setAttribute("userInfo", userInfo);
    
52.         }
    " P, [! q; n2 i& J  ]6 s7 i
53.        
    
54.         public Collection<ScriptSession> getScriptSessionFlag(String userId) {
    ; H+ j4 z5 g4 H% S1 {5 X
55.                 Collection<ScriptSession> list=new ArrayList<ScriptSession>();
    ' {* }6 K$ D. l1 a! V% V8 M
56.                 Collection<ScriptSession> sessions=new ArrayList<ScriptSession>();
    " L- ], S4 B/ f! G% D( w
57.                 WebContext context = WebContextFactory.get();
    ! |. z5 r  u4 t% `1 K: L7 U  I. K
58.                 String currentPage = "/chat/index.jsp";
    + y3 W# |3 Y  I9 Y' d
59.                 Collection sessionsByPage = context.getScriptSessionsByPage(currentPage);
    ! {& O2 `6 t7 ^7 e
60.                 sessions.addAll(sessionsByPage);
    
61.                 if ("0".equals(userId)) {
    $ B' k$ ?" D* E( s* N3 @
62.                         list=sessions;
    
63.                 }else{
    
64.                         for (ScriptSession session : sessions) {
    % g2 \5 @* u" F  @: f% \! V7 c4 |
65.                                 UserInfo userInfo=(UserInfo) session.getAttribute("userInfo");
    * P3 d5 p$ y" {; M' t9 `0 A
66.                                 if (userId.equals(userInfo.getUserId())) {
    * @8 Q4 W! |& q# u' g
67.                                         list.add(session);
    3 U4 `; q# v; j9 @* Q
68.                                         break;
    0 H, W* d0 F: e* ~/ j. Y' U/ D: i
69.                                 }
    
70.                         }
    
71.                 }
    
72.                 return list;
    : B0 p6 |& K& h; c
73.         }
    4 A, Z* b/ \6 e, l% b& ?- g) C
74.        
    8 F* T" l) g# ^  Q' y7 H% D- H9 }
75.         public void sendMessage(String sender,String receiverId,String msg) {
    % L# _. a% P+ @
76.                 Collection<ScriptSession> scriptSessionFlag = this.getScriptSessionFlag(receiverId);
    - o: Z& r# n$ C/ ]' o
77.                 MessageInfo messageInfo = new MessageInfo(sender,receiverId,msg);
    
78.                 messageList.add(messageInfo);
    : L( F" m" V& z
79.                 Util receiverUtil = new Util(scriptSessionFlag);
    
80.                 receiverUtil.removeAllOptions("messageList");
    
81.                 receiverUtil.addOptions("messageList", messageList, "msg");
    
82.         }
    ( X; ^: {& l0 L# `
83. }
    

复制代码

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

4 v' W' m8 g* D% l7 q( k3 V, Z, t

wwlg5292

谢谢楼主分享

wwlg5292

呃,楼主分享链接失效了
3 Q! ?' T, J+ |; S1 z7 d5 H

woniu

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