在一个消费者隐藏多个用户的情况下,在队列中保留和锁定消息的策略

我对无法区分机器的部件有点困惑,但我明白以下几点:

• 您有一个包含消息的队列
• 你有一个消费者
• 消费者接收信息并呼叫服务或类似服务
• 如果通话成功,则可以删除该消息
• 如果呼叫失败,则必须重新处理消息

如果这些假设是正确的,您可以构建一个使用队列中的消息的驼峰路由( 交易 )服务和电话。

• 如果骆驼 路线失败 完成(服务返回错误),错误为 不 处理后,代理进行回滚,然后 消息被重新传递 (立即)
• 如果路由多次失败(当达到最大重新交付值时),消息将发送到 死信队列 (经纪人)把它移到一边,但要保存它
• 如果 路线成功 消息消耗被提交给代理和 删除消息
• 在这样的设置中,您还可以配置更多消费者来并行处理消息(如果被调用的服务允许)

这种行为或多或少是默认行为,如果

• 您的代理配置为持久(避免消息丢失)
• 您使用已处理的消息(与代理的本地事务就足够了)
• 骆驼是的 不 处理错误(当它们被处理时,消息被提交,因为代理没有“看到”任何错误)
• 你从服务中得到一个错误,或者你至少可以决定是否有问题,然后自己抛出错误。代理必须获取异常,以便完成回滚

编辑

根据你的澄清,我理解这与我的假设相反。

那么,我可能会将这两种请求类型视为“工作流步骤”,因为它们是从客户端触发的。

收到

• 使用消息,将其发送给请求者
• 向消息头添加时间戳
• 将消息发送到 另一个队列 (我们就叫它吧 delievered )

删去

• 将消息从 delievered 队列

未删除的邮件

• 使用时间戳头和 message selectors 在一定时间后使用未删除的邮件
• 将它们移回源队列

有了第二个队列,你就有了各种优势

• 正在处理的消息不能再次使用,因此不需要“锁定”
• 源队列只包含等待的消息 delievered 仅对正在处理的消息进行排队
• 在将未删除的邮件发送回源队列时,可以提高邮件优先级,以便快速重新使用这些邮件
• 还可以在将未删除的消息发送回源队列时添加计数器头,以标识多次失败的消息,并以另一种方式处理它们。