Spring5高级编程------Spring-WebSocket实现在客户端和服务器之间发送消息的全双工单套接字连接

2023-10-30 03:18
文章标签 java 实现 连接 spring 编程 客户端 websocket 高级 消息 发送 ------ 接字 spring5 服务器之间 全双工 单套

本文主要是介绍Spring5高级编程------Spring-WebSocket实现在客户端和服务器之间发送消息的全双工单套接字连接，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Spring-WebSocket

  • 一、WebSocket介绍
  • 二、Spring中使用WebSocket
  • 三、使用WebSocket API
    • 1、下面是WebSocket API的组件Maven引入方式
    • 2、下面是用于测试通信的前端单页面
    • 3、基与java全注解方式配置WebSocket
  • 四、基于stomp协议的WebSocket配置
    • 1、JavaConfig方式的配置
    • 2、使用到的实体类、控制器、拦截器
    • 3、前端测试代码
  • 五、两个配置类的详细介绍
    • 1、WebSocketConfigurer
    • 2、WebSocketMessageBrokerConfigurer

一、WebSocket介绍

WebSocket是作为HTML5计划的一部分而开发的一种规范，可以实现在客户端和服务器之间发送消息的全双工单套接字连接。过去，需要实现更新功能的Web应用程序会通过打开多个连接或是使用长轮询来定期轮询服务器端组件以获取更新数据。WebSocket的单套接字能够避免每个客户端需要多个连接并减少开销。
WebSocket

二、Spring中使用WebSocket

从版本4.0开始，Spring框架开始支持WebSocket样式的消息传递以及STOMP作为应用程序级别的子协议。在框架内，可以在spring-websocket模块中找到对WebSocket的支持，该模块与JSR-356兼容。需要注意的是不是所有浏览器都支持WebSocket协议，为了处理这种情况，Spring通过SockJS协议提供了透明的后被选项（根据浏览器的真实情况自动决定使用匹配的协议）。
Spring-WebSocket

三、使用WebSocket API

1、下面是WebSocket API的组件Maven引入方式

注意：SpringMVC项目依赖的其他组件不再这里列出

<dependency><groupId>org.springframework</groupId><artifactId>spring-websocket</artifactId><version>5.2.6.RELEASE</version>
</dependency>
<dependency><groupId>org.springframework</groupId><artifactId>spring-messaging</artifactId><version>5.2.6.RELEASE</version>
</dependency>

2、下面是用于测试通信的前端单页面

<!DOCTYPE html>
<html>
<head>
<title>WebSocket Tester</title>
<script type="text/javascript"src="https://cdn.staticfile.org/jquery/1.10.2/jquery.min.js"></script>
<script type="text/javascript">var ping;var websocket;jQuery(function($) {function writePing(message) {$('#pingOutput').append(message + '\n');}function writeStatus(message) {$('#statusOutput').val($("#statusOutput").val() + message + '\n');}function writeMessage(message) {$('#messageOutput').append(message + '\n');}$('#connect').click(function doConnect() {websocket = new WebSocket($("#target").val());websocket.onopen = function(evt) {writeStatus("CONNECTED");var ping = setInterval(function() {if (websocket != "undefined") {websocket.send("ping");}}, 3000);};websocket.onclose = function(evt) {writeStatus("DISCONNECTED");};websocket.onmessage = function(evt) {if (evt.data === "ping") {writePing(evt.data);} else {writeMessage('ECHO: ' + evt.data);}};websocket.onerror = function(evt) {onError(writeStatus('ERROR: ' + evt.data))};});$('#disconnect').click(function() {if (typeof websocket != 'undefined') {websocket.close();websocket = undefined;} else {alert("Not connected.");}});$('#send').click(function() {if (typeof websocket != 'undefined') {websocket.send($('#message').val());} else {alert("Not connected.");}});});
</script></head>
<body><h2>WebSocket Tester</h2>Target:<input id="target" size="40"value="ws://127.0.0.1:8081/wholesmart-springmvc-web/echoHandler"><br><button id="connect">Connect</button><button id="disconnect">Disconnect</button><br><br>Message:<input id="message" value=""><button id="send">Send</button><br><p>Status output:</p><pre><textarea id="statusOutput" rows="10" cols="50"></textarea></pre><p>Message output:</p><pre><textarea id="messageOutput" rows="10" cols="50"></textarea></pre><p>Ping output:</p><pre><textarea id="pingOutput" rows="10" cols="50"></textarea></pre>
</body>
</html>

