RabbitMQ是當前一個挺火的訊息佇列中介軟體 相比ActiveMQ 訊息更不容易丟失

我之前用的是ActiveMQ 後邊有的時候會莫名其妙的收不到訊息 專案緊後邊也沒時間排查 經朋友的推薦下 換了RabbitMQ 後邊用著也沒啥問題

今天 的RabbitMQ 突然就出了問題 生產者傳送訊息 消費者監聽不到 消費者重啟才能接收到 這樣的情況肯定不行 專案上線的話要是出現這種問題影響很大的

進入RabbitMQ的監控中心 登入 在queue裡邊找到自己的queue 進入 在裡邊可以看到訊息傳送情況

昨天我看了一下我的queue監控 Unacked是1以上 ready是1以上 ready好像是未消費訊息

網上查了一下 好像說訊息未確認 但是卻消費了訊息 這時候訊息堵塞 不知情況如何 先記錄一下

    <rabbit:listener-container  connection-factory="connectionFactory" acknowledge="auto">
        <rabbit:listener ref="searchListenner" queues="coursequeue" response-routing-key="coursequeue"/>
    </rabbit:listener-container>

查看了我的spring配置檔案 我當時的acknowledge為auto 接收到訊息後自動確認訊息 於是就在想 是不是確認不成功了
於是乎 在網上查了手動確認的資料

1.在rabbitmq整合spring的配置檔案中 把下述配置中的acknowledge改為manual

    <rabbit:listener-container  connection-factory="connectionFactory" acknowledge="manual">
        <rabbit:listener ref="searchListenner" queues="coursequeue" response-routing-key="coursequeue"/>
    </rabbit:listener-container
 
>

2.監聽器繼承ChannelAwareMessageListener 然後重寫onMessage 對訊息進行手動確認

@Component("searchListenner")
public class SearchListenner implements ChannelAwareMessageListener   {
    @Override
    public void onMessage(Message message, Channel channel) throws Exception {
        try {
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);//這個就是訊息確認的語句 再往下邊寫自己的邏輯就好
            System.out.println(message.getBody());
        } catch (Throwable e) {
            getLog().error(e.getMessage(), e);
        } 

    }
}

經過上邊的操作 問題解決