如何从 C# 连接到 AWS RabbitMQ？

Question

在我的 C# 应用程序中，我有以下代码：

var factory = new ConnectionFactory
        {
            Port = 5671,
            UserName = "userxxxx",
            Password = "passwordxxx",
            HostName = "amqps://xxxx.mq.us-east-1.amazonaws.com"
        };
        using var connection = factory.CreateConnection();

但在 CreateConnection 期间我收到：

RabbitMQ.Client.Exceptions.BrokerUnreachableException
   HResult=0x80131620
   Message=None of the specified endpoints were reachable
   Source=RabbitMQ.Client 

AWS 控制台显示：

端点：amqps://xxxx.mq.us-east-1.amazonaws.com:5671

我做错了什么？

Answer 1

使用“netcat”之类的工具来验证您是否可以连接到 AWS MQ 上的端口 5671。应该从您尝试连接的同一主机 使用 Netcat。或者，考虑使用基于云的端口扫描器，例如 https://www.whatismyip.com/port-scanner/，让您的本地网络摆脱困境。

netcat 的成功例子：

$ nc -vz myownawsmq.mq.us-east-1.amazonaws.com 5671 连接到 myownawsmq.mq.us-east-1.amazonaws.com 5671 端口 [tcp/amqps] 成功！

如果您收到错误或超时，则说明您的 URL 不正确或端口 5671 被阻止。

当我创建我的 AWS RabbitMQ 实例时，端口 5671 对互联网开放，因为可公开访问是默认设置。您不能将安全组与可公开访问的 RabbitMQ 实例一起使用。如果您为 RabbitMQ 实例设置 Private Access，您将无法从外部访问它。

也有可能 5671 被本地防火墙规则阻止。检查本地网络中的防火墙配置，确保允许 5671。如果基于云的端口扫描器可以连接到端口，但本地扫描不能，则可能是您的本地网络配置。