前言 ThreadLocal解決了在多個(gè)線程針對(duì)一個(gè)變量維護(hù)不同值的功能，如果你想在同一個(gè)線程內(nèi)傳遞一些值，那么就可以用到這個(gè)類模她，它的好處是無(wú)侵入性，這樣我們就不需要再每個(gè)方...
發(fā)簡(jiǎn)信
IP屬地：浙江
-
transmittable-thread-local源碼分析 -
選舉leader的時(shí)間很短吧言沐。隆箩。如果在15分鐘內(nèi)超過(guò)15%的節(jié)點(diǎn)都沒(méi)有正常心跳响驴，就會(huì)進(jìn)入保護(hù)模式秀存。捶码。
Nacos,Eureka與ZooKeeper的比較
著名的CAP理論指出，一個(gè)分布式系統(tǒng)不可能同時(shí)滿足C(一致性)或链、A(可用性)和P(分區(qū)容錯(cuò)性)惫恼。由于分區(qū)容錯(cuò)性在是分布式系統(tǒng)中必須要保證的，因此我們只能在A和C之間進(jìn)行權(quán)衡澳盐。...
-
寫(xiě)的挺好的~贊
spring-kafka源碼閱讀(1)
SPRING-KAFKA源碼 最近看了一點(diǎn)spring-kafka的東西, 看到網(wǎng)上相關(guān)的東西比較少, 就想著自己整理一把. 相關(guān)介紹 kakfa kafka spring-...
-
spring-kafka源碼閱讀(1)
SPRING-KAFKA源碼 最近看了一點(diǎn)spring-kafka的東西, 看到網(wǎng)上相關(guān)的東西比較少, 就想著自己整理一把. 相關(guān)介紹 kakfa kafka spring-...
-
@KafkaListener的時(shí)候祈纯，可以指定containerFactory，然后弄2個(gè)containerFactory進(jìn)行配置2個(gè)kafka叼耙。
Spring-Kafka（六）—— @KafkaListener的花式操作
消息監(jiān)聽(tīng) 對(duì)于Kafka中Topic的數(shù)據(jù)消費(fèi)腕窥，我們一般都選擇使用消息監(jiān)聽(tīng)器進(jìn)行消費(fèi)，怎么把消息監(jiān)聽(tīng)器玩出花來(lái)呢筛婉，那就得看看它所實(shí)現(xiàn)的功能了簇爆。Spring-Kafka中消息監(jiān)...
-
你好，有個(gè)問(wèn)題請(qǐng)教~倾贰，文中說(shuō)：“RocketMQ采用混合型存儲(chǔ)結(jié)構(gòu)的缺點(diǎn)在于冕碟，會(huì)存在較多的隨機(jī)讀操作，因此讀的效率偏低”匆浙，但是消息都是在CommitLog的呀，而且通過(guò)mmap映射到內(nèi)存厕妖，雖然隨機(jī)首尼，但是效率應(yīng)該挺高哇。
消息中間件—RocketMQ消息存儲(chǔ)（一）
文章摘要：MQ分布式消息隊(duì)列大致流程在于消息的一發(fā)一收一存言秸，本篇將為大家主要介紹下RocketMQ存儲(chǔ)部分的架構(gòu)消息存儲(chǔ)是MQ消息隊(duì)列中最為復(fù)雜和最為重要的一部分软能，所以小編也...
-
RocketMQ消息引擎關(guān)于CommitLog淺析前文有簡(jiǎn)單的提到RocketMQ的底層文件存儲(chǔ)模型，基于該存儲(chǔ)模型之上再簡(jiǎn)單的探索一下 CommitLog的一個(gè)底層設(shè)計(jì)举畸，思考RocketMQ如何做到高性能查排？ 對(duì)于Roce...
-
@花溪的小石頭 如果你覺(jué)得這些問(wèn)題弱智，你應(yīng)該很吊哇抄沮，兄弟
螞蟻二面跋核，面試官問(wèn)我零拷貝的實(shí)現(xiàn)原理岖瑰，當(dāng)場(chǎng)懵了…
Intellij IDEA 又過(guò)期了? 試試這個(gè) "狼哥，面試又跪了砂代，碰到了知識(shí)盲區(qū)""哪個(gè)蹋订？""一面還可以，二面面試官問(wèn)我零拷貝的原理刻伊，懵逼了...這塊內(nèi)容沒(méi)去研究過(guò)""哦...
-
@ZX_周雄 給力~懂了露戒，還要一點(diǎn)就是 Lazy為什么要實(shí)現(xiàn)Supplier,直接擁有一個(gè)Supplier變量不行么。
如下：
public class T1220<T> {
private Supplier<T> supplier;
public static <T> T1220<T> of(Supplier<T> supplier) {
return new T1220(supplier);
}
private T1220(Supplier<T> supplier) {
this.supplier = supplier;
}
@Override
public String toString() {
return supplier.get().toString();
}
}JDK1.8 Supplier實(shí)踐及總結(jié)
起因 群里黑神拋出了一個(gè)問(wèn)題捶箱，意圖引起大家的思考 黑神簡(jiǎn)單解釋之后智什，群里仍有同學(xué)不太理解 正好之前筆者在Supplier上有一些實(shí)踐，因此打算跟大家分享一下使用經(jīng)驗(yàn) 基礎(chǔ)知識(shí)...
-
logback中丁屎，“滿足輸出條件撩鹿，才會(huì)執(zhí)行Lazy.toString()，即supplier.get().toString()” 哪里有悦屏，沒(méi)懂节沦。。础爬。??????
JDK1.8 Supplier實(shí)踐及總結(jié)
起因 群里黑神拋出了一個(gè)問(wèn)題甫贯，意圖引起大家的思考 黑神簡(jiǎn)單解釋之后，群里仍有同學(xué)不太理解 正好之前筆者在Supplier上有一些實(shí)踐看蚜，因此打算跟大家分享一下使用經(jīng)驗(yàn) 基礎(chǔ)知識(shí)...
-
666叫搁， submit無(wú)法處理設(shè)置了UncaughtExceptionHandler的線程，以前沒(méi)注意供炎，現(xiàn)在認(rèn)識(shí)更加深刻了渴逻。??????
Java線程池異常處理方案
執(zhí)行多線程并發(fā)任務(wù)的時(shí)候，如果任務(wù)類型相同音诫，一般會(huì)考慮使用線程池惨奕，一方面利用了并發(fā)的優(yōu)勢(shì)，一方面避免創(chuàng)建大量線程得不償失竭钝。使用線程池執(zhí)行的任務(wù)一般是我們自己的代碼梨撞，或者第三方...
-
Java線程池異常處理方案執(zhí)行多線程并發(fā)任務(wù)的時(shí)候，如果任務(wù)類型相同香罐，一般會(huì)考慮使用線程池卧波，一方面利用了并發(fā)的優(yōu)勢(shì)，一方面避免創(chuàng)建大量線程得不償失庇茫。使用線程池執(zhí)行的任務(wù)一般是我們自己的代碼港粱，或者第三方...
-
“則默認(rèn)會(huì)把異常棧信息輸出到終端而使程序直接崩潰”， 還能把程序搞奔潰旦签，老哥你是認(rèn)真的嗎查坪。寸宏。。
Java UncaughtExceptionHandler 解析
問(wèn)：說(shuō)說(shuō)你對(duì) UncaughtExceptionHandler 的認(rèn)識(shí)和理解咪惠？ 答：在虛擬機(jī)中击吱，當(dāng)一個(gè)線程如果沒(méi)有顯式處理（即 try catch）異常而拋出時(shí)會(huì)將該異常事件...
-
num.streams是什么意思。遥昧。覆醇。
Kafka的分區(qū)數(shù)和消費(fèi)者個(gè)數(shù)
Kafka的分區(qū)數(shù)是不是越多越好？ 分區(qū)多的優(yōu)點(diǎn) kafka使用分區(qū)將topic的消息打散到多個(gè)分區(qū)分布保存在不同的broker上炭臭，實(shí)現(xiàn)了producer和consumer消...
-
企鵝玩偶廠仔
-
面試題——Java 類加載/創(chuàng)建對(duì)象的過(guò)程簡(jiǎn)潔回答： 第一步鞋仍，判斷常量池是否能定位類的符號(hào)引用常摧，并且檢查這個(gè)符號(hào)引用代表的類是否被加載、解析威创、初始化過(guò)落午。如果沒(méi)有則執(zhí)行第一步，如果有則執(zhí)行第二步 第二步類加載和初始化(...
-
沒(méi)有符號(hào)引用肚豺，就表示沒(méi)有加載過(guò)類嗎溃斋。。是不是不太對(duì)啊吸申。梗劫。。
面試題——Java 類加載/創(chuàng)建對(duì)象的過(guò)程
簡(jiǎn)潔回答： 第一步截碴，判斷常量池是否能定位類的符號(hào)引用梳侨，并且檢查這個(gè)符號(hào)引用代表的類是否被加載、解析日丹、初始化過(guò)走哺。如果沒(méi)有則執(zhí)行第一步，如果有則執(zhí)行第二步 第二步類加載和初始化(...
