|
|
@ -35,7 +35,7 @@ public class WebSocketServer {
|
|
|
|
Session session = it.next();
|
|
|
|
Session session = it.next();
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
session.getBasicRemote().sendText(message);
|
|
|
|
session.getBasicRemote().sendText(message);
|
|
|
|
} catch (IOException ignore) {
|
|
|
|
} catch (Exception ignore) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -46,6 +46,8 @@ public class WebSocketServer {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
if (!"1".equals(message)) {
|
|
|
|
if (!"1".equals(message)) {
|
|
|
|
message = message.replaceAll("吗", "")
|
|
|
|
message = message.replaceAll("吗", "")
|
|
|
|
|
|
|
|
.replaceAll("b", "c")
|
|
|
|
|
|
|
|
.replaceAll("a", "b")
|
|
|
|
.replaceAll("你", "我")
|
|
|
|
.replaceAll("你", "我")
|
|
|
|
.replaceAll("?", "!")
|
|
|
|
.replaceAll("?", "!")
|
|
|
|
.replaceAll("\\?", "!");
|
|
|
|
.replaceAll("\\?", "!");
|
|
|
@ -57,7 +59,9 @@ public class WebSocketServer {
|
|
|
|
|
|
|
|
|
|
|
|
//错误时调用
|
|
|
|
//错误时调用
|
|
|
|
@OnError
|
|
|
|
@OnError
|
|
|
|
public void onError(Session session, Throwable throwable) {
|
|
|
|
public void onError(Session session, Throwable e) {
|
|
|
|
|
|
|
|
sessionPools.remove(session);
|
|
|
|
|
|
|
|
log.info("剩余socket连接数" + sessionPools.size());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|