32.2.3 接收消息

当Rabbit设施出现时，所有bean都可以注解@RabbitListener来创建一个监听器端点。如果没有定义RabbitListenerContainerFactory，Spring Boot将自动配置一个默认的SimpleRabbitListenerContainerFactory。你可以使用spring.rabbitmq.listener.type属性，转换到一个直接的容器。如果定义MessageConverter 或者MessageRecoverer bean，它将自动关联到默认的factory。

下面的组件创建一个someQueue队列上的监听器端点：

@Component
public class MyBean {

    @RabbitListener(queues = "someQueue")
    public void processMessage(String content) {
        // ...
    }

}

注 具体参考@EnableRabbit的Javadoc。

如果需要创建多个RabbitListenerContainerFactory实例，或想覆盖默认实例，你可以使用Spring Boot提供的SimpleRabbitListenerContainerFactoryConfigurer和DirectRabbitListenerContainerFactoryConfigurer，通过它们可以使用跟自动配置实例相同的配置初始化SimpleRabbitListenerContainerFactory。

提示 使用哪个容器无关紧要，自动配置将会暴露那两个bean。

例如，下面使用一个特殊的MessageConverter配置类创建了另一个factory：

@Configuration
static class RabbitConfiguration {

    @Bean
    public SimpleRabbitListenerContainerFactory myFactory(
            SimpleRabbitListenerContainerFactoryConfigurer configurer) {
        SimpleRabbitListenerContainerFactory factory =
                new SimpleRabbitListenerContainerFactory();
        configurer.configure(factory, connectionFactory);
        factory.setMessageConverter(myMessageConverter());
        return factory;
    }

}

然后，你可以像下面那样在所有@RabbitListener注解方法中使用：

@Component
public class MyBean {

    @RabbitListener(queues = "someQueue", containerFactory="myFactory")
    public void processMessage(String content) {
        // ...
    }

}

你可以启动重试处理那些监听器抛出异常的情况。默认地，RejectAndDontRequeueRecoverer被使用，但是你可以定义一个你自己的MessageRecoverer。当重试次数达到限制时，该消息将被拒绝，要不被丢弃，要不路由到一个dead-letter交换器，如果broker这样配置的话，默认禁用重试。

重要 默认的，如果禁用了重试，且监听器抛出异常，则Rabbit会无限期地进行重试。你可以采用两种方式修改该行为：设置defaultRequeueRejected属性为false，这样就不会重试，或者抛出一个AmqpRejectAndDontRequeueException异常表示该消息应该被拒绝。后面这个是开启重试，且达到最大重试次数时使用的策略。