脚本宝典收集整理的这篇文章主要介绍了rabbitmq高级特性 消息的可靠投递，脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。

概念

confirm模式简单使用

confirm模式会在消息传递后执行一个回调函数 通过回调函数的值我们可以判断是否正确投递消息给交换机 在boot整合rabbITmq基础之后 编辑配置开启confirm模式

sPRing:
  rabbitmq:
    host: 192.168.198.129
    port: 5672
    username: admin
    password: admin
    virtual-host: /
    publisher-confirm-tyPE: correlated

编写回调函数

    @Autowired
    RabbitTemplate rabbitTemplate;
    @test
    void contextLoads() {
        rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
            /**
             *
             * @param correlationData
             * @param ack 确认交换机是否收到消息
             * @param s  失败原因
             */
            @override
            public void confirm(CorrelationData correlationData, boolean ack, String s) {
                System.out.println("confirm方法被执行了");
                if(ack){
                    System.out.println("接受成功 "+s);
                }
                else {
                    System.out.println("接受失败 "+s);
                }
            }
        });
        rabbitTemplate.convertAndSend(RabbitMQconfig.EXCHANGE_NAME,"boot.haha","hello boot and mq");
    }

运行程序可以得知消息正确投递了

修改交换机名字为一个不存在的名字

运行程序

可以看到回调函数成功得知发送失败了 因此通过这种机制我们可以确保消息是否成功投递给交换机

return模式简单使用

脚本宝典总结

以上是脚本宝典为你收集整理的rabbitmq高级特性 消息的可靠投递全部内容，希望文章能够帮你解决rabbitmq高级特性 消息的可靠投递所遇到的问题。

如果觉得脚本宝典网站内容还不错，欢迎将脚本宝典推荐好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。