diff --git a/net.html b/net.html index 6d4a5bfba..2ecd9dcb2 100644 --- a/net.html +++ b/net.html @@ -182,7 +182,7 @@                  2.3 onRead               WebSocket成功连接后回调此方法， 由此方法处理原始的TCP连接， 同时业务代码去控制WebSocket的关闭。
        此模式下 以上方法都应该被重载。

-

        实现一个WebSocket服务需要继承 org.redkale.net.http.WebSocketServlet，以下是一个典型的聊天范例：

+

        实现一个WebSocket服务需要继承 org.redkale.net.http.WebSocketServlet，以下是一个简单的聊天范例：

@WebServlet("/ws/chat")
 public class ChatWebSocketServlet extends WebSocketServlet {
 
@@ -192,6 +192,17 @@
     @Resource
     private UserService userService;
 
+    @Override
+    public void init(HttpContext context, AnyValue conf) {
+        System.out.println("本实例的WebSocketEngine: " + super.engine);
+        System.out.println("本实例的WebSocketNode: " + super.node);
+    }
+
+    @Override
+    public void destroy(HttpContext context, AnyValue conf) {
+        System.out.println("关闭了ChatWebSocketServlet");
+    }
+
     @Override
     protected WebSocket createWebSocket() {
 
@@ -205,12 +216,12 @@
                 message.sendid = user.getUserid(); //将当前用户设为消息的发送方
                 message.sendtime = System.currentTimeMillis(); //设置消息发送时间
                 //给接收方发送消息, 即使接收方在其他WebSocket进程节点上有链接，RedKale也会自动发送到其他链接进程节点上。
-                super.sendEachMessage(message.receiveid, jsonConvert.convertTo(message)); 
+                super.sendEachMessage(message.receiveid, jsonConvert.convertTo(message));
             }
 
             @Override
             protected Serializable createGroupid() { //以用户ID作为WebSocketGroup的groupid
-                this.user = userService.current(String.valueOf(super.getSessionid()));
+                this.user = userService.current(String.valueOf(super.getSessionid()));
                 return this.user == null ? null : this.user.getUserid();
             }