消息中间件

**工作模式：** 简单模式，工作队列模式，发布订阅模式，路由模式，主题模式。

**消息确认：** 消息确认可以减少消息丢失(比如网络波动造成消息丢失)。

- 发送端确认：发送消息后使用异步回调，确认消息是否发送成功，发送失败可以重试。
- 队列中消息过期或者消息已满：消息进入死信队列或者丢弃。
- 消费端确认：`basicAck，basicNack，basicReject`.
以 `RabbitMQ` 为例：
    ```
    @Component
    public class Consumer {
    
        @RabbitListener(queuesToDeclare = @Queue("${spring.rabbitmq.queue.name}"))
        public void handleMessage(Channel channel, @Payload Message message) throws UnsupportedEncodingException {
            // 消息处理逻辑
            String msg = new String(message.getBody(), "UTF-8");
            System.out.println("Received message: " + msg);
            // 配置文件手动确认消息 acknowledge-mode: manual
            long deliveryTag = message.getMessageProperties().getDeliveryTag();
            try {
                channel.basicAck(deliveryTag, false);
            } catch (IOException e) {
                // 消息重试
                try {
                    // multiple = false 只拒绝当前消息，requeue = false 放回队列，防止死信
                    channel.basicNack(deliveryTag, false, true);
                } catch (IOException ex) {
                    // 消息丢弃
                    try {
                        channel.basicReject(deliveryTag, false);
                    } catch (IOException exc) {
                        // 异常处理和日志记录
                        ex.printStackTrace();
                    }
                }
            }
        }
    ```

**死信：** 当消息在一个队列中变成死信 (dead message) 之后，它能被重新被发送到另一个交换器中，这个交换器就是 DLX（Dead-Letter-Exchange），绑定 DLX 的队列就称之为死信队列。
导致的死信的几种原因：
- 消息被拒（Basic.Reject / Basic.Nack 且 requeue = false）
- 消息 TTL 过期。
- 队列满了，无法再添加。

**重复消费（消息一致性）问题：** 
- 生产者多发送了消息：通过生产者异步消息确认可以避免。
- 一条消息被消费者消费了多次：消费者消费消息后，确认消息途中网络中断，消息依然存在队列里，下次会重复消费。生产者可以设置 `messageId`，消费者消费后，存储到 `redis` 中，下次消费利用幂等性判断是否存在，存在则不再消费。

独孤九剑/Java Learning

内容风险标识

评论 (0)

独孤九剑/Java Learning .gitee-modal { width: 500px !important; }

内容风险标识