rocketmq順序消費

rocketmq保證消息的順序消費的原理,其實很簡單,首先須要作到一組須要有序消費的消息發往同一個broker的同一個隊列上,在多線程消費場景下,一個線程只去消費一個隊列上的消息,那麼天然就保證了消息消費的順序性。其實broker並不能徹底保證消息的順序消費,它僅僅能保證的消息的順序發送而已!,只要順序的發送,再保證一個線程只去消費一個隊列上的消息,那麼他就是有序的。java 示例:多線程 生產者
相關文章
相關標籤/搜索