消費者netty客戶端與nettyServer端MQ服務器端保持長連接，MQ服務器端保存
消費者連接。
生產者netty客戶端發送請求給nettyServer端MQ服務器端，MQ服務器端在將該
消息內容發送給消費者。

body:{“msg”:{“userId”:“123456”,“age”:“23”},“type”:“producer”，”topic”:””}

生產者投遞消息給MQ服務器端，MQ服務器端需要緩存該消息
如果mq服務器端宕機之后，消息如何保證不丟失

持久化機制
如果mq接收到生產者投遞消息，如果消費者不在的情況下，該消息是否會丟失？
不會丟失，消息確認機制 必須要消費者消費該消息成功之后，在通知給mq服務器端
刪除該消息。
Mq服務器端將該消息推送消費者：
消費者已經和mq服務器保持長連接。
消費者主動拉取消息：
消費者第一次剛啟動的時候

Mq如何實現抗高并發思想

Mq消費者根據自身能力情況 ，拉取mq服務器端消息消費。
默認的情況下是取出一條消息。

缺點：存在延遲的問題

需要考慮mq消費者提高速率的問題：

如何消費者提高速率：消費者實現集群、消費者批量獲取消息即可。
Maven依賴

<dependencies><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.62</version></dependency><dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.0.23.Final</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.62</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId><version>3.11</version></dependency> </dependencies>

總結

以上是生活随笔為你收集整理的如何基于netty实现mq 编程思路的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。