diff --git a/kernel-d-socket/socket-api/src/main/java/cn/stylefeng/roses/kernel/socket/api/enums/SystemMessageTypeEnum.java b/kernel-d-socket/socket-api/src/main/java/cn/stylefeng/roses/kernel/socket/api/enums/SystemMessageTypeEnum.java
new file mode 100644
index 000000000..f57f9f953
--- /dev/null
+++ b/kernel-d-socket/socket-api/src/main/java/cn/stylefeng/roses/kernel/socket/api/enums/SystemMessageTypeEnum.java
@@ -0,0 +1,39 @@
+package cn.stylefeng.roses.kernel.socket.api.enums;
+
+import lombok.Getter;
+
+/**
+ * 服务端监听器枚举
+ * <p>
+ * 说明：该枚举适用于服务端监听首次连接和断开连接
+ *
+ * @author majianguo
+ * @date 2021/6/3 上午9:14
+ */
+@Getter
+public enum SystemMessageTypeEnum {
+
+    /**
+     * 监听首次连接
+     */
+    SYS_LISTENER_ONOPEN("S00001", "监听首次连接"),
+
+    /**
+     * 监听断开连接
+     */
+    SYS_LISTENER_ONCLOSE("S00002", "监听断开连接"),
+
+    /**
+     * 监听异常信息
+     */
+    SYS_LISTENER_ONERROR("S00003", "监听异常信息");
+
+    private final String code;
+
+    private final String name;
+
+    SystemMessageTypeEnum(String code, String name) {
+        this.code = code;
+        this.name = name;
+    }
+}
diff --git a/kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/server/WebSocketServer.java b/kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/server/WebSocketServer.java
index 1f431c56d..c154425cf 100644
--- a/kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/server/WebSocketServer.java
+++ b/kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/server/WebSocketServer.java
@@ -5,6 +5,7 @@ import cn.stylefeng.roses.kernel.jwt.api.context.JwtContext;
 import cn.stylefeng.roses.kernel.jwt.api.pojo.payload.DefaultJwtPayload;
 import cn.stylefeng.roses.kernel.socket.api.enums.ClientMessageTypeEnum;
 import cn.stylefeng.roses.kernel.socket.api.enums.ServerMessageTypeEnum;
+import cn.stylefeng.roses.kernel.socket.api.enums.SystemMessageTypeEnum;
 import cn.stylefeng.roses.kernel.socket.api.message.SocketMsgCallbackInterface;
 import cn.stylefeng.roses.kernel.socket.api.session.pojo.SocketSession;
 import cn.stylefeng.roses.kernel.socket.business.websocket.message.SocketMessageCenter;
@@ -63,12 +64,11 @@ public class WebSocketServer {
         replyMsg.setServerMsgType(ServerMessageTypeEnum.SYS_REPLY_MSG_TYPE.getCode());
         replyMsg.setToUserId(userId);
 
+        // 创建会话对象
+        SocketSession<GunsSocketOperator> socketSession = new SocketSession<>();
         try {
             // 设置回复内容
             replyMsg.setData(session.getId());
-
-            // 创建会话对象
-            SocketSession<GunsSocketOperator> socketSession = new SocketSession<>();
             socketSession.setSessionId(session.getId());
             socketSession.setUserId(userId);
             socketSession.setSocketOperatorApi(GunsSocketOperator);
@@ -80,6 +80,13 @@ public class WebSocketServer {
         } finally {
             // 回复消息
             GunsSocketOperator.writeAndFlush(replyMsg);
+
+            // 触发首次连接回调
+            SocketMsgCallbackInterface socketMsgCallbackInterface = SocketMessageCenter.getSocketMsgCallbackInterface(SystemMessageTypeEnum.SYS_LISTENER_ONOPEN.getCode());
+            if (ObjectUtil.isNotEmpty(socketMsgCallbackInterface)) {
+                // 触发回调
+                socketMsgCallbackInterface.callback(SystemMessageTypeEnum.SYS_LISTENER_ONOPEN.getCode(), null, socketSession);
+            }
         }
 
     }
@@ -93,7 +100,17 @@ public class WebSocketServer {
      **/
     @OnClose
     public void onClose(Session session) {
-        SessionCenter.closed(session.getId());
+        try {
+            SocketSession<GunsSocketOperator> socketSession = SessionCenter.getSessionBySessionId(session.getId());
+            // 触发首次连接回调
+            SocketMsgCallbackInterface socketMsgCallbackInterface = SocketMessageCenter.getSocketMsgCallbackInterface(SystemMessageTypeEnum.SYS_LISTENER_ONCLOSE.getCode());
+            if (ObjectUtil.isNotEmpty(socketMsgCallbackInterface)) {
+                // 触发回调
+                socketMsgCallbackInterface.callback(SystemMessageTypeEnum.SYS_LISTENER_ONCLOSE.getCode(), null, socketSession);
+            }
+        } finally {
+            SessionCenter.closed(session.getId());
+        }
     }
 
     /**
@@ -154,6 +171,13 @@ public class WebSocketServer {
      **/
     @OnError
     public void onError(Session session, Throwable error) {
+        SocketSession<GunsSocketOperator> socketSession = SessionCenter.getSessionBySessionId(session.getId());
+        // 触发首次连接回调
+        SocketMsgCallbackInterface socketMsgCallbackInterface = SocketMessageCenter.getSocketMsgCallbackInterface(SystemMessageTypeEnum.SYS_LISTENER_ONERROR.getCode());
+        if (ObjectUtil.isNotEmpty(socketMsgCallbackInterface)) {
+            // 触发回调
+            socketMsgCallbackInterface.callback(SystemMessageTypeEnum.SYS_LISTENER_ONERROR.getCode(), error, socketSession);
+        }
         log.error("session 发生错误:" + session.getId());
     }
 }