消息发送到队列，尽管路由键不匹配

在使用 RabbitMQ 时，作者遇到消息被发送到不匹配路由键的队列的问题。作者试图将消息发送到不存在的队列，但消息仍会被发送到另一个存在的队列。文章探讨了问题的可能原因和解决方案。

我试图让兔子向不同的主题发送循环消息。 我有 1 个名为“endpoint/1”的队列 我正在将消息发送到“endpoint/1”和“endpoint/2”。 “endpoint/2”不存在，所以我希望这些消息会消失，但它们会被发送到队列“endpoint/1”事件，尽管没有绑定到它！

我不知道为什么会发生这种情况，我做错了什么吗？

// declare exchange
ch.ExchangeDeclare("uop_fanout", "fanout", false, false, false, false, nil)

//send
ch.Publish("uop_fanout", topic, false, false, amqp.Publishing{Body: msg})

// listend
q, err := ch.QueueDeclare(topic, false, false, false, false, nil)
    if err != nil {
        return nil, err
    }
    err = ch.QueueBind(q.Name, topic, "uop_fanout", false, nil)
    if err != nil {
        return nil, err
    }
    messagesFanout, err := ch.Consume(q.Name, "", false, false, false, false, nil)
    if err != nil {
        return nil, err
    }

解决方案

有了这个声明：

ch.ExchangeDeclare("uop_fanout", "fanout", false, false, false, false, nil)

您正在声明 fanout 类型的交换。这意味着到达交换器的消息将被克隆并发送到绑定到该交换器的所有队列。

不清楚“向不同主题循环发送消息”是什么意思。

如果您只想进行循环负载平衡，则只需将消息路由到单个队列，并为该队列设置两个或更多使用者。

如果您想按主题分发消息，可以使用带有特定路由键的 direct 交换。到达的消息将被发送到与匹配的路由键绑定的队列。

当然，您可以结合这些概念。

来源：https://www.rabbitmq.com/tutorials/amqp-concepts.html

好了，本文到此结束，带大家了解了《消息发送到队列，尽管路由键不匹配》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！