3、基与java全注解方式配置WebSocket

package com.wholesmart.core.config;import org.springframework.context.annotation.Bean;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
import org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;
import com.wholesmart.websocket.EchoHandler;/*** WebSocket配置类，因为我的项目是在主配置类中使用@Import()注解引入该配置类，所以这个类上没有使用@Configuration注解。* * @author dyw* @date 2020年6月23日*/
@EnableWebSocket
public class WebSocketConfiguration implements WebSocketConfigurer {/*** 使用HttpSessionHandshakeInterceptor设置setAllowedOrigins，否则会报403*/@Overridepublic void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {registry.addHandler(echoHandler(), "/echoHandler").addInterceptors(new HttpSessionHandshakeInterceptor()).setAllowedOrigins("*");}@Beanpublic EchoHandler echoHandler() {return new EchoHandler();}
}

package com.wholesmart.websocket;import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;/*** 消息处理器* * @author dyw* @date 2020年6月23日*/
public class EchoHandler extends TextWebSocketHandler {@Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {session.sendMessage(new TextMessage(message.getPayload()));System.out.println(new TextMessage(message.getPayload()));}
}

四、基于stomp协议的WebSocket配置

1、JavaConfig方式的配置

package com.wholesmart.config;import java.util.List;import org.springframework.context.annotation.Bean;
import org.springframework.messaging.converter.MessageConverter;
import org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver;
import org.springframework.messaging.handler.invocation.HandlerMethodReturnValueHandler;
import org.springframework.messaging.simp.config.ChannelRegistration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.SockJsServiceRegistration;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.StompWebSocketEndpointRegistration;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketTransportRegistration;
import org.springframework.web.socket.messaging.StompSubProtocolErrorHandler;
import org.springframework.web.socket.server.HandshakeInterceptor;
import com.wholesmart.websocket.UserHandshakeInterceptor;/*** 为WebSocket客户端定义简单的传输协议配置方法，通常需要配合使用@EnableWebSocketMessageBroker注解开启相应功能* * @author dyw* @date 2020年6月30日*/
@EnableWebSocketMessageBroker
public class WebSocketStompConfiguration implements WebSocketMessageBrokerConfigurer {/*** 有关处理来自客户端的消息和发送到客户端的消息的配置选项*/@Overridepublic void configureWebSocketTransport(WebSocketTransportRegistration registry) {}/*** 注册STOMP端点(可以是多个)，并将端点映射到特定的URL上，并（可选）启用和配置SockJS回退选项。* 这里的配置主要用于构建WebSocketHandlerMapping* * <pre>* 这里的配置项有两种类型：* 1、{@code StompEndpointRegistry} 接口定义的配置* 2、{@code StompWebSocketEndpointRegistration} 接口定义的配置* 3、{@code SockJsServiceRegistration} 接口定义的配置* </pre>*/@Overridepublic void registerStompEndpoints(StompEndpointRegistry registry) {/** 从WebMvcStompEndpointRegistry.getHandlerMapping()方法中可以看出，* WebSocketHandlerMapping优先使用我们这里配置的UrlPathHelper，如果我们这里没有配置这个值，* WebSocketHandlerMapping会使用在其父类AbstractHandlerMapping中创建的UrlPathHelper。*/registry.setUrlPathHelper(null);/** 设置STOMP所使用的HandlerMapping的优先级，默认值为1*/registry.setOrder(1);/** 自定义一个处理客户端错误帧的处理器，* 这里的StompSubProtocolErrorHandler会被设置到WebMvcStompEndpointRegistry类持有的StompSubProtocolHandler对象中*/registry.setErrorHandler(stompSubProtocolErrorHandler());/** websocket的端点，客户端需要注册这个端点进行链接*/StompWebSocketEndpointRegistration stompWebSocketEndpointRegistration = registry.addEndpoint("/stomp/ws");/** 配置允许的浏览器Origin Header的值，这个配置主要是针对浏览器设计的。HTTP 协议中的 Origin Header* 存在于请求中，用于指明当前请求来自于哪个站点。默认空表示只支持同源请求，“*”表示支持所有站点请求，其他以“http://”、“https://”* 表示支持特定站点的请求。*/stompWebSocketEndpointRegistration.setAllowedOrigins("*");/** 没有设置时默认使用DefaultHandshakeHandler*/stompWebSocketEndpointRegistration.setHandshakeHandler(null);/** OriginHandshakeInterceptor为默认拦截器，用于验证* OriginHeader,这里的配置只是多添加一个拦截器，不会覆盖掉默认拦截器。*/stompWebSocketEndpointRegistration.addInterceptors(userHandshakeInterceptor());/** SockJsServiceRegistration为返回值，可以配置SockJS*/SockJsServiceRegistration sockJsServiceRegistration = stompWebSocketEndpointRegistration.withSockJS();/** */sockJsServiceRegistration.setHttpMessageCacheSize(100);}@Beanpublic HandshakeInterceptor userHandshakeInterceptor() {return new UserHandshakeInterceptor();}@Beanpublic StompSubProtocolErrorHandler stompSubProtocolErrorHandler() {return new StompSubProtocolErrorHandler();}/*** 消息中介的相关配置*/@Overridepublic void configureMessageBroker(MessageBrokerRegistry config) {// 客户端订阅消息的基础路径config.setApplicationDestinationPrefixes("/app");// 服务器广播消息的基础路径config.enableSimpleBroker("/topic");}/*** 配置消息转换器，以便在从带注解的方法上提取消息和发送消息时使用。返回的boolean值类型用于确定是否还要添加默认转换器。*/@Overridepublic boolean configureMessageConverters(List<MessageConverter> messageConverters) {return true;}/*** 客户端消息传入通道的相关配置。默认情况下，通道由大小为1的线程池支持。建议生产环境设置合适的自定义线程池配置。*/@Overridepublic void configureClientInboundChannel(ChannelRegistration registration) {WebSocketMessageBrokerConfigurer.super.configureClientInboundChannel(registration);}/*** 客户端消息传出通道的相关配置。默认情况下，通道由大小为1的线程池支持。建议生产环境设置合适的自定义线程池配置。*/@Overridepublic void configureClientOutboundChannel(ChannelRegistration registration) {WebSocketMessageBrokerConfigurer.super.configureClientOutboundChannel(registration);}/*** 添加解析器以支持自定义控制器方法参数类型。不会修改内置方法参数解析器，如果需要修改内置方法参数解析器，直接配置SimpAnnotationMethodMessageHandler*/@Overridepublic void addArgumentResolvers(List<HandlerMethodArgumentResolver> argumentResolvers) {WebSocketMessageBrokerConfigurer.super.addArgumentResolvers(argumentResolvers);}/*** 添加处理程序以支持自定义控制器方法返回值类型。内置处理器的修改直接配置SimpAnnotationMethodMessageHandler*/@Overridepublic void addReturnValueHandlers(List<HandlerMethodReturnValueHandler> returnValueHandlers) {WebSocketMessageBrokerConfigurer.super.addReturnValueHandlers(returnValueHandlers);}}

2、使用到的实体类、控制器、拦截器

package com.wholesmart.websocket.stomp;import java.io.Serializable;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;public class Stock implements Serializable {private static final long serialVersionUID = 7704093854068084650L;private static final String DATE_FORMAT = "yyyy-MM-dd HH:mm:ss";private String code;private double price;private Date date;private String formatDate;public Stock() {}public Stock(String code, double price) {DateFormat dateFormat = new SimpleDateFormat(DATE_FORMAT);date = new Date();formatDate = dateFormat.format(date);this.code = code;this.price = price;}public String getCode() {return code;}public void setCode(String code) {this.code = code;}public double getPrice() {return price;}public void setPrice(double price) {this.price = price;}public Date getDate() {return date;}public void setDate(Date date) {DateFormat dateFormat = new SimpleDateFormat(DATE_FORMAT);formatDate = dateFormat.format(date);this.date = date;}public String getFormatDate() {return formatDate;}public void setFormatDate(String formatDate) {this.formatDate = formatDate;}public static String getDateFormat() {return DATE_FORMAT;}@Overridepublic String toString() {return "Stock [code=" + code + ", price=" + price + "]";}}
package com.wholesmart.web;import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Random;
import javax.annotation.PostConstruct;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.stereotype.Controller;import com.wholesmart.websocket.stomp.Stock;@Controller
public class StockController {private TaskScheduler taskScheduler;private SimpMessagingTemplate simpMessagingTemplate;private List<Stock> stocks = new ArrayList<Stock>();private Random random = new Random(System.currentTimeMillis());public StockController() {stocks.add(new Stock("VMW", 1.00D));stocks.add(new Stock("EMC", 1.00D));stocks.add(new Stock("GOOD", 1.00D));stocks.add(new Stock("IBM", 1.00D));}@MessageMapping("/addStock")public void addStock(Stock stock) {stocks.add(stock);}@Autowiredpublic void setTaskScheduler(TaskScheduler taskScheduler) {this.taskScheduler = taskScheduler;}@Autowiredpublic void setSimpMessagingTemplate(SimpMessagingTemplate simpMessagingTemplate) {this.simpMessagingTemplate = simpMessagingTemplate;}private void broadcastUpdatePrices() {System.out.println("currentThread==" + Thread.currentThread().getName());System.out.println("Stocks  SIZE=======" + stocks.size());for (Stock stock : stocks) {System.out.println("stock===" + stock);stock.setPrice(stock.getPrice() + (getUpdatedStockPrice() * stock.getPrice()));stock.setDate(new Date());}simpMessagingTemplate.convertAndSend("/topic/price", stocks);}private double getUpdatedStockPrice() {double priceChange = random.nextDouble() * 5.0;if (random.nextInt(2) == 1) {priceChange = -priceChange;}return priceChange / 100.0;}@PostConstructprivate void broadcastTimePeriodically() {taskScheduler.scheduleAtFixedRate(() -> {broadcastUpdatePrices();}, 6000);}
}
package com.wholesmart.websocket;import java.util.Map;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.server.HandshakeInterceptor;/*** 自定义WebSocket握手拦截器* * @author dyw* @data 2020年7月2日*/
public class UserHandshakeInterceptor implements HandshakeInterceptor {@Overridepublic boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,Map<String, Object> attributes) throws Exception {System.out.println("UserHandshakeInterceptor.beforeHandshake()");return true;}@Overridepublic void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,Exception exception) {System.out.println("UserHandshakeInterceptor.afterHandshake()");}}

