SpringBoot 整合 WebSocket 实现长连接，将数据库中的数据进行推送

短命女 2024-04-03 08:05 52阅读 0赞

#### 目录 ####

*  什么是 WebSocket？
 *  为什么有了 HTTP 协议还要 WebSocket
 *  简单实现
 *   *  pom.xml
     *  WebSocket 核心配置
     *  添加 WebSocket 工具类
     *  实体类
     *  配置文件
     *  测试接口
 *  建立 WebSocket 连接
 *   *  index.html
 *  测试结果

## 什么是 WebSocket？ ##

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议。

WebSocket 通信协议于2011年被 IETF 定为标准 RFC 6455，并由 RFC7936 补充规范。WebSocket API 也被W3C定为标准。

**WebSocket 使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据**。**在WebSocket API 中，浏览器和服务器只需要完成一次握手，两者之间就直接可以创建持久性的连接，并进行双向数据传输**。

## 为什么有了 HTTP 协议还要 WebSocket ##

HTTP 协议采用的是客户端（浏览器）轮询的方式，即客户端发送请求，服务端做出响应，为了获取最新的数据，需要不断的轮询发出 HTTP 请求，占用大量带宽。

WebSocket 采用了一些特殊的报头，使得浏览器和服务器只需要通过「握手」建立一条连接通道后，此链接保持活跃状态，之后的客户端和服务器的通信都使用这个连接，解决了 Web 实时性的问题，相比于 HTTP 有以下好处：

1.  一个 Web 客户端只建立一个 TCP 连接
2.  WebSocket 服务端可以主动推送（push）数据到 Web 客户端
3.  有更加轻量级的头，减少了数据传输量

## 简单实现 ##

将下来我将使用一个简单的案例，使用 WebSocket 实现长连接，将数据库中的数据进行推送。

### pom.xml ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.7.3</version>
    		<relativePath/> 
    	</parent>
    	<groupId>com.example</groupId>
    	<artifactId>demo</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<name>demo</name>
    	<description>Demo project for Spring Boot</description>
    	<properties>
    		<java.version>1.8</java.version>
    	</properties>
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    			<optional>true</optional>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-websocket</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>fastjson</artifactId>
    			<version>1.2.79</version>
    		</dependency>
    
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>com.baomidou</groupId>
    			<artifactId>mybatis-plus-boot-starter</artifactId>
    			<version>3.4.3.4</version>
    		</dependency>
    
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    			<version>1.2.8</version>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    				<configuration>
    					<excludes>
    						<exclude>
    							<groupId>org.projectlombok</groupId>
    							<artifactId>lombok</artifactId>
    						</exclude>
    					</excludes>
    				</configuration>
    			</plugin>
    		</plugins>
    	</build>
    
    </project>

### WebSocket 核心配置 ###

@Configuration
    public class WebsocketConfiguration {
        
        @Bean
        public ServerEndpointExporter serverEndpointExporter() {
        
            return new ServerEndpointExporter();
        }
    }

### 添加 WebSocket 工具类 ###

@Component
    @ServerEndpoint(value = "/ws/asset")
    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);
        }
    
        @OnClose
        public void onClose() {
        
            webSocketSet.remove(this);
        }
    
        @OnMessage
        public void onMessage(String message) {
        
        }
    
        public void sendMessage(String message) {
        
            for (WebSocket webSocket : webSocketSet) {
        
                try {
        
                    webSocket.session.getBasicRemote().sendText(message);
                } catch (Exception e) {
        
                    e.printStackTrace();
                }
            }
        }
    }

### 实体类 ###

@Data
    @NoArgsConstructor
    @AllArgsConstructor
    @TableName("t_user")
    public class User {
        
        @TableId(value = "id",type = IdType.AUTO)
        private Long id;
        private String name;
        private String age;
    }

### 配置文件 ###

server:
      port: 8989
    
    spring:
      datasource:
        username: root
        password: root
        url: jdbc:mysql://127.0.0.1:3306/test?serverTimezone=GMT%2B8&userUnicode=true&characterEncoding=utf8
        driver-class-name: com.mysql.cj.jdbc.Driver
        type: com.alibaba.druid.pool.DruidDataSource

### 测试接口 ###

