springboot 整合 rabbitMQ（1）

无论有没有异常，标准只有是否主动调用basicAck()、basicNack()等方法，没有调用则一直阻塞.

因此有异常时，(有重试就重试)，抛出异常后，没有调用时，还是会一直阻塞。即使是auto模式的那两个特殊的异常，在manual中都是一样的，不会有特殊处理.

官网对应模式介绍：RabbitMQ Tutorials | RabbitMQ

第四步：编写生产者和消费者

        这里写一个登录成功发送消息给登录人的业务（普通队列模式） 

• P：生产者，也就是要发送消息的程序
• C：消费者：消息的接受者，会一直等待消息到 

生产者：

1. String exchange（交换机名）：

   • 交换器的名称。交换器是一种逻辑实体，用于分发消息到相应的队列。你可以创建自定义的交换器类型，如 Direct、Fanout、Topic 或者 Headers 等。

2. String routingKey（队列名）：

   • 路由键。它是消息与队列之间的桥梁，决定了消息将被发送到哪个队列。路由键的值应匹配队列绑定到交换器时所使用的键。

3. Object message（消息对象）：

   • 要发送的消息对象。这个对象将被转换成字节流，然后发送到 RabbitMQ。Spring AMQP 使用 MessageConverter 将 Java 对象转换为 AMQP 格式的字节流。默认情况下，SimpleMessageConverter 可以处理简单的字符串、Java 序列化对象等。你可以通过配置 RabbitTemplate 的 messageConverter 属性来自定义消息转换器。

4. MessagePostProcessor messagePostProcessor：

   • 这是一个接口，用于在消息发送前对其进行进一步的修改。你可以在这个处理器中设置消息头、属性或其他特定信息。MessagePostProcessor 接口有一个方法 postProcessMessage(Message message)，你可以在这里修改消息实例。

5. CorrelationData correlationData：

   • 相关数据，主要用于跟踪消息的发送结果。在异步发送消息的情况下，你可以使用此参数来关联发送请求和响应。CorrelationData 包含一个唯一标识符，用于识别消息。当收到响应时，可以通过这个标识符找到原始请求。

        发邮件是发给一个人，所以这里只需要传一个队列名和登录人对象。（发送给多个队列时需            要用到交换机）

消费者：

//@Header从消息头中提取消息的递送标签，标签是唯一的，对应唯一的消息
@RabbitListener(queuesToDeclare = @Queue("login_queue"))
public void test01(User getUser, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long         deliveryTag)
{try {发送邮件的代码……//手动确认消息channel.basicAck(deliveryTag,true);} catch (MessagingException e) {throw new RuntimeException(e);} catch (IOException e) {throw new RuntimeException(e);}}

 如果配置了手工消费，一定要消费完后手动确认消息，不然就会重复接收该消息，导致后面的消息接受不到！