package com.zy.asrs.wcs.core.map.websocket;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import javax.websocket.OnClose;
|
import javax.websocket.OnMessage;
|
import javax.websocket.OnOpen;
|
import javax.websocket.Session;
|
import javax.websocket.server.ServerEndpoint;
|
|
@Slf4j
|
@Component
|
@ServerEndpoint(value = "/map/websocket")
|
public class MapWebsocket {
|
|
private Session session;
|
private String sessionId;
|
|
@OnOpen
|
public void onOpen(Session session) {
|
this.session = session;
|
this.sessionId = session.getId();
|
log.info("{} connected", this.sessionId);
|
}
|
|
@OnMessage
|
public void onMessage(String message, Session session) {
|
log.info("{} sendMsg:{}", this.sessionId, message);
|
}
|
|
@OnClose
|
public void onClose(Session session) {
|
log.info("{} closed", this.sessionId);
|
}
|
|
}
|