檢測空閒非同步消費者

儘管非同步消費者效率很高，但一個問題是檢測它們何時處於空閒狀態——如果一段時間沒有訊息到達，使用者可能希望採取一些行動。

從版本 1.6 開始，現在可以配置監聽器容器，以便在一段時間沒有訊息傳遞時釋出 ListenerContainerIdleEvent。當容器空閒時，每隔 idleEventInterval 毫秒就會發佈一個事件。

要配置此功能，請在容器上設定 idleEventInterval。以下示例展示瞭如何在 XML 和 Java 中執行此操作（對於 SimpleMessageListenerContainer 和 SimpleRabbitListenerContainerFactory）：

<rabbit:listener-container connection-factory="connectionFactory"
        ...
        idle-event-interval="60000"
        ...
        >
    <rabbit:listener id="container1" queue-names="foo" ref="myListener" method="handle" />
</rabbit:listener-container>

@Bean
public SimpleMessageListenerContainer smlc(ConnectionFactory connectionFactory) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
    ...
    container.setIdleEventInterval(60000L);
    ...
    return container;
}

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(rabbitConnectionFactory());
    factory.setIdleEventInterval(60000L);
    ...
    return factory;
}

在這些情況下，當容器空閒時，每分鐘釋出一次事件。

事件消費

您可以透過實現 ApplicationListener 來捕獲空閒事件——可以是通用監聽器，也可以是專門接收此特定事件的監聽器。您還可以使用 Spring Framework 4.2 中引入的 @EventListener。

以下示例將 @RabbitListener 和 @EventListener 組合到一個類中。您需要了解應用程式監聽器會收到所有容器的事件，因此如果您想根據哪個容器空閒而採取特定操作，您可能需要檢查監聽器 ID。您還可以為此目的使用 @EventListener 的 condition 屬性。

事件有四個屬性

source: 監聽器容器例項
id: 監聽器 ID（或容器 bean 名稱）
idleTime: 事件釋出時容器已空閒的時間
queueNames: 容器監聽的佇列名稱

以下示例展示瞭如何使用 @RabbitListener 和 @EventListener 註解建立監聽器

public class Listener {

    @RabbitListener(id="someId", queues="#{queue.name}")
    public String listen(String foo) {
        return foo.toUpperCase();
    }

    @EventListener(condition = "event.listenerId == 'someId'")
    public void onApplicationEvent(ListenerContainerIdleEvent event) {
        ...
    }

}

事件監聽器會看到所有容器的事件。因此，在前面的示例中，我們根據監聽器 ID 縮小了接收到的事件範圍。

如果您希望使用空閒事件來停止監聽器容器，則不應在呼叫監聽器的執行緒上呼叫 container.stop()。這樣做總是會導致延遲和不必要的日誌訊息。相反，您應該將事件移交給另一個執行緒，然後該執行緒可以停止容器。