前言 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í)行第二步 第二步類加載和初始化(...
