gpt4 book ai didi

java - 在JMS队列中实现ActiveMQ的粘性 session (消息组)

转载 作者:行者123 更新时间:2023-12-01 15:43:12 25 4
gpt4 key购买 nike

我正在尝试摆脱 ActiveMQ,但我们想要保留的一项功能是消息组。通过将 session ID 添加到 JMS header ,ActiveMQ 会将队列上具有相同 ID 的所有其他消息路由到同一消费者(我们的消费者可能位于不同的机器上),从而允许接收者将一组消息视为一个工作单元。

我的第一个想法只是将 session 置于 CLIENT_ACKNOWLEDGE 模式。我的想法是,如果消费者 A 查看 header 并发现它不是它正在处理的 ID,那么它可以直接删除该消息,而消费者 B 会拾取该消息。我遇到了几个问题,包括 ActiveMQ 的完善,而且我读得越多,就越觉得这不是最初设计的目的。

我能想到的一个想法是建立一个调度队列,然后将消息路由到每个消​​费者的,因为缺乏更好的词,子队列并管理将 session ID 与子队列匹配。

在我走这条路之前,我们对此持怀疑态度,因为它会增加代码的复杂性,然后我们想要,关于 CLIENT_ACKNOWLEDGE 是否有我遗漏的东西?或者我应该先尝试其他完全不同的东西?

最佳答案

关于java - 在JMS队列中实现ActiveMQ的粘性 session (消息组),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/7656666/

25 4 0
文章推荐: java - 使用 js/jquery/java/active x 或其他方式拍摄
文章推荐: FXML 中的 JavaFx 实例
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com