Java 使用websocket

添加依赖

1. <!-- WebSocket 支持 -->
2. <dependency>
3.     <groupId>org.springframework.boot</groupId>
4.     <artifactId>spring-boot-starter-websocket</artifactId>
5. </dependency>

复制代码

添加设置类

1. @Configuration
2. public class WebSocketConfig {
3.     @Bean
4.     public ServerEndpointExporter serverEndpointExporter(){
5.         return new ServerEndpointExporter();
6.     }
7. }

复制代码

添加服务类

1. @Component
2. @ServerEndpoint("/ws/{clientId}")
3. public class WebSocketServer {
5.     private static Map<String, Session> sessionMap = new HashMap<>();
7.     @OnOpen
8.     public void onOpen(Session session, @PathParam("clientId") String clientId) {
9.         System.err.println("客户端：" + clientId + "建立连结");
10.         sessionMap.put(clientId, session);
11.     }
13.     @OnClose
14.     public void onClose(@PathParam("clientId") String clientId) {
15.         sessionMap.remove(clientId);
16.     }
18.     /**
19.      * 收到客户端消息后调用的方法
20.      *
21.      * @param message  客户端发送过来的消息
22.      * @param clientId
23.      */
24.     @OnMessage
25.     public void onMessage(String message, @PathParam("clientId") String clientId) {
26.         System.err.println("收到来自客户端" + clientId + "的消息：" + message);
27.     }
29.     public void sendMessage(String message) {
30.         Collection<Session> sessions = sessionMap.values();
31.         for (Session session : sessions) {
32.             try {
33.                 session.getBasicRemote().sendText(message);
34.             } catch (Exception e) {
35.                 e.printStackTrace();
36.             }
38.         }
39.     }
41. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。