2. 消息队列基础：RabbitMQ核心概念、消息队列在微服务中的作用、消息持久化与确认机制

2.1 RabbitMQ 核心概念

RabbitMQ 是一个基于 AMQP 0-9-1 协议的开源消息代理，在微服务架构中扮演异步通信中枢的角色。理解其核心模型是掌握消息队列的基础。

2.2 消息队列在微服务中的作用

在微服务架构中，服务间同步调用（HTTP/REST）会引入紧耦合、雪崩效应和响应延迟等问题。消息队列通过异步解耦、流量削峰和最终一致性保障，成为微服务通信的核心基础设施。

• 异步解耦：生产者无需等待消费者处理完成，服务间通过消息契约独立演进。
• 流量削峰：突发请求先进入队列，消费者按自身处理能力拉取消息，避免下游服务被击穿。
• 最终一致性：结合本地事务表+消息重试，实现跨服务的分布式事务最终一致。
• 广播通知：Fanout 交换机将事件同时推送给多个订阅服务（如认证成功通知审计、日志、通知服务）。
• 缓冲与恢复：消费者宕机期间消息保留在队列中，恢复后可继续消费，不丢失数据。

2.3 消息持久化与确认机制

消息可靠性是生产环境的核心要求。RabbitMQ 通过三级持久化和两阶段确认机制保障消息不丢失。

2.3.1 三级持久化策略

2.3.2 生产者确认机制（Publisher Confirm）

生产者发送消息后，RabbitMQ 异步返回确认（ack）或未确认（nack），确保消息已到达 Broker。

// Java 示例：开启 Publisher Confirm
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

// 开启确认模式
channel.confirmSelect();

// 发送持久化消息
String message = "OAuth2 Token Event";
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder()
    .deliveryMode(2)  // 消息持久化
    .build();
channel.basicPublish("oauth_exchange", "token.created", props, message.getBytes());

// 同步等待确认
if (channel.waitForConfirms()) {
    System.out.println("消息已确认到达 Broker");
} else {
    System.out.println("消息确认失败，需重试");
}

2.3.3 消费者确认机制（Consumer Ack）

消费者处理完消息后，向 RabbitMQ 发送确认，Broker 才删除消息。支持自动确认和手动确认两种模式。

• 自动确认（autoAck=true）：消息投递后立即标记为已消费，性能高但可能丢失消息（消费者崩溃时）。
• 手动确认（autoAck=false）：消费者处理成功后调用 basicAck，处理失败时调用 basicNack 或 basicReject，支持重新入队。

// Java 示例：手动确认消费
channel.basicConsume("token_queue", false, new DefaultConsumer(channel) {
    @Override
    public void handleDelivery(String consumerTag, Envelope envelope,
                               AMQP.BasicProperties properties, byte[] body) throws IOException {
        try {
            // 处理消息
            processTokenEvent(new String(body, "UTF-8"));
            // 手动确认，false 表示不批量确认
            channel.basicAck(envelope.getDeliveryTag(), false);
        } catch (Exception e) {
            // 处理失败，重新入队（requeue=true）
            channel.basicNack(envelope.getDeliveryTag(), false, true);
        }
    }
});