多租户治理

本文介绍RabbitMQ多租户治理方案，包括资源配额、限流隔离与权限管控。

定义

多租户治理是在单一RabbitMQ集群中，通过Virtual Host隔离、资源配额限制、连接限流与权限管控，实现多个业务线安全共享集群资源、互不干扰的管理机制。

原理

隔离层次

集群资源隔离:
┌─────────────────────────────────────────┐
│           RabbitMQ Cluster              │
├──────────┬──────────┬──────────────────┤
│ vhost_A  │ vhost_B  │ vhost_C          │
│ (业务A)  │ (业务B)  │ (业务C)          │
├──────────┼──────────┼──────────────────┤
│ Queue限流│ Queue限流│ Queue限流        │
│ 连接限额  │ 连接限额  │ 连接限额         │
│ 磁盘配额  │ 磁盘配额  │ 磁盘配额         │
└──────────┴──────────┴──────────────────┘

资源管控维度

权限模型

权限三级:
├─ configure: 队列/交换机创建删除
├─ write:     消息发布
└─ read:      消息消费

权限绑定:
user -> vhost -> permission(正则匹配资源名)

示例

Maven依赖

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

租户初始化

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import java.util.HashMap;
import java.util.Map;

public class TenantInitializer {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("admin");
        factory.setPassword("admin");

        try (Connection conn = factory.newConnection();
             Channel ch = conn.createChannel()) {
            // 为业务A创建Virtual Host
            String vhost = "/tenant_a";
            // 注意：vhost创建需通过HTTP API或rabbitmqctl
            // 此处演示租户资源初始化

            // 声明租户专属Exchange
            ch.exchangeDeclare("tenant_a_exchange", "topic", true);

            // 声明队列并设置限流Policy
            Map<String, Object> queueArgs = new HashMap<>();
            queueArgs.put("x-max-length", 100000); // 最多10万消息
            queueArgs.put("x-max-length-bytes", 1073741824L); // 1GB
            queueArgs.put("x-message-ttl", 86400000L); // 24小时TTL

            ch.queueDeclare("tenant_a.orders", true, false, false, queueArgs);
            ch.queueBind("tenant_a.orders", "tenant_a_exchange", "order.#");

            System.out.println("Tenant A initialized");
        }
    }
}

租户连接示例

import com.rabbitmq.client.*;

public class TenantConnection {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setVirtualHost("/tenant_a"); // 指定租户vhost
        factory.setUsername("tenant_a_user");
        factory.setPassword("tenant_a_pass");
        // 连接数限制在租户级别通过Policy配置

        try (Connection conn = factory.newConnection();
             Channel ch = conn.createChannel()) {
            ch.basicPublish("tenant_a_exchange", "order.created", null,
                "{\"orderId\":123}".getBytes());
            System.out.println("Message published to tenant_a");
        }
    }
}

限流Policy配置

# 设置租户连接数限制
rabbitmqctl set_policy tenant_a_conn_limit "^tenant_a_" \
    '{"conn-max": 100}' --apply-to queues

# 设置租户消息速率限制（每秒1000条）
rabbitmqctl set_policy tenant_a_rate_limit "^tenant_a_" \
    '{"max-publish-rate": 1000, "max-deliver-rate": 1000}' \
    --apply-to queues

# 设置租户磁盘配额
rabbitmqctl set_policy tenant_a_disk "^tenant_a_" \
    '{"max-message-size": 1048576}' --apply-to queues

权限配置

# 创建租户用户
rabbitmqctl add_user tenant_a_user tenant_a_pass

# 设置权限（仅访问tenant_a相关资源）
rabbitmqctl set_permissions -p /tenant_a tenant_a_user ".*" ".*" ".*"

# 限制用户仅能访问特定vhost
rabbitmqctl set_user_tags tenant_a_user tenant_a

注意事项

Virtual Host是租户隔离的核心，不同vhost的队列/交换机完全隔离，不可跨vhost访问。

连接数限制必须在租户级别配置，否则单一租户可能耗尽集群连接资源。

磁盘配额与内存watermark是全局设置，租户级别仅能通过消息TTL与队列长度间接控制。

权限正则匹配需谨慎，避免正则过于宽松导致越权访问。

多租户监控需按vhost拆分指标，否则无法定位单一租户异常。

要点总结

• 多租户通过Virtual Host实现命名空间与资源隔离
• 资源管控维度：连接数、消息速率、磁盘、内存、队列长度
• 权限模型：configure/write/read三级权限绑定vhost
• 限流通过Policy配置，支持publish-rate与deliver-rate
• 监控指标需按vhost拆分，便于定位单一租户异常