我如何使用amqpnetlite dll连接到Rabbitmq

Question

我尝试过此代码

 try
        {
            Address address = new Address("host", 5672, "user", "pass", "/tmdgdai");
            connectionFactory = new ConnectionFactory();

            Session session = new Session(await connectionFactory.CreateAsync((address)));
            SenderLink senderLink = new SenderLink(session, "sender-link", "q1");
            var message = new Message() { BodySection = new Data() { Binary = Encoding.UTF8.GetBytes(inputMessage.Text) } };
            await senderLink.SendAsync(message);

            senderLink.Send(message);
        }
        catch (System.Exception ex)
        {
            logs.Text = ex.ToString();
        }

但得到例外

System.IO.IOException: The handshake failed due to an unexpected packet format.

有人可以帮助我如何使用qmpnetlite连接到Rabbitmq服务器吗？

Answer 1

AmqpNetLite客户端是基于AMQP 1.0的客户端，不适用于RabbitMQ使用的较旧的非标准AMQP协议版本。似乎有一个plugin，可能会允许您向RabbitMQ添加AMQP 1.0支持，但您需要使用AmqpNetLite进行一些测试，以确保一切正常。