| | |
| | | package com.ruoyi.system.websocket; |
| | | |
| | | import com.ruoyi.system.api.util.WebSocketUsers; |
| | | import java.util.concurrent.Semaphore; |
| | | import javax.websocket.OnClose; |
| | | import javax.websocket.OnError; |
| | |
| | | |
| | | @OnMessage |
| | | public void onMessage(String message, Session session) { |
| | | String msg = message.replace("你", "我").replace("吗", "").replace("PING", "PONG") |
| | | .replace("ping", "pong"); |
| | | WebSocketUsers.sendMessageToUserByText(session, msg); |
| | | // String msg = message.replace("你", "我").replace("吗", "").replace("PING", "PONG") |
| | | // .replace("ping", "pong"); |
| | | // WebSocketUsers.sendMessageToUserByText(session, msg); |
| | | } |
| | | } |