路由策略设计

路由策略设计是根据业务场景选择合适的交换机类型与绑定规则，构建清晰、高效、可扩展的消息路由架构。

交换机类型对比

策略选择原则

1. 点对点路由：Direct交换机

适用于消息需精确投递到特定队列的场景：

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

public class DirectStrategy {
    private static final String EXCHANGE = "task_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()) {
            
            channel.exchangeDeclare(EXCHANGE, "direct", true);
            
            // 按优先级路由到不同队列
            channel.queueDeclare("queue_high", true, false, false, null);
            channel.queueDeclare("queue_normal", true, false, false, null);
            channel.queueDeclare("queue_low", true, false, false, null);
            
            channel.queueBind("queue_high", EXCHANGE, "high");
            channel.queueBind("queue_normal", EXCHANGE, "normal");
            channel.queueBind("queue_low", EXCHANGE, "low");
            
            // 按优先级发送任务
            channel.basicPublish(EXCHANGE, "high", null, "Urgent task".getBytes());
            channel.basicPublish(EXCHANGE, "normal", null, "Normal task".getBytes());
            channel.basicPublish(EXCHANGE, "low", null, "Low priority task".getBytes());
        }
    }
}

2. 广播通知：Fanout交换机

适用于消息需分发给所有订阅者的场景：

public class FanoutStrategy {
    private static final String EXCHANGE = "event_broadcast";

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            
            channel.exchangeDeclare(EXCHANGE, "fanout", true);
            
            // 多个服务订阅同一事件
            channel.queueDeclare("queue_email_service", true, false, false, null);
            channel.queueDeclare("queue_sms_service", true, false, false, null);
            channel.queueDeclare("queue_analytics", true, false, false, null);
            
            channel.queueBind("queue_email_service", EXCHANGE, "");
            channel.queueBind("queue_sms_service", EXCHANGE, "");
            channel.queueBind("queue_analytics", EXCHANGE, "");
            
            // 广播事件
            String event = "user.registered:id=12345";
            channel.basicPublish(EXCHANGE, "", null, event.getBytes());
        }
    }
}

3. 主题路由：Topic交换机

适用于多条件组合路由的场景：

public class TopicStrategy {
    private static final String EXCHANGE = "log_topic";

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            
            channel.exchangeDeclare(EXCHANGE, "topic", true);
            
            // 按业务和级别组合路由
            channel.queueDeclare("queue_all_errors", true, false, false, null);
            channel.queueDeclare("queue_payment_logs", true, false, false, null);
            channel.queueDeclare("queue_us_orders", true, false, false, null);
            
            channel.queueBind("queue_all_errors", EXCHANGE, "#.error");
            channel.queueBind("queue_payment_logs", EXCHANGE, "payment.#");
            channel.queueBind("queue_us_orders", EXCHANGE, "order.us.*");
            
            // 组合路由键
            channel.basicPublish(EXCHANGE, "payment.us.error", null, 
                    "Payment error".getBytes());
        }
    }
}

组合策略示例

复杂系统可组合多种交换机类型：

// 架构：Direct用于任务分发 + Fanout用于事件广播 + Topic用于日志聚合
public class CombinedStrategy {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            
            // 任务分发使用Direct
            channel.exchangeDeclare("task_direct", "direct", true);
            channel.queueBind("worker_queue", "task_direct", "process");
            
            // 事件广播使用Fanout
            channel.exchangeDeclare("event_fanout", "fanout", true);
            channel.queueBind("audit_queue", "event_fanout", "");
            
            // 日志聚合使用Topic
            channel.exchangeDeclare("log_topic", "topic", true);
            channel.queueBind("error_log", "log_topic", "*.error");
            
            System.out.println("Combined routing strategy configured");
        }
    }
}

注意事项

• 优先使用Direct交换机，仅在需要广播或多条件匹配时选用Fanout或Topic
• Topic交换机绑定数量过多时性能下降明显，应控制通配符绑定总数
• 路由键设计应具有明确语义，如业务.区域.操作.状态
• 避免过度使用通配符，增加路由匹配复杂度
• 生产环境建议通过配置文件管理路由策略，便于动态调整

要点总结

• Direct适用于精确匹配，Fanout适用于广播，Topic适用于多条件过滤
• 路由策略应根据业务需求选择，优先使用简单匹配
• 复杂系统可组合多种交换机类型实现分层路由
• 路由键设计应规范统一，便于维护和扩展
• 通过配置文件管理路由策略，提升架构灵活性

文章存放路径：D:\git2\jwdev\articles\RABBITMQ\进阶\消息路由与绑定\路由策略设计.md