說(shuō)明 可以直接看看go官方擴(kuò)展包[https://pkg.go.dev/golang.org/x/sync/singleflight]鄙币,大致用途就是針對(duì)并行的返回相同的多個(gè)請(qǐng)...
說(shuō)明 可以直接看看go官方擴(kuò)展包[https://pkg.go.dev/golang.org/x/sync/singleflight]鄙币,大致用途就是針對(duì)并行的返回相同的多個(gè)請(qǐng)...
背景 搭建本地k8s環(huán)境和xxl-job測(cè)試環(huán)境,在k8s環(huán)境中跑通xxl-job調(diào)度器和執(zhí)行器 搭建k8s 注:本次搭建僅針對(duì)mac 安裝docker&k8s 下載dock...
WaitGroup WaitGroup主要用于等待多個(gè)goroutines執(zhí)行完雁仲,具體怎么用這種基操就不說(shuō)了 結(jié)構(gòu) Add和Done Wait 總結(jié) WaitGroup巧妙的...
strings strings包提供了一些常用的字符串操作仔夺,對(duì)于中文也是友好的 Index strings包的strings.go除了Index函數(shù)外還有很多其他的,實(shí)現(xiàn)都比...
channel channel的實(shí)現(xiàn)相對(duì)map簡(jiǎn)單了不少蝎抽,通過(guò)鎖mutex來(lái)保證并發(fā)安全,同時(shí)只提供讀寫(xiě)和關(guān)閉操作路克,channel支持有/無(wú)緩沖區(qū)樟结,對(duì)于有緩沖區(qū)的channe...
context主要用于跨多個(gè)Goroutine設(shè)置截止時(shí)間灰羽、同步信號(hào)驮履、傳遞上下文請(qǐng)求值鱼辙,沒(méi)了解過(guò)Context的先看看這個(gè)Golang Context 源碼分析[https:...
go中的ring實(shí)現(xiàn)了環(huán)形雙向鏈表 源碼解析 舉個(gè)栗子 總結(jié) 別的不說(shuō),Link方法可謂精妙玫镐,包含了向后插入新節(jié)點(diǎn)倒戏、合并兩個(gè)環(huán)形鏈表和刪除鏈表部分節(jié)點(diǎn)三個(gè)功能,而且結(jié)合Pre...
go的list實(shí)現(xiàn)了雙向鏈表 源碼解析 舉個(gè)栗子 總結(jié) list通過(guò)構(gòu)造root標(biāo)識(shí)節(jié)點(diǎn)恐似,實(shí)現(xiàn)了雙向鏈杜跷,快速的找到front和last數(shù)據(jù)節(jié)點(diǎn),且在節(jié)點(diǎn)的插入矫夷,移動(dòng)等操作中葛闷,...
go的heap實(shí)現(xiàn)了堆,關(guān)于堆可以看下數(shù)據(jù)結(jié)構(gòu):堆(Heap)[http://www.reibang.com/p/6b526aa481b1]双藕,這里就不闡述了孵运,go實(shí)現(xiàn)的源碼...
min.insync.replicas=1這個(gè)問(wèn)題,你仔細(xì)看那個(gè)場(chǎng)景吧赤嚼,是在二階段的間隙旷赖,如果遇到了leader副本的更換,follower會(huì)在執(zhí)行日志截?cái)鄷r(shí)丟失數(shù)據(jù)
Kafka - 關(guān)于高水位和Leader Epoch高水位的作用 在 Kafka 中更卒,高水位的作用主要有 2 個(gè)等孵。 定義消息可見(jiàn)性,即用來(lái)標(biāo)識(shí)分區(qū)下的哪些消息是可以被消費(fèi)者消費(fèi)的蹂空。 幫助 Kafka 完成副本同步俯萌。 下面這張圖...
這個(gè)epoch緩存是針對(duì)分區(qū)維度的,每個(gè)leader都會(huì)向zk注冊(cè)上枕,同時(shí)會(huì)同步leader的一些信息到對(duì)應(yīng)controller里面咐熙,而controller本身就是被zk監(jiān)控的,也是保證了高可用性的辨萍,所以就算leader的broker宕機(jī)了棋恼,也沒(méi)事哈
Kafka - 關(guān)于高水位和Leader Epoch高水位的作用 在 Kafka 中,高水位的作用主要有 2 個(gè)锈玉。 定義消息可見(jiàn)性爪飘,即用來(lái)標(biāo)識(shí)分區(qū)下的哪些消息是可以被消費(fèi)者消費(fèi)的。 幫助 Kafka 完成副本同步拉背。 下面這張圖...
@i0shuang 沒(méi)什么作用师崎,更新都是rpc請(qǐng)求,無(wú)用的更新沒(méi)必要椅棺,會(huì)增加數(shù)據(jù)傳輸
Kafka - 關(guān)于高水位和Leader Epoch高水位的作用 在 Kafka 中犁罩,高水位的作用主要有 2 個(gè)齐蔽。 定義消息可見(jiàn)性,即用來(lái)標(biāo)識(shí)分區(qū)下的哪些消息是可以被消費(fèi)者消費(fèi)的昼汗。 幫助 Kafka 完成副本同步。 下面這張圖...