一、客户端设计

🍅 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中创建出一个channel

    public Channel createChannel(){
    // TODO
        return channel;
    }
//    关闭connection
   public 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;
    }


//    这个方法主要和服务器进行交互，
//    目的是为了告知服务器，此处客户端创建了新的channel
    public boolean createChannel() {
//        TODO
        return true;
    }


    //    使用该方法阻塞等待服务器的响应
    private BasicReturns waitResult(String rid) {
        return null;
    }

//    关闭channel,给服务器发送一个type == 0x2的请求
    public boolean close() throws IOException {
        //TODO
        return null;
    }


//创建核心的API方法
}