使用Redisson提供的RDelayedQueue接口午阵。好處: 性能好废岂,基于redis闷串。 支持分布式服務(wù)瓮钥。 不需要輪詢。 RedissonDe...
假設(shè)初始跳表結(jié)構(gòu)為: 一、查詢過程 假如要查找 50碉熄。步驟 1:從頂層開始從最高層(Level 3)的 HEAD 開始桨武。 在這一層中,我們發(fā)現(xiàn)下...
kafka如何保證順序消費(fèi) 想要順序消費(fèi)的業(yè)務(wù)消息使用相同的key具被。這些具有相同key的消息會(huì)被發(fā)往同一個(gè)分區(qū)玻募,kafka能保證同一個(gè)分區(qū)內(nèi)的消...
這篇文章講的很詳細(xì)很好:一文搞懂 kafka consumer 與 broker 交互機(jī)制與原理[https://www.automq.com/...
raft算法保證集群元數(shù)據(jù)的一致性。 保證cap中的cp一姿,當(dāng)發(fā)生嚴(yán)重的網(wǎng)絡(luò)分區(qū)后,放棄可用性跃惫。 raft算法流程:所有跟隨者(follower)...
前提:kafka使用默認(rèn)的配置叮叹。 生產(chǎn)者初始化:生產(chǎn)者初始化后,向集群中任一broker請求元數(shù)據(jù)(配置爆存、主題蛉顽、分區(qū)leader等),并將元數(shù)據(jù)...
三次握手 tcp三次握手目的是確認(rèn)雙方的初始序列號(ISN先较,Initial Sequence Number)携冤。 序列號按字節(jié)累加。其作用是: 數(shù)...
臟讀 (Dirty Read):臟讀發(fā)生在一個(gè)事務(wù)讀取了另一個(gè)事務(wù)尚未提交的數(shù)據(jù)。如果那個(gè)事務(wù)回滾菜循,讀取的數(shù)據(jù)就會(huì)變得不準(zhǔn)確或錯(cuò)誤翘地。例如,事務(wù) ...
Java能使得線程阻塞的基礎(chǔ)工具(其余能阻塞線程的方法都是基于它們的)有4種: synchronized關(guān)鍵字控制對資源的同步訪問癌幕,如果另一個(gè)線...