gitee
/
roses
mirror of https://gitee.com/stylefeng/roses
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

修改变量命名问题

pull/22/head
rays 2021-08-14 15:46:20 +08:00
parent da6e6c7e7c
commit b37dcb2244
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/server/WebSocketServer.java
View File

@ -57,7 +57,7 @@ public class WebSocketServer {
} }
// 操作api包装 // 操作api包装
GunsSocketOperator GunsSocketOperator = new GunsSocketOperator(session); GunsSocketOperator gunsSocketOperator = new GunsSocketOperator(session);
// 回复消息 // 回复消息
WebSocketMessageDTO replyMsg = new WebSocketMessageDTO(); WebSocketMessageDTO replyMsg = new WebSocketMessageDTO();
@ -71,7 +71,7 @@ public class WebSocketServer {
replyMsg.setData(session.getId()); replyMsg.setData(session.getId());
socketSession.setSessionId(session.getId()); socketSession.setSessionId(session.getId());
socketSession.setUserId(userId); socketSession.setUserId(userId);
socketSession.setSocketOperatorApi(GunsSocketOperator); socketSession.setSocketOperatorApi(gunsSocketOperator);
socketSession.setToken(token); socketSession.setToken(token);
socketSession.setConnectionTime(System.currentTimeMillis()); socketSession.setConnectionTime(System.currentTimeMillis());
@ -79,7 +79,7 @@ public class WebSocketServer {
SessionCenter.addSocketSession(socketSession); SessionCenter.addSocketSession(socketSession);
} finally { } finally {
// 回复消息 // 回复消息
GunsSocketOperator.writeAndFlush(replyMsg); gunsSocketOperator.writeAndFlush(replyMsg);
// 触发首次连接回调 // 触发首次连接回调
SocketMsgCallbackInterface socketMsgCallbackInterface = SocketMessageCenter.getSocketMsgCallbackInterface(SystemMessageTypeEnum.SYS_LISTENER_ONOPEN.getCode()); SocketMsgCallbackInterface socketMsgCallbackInterface = SocketMessageCenter.getSocketMsgCallbackInterface(SystemMessageTypeEnum.SYS_LISTENER_ONOPEN.getCode());