?一、客戶端設計

🍅 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方法
}