dataOutput Stream.flush

先补充一下什么是tcp TCP（Transmission Control Protocol）是一种面向连接的、可靠的、基于字节流的传输层通信协议。它是互联网协议套件（TCP/IP）中的一部分，用于在网络中的计算机之间进行可靠的数据传输。 以下是 TCP 的一些主要特点和概念： 面向连接： 在使用 TCP 进行通信时，通信的两端需要先建立连接，然后才能进行数据的传输。连接建立后，双方可以通过这个连接进行数据的可靠传输。 可靠性： TCP 提供可靠的数据传输，确保数据的完整性和顺序性。它使用确认和重传机制来检测丢失的数据包并进行重传，以确保数据的可靠性。 全双工通信： TCP 支持全双工通信，允许双方在同一时间既能发送数据也能接收数据。这使得双方可以同时进行双向的交互。 流控制： TCP 使用流控制机制来防止发送方发送过多的数据导致接收方无法处理。通过通告窗口大小，TCP 可以动态调整发送方的发送速率。 拥塞控制： TCP 通过拥塞控制机制来避免网络拥塞。通过调整发送速率和使用慢启动等算法，TCP 可以适应网络的变化，并减少拥塞的发生。 面向字节流： TCP...

目录 需求分析 RabbitMQ 客户端设定 一个客户端可以有多个模块 每个模块均可以和 Broker Server 之间建立 "逻辑上的连接"（channel） 这几个模块的 channel 彼此之间是相互不影响的 同时这几个 channel 复用了同一个 TCP 连接 此处我们将仿照 RabbitMQ 客户端设定 ConnectionFactory（连接工厂） 这个类持有服务器的地址 该类用于创建 Connection 对象 具体代码编写： import lombok.Getter; import lombok.Setter; import java.io.IOException; @Getter @Setter public class ConnectionFactory { // broker server 的 ip 地址 private String host; // broker server 的端口号 private int port; public Connection newConnection() throws IOException { Connection...

目录 一、客户端代码实现 RabbitMQ 的客户端设定：一个客户端可以有多个模块，每个模块都可以和 broker server 之间建立 “逻辑上的连接” （channel），这几个模块的channel 彼此之间是互相不影响的，同时这几个 channel 又复用的同一个 TCP 连接，省去了频繁 建立/销毁 TCP 连接的开销（三次握手、四次挥手......）. 这里，我们也按照这样的逻辑实现 消息队列 的客户端，主要涉及到以下三个核心类： ConnectionFactory：连接工厂，这个类持有服务器的地址，主要功能就是创建 Connection 对象. Connection：表示一个 TCP连接，持有 Socket 对象，用来 写入请求/读取响应，管理多个Channel 对象. Channel：表示一个逻辑上的连接，需要提供一系列的方法，去和服务器提供的核心 API 对应（客户端提供的这些方法的内部，就是写入了一个特定的请求，然后等待服务器响应）. 1）实现 ConnectionFactory 主要用来创建 Connection 对象.