rabbitmq topic模式设置#通配符情况下消费者队列未接收消息问题排查解决-Toy模板网

这篇具有很好参考价值的文章主要介绍了rabbitmq topic模式设置#通配符情况下消费者队列未接收消息问题排查解决。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

rabbitmq topic模式设置#通配符情况下消费者队列未接收消息问题排查解决

说明

生产者配置
Exchange：topic_exchange_shcool
Routing key：topic.shcool.#

消费者代码配置
Exchange：topic_exchange_shcool
Routing key：topic.shcool.user

@PostConstruct
    public void twoRabbitInit() {
        //声明交换机
        twoRabbitAdmin.declareExchange(new TopicExchange("topic_exchange_shcool", true, false));
        //声明队列
        twoRabbitAdmin.declareQueue(new Queue("topic.shcool.user", true));
        //绑定队列及交换机
        twoRabbitAdmin.declareBinding(BindingBuilder.bind(new Queue("topic.shcool.user", true, false, false))
                .to(new TopicExchange(twoTopicExchange, true, false))
                .with("topic.shcool.user"));
    }

其实以上代码看着没有问题，意思是代码生成一个队列，并把【topic.shcool.user】队列和生产者的【topic_exchange_shcool】exchange绑定，但是生产者发送消息是通过【topic.shcool.#】通配符去发送的，所以在绑定队列和交换机的时候.with方法要设置好Routing key，并不是你队列的名字，Routing key要和消息生产者的Routing key保持一致，否则消费者即使将队列绑定到exchange也永远无法收到消息，正确代码如下：

@PostConstruct
    public void twoRabbitInit() {
        //声明交换机
        twoRabbitAdmin.declareExchange(new TopicExchange("topic_exchange_shcool", true, false));
        //声明队列
        twoRabbitAdmin.declareQueue(new Queue("topic.shcool.user", true));
        //绑定队列及交换机
        twoRabbitAdmin.declareBinding(BindingBuilder.bind(new Queue("topic.shcool.user", true, false, false))
                .to(new TopicExchange(twoTopicExchange, true, false))
                //不设置通配符 消息不会到队列里来
                .with("topic.shcool.#"));
    }