liuxiaolong
2019-05-09 0d1d88cdb668e75ea8609417ac18ae19947e9525
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
/**
 * Copyright &copy; 2015-2020 <a href="http://www.jeeplus.org/">JeePlus</a> All rights reserved.
 */
package com.jeeplus.common.websocket.onchat;
 
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.UnknownHostException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
import java.text.SimpleDateFormat;
import java.util.Collection;
import java.util.Date;
 
import org.java_websocket.WebSocket;
import org.java_websocket.WebSocketImpl;
import org.java_websocket.framing.Framedata;
import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer;
import org.springframework.beans.factory.annotation.Autowired;
 
import com.jeeplus.common.json.AjaxJson;
import com.jeeplus.common.utils.SpringContextHolder;
import com.jeeplus.common.websocket.utils.Constant;
import com.jeeplus.modules.iim.entity.ChatHistory;
import com.jeeplus.modules.iim.service.ChatHistoryService;
 
import java.util.List;
 
public class ChatServer extends WebSocketServer{
 
    
    public ChatServer(int port) throws UnknownHostException {
        super(new InetSocketAddress(port));
    }
 
    public ChatServer(InetSocketAddress address) {
        super(address);
    }
 
    /**
     * 触发连接事件
     */
    @Override
    public void onOpen( WebSocket conn, ClientHandshake handshake ) {
//        Collection<String> onlineUsers = MsgServerPool.getOnlineUser();
//        AjaxJson j = new AjaxJson();
//        j.put("data", onlineUsers);
//        MsgServerPool.sendMessageToUser(conn, "_online_all_status_"+j.getJsonStr());//首次登陆系统时,获取用户的在线状态
    }
 
    /**
     * 触发关闭事件
     */
    @Override
    public void onClose( WebSocket conn, int code, String reason, boolean remote ) {
        userLeave(conn);
        Collection<String> onlineUsers = ChatServerPool.getOnlineUser();
        AjaxJson j = new AjaxJson();
        j.put("data", onlineUsers);
        ChatServerPool.sendMessage("_online_all_status_"+j.getJsonStr());//通知所有用户更新在线信息
    }
 
    /**
     * 客户端发送消息到服务器时触发事件
     */
    @Override
    public void onMessage(WebSocket conn, String message){
        message = message.toString();
        ChatHistoryService chatHistoryService = SpringContextHolder.getBean("chatHistoryService");
            // TODO Auto-generated catch block
        if(null != message && message.startsWith(Constant._online_user_)){//用户上线
            String userId = message.replaceFirst(Constant._online_user_, "");
            this.userjoin(userId,conn);
            
            //通知所有用户更新在线信息
            Collection<String> onlineUsers = ChatServerPool.getOnlineUser();
            AjaxJson j = new AjaxJson();
            j.put("data", onlineUsers);
            ChatServerPool.sendMessage("_online_all_status_"+j.getJsonStr());//通知所有用户更新在线信息
 
            //读取离线信息
            ChatHistory chat = new ChatHistory();
            chat.setUserid2(userId);
            chat.setStatus("0");
            List<ChatHistory> list =chatHistoryService.findList(chat);
            for(ChatHistory c : list){
                ChatServerPool.sendMessageToUser(conn,  c.getUserid1()+Constant._msg_+c.getUserid2()+Constant._msg_+c.getMsg()+Constant._msg_+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(c.getCreateDate()));//向所某用户发送消息
                c.setStatus("1");//标记为已读
                chatHistoryService.save(c);
            }
            
            
        }if(null != message && message.startsWith(Constant._leave_user_)){//用户离线
            this.userLeave(conn);
            Collection<String> onlineUsers = ChatServerPool.getOnlineUser();
            AjaxJson j = new AjaxJson();
            j.put("data", onlineUsers);
            ChatServerPool.sendMessage("_online_all_status_"+j.getJsonStr());//通知所有用户更新在线信息
        }if(null != message && message.contains(Constant._msg_)){//
            String []arr = message.split(Constant._msg_);
            String fromUser = arr[0];
            String toUser = arr[1];
            String msg = arr[2];
            
            //保存聊天记录
            ChatHistory chat = new ChatHistory();
            chat.setUserid1(fromUser);
            chat.setUserid2(toUser);
            chat.setMsg(msg);
            
            chat.setCreateDate(new Date());
            
            
            WebSocket toUserConn = ChatServerPool.getWebSocketByUser(toUser);
            if(toUserConn != null){
                ChatServerPool.sendMessageToUser(ChatServerPool.getWebSocketByUser(toUser),message);//向所某用户发送消息
                chat.setStatus("1");//设置为已读
            }else{
                ChatServerPool.sendMessageToUser(conn, "_sys_对方现在离线,他将在上线后收到你的消息!");//同时向本人发送消息
                chat.setStatus("0");//设置为未读
            }
            
            chatHistoryService.save(chat);
            
        }
    }
    
