spingboot中创建简单的WebSocket服务和使用OKHttp创建socket客户端接收数据

背景

springboot 中使用okhttp3创建webSocket服务端 server1 和客户端
client1,客户端clinet1调用server1用于发送图片,创建客户端client2接收此图片.

在Spring
Boot中使用OkHttp3创建WebSocket服务端和客户端,涉及到两个不同的操作:建立WebSocket服务端和创建WebSocket客户端。OkHttp3库主要用于客户端操作,因此对于服务端,我们将使用Spring的WebSocket支持。

步骤 1: 创建WebSocket服务端(Server1)

  1. 添加Spring WebSocket依赖

pom.xml中添加Spring Boot的WebSocket依赖:

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
  1. 配置WebSocket

创建一个配置类来启用WebSocket并注册一个endpoint:

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {@Overridepublic void registerStompEndpoints(StompEndpointRegistry registry) {registry.addEndpoint("/ws").setAllowedOrigins("*").withSockJS();}@Overridepublic void configureMessageBroker(MessageBrokerRegistry registry) {registry.enableSimpleBroker("/topic");registry.setApplicationDestinationPrefixes("/app");}
}
  1. 创建消息处理器

创建一个控制器来处理发送到服务端的消息:

import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Controller;@Controller
public class ImageMessageController {@MessageMapping("/receive-image")@SendTo("/topic/image")public byte[] receiveImage(byte[] imageData) {// 处理接收到的图片数据return imageData; // 将图片数据转发到订阅了 /topic/image 的客户端}
}

步骤 2: 创建WebSocket客户端(Client1)

