rocketmq顺序消费

rocketmq保证消息的顺序消费的原理,其实很简单,首先须要作到一组须要有序消费的消息发往同一个broker的同一个队列上,在多线程消费场景下,一个线程只去消费一个队列上的消息,那么天然就保证了消息消费的顺序性。其实broker并不能彻底保证消息的顺序消费,它仅仅能保证的消息的顺序发送而已!,只要顺序的发送,再保证一个线程只去消费一个队列上的消息,那么他就是有序的。java 示例:多线程 生产者
相关文章
相关标签/搜索