我现在有个专门消费消息的系统，怎么动态控制，让不同的机器（容器、节点、pod）消费不同的队列呢？

xiaokongwu · 7 小时 7 分钟前 · 282 次点击

我现在有个专门消费消息的系统，跑在 k8s 集群里。怎么动态控制，让不同的机器（容器、节点、pod ）消费不同的队列呢？

逻辑都是通用的，但可能会有很多渠道的消息送过来。不同渠道消息可以用一个队列，也可以用多个队列。

但是不通渠道的消息流量大小也不同，某些渠道的流量可能会比较大，消息也很多，需要更多的节点去处理。

那我想指定某些 pod 去消费某个队列的消息，有什么好办法呢？

比如我这个应用一个创建了 20 个副本，我想让其中 10 副本个消费 A 队列，5 个消费 B 队列，5 个消费 C 队列。

而且这个副本数可以动态控制，随时增加（重启生效也可以）。

3 条回复 • 2021-09-26 23:16:48 +08:00

fkdog 6 小时 59 分钟前

把队列名称配置成启动参数。
配置不同的名称参数则启动后消费不同的队列。
参数化的配置还能方便你随时扩容。

xiaokongwu 6 小时 40 分钟前

@fkdog 也是，回头去咨询下运维的同事。能不能在发布的时候指定动态环境变量、jvm 启动参数之类的，把队列的参数放进去

joesonw 5 小时 28 分钟前 via iPhone

有状态的就上 StatefulSet，每个 pod 是一个顺序的 index 。但是与横向扩展相斥。最好是在队列 broker 层面解决。

我现在有个专门消费消息的系统，怎么动态控制，让不同的机器（容器、节点、pod）消费...