| | |
|---|
| | | import java.util.concurrent.CopyOnWriteArrayList; |
|---|
| | | import java.util.concurrent.Semaphore; |
|---|
| | | |
|---|
| | | @ServerEndpoint(value = "/api/talk/{username}") |
|---|
| | | @ServerEndpoint(value = "/api/talk/{webSocketName}") |
|---|
| | | @Component |
|---|
| | | public class WebSocketServer { |
|---|
| | | |
|---|
| | |
|---|
| | | * 向当前用户的所有会话发送消息 |
|---|
| | | */ |
|---|
| | | public void sendToWeb(String webSocketName, String message) { |
|---|
| | | List<WebSocketServer> sessions = sessionMap.get(webSocketName); |
|---|
| | | List<WebSocketServer> sessions = sessionMap.get(webSocketName); |
|---|
| | | if (sessions == null) return; |
|---|
| | | sessions.forEach(ws -> { |
|---|
| | | try { |
|---|
