如何使用主機連接參數的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參數它似乎並沒有連接（我得到「沒有指定的終點可達」）

即使我的列表只包含一個元素。現在

，如果我使用單主機實現這樣的，它工作正常：

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

我想你可能需要爲連接工廠

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擁有的HostnameSelector屬性設置的值您自己的主機選擇策略。