diff --git a/src/main/java/com/xydl/cac/socket/WebSocketServer.java b/src/main/java/com/xydl/cac/socket/WebSocketServer.java
index 9c866a0..d12901c 100644
--- a/src/main/java/com/xydl/cac/socket/WebSocketServer.java
+++ b/src/main/java/com/xydl/cac/socket/WebSocketServer.java
@@ -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) {
+        }
     }
 
     //错误时调用