最近看rocketmq顺序消费的源码有个疑问?
2021-07-01 本文已影响0人
Britney_z
例如顺序消费也是多线程处理,对于同一个topic 同一个队列,如果第二次的响应比第一次的请求响应更快的话,即使锁定具体队列,那也做不到顺序消费了吧?
只有第一次响应结束之后,才能发起第二次请求,所以消费者请求是单线程的,所以不存在上面所说的问题
例如顺序消费也是多线程处理,对于同一个topic 同一个队列,如果第二次的响应比第一次的请求响应更快的话,即使锁定具体队列,那也做不到顺序消费了吧?
只有第一次响应结束之后,才能发起第二次请求,所以消费者请求是单线程的,所以不存在上面所说的问题