2020-12-25:MQ中,如何保證訊息的順序性?#福大大架構師每日一題#
uj5u.com熱心網友回復:
不知道111111uj5u.com熱心網友回復:
每個 queue 一個 consumer 能滿足你的處理速度不?如果滿足的話就可以用這種方式uj5u.com熱心網友回復:
RabbitMQ:創建多個 queue,每個消費者固定消費一個 queue 的訊息。或者,一個 queue 但是對應一個 consumer,consumer內部用記憶體佇列做排隊分發給不同的worker。
Kafka:執行緒處理前增加個記憶體佇列,每個執行緒只負責處理其中一個記憶體佇列的訊息。
RocketMQ:同一個任務的 binlog 進入到同一個 MessageQueue 中就可以了,MessageQueue內是有序的。
uj5u.com熱心網友回復:
3樓,大佬,全面詳細uj5u.com熱心網友回復:
同一個訊息通道里面的訊息不都先進先出依次執行的嘛。轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/240163.html
標籤:Java相關
下一篇:CAS5.3系統中配置不生效問題