@RestController
    public class TestController {
        
    
        @Autowired
        private WebSocket webSocket;
        @Autowired
        private UserDao userDao;
    
        /**
         * http://localhost:8989/add?name=zhangsan&age=12
         * @param name
         * @param age
         */
        @GetMapping("add")
        public void add(String name,String age) {
        
            User user = new User();
            user.setName(name);
            user.setAge(age);
            userDao.insert(user);
            send();
        }
        
        /**
         * http://localhost:8989/delete?id=?
         * @param id
         */
        @GetMapping("delete")
        public void delete(String id) {
        
            userDao.deleteById(id);
            send();
        }
    
        @GetMapping("list")
        public void list() {
        
            send();
        }
    
        public void send() {
        
            List<User> users = userDao.selectList(new QueryWrapper<>());
            webSocket.sendMessage(JSON.toJSONString(users));
        }
    
    }

## 建立 WebSocket 连接 ##

前端页面直接使用「ws协议」建立连接

var socket = new WebSocket("ws://localhost:8989/ws/asset");

### index.html ###

<!DOCTYPE html>
    <html lang="en">
    <head>
        <meta charset="UTF-8">
        <title>展示数据</title>
        <script src="http://libs.baidu.com/jquery/2.0.0/jquery.min.js"></script>
        <style>
            #data_info {
          
                width: 100%;
                font-size: 16px;
                white-space: pre-wrap;
                word-wrap: break-word;
                background-color: white;
                border: 0px;
            }
    
            .string {
          
                color: green;
            }
    
            .number {
          
                color: darkorange;
            }
    
            .boolean {
          
                color: blue;
            }
    
            .null {
          
                color: magenta;
            }
    
            .key {
          
                color: red;
            }
    
    
        </style>
    </head>
    <body>
    <div class="col-sm-10 healthName" id="msg" style="height: 550px;overflow-x: auto;overflow-y: auto">
        <pre id="data_info"></pre>
    </div>
    <script>
    
    
    </script>
    <script type="text/javascript">
        var socket;
        if (typeof (WebSocket) == "undefined") {
          
            alert("出现错误")
        } else {
          
            socket = new WebSocket("ws://localhost:8989/ws/asset");
            socket.onopen = function () {
          
                console.log("Socket 已打开");
                socket.send("消息发送测试(From Client)");
            };
            socket.onmessage = function (msg) {
          
                $("#messageId").append(msg.data + "n");
                var show = document.getElementById('data_info');
                var msg = msg.data;
                var jsondata = {
          };
                jsondata = JSON.parse(msg);
                show.innerHTML = pretifyJson(jsondata, true);
    
                function pretifyJson(json, pretify = true) {
          
                    if (typeof json !== 'string') {
          
                        if (pretify) {
          
                            json = JSON.stringify(json, undefined, 4);
                        } else {
          
                            json = JSON.stringify(json);
                        }
                    }
                    return json.replace(/("(\\u[a-zA-Z0-9]{4}|\\[^u]|[^\\"])*"(\s*:)?|\b(true|false|null)\b|-?\d+(?:\.\d*)?(?:[eE][+\-]?\d+)?)/g,
                        function (match) {
          
                            let cls = "<span>";
                            if (/^"/.test(match)) {
          
                                if (/:$/.test(match)) {
          
                                    cls = "<span class='key'>";
                                } else {
          
                                    cls = "<span class='string'>";
                                }
                            } else if (/true|false/.test(match)) {
          
                                cls = "<span class='boolean'>";
                            } else if (/null/.test(match)) {
          
                                cls = "<span class='null'>";
                            }
                            return cls + match + "</span>";
                        }
                    );
                }
            };
            socket.onclose = function () {
          
            };
            socket.onerror = function () {
          
                alert("发生了错误");
            }
            window.unload = function () {
          
                socket.close();
            };
        }
    </script>
    
    </body>
    </html>

## 测试结果 ##

![在这里插入图片描述][d155c0cc24be4dc49851f567630e0186.png]  
![在这里插入图片描述][e5cad781a247426ab1fdaa08ca40635f.png]  
![在这里插入图片描述][5be3f9bb287840e1ad0ba9a8e261e296.png]

[d155c0cc24be4dc49851f567630e0186.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/be5909ffff9f4a5497bf309f1bc2d17f.png
[e5cad781a247426ab1fdaa08ca40635f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/235577fe174f4d019f5d9e804269baed.png
[5be3f9bb287840e1ad0ba9a8e261e296.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/213e13285e384b85b1d31434788208fe.png