总结之WebSocket（一）——日常应用

电玩女神 2023-07-23 04:58 1阅读 0赞

#### 基于springboot2.+的webSocket应用 ####

springboot内容本章不详细描述  
maven依赖websocket

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

API描述  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0lNYW5peQ_size_16_color_FFFFFF_t_70]  
后端WebSocket基础方法

import javax.websocket.OnClose;
    import javax.websocket.OnMessage;
    import javax.websocket.OnOpen;
    import javax.websocket.Session;
    import javax.websocket.server.ServerEndpoint;
    import java.util.concurrent.CopyOnWriteArraySet;
    
    /**
     * @author Maniy.top
     * @date 2018/4/8 22:50
     * @name liuzonghua
     */
    @ServerEndpoint("/webSocket")
    public class WebSocket {
        private Session session;
        public static String okMessage="";
        private static CopyOnWriteArraySet<WebSocket> webSocketSet =new CopyOnWriteArraySet<>();
    
        @OnOpen
        public void onOpen(Session session){
            this.session =session;
            webSocketSet.add(this);
            log.info("[websocket消息] 有新的连接,总数:{}",webSocketSet.size());
        }
        @OnClose
        public void onClose(){
            webSocketSet.remove(this);
            log.info("[websocket消息] 连接断开,总数:{}",webSocketSet.size());
        }
    //    @OnMessage
    //    public void onMessage(String message){
    //        log.info("[websocket消息] 收到客户端发来的消息:{}",message);
    //    }
    
        @OnMessage
        public void onMessage(String message){
             this.okMessage=System.currentTimeMillis()+"|"+message;
    
            System.out.println(this.okMessage);
            log.info("[websocket消息] 收到客户端发来的消息:{}",message);
    
    
        }
    
        public void sendMessage(String message){
            for (WebSocket webSocket:webSocketSet){
                log.info("[websocket] 广播消息,message={}",message);
                try {
    
    
                webSocket.session.getBasicRemote().sendText(message);
                }catch (Exception e){
                    e.printStackTrace();
                }
    
            }
        }
    
        public String getOkMessage() {
            return okMessage;
        }
    
        public void setOkMessage(String okMessage) {
            this.okMessage = okMessage;
        }
    }

#### 使用 ####

@Autowired  
private WebSocket webSocket;

//发送websocket消息  
webSocket.sendMessage(“categorySave”);

## WebSocket前端编码 ##

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0lNYW5peQ_size_16_color_FFFFFF_t_70]: /images/20230528/0e8aaf02489940078160d28ebc2722de.png