提交websocket相关代码

dev_2.0.0
liu
parent 1fc3b08900
commit 2ce1252556

@ -24,10 +24,6 @@ public class KickUserListener implements MessageListener {
String messageString = message.toString(); String messageString = message.toString();
UserWebSocketDTO user = JSONUtil.toBean(messageString, UserWebSocketDTO.class); UserWebSocketDTO user = JSONUtil.toBean(messageString, UserWebSocketDTO.class);
log.info("Redis的Channel:{}收到踢用户{}下线消息", UserTokenConstant.KICK_CHANNEL, user.getUserId()); log.info("Redis的Channel:{}收到踢用户{}下线消息", UserTokenConstant.KICK_CHANNEL, user.getUserId());
try { userResourceCheck.kickUser(user.getUserId(), user.getIgnoreSessionId());
userResourceCheck.kickUser(user.getUserId(), user.getIgnoreSessionId());
} catch (IOException e) {
throw new RuntimeException(e);
}
} }
} }

@ -55,7 +55,7 @@ public class UserResourceCheck {
} }
/** /**
* websocket * websocket,5
*/ */
@Scheduled(fixedDelay = 5 * 1000L) @Scheduled(fixedDelay = 5 * 1000L)
public void keepalive() { public void keepalive() {

Loading…
Cancel
Save