SpringBoot中使用RabbitMQ消息队列——路由、通配符、订阅模式 这篇文章中已经整合了rabbitmq。
1.rabbitmq 默认交换机
代码语言：javascript复制//创建队列
@Bean
public Queue defaultQueue() {
return new Queue("default_queue");
}
//发送消息
amqpTemplate.convertAndSend("default_queue","hello default");
//接收
@RabbitListener(queues = "default_queue")
public void defaultQueue(String string) {
log.info("【监听到消息】" string);
}以上方式未创建exchange，说明rabbitmq 默认交换机是direct exchange.
2.监听消费
同样使用上面的默认交换机，使用两个监听
代码语言：javascript复制 @RabbitListener(queues = "default_queue")
public void defaultQueue(String string) {
log.info("【监听到消息】" string);
}
@RabbitListener(queues = "default_queue")
public void defaultQueue2(String string) {
log.info("【监听到消息2】" string);
}
//结果
【sendFanout已发送消息】
【监听到消息2】hello default
【sendFanout已发送消息】
【监听到消息】hello default两个监听器轮流监听,topic exchange 测试也是一样轮流监听
3.发送消息到队列，未监听消费
如图，未监听消息还在队列中。 Ready:就绪状态，处于队列中说明没有被监听 Unacked: 已被监听，但未确认消费，断开后变成Ready状态
默认是自动消费，监听启动后会将该消息消费掉。
4.手动确认消费ACK
rabbitmq 默认是自动消费，改为手动确认。 1）配置文件
代码语言：javascript复制# none意味着没有任何的应答会被发送。manual意味着监听者必须通过调用Channel.basicAck()来告知所有的消息。
# auto意味着容器会自动应答，除非MessageListener抛出异常，这是默认配置方式。
spring.rabbitmq.listener.simple.acknowledge-mode=manual2）监听
代码语言：javascript复制 @RabbitListener(queues = RabbitMQConfig.FANOUT_QUEUE2)
public void receiveTopic2(String string, Message message, Channel channel) throws IOException {
channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
log.info("【receiveTopic2监听到消息】" string);
}5.声明MessageQueue
在Rabbit MQ中，无论是生产者发送消息还是消费者接受消息，都首先需要声明一个MessageQueue。这就存在一个问题，是生产者声明还是消费者声明呢？要解决这个问题，首先需要明确：
a)消费者是无法订阅或者获取不存在的MessageQueue中信息。
b)消息被Exchange接受以后，如果没有匹配的Queue，则会被丢弃。
在明白了上述两点以后，就容易理解如果是消费者去声明Queue，就有可能会出现在声明Queue之前，生产者已发送的消息被丢弃的隐患。如果应用能够通过消息重发的机制允许消息丢失，则使用此方案没有任何问题。但是如果不能接受该方案，这就需要无论是生产者还是消费者，在发送或者接受消息前，都需要去尝试建立消息队列。这里有一点需要明确，如果客户端尝试建立一个已经存在的消息队列，Rabbit MQ不会做任何事情，并返回客户端建立成功的。
