我希望创建一个消费者,处理来自多个可变数量源的消息,这些源动态连接或断开连接。
我需要的是每个消费者优先处理每个源的前N条消息。然后运行多个消费者以提高速度。
我一直在阅读工作队列,路由和主题等文档,以及其他许多文档,但没有找到如何实现此功能。我也进行了一些测试,但没有成功。
有人能指点我如何做或在哪里阅读相关信息吗?
--编辑--
QueueA-----A3--A2--A1-┐
QueueB-----B3--B2--B1-┼------ 消费者
QueueC-----C3--C2--C1-┘
所期望的效果是每个消费者都能获取每个队列的第一条信息。例如:A1、B1、C1、A2、B2、C2、A3、B3、C3等等。如果创建了新队列(QueueD),消费者将以同样的方式开始接收来自该队列的消息。
我需要的是每个消费者优先处理每个源的前N条消息。然后运行多个消费者以提高速度。
我一直在阅读工作队列,路由和主题等文档,以及其他许多文档,但没有找到如何实现此功能。我也进行了一些测试,但没有成功。
有人能指点我如何做或在哪里阅读相关信息吗?
--编辑--
QueueA-----A3--A2--A1-┐
QueueB-----B3--B2--B1-┼------ 消费者
QueueC-----C3--C2--C1-┘
所期望的效果是每个消费者都能获取每个队列的第一条信息。例如:A1、B1、C1、A2、B2、C2、A3、B3、C3等等。如果创建了新队列(QueueD),消费者将以同样的方式开始接收来自该队列的消息。