【发布时间】:2018-07-19 14:42:55
【问题描述】:
我是 RabbitMQ 的新手,我有一个问题。这是我在教程中经常看到的示例 sn-p。
public static void Send(string queueName, string data)
{
using (IConnection connection = new ConnectionFactory().CreateConnection())
{
using (IModel channel = connection.CreateModel())
{
channel.QueueDeclare(queue: queueName,
durable: true,
exclusive: false,
autoDelete: false,
arguments: null);
// Publish to the named queue
channel.BasicPublish(string.Empty, queue, null, Encoding.UTF8.GetBytes(data));
}
}
}
我很困惑,因为每次你想调用Send 函数时声明一个队列的概念对我来说有点奇怪。这是否意味着它每次都会创建一个新队列?
一些用于从队列接收的示例代码也有一个queueDeclare 调用。为什么需要它?
【问题讨论】:
-
如果您想了解有关消息传递和 EAI 的更多信息,请阅读 Enterprise Integration Patterns 一书。几乎所有当代 EAI 系统都基于它