package com.whyc.webSocket.receiver;
|
|
import org.springframework.web.socket.CloseStatus;
|
import org.springframework.web.socket.TextMessage;
|
import org.springframework.web.socket.WebSocketHttpHeaders;
|
import org.springframework.web.socket.WebSocketSession;
|
import org.springframework.web.socket.handler.TextWebSocketHandler;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
public class ThirdPartyWebSocketHandler extends TextWebSocketHandler {
|
|
private static final Logger log = LoggerFactory.getLogger(ThirdPartyWebSocketHandler.class);
|
private WebSocketSession session;
|
|
@Override
|
public void afterConnectionEstablished(WebSocketSession session) {
|
this.session = session;
|
log.info("WebSocket connection established.");
|
}
|
|
@Override
|
public void handleTextMessage(WebSocketSession session, TextMessage message) {
|
log.info("Received message: {}", message.getPayload());
|
// 可以在这里做业务处理，比如发布事件、存入队列等
|
String jsonStr = message.getPayload();
|
|
}
|
|
@Override
|
public void handleTransportError(WebSocketSession session, Throwable exception) {
|
log.error("Transport error occurred.", exception);
|
}
|
|
@Override
|
public void afterConnectionClosed(WebSocketSession session, CloseStatus status) {
|
log.info("WebSocket connection closed: {}", status);
|
this.session = null;
|
}
|
|
public WebSocketSession getSession() {
|
return session;
|
}
|
}
|
