|
@@ -33,7 +33,7 @@ public class WebSocketHandler extends AbstractWebSocketHandler {
|
|
|
@Override
|
|
|
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
|
|
|
String phone = session.getPrincipal().getName().split(":")[1];
|
|
|
- LOGGER.info("{}上线", session.getPrincipal().getName().split(":")[1]);
|
|
|
+ LOGGER.info("{}上线", phone);
|
|
|
WS_CLIENTS.put(phone, session);
|
|
|
super.afterConnectionEstablished(session);
|
|
|
file = new File("E:\\Temp\\record.wav");
|
|
@@ -42,7 +42,8 @@ public class WebSocketHandler extends AbstractWebSocketHandler {
|
|
|
|
|
|
@Override
|
|
|
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
|
|
|
- LOGGER.info("{}: {}", session.getPrincipal().getName().split(":")[1], message.getPayload());
|
|
|
+ String phone = session.getPrincipal().getName().split(":")[1];
|
|
|
+ LOGGER.info("{}: {}", phone, message.getPayload());
|
|
|
super.handleMessage(session, message);
|
|
|
}
|
|
|
|
|
@@ -66,9 +67,9 @@ public class WebSocketHandler extends AbstractWebSocketHandler {
|
|
|
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
|
|
|
super.handleTransportError(session, exception);
|
|
|
exception.printStackTrace();
|
|
|
- LOGGER.info("发生了错误,移除客户端: {}", session.getPrincipal().getName().split(":")[1]);
|
|
|
- session.close();
|
|
|
String phone = session.getPrincipal().getName().split(":")[1];
|
|
|
+ LOGGER.info("发生了错误,移除客户端: {}", phone);
|
|
|
+ session.close();
|
|
|
WS_CLIENTS.remove(phone);
|
|
|
createHeader();
|
|
|
}
|