#

luxiaotao1123

2024-04-12 5c0622d48c825ca4b75f63dda78d51ed75bc7a2f

 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MapWebSocket.java

@@ -10,19 +10,24 @@
@Slf4j
@Component
@ServerEndpoint(value = "/ws/map/websocket")
public class MapWebsocket {
public class MapWebSocket {

    private static final long MAX_IDLE_TIMEOUT = 120 * 1000;

    private static final ConcurrentHashMap<String, Session> sessions = new ConcurrentHashMap<>();

    @OnOpen
    public void onOpen(Session session) {
        session.setMaxIdleTimeout(MAX_IDLE_TIMEOUT);
        sessions.put(session.getId(), session);
        log.info("Opened new session in instance " + session.getId());
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        log.info("Received WebSocket message: {}", message);
        if (!message.equals("1")) {
            log.info("Received WebSocket message: {}", message);
        }
    }

    @OnClose