    @Override
    public void onMessage(WebSocket conn, ByteBuffer buffer){
         Charset charset = null;
            CharsetDecoder decoder = null;
            CharBuffer charBuffer = null;
        try {
             charset = Charset.forName("UTF-8");
                decoder = charset.newDecoder();
                // charBuffer = decoder.decode(buffer);//用这个的话,只能输出来一次结果,第二次显示为空
                charBuffer = decoder.decode(buffer.asReadOnlyBuffer());
                //return charBuffer.toString();
        System.out.println( charBuffer.toString());
        } catch (Exception ex) {
        ex.printStackTrace();
        }
    }
 
    public void onFragment( WebSocket conn, Framedata fragment ) {
    }
 
    /**
     * 触发异常事件
     */
    @Override
    public void onError( WebSocket conn, Exception ex ) {
        ex.printStackTrace();
        if( conn != null ) {
            //some errors like port binding failed may not be assignable to a specific websocket
        }
    }
 
    
    /**
     * 用户加入处理
     * @param user
     */
    public void userjoin(String user, WebSocket conn){
//        AjaxJson j = new AjaxJson();
//        j.put("type", "user_join");
//        j.put("user", "<a onclick=\"toUserMsg('"+user+"');\">"+user+"</a>");
//        MsgServerPool.sendMessage(j.getJsonStr());                //把当前用户加入到所有在线用户列表中
//        String joinMsg = "{\"from\":\"[系统]\",\"content\":\""+user+"上线了\",\"timestamp\":"+new Date().getTime()+",\"type\":\"message\"}";
//        MsgServerPool.sendMessage(joinMsg);                        //向所有在线用户推送当前用户上线的消息
//        j = new AjaxJson();
//        j.put("type", "get_online_user");
        ChatServerPool.addUser(user,conn);                            //向连接池添加当前的连接对象
//        j.put("list", MsgServerPool.getOnlineUser());
//        MsgServerPool.sendMessageToUser(conn, j.getJsonStr());    //向当前连接发送当前在线用户的列表
    }
    
    /**
     * 用户下线处理
     * @param user
     */
    public void userLeave(WebSocket conn){
        String user = ChatServerPool.getUserByKey(conn);
        boolean b = ChatServerPool.removeUser(conn);                //在连接池中移除连接
//        if(b){
//            AjaxJson j = new AjaxJson();
//            j.put("type", "user_leave");
//            j.put("user", "<a onclick=\"toUserMsg('"+user+"');\">"+user+"</a>");
//            MsgServerPool.sendMessage(j.getJsonStr());            //把当前用户从所有在线用户列表中删除
//            String joinMsg = "{\"from\":\"[系统]\",\"content\":\""+user+"下线了\",\"timestamp\":"+new Date().getTime()+",\"type\":\"message\"}";
//            MsgServerPool.sendMessage(joinMsg);                    //向在线用户发送当前用户退出的消息
//        }
    }
    public static void main( String[] args ) throws InterruptedException , IOException {
        WebSocketImpl.DEBUG = false;
        int port = 8667; //端口
        ChatServer s = new ChatServer(port);
        s.start();
        //System.out.println( "服务器的端口" + s.getPort() );
    }
 
}