一、客户端设计

🍅 1、设计三个核心类

🍅 2、完善Connection类

🎄 读取请求和响应、创建channel

🎄 添加扫描线程

🎄 处理不同的响应

🎄 关闭连接

🍅 3、完善Channel类

🎄 编写createChannel()

🎄 编写waitResult(）和putRetuens()方法

🎄 编写其他核心API

🎊 交换机

🎊 队列

🎊 绑定

🎊发布消息

🎊 订阅消息

🎊 确认消息

二、客户端测试

🍅 1、准备工作和收尾工作

🍅 2、测试connection

🍅 3、测试channnel的创建

🍅 4、测试交换机

🍅 5、测试队列

🍅 6、测试绑定

一、客户端设计

🍅 1、设计三个核心类

三个核心类：

（1）ConnectoonFactory连接工厂：这个类，持有服务器的地址，主要功能是创建出连接Connectiond对象

（2）Connection：表示一个TCP连接，持有Socket对象，写入请求/读取响应，管理多个Channel对象

（3）Channel：表示一个逻辑上的连接。当前设定的交互模型，一个TCP连接是可以进行复用的，一个客户端可以有多个模块，每个模块都可以和brokerServer之间建立“逻辑上的连接”（channel）,但是这几个模块的channel之间是互相不影响的。同时还需要提供一系列的方法，与服务器提供的核心API进行对应。

先创建这三个核心的类

在包mqclient中创建这三个类。

@Data
public class ConnectionFactory {
//    BrokerServer的ip地址private String host;
//    BrokerServer端口号private int port;public Connection newConnection(){Connection connection = new Connection(host,port);return connection;}
}

@Data
public class Connection {private Socket socket = null;//    需要管理多个channel，使用哈希表把若干个channel组织起来private ConcurrentHashMap<String ,Channel> channelMap = new ConcurrentHashMap<>();private InputStream inputStream;private OutputStream outputStream;private DataInputStream dataInputStream;private DataOutputStream dataOutputStream;private ExecutorService callbackPool = null;public Connection(String host,int port) throws IOException {socket = new Socket(host,port);inputStream = socket.getInputStream();outputStream = socket.getOutputStream();dataInputStream = new DataInputStream(inputStream);dataOutputStream = new DataOutputStream(outputStream);}//    使用该方法分别处理，当前响应是一个针对控制请求的响应，还是服务器推送的响应private void dispatchResponse(Response response) throws IOException, ClassNotFoundException, MqException {//TODO}//    发送请求public void writeRequest(Request request) throws IOException {
//        TODO}//    读取响应public Response readResponse() throws IOException {
//        TODO}//    通过这个方法,再connection中创建出一个channelpublic Channel createChannel(){// TODOreturn channel;}
//    关闭connectionpublic void close() {//TODO}
}

@Data
public class Channel {private String channelId;
//    当前channel属于哪个连接private Connection connection;
//    用来存储后续客户端收到的服务器的响应private ConcurrentHashMap<String, BasicReturns> basicReturnsMap = new ConcurrentHashMap<>();
//    如果当前的Channel订阅了某个队列，此处就需要记录对应的回调是什么
//    当该队列的消息返回回来的时候，就调用回调
//    约定一个channel值能有一个回调private Consumer consumer = null;public Channel(String channelId, Connection connection) {this.channelId = channelId;this.connection = connection;}//    这个方法主要和服务器进行交互，
//    目的是为了告知服务器，此处客户端创建了新的channelpublic boolean createChannel() {
//        TODOreturn true;}//    使用该方法阻塞等待服务器的响应private BasicReturns waitResult(String rid) {return null;}//    关闭channel,给服务器发送一个type == 0x2的请求public boolean close() throws IOException {//TODOreturn null;}//创建核心的API方法
}