diff --git a/src/main/java/com/gxwebsoft/common/core/socketio/config/SocketIOConfig.java b/src/main/java/com/gxwebsoft/common/core/socketio/config/SocketIOConfig.java index 1097481..3fe7fd0 100644 --- a/src/main/java/com/gxwebsoft/common/core/socketio/config/SocketIOConfig.java +++ b/src/main/java/com/gxwebsoft/common/core/socketio/config/SocketIOConfig.java @@ -1,8 +1,10 @@ package com.gxwebsoft.common.core.socketio.config; +import com.corundumstudio.socketio.SocketIOServer; import com.gxwebsoft.common.core.config.ConfigProperties; import com.gxwebsoft.common.core.security.JwtSubject; import com.gxwebsoft.common.core.security.JwtUtil; +import com.gxwebsoft.common.core.socketio.cache.ClientCache; import com.gxwebsoft.common.core.socketio.handler.SocketIOHandler; import com.gxwebsoft.common.system.entity.User; import com.gxwebsoft.common.system.service.UserService; @@ -71,10 +73,10 @@ public class SocketIOConfig implements InitializingBean { config.setKeyStorePassword("123456"); // 设置证书密码 // 启动socket服务 -// SocketIOServer server = new SocketIOServer(config); -// server.addListeners(socketIOHandler); -// server.start(); -// ClientCache.setSocketIOServer(server); -// logger.debug("Netty SocketIO启动:{}:{}",host,port); + SocketIOServer server = new SocketIOServer(config); + server.addListeners(socketIOHandler); + server.start(); + ClientCache.setSocketIOServer(server); + logger.debug("Netty SocketIO启动:{}:{}",host,port); } }