面試官：同一個消費(fèi)組內(nèi)的消費(fèi)者，如果訂閱了相同的 topic，但是訂閱的 tag 不一樣，會有什么問題嗎？

我：會出現(xiàn)丟消息的情況。

面試官：能詳細(xì)說一說嗎？

我：RocketMQ 要求同一個消費(fèi)組內(nèi)的消費(fèi)者必須訂閱關(guān)系一致，如果訂閱關(guān)系不一致，會出現(xiàn)消息丟失的問題。

面試官：什么是訂閱關(guān)系一致呢？

我：訂閱關(guān)系一致是指同一個消費(fèi)者組下所有消費(fèi)者所訂閱的 Topic、Tag 必須完全一致。如下圖所示：

其中，消費(fèi)組 1 中的消費(fèi)組都訂閱了 Topic1 中的 Tag1，消費(fèi)組 2 中的消費(fèi)組都訂閱了 Topic1 中的所有 Tag 以及 Topic2 中的 Tag1 || Tag2，消費(fèi)組 3 中的消費(fèi)組都訂閱了 Topic2 中的 Tag1 和 Tag2。

面試官：能舉幾個訂閱關(guān)系不一致的例子嗎？

我：訂閱不一致的情況有三種，如下圖：

• 消費(fèi)組 1 的 Consumer1 和 Consumer2 都訂閱了 Topic1，但是訂閱的 Tag 不一致。

• 消費(fèi)組 2 的 Consumer1 和 Consumer2 訂閱的 Topic 不一致。

• 消費(fèi)組 3 的 Consumer1 和 Consumer2 訂閱的 Topic 和 Tag 都一致，但是訂閱 Tag 的順序不一致。

面試官：為什么訂閱關(guān)系不一致會導(dǎo)致消息丟失呢？

我：RocketMQ 的存儲架構(gòu)，如下圖：

為了 提高消費(fèi)效率，RocketMQ 引入了 ConsumeQueue，ConsumerQueue 中保存消息在 CommitLog 文件中的物理偏移量。ConsumerQueue 中的元素內(nèi)容如下：

• 前 8 個字節(jié)記錄消息在 CommitLog 中的偏移量。

• 中間 4 個字節(jié)記錄消息消息大小。

• 最后 8 個字節(jié)記錄消息中 tag 的 hashcode。

這個 tag 的作用是過濾消息，假如一個 Consumer 訂閱了 Topic1 中的 Tag1，那這個 Consumer ?拉取消息時，首先從 Name Server 獲取訂閱關(guān)系，得到當(dāng)前 Consumer 訂閱的所有 tag 的 hashcode 集合 codeSet。每次從 ConsumerQueue 獲取一條記錄，就要判斷最后 8 個字節(jié) tag hashcode 是否在 codeSet 中，比如 Tag2 不在 codeSet 中，就會被過濾掉。如下圖：

消費(fèi)組 1 消費(fèi) Topic1 中的消息時，Consumer1 通過 ConsumeQueue1 和 ConsumeQueue2 進(jìn)行消費(fèi)，Consumer2 通過 ConsumeQueue3 和 ConsumeQueue4 進(jìn)行消費(fèi)，如果 Consumer1 訂閱了 Tag1， ? ?Consumer2 訂閱了 Tag2，那 Consumer1 從 ConsumeQueue1 和 ConsumeQueue2 消費(fèi)消息時，就會把 Tag2 中的消息過濾掉，這樣即使 Consumer2 訂閱了 Tag2，也不能消費(fèi)到 ConsumeQueue1 和 ConsumeQueue2 里 Tag2 中的消息了。

面試官:有沒有方法可以快速知道消費(fèi)組中有沒有訂閱關(guān)系不一致的問題？

我：可以在 RocketMQ 的控制臺看到。在 RocketMQ 的實(shí)例列表中，進(jìn)入 Group 管理頁面，查看要查找的 Group ID，查看詳情，如下圖：(下圖來自阿里云)

面試官：恭喜你，通過了。

有道無術(shù)，術(shù)可成；有術(shù)無道，止于術(shù)

歡迎大家關(guān)注Java之道公眾號

好文章，我在看??

總結(jié)

以上是生活随笔為你收集整理的阿里二面：RocketMQ同一个消费组内的消费者订阅量不同tag，会有问题吗？的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。