說明 可以直接看看go官方擴展包[https://pkg.go.dev/golang.org/x/sync/singleflight]，大致用途就是針對并行的返回相同的多個請...
發(fā)簡信
IP屬地：湖北
-
singleflight
-
k8s搭建xxl-job測試環(huán)境背景 搭建本地k8s環(huán)境和xxl-job測試環(huán)境，在k8s環(huán)境中跑通xxl-job調(diào)度器和執(zhí)行器 搭建k8s 注：本次搭建僅針對mac 安裝docker&k8s 下載dock...
-
-
go之WaitGroup
WaitGroup WaitGroup主要用于等待多個goroutines執(zhí)行完，具體怎么用這種基操就不說了 結構 Add和Done Wait 總結 WaitGroup巧妙的...
-
go之strings
strings strings包提供了一些常用的字符串操作，對于中文也是友好的 Index strings包的strings.go除了Index函數(shù)外還有很多其他的，實現(xiàn)都比...
-
go之channel
channel channel的實現(xiàn)相對map簡單了不少，通過鎖mutex來保證并發(fā)安全，同時只提供讀寫和關閉操作，channel支持有/無緩沖區(qū)，對于有緩沖區(qū)的channe...
-
context.go
context主要用于跨多個Goroutine設置截止時間、同步信號、傳遞上下文請求值，沒了解過Context的先看看這個Golang Context 源碼分析[https:...
-
container之ring
go中的ring實現(xiàn)了環(huán)形雙向鏈表 源碼解析 舉個栗子 總結 別的不說，Link方法可謂精妙，包含了向后插入新節(jié)點、合并兩個環(huán)形鏈表和刪除鏈表部分節(jié)點三個功能，而且結合Pre...
-
container之list
go的list實現(xiàn)了雙向鏈表 源碼解析 舉個栗子 總結 list通過構造root標識節(jié)點，實現(xiàn)了雙向鏈，快速的找到front和last數(shù)據(jù)節(jié)點，且在節(jié)點的插入，移動等操作中，...
-
container之heap
go的heap實現(xiàn)了堆，關于堆可以看下數(shù)據(jù)結構：堆（Heap）[http://www.itdecent.cn/p/6b526aa481b1]，這里就不闡述了，go實現(xiàn)的源碼...
-
min.insync.replicas=1這個問題，你仔細看那個場景吧，是在二階段的間隙，如果遇到了leader副本的更換，follower會在執(zhí)行日志截斷時丟失數(shù)據(jù)
Kafka - 關于高水位和Leader Epoch
高水位的作用 在 Kafka 中，高水位的作用主要有 2 個。 定義消息可見性，即用來標識分區(qū)下的哪些消息是可以被消費者消費的。 幫助 Kafka 完成副本同步。 下面這張圖...
-
這個epoch緩存是針對分區(qū)維度的，每個leader都會向zk注冊，同時會同步leader的一些信息到對應controller里面，而controller本身就是被zk監(jiān)控的，也是保證了高可用性的，所以就算leader的broker宕機了，也沒事哈
Kafka - 關于高水位和Leader Epoch
高水位的作用 在 Kafka 中，高水位的作用主要有 2 個。 定義消息可見性，即用來標識分區(qū)下的哪些消息是可以被消費者消費的。 幫助 Kafka 完成副本同步。 下面這張圖...
-
@i0shuang 沒什么作用，更新都是rpc請求，無用的更新沒必要，會增加數(shù)據(jù)傳輸
Kafka - 關于高水位和Leader Epoch
高水位的作用 在 Kafka 中，高水位的作用主要有 2 個。 定義消息可見性，即用來標識分區(qū)下的哪些消息是可以被消費者消費的。 幫助 Kafka 完成副本同步。 下面這張圖...