|
@@ -38,8 +38,8 @@ public class SocketServer {
|
|
|
private final MidjourneyService midjourneyService;
|
|
private final MidjourneyService midjourneyService;
|
|
|
|
|
|
|
|
@HandshakeBefore
|
|
@HandshakeBefore
|
|
|
- public void handshakeBefore(HttpHeaders headers,@PathParam String userid) {
|
|
|
|
|
- log.info("handshakeBefore userId: {} host: {}", userid, headers.get("HOST"));
|
|
|
|
|
|
|
+ public void handshakeBefore(HttpHeaders headers,@PathParam(value="userToken") String userToken) {
|
|
|
|
|
+ log.info("handshakeBefore userToken: {} host: {}", userToken, headers.get("HOST"));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -157,19 +157,19 @@ public class SocketServer {
|
|
|
* @param evt
|
|
* @param evt
|
|
|
*/
|
|
*/
|
|
|
@OnEvent
|
|
@OnEvent
|
|
|
- public void onEvent(Session session,@PathParam String userid, Object evt) {
|
|
|
|
|
|
|
+ public void onEvent(Session session,@PathParam(value="userToken") String userToken, Object evt) {
|
|
|
if (evt instanceof IdleStateEvent) {
|
|
if (evt instanceof IdleStateEvent) {
|
|
|
IdleStateEvent idleStateEvent = (IdleStateEvent) evt;
|
|
IdleStateEvent idleStateEvent = (IdleStateEvent) evt;
|
|
|
switch (idleStateEvent.state()) {
|
|
switch (idleStateEvent.state()) {
|
|
|
case READER_IDLE:
|
|
case READER_IDLE:
|
|
|
- log.info("clent : {} heartbeat read timeout event",userid);
|
|
|
|
|
|
|
+ log.info("clent : {} heartbeat read timeout event",userToken);
|
|
|
break;
|
|
break;
|
|
|
case WRITER_IDLE:
|
|
case WRITER_IDLE:
|
|
|
- log.info("clent : {} heartbeat write timeout event",userid);
|
|
|
|
|
|
|
+ log.info("clent : {} heartbeat write timeout event",userToken);
|
|
|
session.close();
|
|
session.close();
|
|
|
break;
|
|
break;
|
|
|
case ALL_IDLE:
|
|
case ALL_IDLE:
|
|
|
- log.info("clent : {} heartbeat all timeout event",userid);
|
|
|
|
|
|
|
+ log.info("clent : {} heartbeat all timeout event",userToken);
|
|
|
break;
|
|
break;
|
|
|
default:
|
|
default:
|
|
|
break;
|
|
break;
|