目录

交换器、队列、绑定的声明
关于消息序列化
同一个队列多消费类型
注解将消息和消息头注入消费者方法
关于消费者确认
关于发送者确认模式
消费消息、死信队列和RetryTemplate
RPC模式的消息（不常用）
关于消费模型
关于RabbitMq客户端的线程模型

在公司里一直在用RabbitMQ，由于api已经封装的很简单，关于RabbitMQ本身还有封装的实现没有了解，最近在看RabbitMQ实战这本书，结合网上的一些例子和spring文档，实现了RabbitMQ和spring的集成，对着自己平时的疑惑做了一些总结。

交换器、队列、绑定的声明
SpringAMQP项目对RabbitMQ做了很好的封装，可以很方便的手动声明队列，交换器，绑定。如下：

/**
 * 队列
 * @return
 */
@Bean
@Qualifier(RabbitMQConstant.PROGRAMMATICALLY_QUEUE)
Queue queue() {
    return new Queue(RabbitMQConstant.PROGRAMMATICALLY_QUEUE, false, false, true);
}

/**
 * 交换器
 * @return
 */
@Bean
@Qualifier(RabbitMQConstant.PROGRAMMATICALLY_EXCHANGE)
TopicExchange exchange() {
    return new TopicExchange(RabbitMQConstant.PROGRAMMATICALLY_EXCHANGE, false, true);
}
/**
 * 声明绑定关系
 * @return
 */
@Bean
Binding binding(@Qualifier(RabbitMQConstant.PROGRAMMATICALLY_EXCHANGE) TopicExchange exchange,
                @Qualifier(RabbitMQConstant.PROGRAMMATICALLY_QUEUE) Queue queue) {
    return BindingBuilder.bind(queue).to(exchange).with(RabbitMQConstant.PROGRAMMATICALLY_KEY);
}

/**
 * 声明简单的消费者，接收到的都是原始的{@link Message}
 *
 * @param connectionFactory
 *
 * @return
 */
@Bean
SimpleMessageListenerContainer simpleContainer(ConnectionFactory connectionFactory) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setMessageListener(message -> log.info("simple receiver,message:{}", message));
    container.setQueueNames(RabbitMQConstant.PROGRAMMATICALLY_QUEUE);
    return container;
}

消费者和生产者都可以声明，交换器这种一般经常创建，可以手动创建。需要注意对于没有路由到队列的消息会被丢弃。

如果是Spring的话还需要声明连接：