SpringBoot_WebSocket

旧城等待， 2021-10-06 03:00 384阅读 0赞

### SpringBoot\_WebSocket简单使用 ###

*  引入依赖
 *  核心代码
 *  页面代码示例

# 引入依赖 #

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-websocket</artifactId>
    </dependency>

# 核心代码 #

/**
     * 
     * webSocket服务端
     */
    @Component
    @ServerEndpoint("/webSocket")
    @Slf4j
    public class WebSocket {
    
        private Session session;
        private static CopyOnWriteArraySet<WebSocket> webSocketSet = new CopyOnWriteArraySet<>();
    
        @OnOpen
        public void onOpen(Session session) {
            this.session = session;
            webSocketSet.add(this);
            log.info("连接数:{}", webSocketSet.size());
        }
    
        @OnClose
        public void onClose() {
            webSocketSet.remove(this);
            log.info("连接数:{}", webSocketSet.size());
        }
    
        @OnMessage
        public void onMessage(String message) {
            log.info("收到客户端发来的消息:{}", message);
        }
        public void sendMessage(String message) {
             log.info("广播消息：{}", message);
            for (WebSocket webSocket: webSocketSet) {
                try {
                    webSocket.session.getBasicRemote().sendText(message);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
    /**
     * websocket配置
     * 
     * @author vander
     *
     */
    @Configuration
    public class WebSocketConfig {
    
        /**
         * @return
         */
        @Bean
        public ServerEndpointExporter serverEndpointExporter() {
            return new ServerEndpointExporter();
        }
    }

# 页面代码示例 #

SpringBoot_WebSocket

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 springbootWebSocket环境搭建