消息队列主流产品

RabbitMQ、Kafka、RocketMQ 是当前最主流的三款消息队列产品，各有侧重。

核心对比

RabbitMQ

定位：企业级消息总线，侧重灵活路由与低延迟。

核心特性：

• 支持多种 Exchange 类型：Direct、Fanout、Topic、Headers
• 通过路由键（RoutingKey）实现消息精确分发
• 支持消息确认、死信队列、延迟队列
• 提供管理界面，易于运维

适用场景：企业应用集成、RPC 异步化、对延迟敏感的业务。

Maven 依赖：

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.20.0</version>
</dependency>

Topic Exchange 示例：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class RabbitMQTopicExample {
    private static final String EXCHANGE = "log.exchange";

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");

        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            // 声明 Topic Exchange，支持通配符路由
            channel.exchangeDeclare(EXCHANGE, "topic");

            // 发送错误日志，路由键为 "error.mysql"
            String message = "MySQL connection timeout";
            channel.basicPublish(EXCHANGE, "error.mysql", null, message.getBytes("UTF-8"));
            System.out.println("日志已发送，路由键: error.mysql");
        }
    }
}

RabbitMQ 不适合海量日志/事件数据的连续高吞吐写入。

Kafka

定位：分布式流处理平台，侧重超高吞吐与日志持久化。

核心特性：

• 基于 Topic-Partition 模型，天然支持水平扩展
• 消息按 Offset 顺序写入，支持回溯消费
• 无消息确认机制，消费者自行维护 Offset
• 与 Spark、Flink 等流处理框架深度集成

适用场景：日志收集、事件溯源、流数据处理、大数据管道。

Kafka 不适合需要复杂路由或低延迟响应的场景。

RocketMQ

定位：金融级分布式消息中间件，侧重事务一致性与高可靠。

核心特性：

• 支持事务消息，保证本地事务与消息发送的原子性
• 支持顺序消息、延迟消息、重试消息
• 集群部署简单，支持多机房容灾
• 阿里巴巴双十一验证

适用场景：金融交易、订单流程、对消息一致性要求极高的场景。

事务消息示例（概念性）：

import org.apache.rocketmq.client.producer.TransactionMQProducer;
import org.apache.rocketmq.common.message.Message;

public class RocketMQTransactionExample {
    public static void main(String[] args) throws Exception {
        TransactionMQProducer producer = new TransactionMQProducer("transaction_group");
        producer.setNamesrvAddr("localhost:9876");
        producer.start();

        Message message = new Message("TransactionTopic", "order", "1001",
                "{\"orderId\": 1001, \"status\": \"created\"}".getBytes());

        // 发送半消息，执行本地事务后确认提交
        producer.sendMessageInTransaction(message, null);
        System.out.println("事务消息已发送");
    }
}

RocketMQ 依赖 Java 生态，对 Java 开发者更友好，但社区活跃度低于 Kafka。

选型建议

选型无绝对优劣，关键看业务场景的核心诉求：吞吐量、延迟、路由能力、可靠性。

要点总结

• RabbitMQ：企业级消息总线，灵活路由 + 低延迟，适合微服务通信
• Kafka：分布式流平台，超高吞吐 + 日志持久化，适合大数据场景
• RocketMQ：金融级中间件，事务消息 + 高可靠，适合交易场景
• 选型核心：吞吐量、延迟、路由、可靠性四维度评估