• RabbitMQ 模拟实现【五】:网络通信设计


    网络通信设计

    基于 TCP 自定义应用层协议

    在这里插入图片描述

    • Type 希望客户端能远程调用服务器的核心API,type就是描述调用哪一个API的
    • Length 表示接下来的Payload的长度
    • Payload 是真正需要用到的数据.
      Type表示请求响应不同功能,取值如下:
    • 0x1 创建channel
    • 0x2 关闭channel
    • 0x3 创建 exchange
    • 0x4 销毁 exchange
    • 0x5 创建 queue
    • 0x6 销毁 queue
    • 0x7 创建 binding
    • 0x8 销毁 binding
    • 0x9 发送 message
    • 0xa 订阅 message
    • 0xb 返回 ack(手动应答消息)
    • 0xc 服务器给客户端推送消息(自动推送消息的独有响应)

    channel参数

    • ⼀个客户端可以有多个模块。每个模块都可以和 brokerserver 之间建⽴”逻辑上的连接“ (channel)
      这⼏个模块的 channel 彼此之间是相互不影响的但是这⼏个 channel 复⽤了同⼀个 TCP 连接
    • channel 其实只是咱们逻辑上的一个信道, TCP 的连接是需要三次握手的,因此咱们为了尽量减少短时间多次发送请求时,用于建立 TCP 连接的资源消耗,故而咱们就建立一个逻辑上的信道,让这些信道去共享一个 TCP 连接,达到对这一个 TCP 连接的复用,从而减少多次建立 TCP 连接的资源消耗.
    • ExchangeDelcare 举例,服务器与客户端之间利用channel实现如下流程:
      在这里插入图片描述

    服务器实现

    消息队列本体服务器(本质上就是⼀个 TCP 的服务器)
    在这里插入图片描述

    客户端实现

    • Connection 类

      • 表示一个TCP连接
      • 该类持有 Socket对象
      • 管理多个 Channel 对象
      • 可以发送请求,读取响应(创建⼀个扫描线程,由这个线程负责不停地从 socket 中读取响应数据,把这个响应数据再交给对应的 channel 进⾏处理)
    • Channel 类

      • 表示一个逻辑上的连接
      • 提供⼀系列的⽅法,去和服务器提供的核⼼API对应
    • ConnectionFactory 类

      • ConnectionFactory类主要功能:创建出连接 Connection 对象
      • 该类实现:
    @Data
    public class ConnectionFactory {
    // brokerserver 的ip地址
    private String host;
    // brokerserver 的port
    private int port;
    public Connection newConnection() throws IOException {
    Connection connection = new Connection(host,port);
    return connection;
    }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
  • 相关阅读:
    ensp基础命令大全(华为设备命令)
    Python卡方分布
    快速搭建SpringBoot3.x项目
    如何建设一个用于编译 iOS App 的 macOS 云服务器集群?
    Flutter dio上传大文件时应用内存不足问题解决
    物联网协议MQTT
    LeetCode-754. 到达终点数字【数学】
    CICD 流程学习(四)搜素服务与消息队列
    find命令
    【C++】继承
  • 原文地址:https://blog.csdn.net/m0_65038072/article/details/136706796