当前位置：首页 > news >正文

基于RabbitMQ的模拟消息队列之六——网络通信设计

news 2025/12/15 8:26:03

自定义基于TCP的应用层通信协议。实现客户端对服务器的远程调用
编写服务器及客户端代码

文章目录

基于TCP的自定义应用层协议
- 一、请求
- - 1.请求格式
  - 2.创建Request类
- 二、响应
- - 1.响应格式
  - 2.创建Response类
- 三、客户端-服务器交互
- 四、type
- 五、请求payload
- - 1.BasicAruguments(方法公共参数）
  - 2.每个方法的参数
  - - ExchangeDelareArguments
    - ExchangeDeleteArguments
    - QueueDeclareArguments
    - QueueDeleteArguments
    - QueueBindArguments
    - QueueUnbindArguments
    - BasicPublishArguments
    - BasicConsumeArguments
    - BasicAckArguments
- 六、响应payload
- - 1.BasicReturns(返回结果公共参数）
  - 2.SubscribeReturns
编写服务器代码
- - 一、创建BrokerServer
  - 二、初始化ServerSocket
  - 三、开启服务器
  - 四、停止服务器（便于测试）
  - 五、处理连接
  - - 1.读取请求并解析
    - 2.根据请求计算响应
    - 3.将响应返回给客户端
    - 4.清除有关断开连接的socket对应的会话信息
编写客户端代码
- 一、ConnectionFactory 连接工厂
- - 创建Connection对象
- 二、Connection 一次TCP连接
- - 1.Connection 属性
  - 2.初始化
  - 3.写入请求
  - 4.读取响应
  - 5.创建channel
  - 6.处理响应
  - 7.关闭连接
- 三、Channel 逻辑上的连接
- - 1.属性
  - 2.API（远程调用服务器的）
  - - 创建channel
    - 销毁channel
    - 创建交换机
    - 删除交换机
    - 创建队列
    - 删除队列
    - 创建绑定
    - 删除绑定
    - 发布消息
    - 订阅消息
    - 确认消息
  - 3.实现阻塞等待服务器的响应
  - - waitResult
    - putResult
编写Demo
- 1.生产者客户端
- 2.消费者客户端
- 测试
- - 1. 启动服务器
  - 2.启动生产者
  - 3.启动消费者

基于TCP的自定义应用层协议

一、请求

1.请求格式

在这里插入图片描述
type:哪个方法
length:payload的长度
payload：调用的方法的参数

2.创建Request类

在这里插入图片描述

二、响应

1.响应格式

在这里插入图片描述

type:哪个方法
length:payload的长度
payload：调用的方法的结果

2.创建Response类

在这里插入图片描述

三、客户端-服务器交互

在这里插入图片描述

四、type

0X1 创建channel
0X2 销毁channel
0X3 创建交换机 exchangeDeclare
0X4 删除交换机 exchangeDelete
0X5 创建队列 queueDeclare
0X6 删除队列 queueDelete
0X7 创建绑定 queueBind
0X8 删除绑定 queueUnbind
0X9 发布消息 basicPublish
0Xa 订阅消息 basicConsume
0xb 确认消息 basicAck
0xc 服务器给客户端推送消息（响应独有）

五、请求payload

1.BasicAruguments(方法公共参数）

rid（一次请求/响应）
channelId（一次逻辑上的连接）

2.每个方法的参数

需要继承BasicArguments

ExchangeDelareArguments

在这里插入图片描述

ExchangeDeleteArguments

在这里插入图片描述

QueueDeclareArguments

在这里插入图片描述

QueueDeleteArguments

在这里插入图片描述

QueueBindArguments

在这里插入图片描述

QueueUnbindArguments

在这里插入图片描述

BasicPublishArguments

在这里插入图片描述

BasicConsumeArguments

在这里插入图片描述

BasicAckArguments

在这里插入图片描述

以ExchangeDeclare方法为例，具体的请求格式如下：
在这里插入图片描述

六、响应payload

1.BasicReturns(返回结果公共参数）

rid （一次请求/响应）
channelId （一次逻辑上的连接）
ok （方法运行结果）

以exchangeDeclare为例，具体的响应格式：
在这里插入图片描述
其他的方法返回的响应payload都是BasicReturns序列化后的结果，除了0xc，是响应独有的。

2.SubscribeReturns

服务器通过Consumer接口实现推送消息给客户端（队列收到消息的时候会调用回调方法）

在这里插入图片描述
响应具体格式：

编写服务器代码

一、创建BrokerServer

在这里插入图片描述

二、初始化ServerSocket

给Serversocket初始化，监听一个端口
在这里插入图片描述

三、开启服务器

接受客户端的连接请求
线程池处理连接

在这里插入图片描述

四、停止服务器（便于测试）

runnable设置成false
抛弃线程池的所有任务
关闭ServerSocket服务器连接

在这里插入图片描述

五、处理连接

读取请求并解析
根据请求计算响应
将响应返回给客户端
关闭客户端连接
清除断开连接的socket的会话信息（channelId-socket）

在这里插入图片描述

1.读取请求并解析

在这里插入图片描述

2.根据请求计算响应

在这里插入图片描述

3.将响应返回给客户端

在这里插入图片描述

4.清除有关断开连接的socket对应的会话信息

在这里插入图片描述

编写客户端代码

一、ConnectionFactory 连接工厂

服务器地址
创建connecion对象

创建Connection对象

在这里插入图片描述

二、Connection 一次TCP连接

socket对象 socket=new socket(host,port)
多个channel 对象（创建channel对象）
写入请求
读取响应
处理响应

1.Connection 属性

在这里插入图片描述

2.初始化

在这里插入图片描述

3.写入请求

在这里插入图片描述

4.读取响应

在这里插入图片描述

5.创建channel

在这里插入图片描述

6.处理响应

此处在构造方法中，补充创建一个扫描线程，当连接未断开时，不停的扫描（读取）服务器返回的响应。处理响应。
如果是SubScirbleReturns,使用线程池执行消费者的回调。
如果是BasicReturns,将响应的basicReturns放入对应channel的basicReturnsMap中。

在这里插入图片描述

7.关闭连接

在这里插入图片描述

三、Channel 逻辑上的连接

对应API，实现客户端对服务器的远程调用

1.属性

在这里插入图片描述

2.API（远程调用服务器的）

构造请求
写入请求
阻塞等待服务器的响应结果

生成rid:
在这里插入图片描述

创建channel

在这里插入图片描述

销毁channel

在这里插入图片描述

创建交换机

在这里插入图片描述

删除交换机

在这里插入图片描述

创建队列

在这里插入图片描述

删除队列

在这里插入图片描述

创建绑定

在这里插入图片描述

删除绑定

在这里插入图片描述

发布消息

在这里插入图片描述

订阅消息

在这里插入图片描述

确认消息

在这里插入图片描述

3.实现阻塞等待服务器的响应

waitResult

根据rid,在basicReturnsMap集合中找;如果找到了，就返回，找不到阻塞等待。
在这里插入图片描述

putResult

将rid-basicReturns 放入basicReturnsMap集合中
在这里插入图片描述

编写Demo

实现消息队列生产者-消费者模型。

1.生产者客户端

在这里插入图片描述

2.消费者客户端

在这里插入图片描述

测试

1. 启动服务器

在这里插入图片描述

2.启动生产者

在这里插入图片描述

3.启动消费者

在这里插入图片描述

基于RabbitMQ的模拟消息队列之六——网络通信设计

自定义基于TCP的应用层通信协议。实现客户端对服务器的远程调用编写服务器及客户端代码文章目录基于TCP的自定义应用层协议一、请求1.请求格式2.创建Request类二、响应1.响应格式2.创建Response类三、客户端-服务器交互四、type五、请求payload1.BasicAruguments(方法公共…...

编程日记 2023/9/10 16:45:46

算法：数组中的最大差值---“打擂台法“

文章来源： https://blog.csdn.net/weixin_45630258/article/details/132737088 欢迎各位大佬指点、三连 1、题目： 给定一个整数数组 nums，找出给定数组中两个数字之间的最大差值。要求，第二个数字必须大于第一个数字。 2、分析特…...

编程日记 2023/9/10 16:44:42

三种方式查看 JVM 垃圾收集器

一、引言不同版本的 JVM 默认使用的垃圾收集器是不同的，目前的新生代和老年代的垃圾收集器如下图所示，新生代和老年代之间的连线表示这些垃圾收集器可以进行搭配使用垃圾收集器的名字和 JVM 里面的参数对照表如下，即在 JVM 里面并不是存储的…...

编程日记 2023/9/10 16:43:41

React中函数式组件与类组件有何不同？

Function Component 与 Class Component 有何不同目录 Function Component 与 Class Component 有何不同文章核心观点： 解释一下： 总结： 文章核心观点： Function components capture the rendered values.函数式组件捕获…...

编程日记 2023/9/10 16:42:40

windows11安装docker时，修改默认安装到C盘

1、修改默认安装到C盘 2、如果之前安装过docker，请删除如下目录：C:\Program Files\Docker 3、在D盘新建目录：D:\Program Files\Docker 4、winr，以管理员权限运行cmd 5、在cmd中执行如下命令，建立软联接： m…...

编程日记 2023/9/10 16:41:36

python模块之 aiomysql 异步mysql

mysql安装教程 mysql语法大全 python 模块pymysql模块，连接mysql数据库一、介绍 aiomysql 是一个基于 asyncio 的异步 MySQL 客户端库，用于在 Python 中与 MySQL 数据库进行交互。它提供了异步的数据库连接和查询操作，适用于异步编程环境 …...

编程日记 2023/9/10 16:40:34

开开心心带你学习MySQL数据库之第八篇

索引和事务 ~~ 数据库运行的原理知识面试题索引索引(index) > 目录索引存在的意义,就是为了加快查找速度!!(省略了遍历的过程) 查找速度是快了，但是付出了一定的代价!! 1.需要付出额外的空间代价来保存索引数据 2.索引可能会拖慢新增,删除,修改的速度 ~~ …...

编程日记 2023/9/10 16:39:33

yml配置动态数据源(数据库@DS)与引起(If you want an embedded database (H2, HSQL or Derby))类问题

1：yml 配置 spring:datasource:dynamic:datasource:master:url: jdbc:mysql://192.168.11.50:3306/dsdd?characterEncodingUTF-8&useUnicodetrue&useSSLfalse&tinyInt1isBitfalse&allowPublicKeyRetrievaltrue&serverTimezoneUTCusername: ro…...

编程日记 2023/9/10 16:37:30

yolov5运行过程遇到的小问题（随时更新）

1.关于git的问题解决办法：插入下面代码 import os os.environ["GIT_PYTHON_REFRESH"] "quiet"2.页面太小无法完成操作解决办法: 如果不好使再考虑降低Batch_Size大小或者调整虚拟内存可用硬盘空间大小！（调整虚拟内存…...

编程日记 2023/9/10 16:36:29

使用FabricJS创建Image对象的JSON表示

本篇文章介绍一下如何创建图像的 JSON 表示形式使用 FabricJS 的对象。我们可以通过创建一个实例来创建一个 Image 对象织物.图像。由于它是FabricJS的基本元素之一，我们也可以轻松地通过应用角度、不透明度等属性来自定义它。为了创建 JSON Image 对象的表示&am…...

编程日记 2023/9/10 16:35:28

【牛客刷题】反转固定区间链表、每k个节点一组反转

链表内指定区间反转_牛客题霸_牛客网 ListNode* reverseList(ListNode* head, ListNode* tail) {ListNode* pre nullptr;ListNode* cur head;while (cur ! tail) { 最后cur就是tailListNode* temp cur->next;cur->next pre;pre cur;cur temp;}return pre;}ListNode…...

编程日记 2023/9/10 16:34:28

算法：数组常见套路1---双指针、取模、打擂台法

文章来源： https://blog.csdn.net/weixin_45630258/article/details/132738318 欢迎各位大佬指点、三连一、数组的合并–双指针[快慢指针] 1、题目： 给你两个按非递减顺序排列的整数数组 nums1 和 nums2，另有两个整数 m 和 n &#xff0…...

编程日记 2023/9/10 16:33:26

App 出海实践：Google Play 结算系统

作者：业志陈现如今，App 出海热度不减，是很多公司和个人开发者选择的一个市场方向。App 为了实现盈利，除了接入广告这种最常见的变现方式外，就是通过提供各类虚拟商品或者是会员服务来吸引用户付费了，此时 …...

编程日记 2023/9/10 16:32:25

国际慈善日 | 追寻大爱无疆，拓世科技集团的公益之路

每年的9月5日，是联合国大会正式选定的国际慈善日。这一天的设立，旨在通过提高公众对慈善活动的意识，鼓励慈善公益活动通过各种形式在全球范围内得到增强和发展。这是一个向慈善公益事业致敬的日子，同时也是呼吁全球团结一致共同发…...

编程日记 2023/9/10 16:31:24

关于DNS的一些认识

目录什么是DNS？ 一台具有单个DNS的机器可以拥有多个地址吗？ 一台计算机可以有多个属于不同顶级域的DNS名字吗？ 什么是DNS？ DNS是域名系统（Domain Name System）的缩写，它是互联网中用于将域名…...

编程日记 2023/9/10 16:30:23

游戏性能优化

Unity性能优化主要包括以下方面： 1.渲染性能。包括减少Draw Calls、减少三角面数、使用LOD、使用批处理技术、减少实时光源等，以提高游戏的帧率和渲染效率。 2.内存性能。包括使用对象池、使用合适的纹理、使用异步加载资源等，以减少内存占…...

编程日记 2023/9/10 16:29:22

公开游戏、基于有向图的游戏

目录〇，背景一，公开游戏、策梅洛定理 1，公开游戏 2，策梅洛定理二，有向图游戏 1，狭义有向图游戏 2，广义有向图游戏 3，狭义有向图游戏的SG数 4，Bash Game 力扣…...

编程日记 2023/9/10 16:28:19

CSS学习笔记05

CSS笔记05 定位 position CSS 属性position - 用于指定一个元素在文档中的定位方式。top，right，bottom 和 left 属性则决定了该元素的最终位置。position 有以下常用的属性值： position: static; - 默认值。指定元素使用正常的布局行为&am…...

编程日记 2023/9/10 16:27:18

Linux查看指定端口是否被占用

在Linux中，可以使用多种方法来检查一个特定端口（例如3306，通常由MySQL使用）是否被占用： 使用netstat命令: 如果系统中已安装了netstat，可以使用以下命令检查3306端口： netstat -tuln | grep 330…...

编程日记 2023/9/10 16:26:17

【Python 自动化】小说推文一键生成思路概述

最近看了一下小说推文成品软件的思路，发现可以完全迁移到我的 BookerAutoVideo 上面来。这篇短文里面，我试着分析一下整个推文视频生成的流程，以及简要阐述一下有什么工具。整体流程是这样： 分句原文是按照段落组织的&#xf…...

编程日记 2023/9/10 16:25:15

生成xcframework

打包 XCFramework 的方法 XCFramework 是苹果推出的一种多平台二进制分发格式，可以包含多个架构和平台的代码。打包 XCFramework 通常用于分发库或框架。使用 Xcode 命令行工具打包通过 xcodebuild 命令可以打包 XCFramework。确保项目已经配置好需要支持的平台…...

编程新知 2025/10/5 2:30:38

工业安全零事故的智能守护者：一体化AI智能安防平台

前言： 通过AI视觉技术，为船厂提供全面的安全监控解决方案，涵盖交通违规检测、起重机轨道安全、非法入侵检测、盗窃防范、安全规范执行监控等多个方面，能够实现对应负责人反馈机制，并最终实现数据的统计报表。提升船厂…...

编程新知 2025/12/14 7:46:59

高频面试之3Zookeeper

高频面试之3Zookeeper 文章目录高频面试之3Zookeeper3.1 常用命令3.2 选举机制3.3 Zookeeper符合法则中哪两个？3.4 Zookeeper脑裂3.5 Zookeeper用来干嘛了 3.1 常用命令 ls、get、create、delete、deleteall3.2 选举机制半数机制（过半机制&#xff0…...

编程新知 2025/12/13 16:17:43

Qwen3-Embedding-0.6B深度解析：多语言语义检索的轻量级利器

第一章引言：语义表示的新时代挑战与Qwen3的破局之路 1.1 文本嵌入的核心价值与技术演进在人工智能领域，文本嵌入技术如同连接自然语言与机器理解的“神经突触”——它将人类语言转化为计算机可计算的语义向量，支撑着搜索引擎、推荐系统、…...

编程新知 2025/11/6 8:47:31

全面解析各类VPN技术：GRE、IPsec、L2TP、SSL与MPLS VPN对比

目录引言 VPN技术概述 GRE VPN 3.1 GRE封装结构 3.2 GRE的应用场景 GRE over IPsec 4.1 GRE over IPsec封装结构 4.2 为什么使用GRE over IPsec？ IPsec VPN 5.1 IPsec传输模式（Transport Mode） 5.2 IPsec隧道模式（Tunne…...

编程新知 2025/11/3 0:44:41

selenium学习实战【Python爬虫】

selenium学习实战【Python爬虫】文章目录 selenium学习实战【Python爬虫】一、声明二、学习目标三、安装依赖3.1 安装selenium库3.2 安装浏览器驱动3.2.1 查看Edge版本3.2.2 驱动安装四、代码讲解4.1 配置浏览器4.2 加载更多4.3 寻找内容4.4 完整代码五、报告文件爬取5.1 提…...

编程新知 2025/12/13 10:57:35

如何在网页里填写 PDF 表格？

有时候，你可能希望用户能在你的网站上填写 PDF 表单。然而，这件事并不简单，因为 PDF 并不是一种原生的网页格式。虽然浏览器可以显示 PDF 文件，但原生并不支持编辑或填写它们。更糟的是，如果你想收集表单数据&#xff…...

编程新知 2025/12/9 12:17:40

听写流程自动化实践，轻量级教育辅助

随着智能教育工具的发展，越来越多的传统学习方式正在被数字化、自动化所优化。听写作为语文、英语等学科中重要的基础训练形式，也迎来了更高效的解决方案。这是一款轻量但功能强大的听写辅助工具。它是基于本地词库与可选在线语音引擎构建，…...

编程新知 2025/12/10 2:13:51

Yolov8 目标检测蒸馏学习记录

yolov8系列模型蒸馏基本流程，代码下载：这里本人提交了一个demo:djdll/Yolov8_Distillation: Yolov8轻量化_蒸馏代码实现在轻量化模型设计中，**知识蒸馏（Knowledge Distillation）**被广泛应用，作为提升模型…...

编程新知 2025/12/14 3:26:26

文章目录

基于TCP的自定义应用层协议

一、请求

1.请求格式

2.创建Request类

二、响应

1.响应格式

2.创建Response类

三、客户端-服务器交互

四、type

五、请求payload

1.BasicAruguments(方法公共参数）

2.每个方法的参数

ExchangeDelareArguments

ExchangeDeleteArguments

QueueDeclareArguments

QueueDeleteArguments

QueueBindArguments

QueueUnbindArguments

BasicPublishArguments

BasicConsumeArguments

BasicAckArguments

六、响应payload

1.BasicReturns(返回结果公共参数）

2.SubscribeReturns

编写服务器代码

一、创建BrokerServer

二、初始化ServerSocket

三、开启服务器

四、停止服务器（便于测试）

五、处理连接

1.读取请求并解析

2.根据请求计算响应

3.将响应返回给客户端

4.清除有关断开连接的socket对应的会话信息

编写客户端代码

一、ConnectionFactory 连接工厂

创建Connection对象

二、Connection 一次TCP连接

1.Connection 属性

2.初始化

3.写入请求

4.读取响应

5.创建channel

6.处理响应

7.关闭连接

三、Channel 逻辑上的连接

1.属性

2.API（远程调用服务器的）

创建channel

销毁channel

创建交换机

删除交换机

创建队列

删除队列

创建绑定

删除绑定

发布消息

订阅消息

确认消息

3.实现阻塞等待服务器的响应

waitResult

putResult

编写Demo

1.生产者客户端

2.消费者客户端

测试

1. 启动服务器

2.启动生产者

3.启动消费者

相关文章：