3、前端测试代码

<!DOCTYPE html>
<html>
<head>
<title>WebSocket Tester</title>
<script type="text/javascript"src="https://cdn.staticfile.org/jquery/1.10.2/jquery.min.js"></script>
<script type="text/javascript"src="https://cdn.jsdelivr.net/sockjs/0.3.4/sockjs.min.js"></script>
<script type="text/javascript"src="https://cdn.bootcdn.net/ajax/libs/stomp.js/2.3.2/stomp.min.js"></script>
<script type="text/javascript">var stomp = Stomp.over(new SockJS("/wholesmart-springmvc-web/stomp/ws"));function displayStockPrice(frame) {var prices = JSON.parse(frame.body);$('#price').empty();console.log(prices);for ( var i in prices) {var price = prices[i];$('#price').append($('<tr>').append($('<td>').html(price.code),$('<td>').html(price.price.toFixed(2)),$('<td>').html(price.formatDate)));}}var connectCallback = function() {stomp.subscribe('/topic/price', displayStockPrice);}var errorCallback = function(error) {alert(error.headers.message);}stomp.connect("guest", "guest", connectCallback, errorCallback);$(document).ready(function() {$('.addStockButton').click(function(e) {e.preventDefault();var jsonstr = JSON.stringify({'code' : $('.code').val(),'price' : Number($('.price').val())});stomp.send("/app/addStock", {}, jsonstr);return false;});});
</script></head>
<body><h1><b>Stock Ticker</b></h1><table border="1"><thead><tr><th>Code</th><th>Price</th><th>Time</th></tr></thead><tbody id="price"></tbody></table><p class="addStock">Code:<input class="code" /><br> Price:<input class="price" /><br><button class="addStockButton">And Stock</button></p>
</body>
</html>

