您可以在 RabbitMQ .Net 客户端中处理队列时发布消息吗？

Question

我有几个消息传递场景，需要在 c# 中使用 RabbitMQ 2.1.0 的帮助... 1）我想让订阅者监听“原始”队列；然后做一些 预处理并发布新消息，例如“预处理”到相同的消息 交换。 2) 与 1 类似，但发布到不同的交易所，

我在 .Net 客户端用户指南中注意到它说不要调用 .basicPublish 在回调期间阻塞线程。

using (IConnection conn = connectionFactory.CreateConnection())
{
    using (IModel model = conn.CreateModel())
    {
        var sub = new Subscription(model, "rtls");
        foreach (BasicDeliverEventArgs iter in sub)
        {
            var message = System.Text.Encoding.UTF8.GetString(iter.Body);
            //do stuff and build up a new message
            //possibly create a new connection?
            //  ***.BasicPublish(new message);

            sub.Ack(iter);
        }

    }
}

我想在我之前成功处理并发布新消息 发送原始消息的ack()；只是为了让我确信每条消息都是 已处理。

这是正确的处理方式还是会导致线程问题？

感谢您的帮助！

Answer 1

您所说的关于回调的内容是正确的，但它仅适用于您子类化 DefaultBasicConsumer （或从头开始编写自己的消费者）。

在您的情况下，订阅是消费者，它本身不应该导致任何锁定。您拥有的代码很好，因为它仅使用订阅使用者。那时 BasicPublish 应该是安全的。

您的代码也恰好（或多或少）是我们的 订阅者示例。

另外，很抱歉没有在rabbitmq-discuss 上回复。