websocket协议全双工协议

 javax
         javaee-api
        7.0provided

　　　　　　
  
  
      Welcome
发送消息
     
关闭WebSocket连接
     

 
 
 

 1 package me.gacl.websocket;
 2 
 3 import java.io.IOException;
 4 import java.util.concurrent.CopyOnWriteArraySet;
 5 
 6 import javax.websocket.*;
 7 import javax.websocket.server.ServerEndpoint;
 8 
 9 /**
10  * @ServerEndpoint 注解是一个类层次的注解，它的功能主要是将目前的类定义成一个websocket服务器端,
11  * 注解的值将被用于监听用户连接的终端访问URL地址,客户端可以通过这个URL来连接到WebSocket服务器端
12  */
13 @ServerEndpoint("/websocket")
14 public class WebSocketTest {
15     //静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
16     private static int onlineCount = 0;
17 
18     //concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。若要实现服务端与单一客户端通信的话，可以使用Map来存放，其中Key可以为用户标识
19     private static CopyOnWriteArraySet webSocketSet = new CopyOnWriteArraySet();
20 
21     //与某个客户端的连接会话，需要通过它来给客户端发送数据
22     private Session session;
23 
24     /**
25      * 连接建立成功调用的方法
26      * @param session  可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据
27      */
28     @OnOpen
29     public void onOpen(Session session){
30         this.session = session;
31         webSocketSet.add(this);     //加入set中
32         addOnlineCount();           //在线数加1
33         System.out.println("有新连接加入！当前在线人数为" + getOnlineCount());
34     }
35 
36     /**
37      * 连接关闭调用的方法
38      */
39     @OnClose
40     public void onClose(){
41         webSocketSet.remove(this);  //从set中删除
42         subOnlineCount();           //在线数减1
43         System.out.println("有一连接关闭！当前在线人数为" + getOnlineCount());
44     }
45 
46     /**
47      * 收到客户端消息后调用的方法
48      * @param message 客户端发送过来的消息
49      * @param session 可选的参数
50      */
51     @OnMessage
52     public void onMessage(String message, Session session) {
53         System.out.println("来自客户端的消息:" + message);
54         //群发消息
55         for(WebSocketTest item: webSocketSet){
56             try {
57                 item.sendMessage(message);
58             } catch (IOException e) {
59                 e.printStackTrace();
60                 continue;
61             }
62         }
63     }
64 
65     /**
66      * 发生错误时调用
67      * @param session
68      * @param error
69      */
70     @OnError
71     public void onError(Session session, Throwable error){
72         System.out.println("发生错误");
73         error.printStackTrace();
74     }
75 
76     /**
77      * 这个方法与上面几个方法不一样。没有用注解，是根据自己需要添加的方法。
78      * @param message
79      * @throws IOException
80      */
81     public void sendMessage(String message) throws IOException{
82         this.session.getBasicRemote().sendText(message);
83         //this.session.getAsyncRemote().sendText(message);
84     }
85 
86     public static synchronized int getOnlineCount() {
87         return onlineCount;
88     }
89 
90     public static synchronized void addOnlineCount() {
91         WebSocketTest.onlineCount++;
92     }
93 
94     public static synchronized void subOnlineCount() {
95         WebSocketTest.onlineCount--;
96     }
97 }