2

我是 RabbitMQ 的新手并尝试一下。在我的 RabbitMQ 服务器中,我设置了一个 Exchange (TestExch) 并创建了 2 个队列(TestQ 和 NewQ)。然后,我使用路由键(Q1 和 Q2)创建了从 TestExch 到队列的绑定。

这是我用来发布消息的 mt c# 代码:

string message = Console.ReadLine();
while(!String.IsNullOrEmpty(message))
{
    counter++;
    byte[] messageBuffer = Encoding.Default.GetBytes(message);

    string q = counter % 2 == 0 ? "Q1" : "Q2";
    model.BasicPublish("TestExch", q, properties, messageBuffer);

    Console.WriteLine(message + " => " + q);
    message = Console.ReadLine();
}

但是当我发送消息时查看服务器时,我看到它被插入到两个队列中。

我究竟做错了什么?

4

1 回答 1

2

问题是我定义的交换类型是扇出——为了得到我期望的结果,我需要使用直接选项。

于 2015-01-27T14:43:08.997 回答