【问题标题】:CachingConnectionFactory confirm type simple vs correlatedCachingConnectionFactory 确认类型简单与相关
【发布时间】:2020-05-08 06:56:14
【问题描述】:

CachingConnectionFactory 确认类型简单与相关之间有什么区别。

【问题讨论】:

    标签: spring-boot rabbitmq spring-amqp spring-rabbit


    【解决方案1】:

    correlated 表示你在发送时传入了一些相关数据,收到确认后你会收到回调;回调获取相关数据 - 所以您知道确认是针对哪个发送的。您可以等待相关数据中的Future<?>,如果它被返回,它也可以包含返回的消息。

    使用simple,这只是意味着您可以阻止等待确认您发送的所有消息已收到(waitForConfirmsOrDie)。通过简单的确认没有提供相关性。

    https://docs.spring.io/spring-amqp/docs/2.2.6.RELEASE/reference/html/#template-confirms

    https://docs.spring.io/spring-amqp/docs/2.2.6.RELEASE/reference/html/#scoped-operations

    【讨论】:

    • 非常感谢,我还没有见过这么活跃的人。我在第一种方法中尝试了两种方法,响应是异步的,第二种方法是同步的,这是正确的假设吗??
    • 确认是异步返回的,但 waitForConfirmsOrDie 会阻塞直到它们到达(或超时)。
    • 好吧,让我试试,waitForConfirmOrDie 方法返回布尔值是否意味着消息到达交易所,反之亦然?
    • 查看 Channel (amqp-client) 的 javadocs。如果所有 ack 都是好的,则返回 true,如果任何 ack 不好,则抛出异常。
    • 非常感谢加里❤
    猜你喜欢
    • 1970-01-01
    • 2013-01-28
    • 1970-01-01
    • 2023-03-17
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2019-03-06
    相关资源
    最近更新 更多