无法通过Apache.NMS连接Amazon MQ代理的问题求助

核心问题 #

你遇到的错误根源是使用了错误的NuGet包：Apache.NMS.ActiveMQ仅支持ActiveMQ原生TCP协议（即本地测试用的tcp://格式），并不支持AMQP协议的连接URI。AWS MQ提供的amqp+ssl://端点需要专门的AMQP协议客户端库。

另外代码中存在区域不一致问题：代理端点属于us-east-1，但连接URI写的是us-east-2，这会导致无法正确定位到目标代理。

具体修复步骤 #

1. 替换NuGet包 #

移除Apache.NMS.ActiveMQ，安装官方支持AMQP协议的Apache.NMS.AMQP包：

<ItemGroup>
  <PackageReference Include="Apache.NMS.AMQP" Version="2.2.0" /> <!-- 建议使用最新稳定版 -->
</ItemGroup>

2. 修正连接URI #

• 统一区域：确保URI中的区域与AWS MQ代理的区域完全一致（比如均为us-east-1）
• 补充认证信息：AWS MQ强制要求用户名密码认证，需将其嵌入URI中；同时使用标准amqps://格式替代amqp+ssl://

示例URI：

Uri connecturi = new Uri("amqps://你的AWS_MQ用户名:你的AWS_MQ密码@b-***-1.mq.us-east-1.amazonaws.com:5671");

3. 调整代码逻辑 #

无需显式指定ActiveMQ专属工厂，直接使用NMSConnectionFactory即可，Apache.NMS.AMQP会自动注册AMQP协议的工厂实现：

using System;
using Apache.NMS;

namespace AMQPTest
{
    public class TestMain
    {
        public static void Main()
        {
            // 替换为你的实际认证信息和端点
            Uri connecturi = new Uri("amqps://admin:yourMQPassword@b-***-1.mq.us-east-1.amazonaws.com:5671");
            Console.WriteLine("About to connect to " + connecturi);

            IConnectionFactory factory = new NMSConnectionFactory(connecturi);
            
            // 完成连接与会话创建
            using (IConnection connection = factory.CreateConnection())
            {
                connection.Start();
                using (ISession session = connection.CreateSession())
                {
                    Console.WriteLine("连接AWS MQ成功！");
                    // 后续业务逻辑写在这里
                }
            }
        }
    }
}

4. 测试环境临时配置（可选） #

如果遇到SSL证书验证失败的问题，可在URI中添加参数临时禁用主机名验证（仅用于测试，生产环境不推荐）：

Uri connecturi = new Uri("amqps://admin:yourMQPassword@b-***-1.mq.us-east-1.amazonaws.com:5671?transport.verifyHostName=false");

内容的提问来源于stack exchange，提问作者Mathias F