MassTransit

Question

我正在尝试使用我们的 Amazon MQ 实例获取基本的 PoC 应用程序运行 MassTransit，当我在 IBusControl 上调用 StartAsync 时运行遇到以下问题：

MassTransit.ActiveMqTransport.ActiveMqConnectException: 连接异常: (user)@(host) ---> Apache.NMS.NMSConnectionException：连接到 (host) 时出错 ---> System.Net.Sockets.SocketException (0xFFFFFFFE)：未知错误 (0xfffffffe) 在 Apache.NMS.ActiveMQ.Transport.Tcp.TcpTransportFactory.DoConnect（字符串主机、Int32 端口、字符串本地地址、Int32 本地端口）

注意：在上面的例外情况中，我编辑了粗体项目以删除敏感信息。我们知道我们使用的凭据实际上是正确的，因为我们对使用相同凭据的 NMS 和 ActiveMq 进行了集成测试。但是当尝试使用 MassTransit 连接时，我们收到上述错误。

我尝试了多种不同的方法，但它们都产生了相同的结果。下面是一些示例代码，可以大致了解我们如何尝试连接：

var busControl = Bus.Factory.CreateUsingActiveMq(configurator =>
            {
                configurator.Host(host, activeMqHostConfigurator =>
                {
                    activeMqHostConfigurator.Username(activeMqConfiguration.UserName);
                    activeMqHostConfigurator.Password(activeMqConfiguration.Password);
                });
            });
await busControl.StartAsync(new CancellationTokenSource(TimeSpan.FromSeconds(10)).Token);

对 StartAsync 的调用引发了异常。我怀疑这是 MassTransit 的问题，它更有可能是我遗漏的东西，但我看不出有什么问题，我也让我的团队对其进行了审查。

Answer 1

正如我在评论中提到的，这最终与 MassTransit 无关。这是因为主机不活跃。

MassTransit - 启动总线时 AmazonMQ 的套接字异常

MassTransit - Socket exception with AmazonMQ when starting bus

activemq

nms