1. 程式人生 > >關於rocketmq不能消費的問題

關於rocketmq不能消費的問題

專案使用了訊息中介軟體rocketmq,用於兩個關聯專案之間的通訊,

先前消費者一直是可以消費的,突然有一天消費者消費不到資料了,

解決過程mark一下,

1,懷疑是不是生產者出問題了,沒有生產資料。

和生產者那邊聯絡了一下,那邊回覆說一直有生產資料的,排除

2,懷疑是不是什麼配置有問題,導致不能消費。

仔細檢查了下,消費者組、topic、tag、地址、埠和生產者那邊溝通了一下,發現這些東西也都沒問題。排除

3,沒辦法,找管理要了生產環境的rocketmq的控制檯看了下。


檢視消費詳情的時候發現了問題,訊息都被另外一個伺服器上的消費者消費了(有三個平臺釋出的是相同的程式碼,但不是叢集的)。當時就感到有點懵,因為為了防止訊息被其他伺服器上的消費者消費,我特意作了判斷,讓其他伺服器上的消費者訂閱其他的消費者組,沒想到即使訂閱了其他的消費者組,因為topic和tag沒變,它還是能消費生產者生產的資料。所以只能最後加一個環境變數將其他伺服器上的消費者關閉了。