Spring Boot 实现 WebSocket 的代码示例
参考资料
The WebSocket Protocol（RFC 6455）
什么是 WebSocket ？
WebSocket协议提供了一种标准化的方法，通过单个TCP连接在客户机和服务器之间建立全双工、双向的通信通道。它是一种不同于HTTP的TCP协议，但被设计为在HTTP上工作，使用端口80和443，并允许重用现有的防火墙规则。
WebSocket 协议是独立的基于 TCP 协议。它与 HTTP 的唯一关系是，它的握手会被 HTTP 服务器解释为 Upgrade 请求。
使用“Upgrade: websocket”切换到 websocket 协议：
GET /spring-websocket-portfolio/portfolio HTTP/1.1 Host: localhost:8080 Upgrade: websocket Connection: Upgrade Sec-WebSocket-Key: Uc9l9TMkWGbHFD2qnFHltg== Sec-WebSocket-Protocol: v10.stomp, v11.stomp Sec-WebSocket-Version: 13 Origin: http://localhost:8080
websocket 服务器返回 “101”：
HTTP/1.1 101 Switching Protocols Upgrade: websocket Connection: Upgrade Sec-WebSocket-Accept: 1qVdfYHU9hPOl4JYYNXF623Gzn0= Sec-WebSocket-Protocol: v10.stomp
HTTP vs WebSocket
HTTP 中，应用会提供很多 URLs。客户端通过 请求-响应风格访问这些 URLs。服务器根据请求的 URL、方法、请求头路由这些请求到合适的处理。
WebSocket 初始化连接只使用1个 URL。之后，所有的消息使用相同的 TCP 连接。WebSocket 是一个低等级的协议，它没有规定消息内容的任何语义。这意味着，除非客户机和服务器在消息语义上达成一致，否则无法路由或处理消息。
WebSocket 客户端与服务器可以通过HTTP 握手请求的 Sec-WebSocket-Protocol 请求头商定更高级别的消息协议（像 STOMP）
什么时候使用 WebSocket？
WebSockets可以使网页具有动态和交互性。然而，在许多情况下，Ajax和HTTP流或长轮询的组合可以提供一个简单而有效的解决方案。
例如，新闻、邮件和社交源需要动态更新，但每隔几分钟更新一次可能完全没有问题。另一方面，协作、游戏和金融应用需要更接近实时。
代码示例
1. SpringBoot 使用原生 WebSocket
1.1 引入 spring-boot-starter-websocket jar
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
<version>2.6.7</version>
</dependency>1.2 编写 WebSocketHandler
通过以下方式实现 WebSocket 服务端：
实现 WebSocketHandler 接口继承 BinaryWebSocketHandler、TextWebSocketHandler 类
package org.spring.boot.websocket;
import java.nio.charset.StandardCharsets;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;
/**
* websocket 处理类：在请求信息的基础上加上“服务器返回：”，然后返回给客户端
* @author black
*
*/
public class EchoTextWebSocketHandler extends TextWebSocketHandler {
@Override
protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
// 收到的信息
String requestMsg = message.getPayload();
System.out.println("服务器收到：" + requestMsg );
// 组织响应信息
String responseMsg = "服务器返回: " + requestMsg;
System.out.println(responseMsg );
TextMessage respMsg = new TextMessage(responseMsg.getBytes(StandardCharsets.UTF_8));
// 返回给客户端
session.sendMessage( respMsg);
}
}1.3 编写 WebSocket 配置
package org.spring.boot.websocket;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistration;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
/**
* WebSocket 配置类
* @author black
*
*/
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
// 为指定的URL 配置具体的 WebSocketHandler
WebSocketHandlerRegistration registration = registry.addHandler(echoHandler(), "/echo");
// registration 能够对 WebSocketHandler 进行配置
}
@Bean
public WebSocketHandler echoHandler() {
return new EchoTextWebSocketHandler();
}
}1.4 启动类
package org.spring.boot.websocket;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* Spring boot 使用 websocket 代码示例
*
*/
@SpringBootApplication
public class SpringBootWebSocketBootstrap
{
public static void main( String[] args )
{
SpringApplication.run(SpringBootWebSocketBootstrap.class, args);
}
}应用默认端口为 8080 ，嵌入式容器是 tomcat。
1.5 测试
使用 Postman 进行 WebSocket 测试.
新建WebSocket 请求：
输入“localhost:8080”
点击【Connect】,下面显示:
展开 “Connected to localhost:8080/echo”,具体内容：
# Handshake Details Request URL: http://localhost:8080/echo Request Method: GET Status Code: 101 # Request Headers Sec-WebSocket-Version: 13 Sec-WebSocket-Key: 1bNYHBOf9wqNuy2WUOYIsQ== Connection: Upgrade Upgrade: websocket Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits Host: localhost:8080 # Response Headers Upgrade: websocket Connection: upgrade Sec-WebSocket-Accept: uh9IkfewEg11GuuAKnbXmpH+Yqo= Sec-WebSocket-Extensions: permessage-deflate;client_max_window_bits=15 Date: Sat, 30 Apr 2022 05:53:23 GMT
输入“hello, 我是 black!”
点击【Send】
上图可以看出消息是按倒序展示的。
最后点击url旁边的【Disconnect】按钮关闭连接：
验证结束。
到此这篇关于Spring Boot 实现 WebSocket 示例的文章就介绍到这了,更多相关Spring Boot WebSocket 示例内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
java Person,Student,GoodStudent 三个类的继承、构造函数的执行
这篇文章主要介绍了java Person,Student,GoodStudent 三个类的继承、构造函数的执行,需要的朋友可以参考下2017-02-02
这篇文章主要介绍了在CentOS上配置Java环境变量的教程,同时适用于Fedora等其他RedHat系的Linux系统,需要的朋友可以参考下2015-06-06
这篇文章主要介绍了Java基础之八大排序算法,文中有非常详细的代码示例,对正在学习java基础的小伙伴们有非常好的帮助,需要的朋友可以参考下2021-04-04
jsoup是一个非常好的解析网页的包，用java开发的，提供了类似DOM，CSS选择器的方式来查找和提取文档中的内容,提取文档内容时会出现超时的情况，解决方法可看下文2013-11-11
spring NamedContextFactory实现服务隔离的示例详解
假设我们有个场景,我们需要实现服务之间的数据隔离、配置隔离、依赖的spring bean之间隔离,大家会有什么实现思路？今天给大家介绍spring-cloud-context里面有个NamedContextFactory可以达到上面的效果,需要的朋友可以参考下2024-05-05
这篇文章主要介绍了如何解决Spring MVC中响应乱码问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2025-03-03
这篇文章主要介绍了maven+springboot打成jar包的方法,非常不错，具有一定的参考借鉴价值，需要的朋友可以参考下2018-10-10
IDEA mybatis Mapper.xml报红的最新解决办法
这篇文章主要介绍了IDEA mybatis Mapper.xml报红的解决办法,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2023-04-04
这篇文章主要介绍了Java中的Excel框架使用详解,Java解析、生成Excel比较有名的框架有Apache poi、jxl,但他们都存在一个严重的问题就是非常的耗内存,poi有一套SAX模式的API可以一定程度的解决一些内存溢出的问题,需要的朋友可以参考下2023-11-11
动态代理指的是，代理类和目标类的关系在程序运行的时候确定的，客户通过代理类来调用目标对象的方法，是在程序运行时根据需要动态的创建目标类的代理对象。本文将通过案例详细讲解一下Java动态代理的原理及实现，需要的可以参考一下2022-08-08
最新评论