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

文章目录

• 网络通信设计
• • 基于 TCP 自定义应用层协议
  • channel参数
  • 服务器实现
  • 客户端实现

    网络通信设计

    基于 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;
                  }
                  }