Socket添加关闭会话接口

kernel-d-socket/socket-api/src/main/java/cn/stylefeng/roses/kernel/socket/api/SocketOperatorApi.java

@@ -47,6 +47,15 @@ public interface SocketOperatorApi {
      **/
     void sendMsgOfAllUserSession(String msgType, Object msg);
 
+    /**
+     * 根据会话id关闭会话
+     *
+     * @param socketId 会话id
+     * @author majianguo
+     * @date 2021/8/13 16:00
+     **/
+    void closeSocketBySocketId(String socketId);
+
     /**
      * 监听指定类型消息
      * <p>

kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/operator/WebSocketOperator.java

@@ -68,6 +68,11 @@ public class WebSocketOperator implements SocketOperatorApi {
         }
     }
 
+    @Override
+    public void closeSocketBySocketId(String socketId) {
+        SessionCenter.closed(socketId);
+    }
+
     @Override
     public void msgTypeCallback(String msgType, SocketMsgCallbackInterface callbackInterface) {
         SocketMessageCenter.setMessageListener(msgType, callbackInterface);