|
|
|
@ -20,13 +20,13 @@ public class WebSocketServer {
|
|
|
|
|
@OnOpen
|
|
|
|
|
public void onOpen(Session session) {
|
|
|
|
|
sessionPools.add(session);
|
|
|
|
|
log.info("当前连接数" + sessionPools.size());
|
|
|
|
|
log.info("当前socket连接数" + sessionPools.size());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@OnClose
|
|
|
|
|
public void onClose(Session session) {
|
|
|
|
|
sessionPools.remove(session);
|
|
|
|
|
log.info("剩余连接数" + sessionPools.size());
|
|
|
|
|
log.info("剩余socket连接数" + sessionPools.size());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void sendMessage(String message) {
|
|
|
|
@ -42,8 +42,17 @@ public class WebSocketServer {
|
|
|
|
|
|
|
|
|
|
//收到客户端信息
|
|
|
|
|
@OnMessage
|
|
|
|
|
public void onMessage(String message) {
|
|
|
|
|
// log.info("收到客户端信息:{}", message);
|
|
|
|
|
public void onMessage(Session session, String message) {
|
|
|
|
|
try {
|
|
|
|
|
if (!"1".equals(message)) {
|
|
|
|
|
message = message.replaceAll("吗", "")
|
|
|
|
|
.replaceAll("你", "我")
|
|
|
|
|
.replaceAll("?", "!")
|
|
|
|
|
.replaceAll("\\?", "!");
|
|
|
|
|
session.getBasicRemote().sendText(message);
|
|
|
|
|
}
|
|
|
|
|
} catch (IOException ignore) {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//错误时调用
|
|
|
|
|