當Rabbit基礎結構存在時，可以使用`@RabbitListener`對任何bean進行注釋以創建偵聽器端點。 如果未定義`RabbitListenerContainerFactory`，則會自動配置默認的`SimpleRabbitListenerContainerFactory`，您可以使用`spring.rabbitmq.listener.type`屬性切換到直接容器。 如果定義了`MessageConverter`或`MessageRecoverer` bean，它將自動與默認工廠關聯。 以下示例組件在someQueue隊列上創建一個偵聽器端點： ~~~ @Component public class MyBean { @RabbitListener(queues = "someQueue") public void processMessage(String content) { // ... } } ~~~ 如果需要創建更多`RabbitListenerContainerFactory`實例，或者如果要覆蓋缺省值，Spring Boot提供了一個`SimpleRabbitListenerContainerFactoryConfigurer`和一個`DirectRabbitListenerContainerFactoryConfigurer`，您可以使用它來初始化`SimpleRabbitListenerContainerFactory`和`DirectRabbitListenerContainerFactory`，其設置與自動配置使用的工廠相同。 >您選擇的容器類型無關緊要。 這兩個bean通過自動配置公開。 > 例如，以下配置類公開了另一個使用特定`MessageConverter`的工廠： ~~~ @Configuration static class RabbitConfiguration { @Bean public SimpleRabbitListenerContainerFactory myFactory( SimpleRabbitListenerContainerFactoryConfigurer configurer) { SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory(); configurer.configure(factory, connectionFactory); factory.setMessageConverter(myMessageConverter()); return factory; } } ~~~ 然后，您可以在任何`@ RabbitListener`-annotated方法中使用工廠，如下所示： ~~~ @Component public class MyBean { @RabbitListener(queues = "someQueue", containerFactory="myFactory") public void processMessage(String content) { // ... } } ~~~ 您可以啟用重試來處理偵聽器拋出異常的情況。 默認情況下，使用`RejectAndDontRequeueRecoverer`，但您可以定義自己的`MessageRecoverer`。 當重試耗盡時，如果代理配置了這樣做，則拒絕該消息并將其丟棄或路由到死信交換。 默認情況下，禁用重試。 >默認情況下，如果禁用重試并且偵聽器拋出異常，則會無限期地重試傳遞。 您可以通過兩種方式修改此行為：將`defaultRequeueRejected`屬性設置為false，以便嘗試零重新傳遞或拋出`AmqpRejectAndDontRequeueException`以指示應拒絕該消息。 后者是啟用重試并且達到最大傳遞嘗試次數時使用的機制。