【问题标题】:RabbitMQ - Optionally create additional message?RabbitMQ - 可选择创建附加消息?
【发布时间】:2012-07-25 07:54:44
【问题描述】:

我有两个脚本在一个队列中生成消息,其中一个脚本希望队列在消息成功确认后生成附加消息 - 请注意这不是 RPC 我想选择性地进行一次附加处理第一条消息已成功完成,但在成功处理第一条消息之前,我无法进行第二轮处理。

有人有这方面的经验吗?我最初的想法是向标识“下一步”的初始消息发送附加参数,但这似乎有点老套,所以我希望有更好的解决方案。

【问题讨论】:

    标签: rabbitmq amqp


    【解决方案1】:

    检查我对这个问题的回答: RabbitMQ get message send confirm

    这个功能应该允许你做你想做的事。

    【讨论】:

    • 这不是我所追求的——这似乎是更多基于 RPC 的(即提交 X 和接收 Y 并执行 Z)——我在执行 X 并可选地排队以下其他任务任务的完成(不一定是 1,例如可能是 10)。
    • 返回监听器将告诉生产者(可能与正在发布的线程不同的线程)消息已被传递,然后您可以做任何您想做的事情。返回侦听器线程需要有一个规则来决定它在收到并确认最后一条消息的到达后要做什么。
    • 不确定我是否解释得足够好,抱歉。我可能有 2+ 个脚本会生成稍后执行的消息(即这些可能是用户脚本,因此不会有“等待”的可能,因为线程将被停止)。然后需要将其中一些消息发送到其他脚本以添加进一步处理,但其可选的并非所有消息都需要进一步处理。我希望使用脚本为其他队列创建更多消息 - 但是向脚本指示它需要选择性地传递它的最佳方法是什么?
    猜你喜欢
    • 2016-11-24
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2022-09-30
    • 1970-01-01
    相关资源
    最近更新 更多