删除无效Test代码

citu-module-infra/citu-module-infra-biz/src/main/java/com/citu/module/infra/websocket/WebSocketTest.java

@@ -1,2 +1,67 @@
-package com.citu.module.infra.websocket;public class Test {
-}
+//package com.citu.module.infra.websocket;
+//
+//import cn.hutool.json.JSONUtil;
+//import org.springframework.stereotype.Component;
+//
+//import javax.websocket.OnClose;
+//import javax.websocket.OnMessage;
+//import javax.websocket.OnOpen;
+//import javax.websocket.Session;
+//import javax.websocket.server.PathParam;
+//import javax.websocket.server.ServerEndpoint;
+//import java.io.IOException;
+//import java.util.concurrent.ConcurrentHashMap;
+//
+//@ServerEndpoint(value = "/ws2")
+//@Component
+//public class WebSocketTest {
+//    private static ConcurrentHashMap<String, WebSocketTest> webSocketMap = new ConcurrentHashMap<>();
+//    //实例一个session，这个session是websocket的session
+//    private Session session;
+//
+//    //新增一个方法用于主动向客户端发送消息
+//    public static void sendMessage(Object message, String userId) {
+//        WebSocketTest webSocket = webSocketMap.get(userId);
+//        if (webSocket != null) {
+//            try {
+//                webSocket.session.getBasicRemote().sendText(JSONUtil.toJsonStr(message));
+//                System.out.println("【websocket消息】发送消息成功,用户="+userId+",消息内容"+message.toString());
+//            } catch (IOException e) {
+//                e.printStackTrace();
+//            }
+//        }
+//    }
+//
+//    public static ConcurrentHashMap<String, WebSocketTest> getWebSocketMap() {
+//        return webSocketMap;
+//    }
+//
+//    public static void setWebSocketMap(ConcurrentHashMap<String, WebSocketTest> webSocketMap) {
+//        WebSocketTest.webSocketMap = webSocketMap;
+//    }
+//
+//    //前端请求时一个websocket时
+//    @OnOpen
+//    public void onOpen(Session session, @PathParam("userId") String userId) {
+//        this.session = session;
+//        webSocketMap.put(userId, this);
+//        sendMessage("CONNECT_SUCCESS", userId);
+//        System.out.println("【websocket消息】有新的连接,连接id"+userId);
+//    }
+//
+//    //前端关闭时一个websocket时
+//    @OnClose
+//    public void onClose(@PathParam("userId") String userId) {
+//        webSocketMap.remove(userId);
+//        System.out.println("【websocket消息】连接断开,总数:"+ webSocketMap.size());
+//    }
+//
+//    //前端向后端发送消息
+//    @OnMessage
+//    public void onMessage(String message) {
+//        if (!message.equals("ping")) {
+//            System.out.println("【websocket消息】收到客户端发来的消息:"+message);
+//        }
+//    }
+//}
+//