• WebScoket

    一、前端页面

    1. html>
    2. <html lang="en">
    3. <head>
    4.     <meta charset="UTF-8">
    5.     <title>webSockettitle>
    6.     <style type="text/css">
    7.     style>
    8. head>
    9. <body>
    10. <h1>WebSocketh1>
    11. <input type="button" onclick="websocket.send('666666666')" value="点我发消息"/>
    12. body>
    13. <script type="application/javascript">
    14.     var websocket = {
    15.         send: function (str) {
    16.         }
    17.     };
    18.     window.onload = function () {
    19.         if (!'WebSocket' in window) return;
    20.         webSocketInit();
    21.     };
    22.     function webSocketInit() {
    23.         websocket = new WebSocket("ws://localhost:8081//websocket/socket");
    24.         //成功建立连接
    25.         websocket.onopen = function () {
    26.             websocket.send("成功连接到服务器");
    27.         };
    28.         //接收到消息
    29.         websocket.onmessage = function (event) {
    30.             console.log(event.data)
    31.         };
    32.         //连接发生错误
    33.         websocket.onerror = function () {
    34.             alert("WebSocket连接发生错误");
    35.         };
    36.         //连接关闭
    37.         websocket.onclose = function () {
    38.             alert("WebSocket连接关闭");
    39.         };
    40.         //监听窗口关闭事件，当窗口关闭时，主动关闭websocket连接
    41.         window.onbeforeunload = function () {
    42.             websocket.close()
    43.         };
    44.     }
    45. script>
    46. html>

    二、后端代码

            2.1 maven引入

    1.         
    2.         <dependency>
    3.             <groupId>org.springframework.bootgroupId>
    4.             <artifactId>spring-boot-starter-websocketartifactId>
    5.         dependency>

            2.2 配置类

    1. import org.springframework.context.annotation.Bean;
    2. import org.springframework.context.annotation.Configuration;
    3. import org.springframework.web.socket.config.annotation.EnableWebSocket;
    4. import org.springframework.web.socket.server.standard.ServerEndpointExporter;
    5.  
    6. @Configuration
    7. @EnableWebSocket
    8. public class WebSocketConfig {
    9.  
    10.     @Bean
    11.     public ServerEndpointExporter serverEndpointExporter() {
    12.         return new ServerEndpointExporter();
    13.     }
    14.  
    15. }

            2.3 接收实现类

    1. import org.springframework.stereotype.Component;
    2.  
    3. import javax.websocket.*;
    4. import javax.websocket.server.ServerEndpoint;
    5. import java.io.IOException;
    6. import java.util.concurrent.CopyOnWriteArraySet;
    7.  
    8. @Component
    9. @ServerEndpoint("/websocket/socket") //暴露的ws应用的路径
    10. public class WebSocket {
    11.     //concurrent包下线程安全的Set
    12.     private static final CopyOnWriteArraySet SESSIONS = new CopyOnWriteArraySet<>();
    13.     private Session session;
    14.  
    15.     @OnOpen
    16.     public void onOpen(Session session) {
    17.         this.session = session;
    18.         SESSIONS.add(this);
    19.         System.out.println(String.format("成功建立连接~ 当前总连接数为:%s", SESSIONS.size()));
    20.         System.out.println(this);
    21.     }
    22.  
    23.     @OnClose
    24.     public void onClose() {
    25.         SESSIONS.remove(this);
    26.         System.out.println(String.format("成功关闭连接~ 当前总连接数为:%s", SESSIONS.size()));
    27.     }
    28.  
    29.     @OnMessage
    30.     public void onMessage(String message, Session session) {
    31.         System.out.println(message);
    32.     }
    33.  
    34.     @OnError
    35.     public void onError(Session session, Throwable error) {
    36.         System.out.println("发生错误");
    37.         error.printStackTrace();
    38.     }
    39.  
    40.     /**
    41.      * 指定发消息
    42.      *
    43.      * @param message
    44.      */
    45.     public void sendMessage(String message) {
    46.         try {
    47.             this.session.getBasicRemote().sendText(message);
    48.         } catch (IOException e) {
    49.             e.printStackTrace();
    50.         }
    51.     }
    52.  
    53.     /**
    54.      * 群发消息
    55.      *
    56.      * @param message
    57.      */
    58.     public static void fanoutMessage(String message) {
    59.         SESSIONS.forEach(ws -> ws.sendMessage(message));
    60.     }
    61. }

     

     

  • 相关阅读:
    隐藏底部任务栏图标的方法
    MATLAB算法实战应用案例精讲-【图像处理】SLAM技术详解（应用篇）
    虚数是什么
    STM32开发（三十）STM32F103 数据手册 —— 模拟/数字转换 DAC 详解
    java酒店管理系统设计与实现计算机毕业设计MyBatis+系统+LW文档+源码+调试部署
    供应链和物流的自动化新时代
    JavaScript之void 0 === undefined
    RabbitMQ 延时消息实现方式
    #Powerbi 1分钟学会，利用AI，为powerbi报表进行高端颜色设计
    冥想第九百四十八天
  • 原文地址：https://blog.csdn.net/weixin_51722520/article/details/133377584