![240](https://upload.jianshu.io/users/upload_avatars/11345047/746ef643-39df-4d7b-a7c7-3ec89b2e8b0d.jpeg?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
RocketMQ提供了基于Tag的消息過濾機制尝江,不少使用者都有問到如下問題: 消費組訂閱關(guān)系不一致為什么會到來消息丟失外盯?如果一個tag的消息數(shù)量...
如果你曾經(jīng)使用過RocketMQ裆站,那么一定對以下發(fā)送消息的代碼不陌生 Producer啟動 其實僅僅一行代碼均践,在produer端的后臺啟動了多個...
前文我們梳理了消息在Commit Log文件的存儲過程展姐,討論了消息的落盤策略躬存,然而僅僅通過Commit Log存儲消息是遠遠不夠的谋作,例如當(dāng)我們需...
寫入流程 簡單可以分為三大塊: 寫入前準(zhǔn)備加鎖后消息寫入消息落盤及集群同步 其實消息的寫入準(zhǔn)備工作也比較好理解孝扛,主要是消息狀態(tài)的檢查以及各類存儲...
Java堆棧內(nèi)存與堆外內(nèi)存 堆棧內(nèi)存堆棧內(nèi)存指的是堆內(nèi)存和棧內(nèi)存:堆內(nèi)存是GC管理的內(nèi)存疗琉,棧內(nèi)存是線程內(nèi)存冈欢。 堆內(nèi)存結(jié)構(gòu): 還有一個更細致的結(jié)構(gòu)...
https://draveness.me/whys-the-design-tcp-time-wait/[https://draveness.me...
SO_RCVTIMEO, SO_SNDTIMEO介紹 套接字選項SO_RCVTIMEO: 用來設(shè)置socket接收數(shù)據(jù)的超時時間歉铝;套接字選項SO...
在看到 go 字符串的時候, 偶然看到 []rune(s), 它可以將字符串轉(zhuǎn)化成 unicode 碼點凑耻。那么它和 []byte(s) 有什么區(qū)...
[TOC] 前言 K8s是一個強大的平臺太示,但它的網(wǎng)絡(luò)比較復(fù)雜,涉及很多概念香浩,例如Pod網(wǎng)絡(luò)类缤,Service網(wǎng)絡(luò),Cluster IPs邻吭,Node...