五、两个配置类的详细介绍

1、WebSocketConfigurer

2、WebSocketMessageBrokerConfigurer

大家可以试图做各种理性分析，但最终回避不了这样的事实：人是一个个愚昧的、情绪化的个体，我们在有生之涯不知所措，用有限的视野辨识光明，凭着本能在惊恐中寻找猎物和栖息处。

这篇关于Spring5高级编程------Spring-WebSocket实现在客户端和服务器之间发送消息的全双工单套接字连接的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/305241。

相关文章

windos server2022里的DFS配置的实现

windos server2022里的DFS配置的实现

《windosserver2022里的DFS配置的实现》DFS是WindowsServer操作系统提供的一种功能,用于在多台服务器上集中管理共享文件夹和文件的分布式存储解决方案,本文就来介绍一下wi... 目录什么是DFS？优势：应用场景：DFS配置步骤什么是DFS？DFS指的是分布式文件系统（Distr
阅读更多...
NFS实现多服务器文件的共享的方法步骤

NFS实现多服务器文件的共享的方法步骤

《NFS实现多服务器文件的共享的方法步骤》NFS允许网络中的计算机之间共享资源,客户端可以透明地读写远端NFS服务器上的文件,本文就来介绍一下NFS实现多服务器文件的共享的方法步骤,感兴趣的可以了解一... 目录一、简介二、部署1、准备1、服务端和客户端：安装nfs-utils2、服务端：创建共享目录3、服
阅读更多...
SpringBoot使用Apache Tika检测敏感信息

