VHost 资源隔离

RabbitMQ的Virtual Host（VHost）提供类似命名空间的资源隔离机制，不同VHost间的队列、交换机、权限完全独立。

VHost 核心概念

隔离边界

VHost 与 Namespace 对比

VHost 管理操作

创建与删除 VHost

# 创建 VHost
rabbitmqctl add_vhost orders
rabbitmqctl add_vhost payments
rabbitmqctl add_vhost notifications

# 查看现有 VHost
rabbitmqctl list_vhosts name tracing description

# 删除 VHost（会删除其中所有资源）
rabbitmqctl delete_vhost test_vhost

绑定用户权限

# 为 orders VHost 创建专属用户
rabbitmqctl add_user orders_svc orders_pass_123
rabbitmqctl set_user_tags orders_svc management
rabbitmqctl set_permissions -p orders orders_svc ".*" ".*" ".*"

# 同一用户在不同 VHost 可配置不同权限
rabbitmqctl set_permissions -p payments orders_svc "" "order\..*" "order\..*"

Java 客户端使用 VHost

连接指定 VHost

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;
import com.rabbitmq.client.AMQP;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;

/**
 * RabbitMQ VHost 使用示例
 */
public class VHostExample {

    private static final String HOST = "localhost";
    private static final int PORT = 5672;

    public static void main(String[] args) throws Exception {
        // 连接 orders VHost
        ConnectionFactory ordersFactory = createConnectionFactory(
            "orders", "orders_svc", "orders_pass_123");
        
        try (Connection ordersConn = ordersFactory.newConnection();
             Channel ordersChannel = ordersConn.createChannel()) {
            
            // 在 orders VHost 中操作
            ordersChannel.queueDeclare("order.created", true, false, false, null);
            ordersChannel.exchangeDeclare("order.exchange", "direct", true);
            ordersChannel.queueBind("order.created", "order.exchange", "order.created");
            
            String message = "{\"orderId\": 1001, \"action\": \"created\"}";
            ordersChannel.basicPublish("order.exchange", "order.created", null,
                message.getBytes(StandardCharsets.UTF_8));
            System.out.println("消息已发送到 orders VHost");
        }

        // 连接 payments VHost
        ConnectionFactory paymentsFactory = createConnectionFactory(
            "payments", "payments_svc", "payments_pass_456");
        
        try (Connection paymentsConn = paymentsFactory.newConnection();
             Channel paymentsChannel = paymentsConn.createChannel()) {
            
            // payments VHost 中的同名队列是独立的
            paymentsChannel.queueDeclare("order.created", true, false, false, null);
            System.out.println("payments VHost 中 order.created 队列独立存在");
        }
    }

    private static ConnectionFactory createConnectionFactory(String vhost, String username, String password) {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost(HOST);
        factory.setPort(PORT);
        factory.setVirtualHost(vhost);  // 关键：指定 VHost
        factory.setUsername(username);
        factory.setPassword(password);
        factory.setConnectionTimeout(5000);
        return factory;
    }
}

每个 VHost 连接必须在 ConnectionFactory 中明确指定 virtualHost 参数。

多环境 VHost 规划

环境隔离方案

VHost 配额管理

# 查看 VHost 资源使用情况
rabbitmqctl list_vhosts name
rabbitmqctl list_queues -p orders name messages consumers
rabbitmqctl list_exchanges -p orders name type

# 通过 Policy 限制队列数量或消息大小
rabbitmqctl set_policy -p orders max-length "^order\." \
  '{"max-length": 100000}' --apply-to queues

rabbitmqctl set_policy -p orders max-message-size "^order\." \
  '{"max-payload-size": 1048576}' --apply-to queues

注意事项

• VHost 不是物理隔离：所有 VHost 共享同一集群资源（CPU/内存/磁盘）
• 跨 VHost 通信：需通过 Shovel/Federation 插件实现消息同步
• 权限独立：同一用户在不同 VHost 需分别配置权限
• 删除谨慎：删除 VHost 会永久删除其中所有队列、交换机与消息
• 监控覆盖：监控需覆盖所有 VHost，不能仅监控默认 VHost

要点总结

• 完全逻辑隔离：VHost 提供队列、交换机、权限的完全逻辑隔离
• 连接时指定：Java Client 通过 setVirtualHost() 指定目标 VHost
• 多环境规划：按 dev/test/staging/prod 划分 VHost 实现环境隔离
• 权限独立配置：每个 VHost 需独立配置用户权限
• 资源共享：VHost 是逻辑隔离，物理资源仍共享，需合理规划容量