如何使用 RabbitMQ 主机列表连接参数

Question

我在 C# rabbitMQ 库中创建连接时尝试使用 IList<string> 参数：

IConnection CreateConnection(IList hostnames)

我的代码如下：

    private IConnection CreateConnection()
    {
        var connectionFactory = new ConnectionFactory
        {
            UserName = _userName,
            Password = _password,
            VirtualHost = _vhost,
            AutomaticRecoveryEnabled = DEFAULT_AUTO_RECOVER,
            RequestedHeartbeat = HEARTBEAT_TIMEOUT_SECONDS,
            Port = AmqpTcpEndpoint.UseDefaultPort,
        };
        // _hosts contains valid IPs "###.###.###.###"
        return connectionFactory.CreateConnection(_hosts);
    }

但不管我对 hosts 参数的假设如何，它似乎都无法连接（我得到 "None of the specified endpoints were reachable"）

即使我的列表只包含一个元素。

现在，如果我像这样使用单一主机实现，它可以正常工作：

    private IConnection CreateConnection()
    {
        var connectionFactory = new ConnectionFactory
        {
            UserName = _userName,
            Password = _password,
            VirtualHost = _vhost,
            AutomaticRecoveryEnabled = DEFAULT_AUTO_RECOVER,
            RequestedHeartbeat = HEARTBEAT_TIMEOUT_SECONDS,
            Port = AmqpTcpEndpoint.UseDefaultPort,
            HostName = _hosts.First() // or just one string
        };
        return connectionFactory.CreateConnection();
    }

我知道 RabbitMQ 建议不要在客户端存储主机集，但我只是想让他们提供的方法起作用。

Answer 1

我认为您可能需要为连接工厂

的HostnameSelector属性设置一个值

private IConnection CreateConnection()
{
    var connectionFactory = new ConnectionFactory
    {
        UserName = _userName,
        Password = _password,
        VirtualHost = _vhost,
        AutomaticRecoveryEnabled = DEFAULT_AUTO_RECOVER,
        RequestedHeartbeat = HEARTBEAT_TIMEOUT_SECONDS,
        Port = AmqpTcpEndpoint.UseDefaultPort,
        HostnameSelector = new RandomHostnameSelector()
    };
    // _hosts contains valid IPs "###.###.###.###"
    return connectionFactory.CreateConnection(_hosts);
}

RabbitMQ 提供了一个 RandomHostnameSelector

class RandomHostnameSelector : IHostnameSelector
{
    string IHostnameSelector.NextFrom(IList<string> options)
    {
        return options.RandomItem();
    }
}

或者您可以创建自己的 IHostnameSelector 实现以拥有自己的主机选择策略。

如何使用 RabbitMQ 主机列表连接参数

How to use RabbitMQ list of hosts connection parameter

c#

amqp

rabbitmq