SpringBoot使用Apache Tika检测敏感信息

《SpringBoot使用ApacheTika检测敏感信息》ApacheTika是一个功能强大的内容分析工具,它能够从多种文件格式中提取文本、元数据以及其他结构化信息,下面我们来看看如何使用Ap... 目录Tika 主要特性1. 多格式支持2. 自动文件类型检测3. 文本和元数据提取4. 支持 OCR（光学
阅读更多...
Java内存泄漏问题的排查、优化与最佳实践

Java内存泄漏问题的排查、优化与最佳实践

《Java内存泄漏问题的排查、优化与最佳实践》在Java开发中,内存泄漏是一个常见且令人头疼的问题,内存泄漏指的是程序在运行过程中,已经不再使用的对象没有被及时释放,从而导致内存占用不断增加,最终... 目录引言1. 什么是内存泄漏？常见的内存泄漏情况2. 如何排查 Java 中的内存泄漏？2.1 使用 J
阅读更多...
JAVA系统中Spring Boot应用程序的配置文件application.yml使用详解

JAVA系统中Spring Boot应用程序的配置文件application.yml使用详解

《JAVA系统中SpringBoot应用程序的配置文件application.yml使用详解》：本文主要介绍JAVA系统中SpringBoot应用程序的配置文件application.yml的... 目录文件路径文件内容解释1. Server 配置2. Spring 配置3. Logging 配置4. Ma
阅读更多...
Java 字符数组转字符串的常用方法

Java 字符数组转字符串的常用方法

《Java字符数组转字符串的常用方法》文章总结了在Java中将字符数组转换为字符串的几种常用方法,包括使用String构造函数、String.valueOf()方法、StringBuilder以及A... 目录1. 使用String构造函数1.1 基本转换方法1.2 注意事项2. 使用String.valu
阅读更多...
C#使用yield关键字实现提升迭代性能与效率

C#使用yield关键字实现提升迭代性能与效率

《C#使用yield关键字实现提升迭代性能与效率》yield关键字在C#中简化了数据迭代的方式,实现了按需生成数据,自动维护迭代状态,本文主要来聊聊如何使用yield关键字实现提升迭代性能与效率,感兴... 目录前言传统迭代和yield迭代方式对比yield延迟加载按需获取数据yield break显式示迭
阅读更多...
Python实现高效地读写大型文件

Python实现高效地读写大型文件

《Python实现高效地读写大型文件》Python如何读写的是大型文件,有没有什么方法来提高效率呢,这篇文章就来和大家聊聊如何在Python中高效地读写大型文件,需要的可以了解下... 目录一、逐行读取大型文件二、分块读取大型文件三、使用 mmap 模块进行内存映射文件操作（适用于大文件）四、使用 pand
阅读更多...
python实现pdf转word和excel的示例代码

python实现pdf转word和excel的示例代码

《python实现pdf转word和excel的示例代码》本文主要介绍了python实现pdf转word和excel的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价... 目录一、引言二、python编程1，PDF转Word2，PDF转Excel三、前端页面效果展示总结一
阅读更多...
java脚本使用不同版本jdk的说明介绍

java脚本使用不同版本jdk的说明介绍

《java脚本使用不同版本jdk的说明介绍》本文介绍了在Java中执行JavaScript脚本的几种方式,包括使用ScriptEngine、Nashorn和GraalVM,ScriptEngine适用... 目录Java脚本使用不同版本jdk的说明1.使用ScriptEngine执行javascript2.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2