  1. 添加OkHttp依赖

pom.xml中添加OkHttp3依赖:

<dependency><groupId>com.squareup.okhttp3</groupId><artifactId>okhttp</artifactId><version>4.9.0</version> <!-- 请使用最新版本 -->
</dependency>
  1. 创建WebSocket客户端

创建一个客户端来连接到WebSocket服务端并发送图片:

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.WebSocket;
import okhttp3.WebSocketListener;
import okio.ByteString;public class ImageWebSocketClient extends WebSocketListener {private final OkHttpClient client = new OkHttpClient();private WebSocket webSocket;public void connect(String url) {Request request = new Request.Builder().url(url).build();webSocket = client.newWebSocket(request, this);}public void sendImage(byte[] imageData) {if (webSocket != null) {webSocket.send(ByteString.of(imageData));}}@Overridepublic void onOpen(WebSocket webSocket, okhttp3.Response response) {super.onOpen(webSocket, response);// WebSocket连接成功建立}@Overridepublic void onMessage(WebSocket webSocket, ByteString bytes) {super.onMessage(webSocket, bytes);// 处理接收到的二进制消息}@Overridepublic void onClosed(WebSocket webSocket, int code, String reason) {super.onClosed(webSocket, code, reason);// 处理WebSocket关闭事件}@Overridepublic void onFailure(WebSocket webSocket, Throwable t, okhttp3.Response response) {super.onFailure(webSocket, t, response);// 处理WebSocket连接失败事件}public void close() {if (webSocket != null) {webSocket.close(1000, "End of session");}}
}

步骤 3: 创建另一个客户端(Client2)

创建另一个客户端来接收由Client1发送的图片:

public class ImageReceivingClient extends WebSocketListener {private final OkHttpClient client = new OkHttpClient();private WebSocket webSocket;public void connect(String url) {Request request = new Request.Builder().url(url).build();webSocket = client.newWebSocket(request, this);}@Overridepublic void onMessage(WebSocket webSocket, ByteString bytes) {super.onMessage(webSocket, bytes);// 处理接收到的图片数据byte[] imageData = bytes.toByteArray();// 可以在这里将图片数据保存到文件或进行其他处理}public void close() {if (webSocket != null) {webSocket.close(1000, "End of session");}}
}

步骤 4: 使用客户端

在你的服务中,使用上面创建的ImageWebSocketClientImageReceivingClient来发送和接收图片。

public class WebSocketService {public void sendImage(String url, byte[] imageData) {ImageWebSocketClient client = new ImageWebSocketClient();client.connect(url);client.sendImage(imageData);client.close();}public void receiveImage(String url) {ImageReceivingClient client = new ImageReceivingClient();client.connect(url);// 保持连接,直到需要断开}
}

注意事项

  • 确保WebSocket服务端和客户端使用相同的协议(ws://或wss://)。
  • 在生产环境中,确保使用wss://来加密WebSocket连接。
  • 处理WebSocket连接的异常和错误,确保应用的健壮性。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/879016.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Android使用Room后无法找到字符BR

一般来讲&#xff0c;无法找到BR字符多与Data Binding 相关。 在 Android Studio 中使用 Data Binding 时&#xff0c;如果突然出现 “BR 文件不可用” 或 “找不到符号 BR” 的错误&#xff0c;可能是由以下原因造成的&#xff1a; Data Binding 未启用&#xff1a;确保在你的…

MySQL:进阶巩固-SQL优化

目录 一、INSERT优化1.1 采用批量插入的方式1.2 采用手动提交的方式1.3 主键顺序插入1.4 大批量插入数据 二、主键优化三、ORDER BY 排序优化四、GROUP BY 分组优化五、LIMIT优化六、COUNT优化 一、INSERT优化 1.1 采用批量插入的方式 INSERT INTO tb_user values(1, zhangsa…

标题:深入理解 JavaScript 中的定时器

目录 一、定时器的基本概念 1. setInterval 2. setTimeout 二、代码示例分析 一、定时器的基本概念 在 JavaScript 中&#xff0c;定时器是一种用于在特定时间间隔后执行代码或者重复执行代码的机制。主要包含两种类型的定时器&#xff1a;setInterval和setTimeout。 1. …

K8S 发布应用

前言 昨儿个用 unbuntu20.04 又装了一次K8S 用的 kubeadm containerd Cilium (CNI) 又重新撸了一遍 这里只记录 应用发布的笔记 正文 #创建deployment kubectl create deployment nginx --imagenginx #我这边大约30秒后显示为 ready kubectl get deployments kubectl desc…

3GPP协议入门——物理层基础(一)

1. 频段/带宽 NR指定了两个频率范围&#xff0c;FR1&#xff1a;通常称Sub 6GHz&#xff0c;也称低频5G&#xff1b;FR2&#xff1a;通常称毫米波&#xff08;Millimeter Wave&#xff09;&#xff0c;也称高频5G。 2. 子载波间隔 NR中有15kHz&#xff0c;30kHz&#xff0c;6…

基于微信小程序的人才招聘系统的设计与实现

作者&#xff1a;计算机学姐 开发技术&#xff1a;SpringBoot、SSM、Vue、MySQL、JSP、ElementUI等&#xff0c;“文末源码”。 专栏推荐&#xff1a;前后端分离项目源码、SpringBoot项目源码、SSM项目源码 系统展示 基于微信小程序JavaSpringBootVueMySQL的人才招聘系统的设计…

Springboot整合websocket(附详细案例代码)

文章目录 WebSocket简述WebSocket是什么&#xff1f;WebSocket 的特点WebSocket 的工作流程WebSocket的消息(帧)格式WebSocket 与 HTTP springboot中整合WebSocketpom依赖实体类配置类握手配置类WebSocket配置类 自定义异常类webSocket服务类websocket中Session的 getBasicRemo…

【第25章】Spring Cloud之Sentinel控制台详解

文章目录 前言一、实时监控二、簇点链路三、流控规则四、熔断规则五、热点规则六、系统规则七、授权规则八、集群流控九、机器列表总结 前言 前面我们详细介绍了Sentinel控制台的安装过程&#xff0c;这里我们来了解各个菜单的功能作用。 一、实时监控 同一个服务下的所有机器…

chunk-vendors.js 文件过大导致页面加载缓慢解决方案

1、路由懒加载 在 Webpack 中&#xff0c;我们可以使用动态 import语法来定义代码分块点 (split point)&#xff1a; import(./Foo.vue) // 返回 Promise如果您使用的是 Babel&#xff0c;你将需要添加 syntax-dynamic-import 插件&#xff0c;才能使 Babel 可以正确地解析语…

Docker 安装配置 RocketMq (带代码和可视化界面) 一文搞定

Docker 安装配置 RocketMq 前言RocketMq拆解和分析前置内容1、NameServer2、Broker2、可视化界面SpringBoot RocketMq 实战(后续有需求再继续) 前言 本文着重于基于Docker 安装 RocketMq &#xff0c;默认是有 JAVA和 Docker 环境的&#xff0c;如无 基础&#xff08;java do…

启动spring boot项目时,第三方jar包扫描不到的问题

讲述一下遇到的问题&#xff1a; 在启动类Application上使用ComponentScan 这个注解来扫描第三方的包&#xff0c;然后就会出现报错。异常就是无法加载本地的bean&#xff0c;但是可以加载到第三方的bean&#xff1b; 了解过spring boot启动流程的都知道&#xff0c;Springboo…

局域网远程桌面工具:NoMachine 介绍、安装与使用

局域网远程桌面工具&#xff1a;NoMachine 介绍、安装与使用 NoMachine 简介Linux 安装Windows安装使用 NoMachine 简介 NoMachine是一款很常见的远程桌面工具&#xff0c;尤其在EDA领域&#xff0c;常常被用作远程接入方案。NoMachine可以用于个人远程连接&#xff0c;类似于…

决策树模型python代码实现

计算熵函数&#xff08;二元熵&#xff09; # UNQ_C1 # GRADED FUNCTION: compute_entropydef compute_entropy(y):"""Computes the entropy for Args:y (ndarray): Numpy array indicating whether each example at a node isedible (1) or poisonous (0)Retu…

计算机网络:http协议

计算机网络&#xff1a;http协议 一、本文内容与前置知识点1. 本文内容2. 前置知识点 二、HTTP协议工作简介1. 特点2. 传输时间分析3. http报文结构 三、HTTP版本迭代1. HTTP1.0和HTTP1.1主要区别2. HTTP1.1和HTTP2主要区别3. HTTPS与HTTP的主要区别 四、参考文献 一、本文内容…

Kafka【十三】消费者消费消息的偏移量

偏移量offset是消费者消费数据的一个非常重要的属性。默认情况下&#xff0c;消费者如果不指定消费主题数据的偏移量&#xff0c;那么消费者启动消费时&#xff0c;无论当前主题之前存储了多少历史数据&#xff0c;消费者只能从连接成功后当前主题最新的数据偏移位置读取&#…

【贪心算法】区间类算法题(整数替换、俄罗斯套娃、重构字符串等、C++)

文章目录 1. 前言2. 算法题1.整数替换2.俄罗斯套娃信封问题3.可被三整除的最大和4.距离相等的条形码5.重构字符串 1. 前言 贪心算法&#xff08;Greedy Algorithm&#xff09;是一种在每一步选择中都采取当前状态下最优决策的算法。贪心算法通常用来解决最优化问题&#xff0c…

anolis 8 安装部署spdk

SPDK的部署可以参考官方 https://github.com/spdk/spdk 有文档 这里记录一下&#xff0c;基于 Anolis OS release 8.6 kernel 5.10.134-13.an8.x86_64v 下的部署以及遇到的问题 使用 v22 版本 &#xff0c; 这里会git clone github项目&#xff0c;国内访问github会失败&…

Elasticsearch数据写入过程

1. 写入请求 当一个写入请求&#xff08;如 Index、Update 或 Delete 请求&#xff09;通过REST API发送到Elasticsearch时&#xff0c;通常包含一个文档的内容&#xff0c;以及该文档的索引和ID。 2. 请求路由 协调节点&#xff1a;首先&#xff0c;请求会到达一个协调节点…

大数据决策分析平台建设方案(可编辑的56页PPT)

引言&#xff1a;在当今信息爆炸的时代&#xff0c;大数据已成为企业决策制定、业务优化与市场洞察的重要驱动力。为了充分挖掘大数据的潜在价值&#xff0c;提升决策效率与精准度&#xff0c;构建一套高效、灵活、可扩展的大数据决策分析平台显得尤为重要。通过大数据分析平台…

C++ 中的 vector 容器详解与应用示例

vector 是 C 标准模板库&#xff08;STL&#xff09;中最常用的顺序容器之一。与数组相比&#xff0c;vector 具有动态大小调整、内存自动管理等特点&#xff0c;极大地方便了日常编程工作。本文将从 vector 的基本用法、常用操作、具体示例等方面进行详细介绍。 1. vector 简介…