如何保证消息的顺序性？

轩辕小不懂发布于 2021-10-14 14:01

阅读 499

答案 1

分类：资源下载

Nen 2021-10-14 14:20

- 程序员

RabbitMQ

拆分多个 Queue，每个 Queue一个 Consumer，就是多一些 Queue 而已，确实是麻烦点；或者就一个 Queue 但是对应一个 Consumer，然后这个

Consumer 内部用内存队列做排队，然后分发给底层不同的 Worker 来处理。

Kafka

1. 一个 Topic，一个 Partition，一个 Consumer，内部单线程消费，单线程吞吐量太低，一般不会用这个。

2. 写 N 个内存 Queue，具有相同 key 的数据都到同一个内存 Queue；然后对于 N 个线程，每个线程分别消费一个内存 Queue 即可，这样就能保

证顺序性。