无法使用 AMQP.Lite 和 IBMMQ 8.0 发送消息

Question

我正在基于我们使用 IBMMQ 8.0 的基础架构开发一项新服务（我必须承认我不是 IBMMQ 的专家，我将它用作简单的集成，而没有深入研究它的实现）。

我现在正在尝试将它与 amqpnetlite 一起使用（以便将它与 .NET Core 一起使用）。

到目前为止，这是我的 sn-p

 Address address = new Address("amqp://10.112.62.102:1414");
        Connection connection = new Connection(address);
        Session session = new Session(connection);

        Message message = new Message("Hello AMQP!");
         var sender = new SenderLink(session, "AONMQCOL1", "MQ_TEST");
        sender.Send(message);
        Console.WriteLine("Sent Hello AMQP!");

我收到异常 AmqpException：传输“TcpTransport”已关闭。执行发送时。在连接对象上我有 IsClosed = false 所以我认为连接是打开的。

作为确认，我应该在 SenderLink 的构造函数中添加什么作为“地址”和“名称”？

谢谢

Answer 1

您正在运行的 MQ 服务器的确切版本是什么？即发出 dspmqver 命令。

您需要处于 IBM MQ v8 的 Fixack 2 中添加的命令级别 801。即 IBM MQ v8.0.0.2。请参阅 here 了解更多详情。

你有没有启动AMQP服务，然后启动通道？

即运行mqsc 命令：

START SERVICE(SYSTEM.AMQP.SERVICE)

START CHANNEL(SYSTEM.DEF.AMQP)

最后，您是否连接到正确的端口号？默认端口号为 5672。