Kafka研究系列之時間輪TimerWheel

what       電商中經常會有些延時操作的業務,比如30分鐘未支付則取消訂單,kafka中消息到達broker後,寫入延時隊列,如果在超時時間內ISR列表節點沒有全部同步消息,則返回客戶端超時異常,因此時間輪的本質就是一個延時隊列。 why        java中自帶的延時隊列DeleyQueue,底層使用優先隊列PriorityQueue實現,本質是一個小頂堆,在入隊時需要和父節點不斷比
相關文章
相關標籤/搜索