前言 ThreadLocal解決了在多個(gè)線程針對(duì)一個(gè)變量維護(hù)不同值的功能，如果你想在同一個(gè)線程內(nèi)傳遞一些值详瑞，那么就可以用到這個(gè)類，它的好處是無侵入性坝橡，這樣我們就不需要再每個(gè)方...
發(fā)簡(jiǎn)信
IP屬地：浙江
-
transmittable-thread-local源碼分析 -
選舉leader的時(shí)間很短吧驳庭。。如果在15分鐘內(nèi)超過15%的節(jié)點(diǎn)都沒有正常心跳蹲堂，就會(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)衡。...
-
寫的挺好的~贊
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)聽 對(duì)于Kafka中Topic的數(shù)據(jù)消費(fèi)捌肴，我們一般都選擇使用消息監(jiān)聽器進(jìn)行消費(fèi)，怎么把消息監(jiān)聽器玩出花來呢哭靖，那就得看看它所實(shí)現(xiàn)的功能了具垫。Spring-Kafka中消息監(jiān)...
-
你好试幽，有個(gè)問題請(qǐng)教~，文中說：“RocketMQ采用混合型存儲(chǔ)結(jié)構(gòu)的缺點(diǎn)在于起宽，會(huì)存在較多的隨機(jī)讀操作济榨，因此讀的效率偏低”，但是消息都是在CommitLog的呀腐晾，而且通過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...
-
@花溪的小石頭 如果你覺得這些問題弱智懦趋，你應(yīng)該很吊哇仅叫，兄弟
螞蟻二面糙捺，面試官問我零拷貝的實(shí)現(xiàn)原理，當(dāng)場(chǎng)懵了…
Intellij IDEA 又過期了? 試試這個(gè) "狼哥洪灯，面試又跪了坎缭，碰到了知識(shí)盲區(qū)""哪個(gè)？""一面還可以签钩，二面面試官問我零拷貝的原理掏呼，懵逼了...這塊內(nèi)容沒去研究過""哦...
-
@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è)問題憎夷，意圖引起大家的思考 黑神簡(jiǎn)單解釋之后，群里仍有同學(xué)不太理解 正好之前筆者在Supplier上有一些實(shí)踐昧旨，因此打算跟大家分享一下使用經(jīng)驗(yàn) 基礎(chǔ)知識(shí)...
-
logback中拾给，“滿足輸出條件，才會(huì)執(zhí)行Lazy.toString()兔沃，即supplier.get().toString()” 哪里有蒋得，沒懂。粘拾。窄锅。??????
JDK1.8 Supplier實(shí)踐及總結(jié)
起因 群里黑神拋出了一個(gè)問題，意圖引起大家的思考 黑神簡(jiǎn)單解釋之后，群里仍有同學(xué)不太理解 正好之前筆者在Supplier上有一些實(shí)踐入偷，因此打算跟大家分享一下使用經(jīng)驗(yàn) 基礎(chǔ)知識(shí)...
-
666追驴， submit無法處理設(shè)置了UncaughtExceptionHandler的線程，以前沒注意疏之，現(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 解析
問：說說你對(duì) UncaughtExceptionHandler 的認(rèn)識(shí)和理解三椿？ 答：在虛擬機(jī)中，當(dāng)一個(gè)線程如果沒有顯式處理（即 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ì)象的過程簡(jiǎn)潔回答： 第一步鸦列，判斷常量池是否能定位類的符號(hào)引用，并且檢查這個(gè)符號(hào)引用代表的類是否被加載鹏倘、解析薯嗤、初始化過。如果沒有則執(zhí)行第一步纤泵，如果有則執(zhí)行第二步 第二步類加載和初始化(...
-
沒有符號(hào)引用骆姐，就表示沒有加載過類嗎镜粤。。是不是不太對(duì)啊玻褪。肉渴。。
面試題——Java 類加載/創(chuàng)建對(duì)象的過程
簡(jiǎn)潔回答： 第一步带射，判斷常量池是否能定位類的符號(hào)引用同规，并且檢查這個(gè)符號(hào)引用代表的類是否被加載、解析窟社、初始化過券勺。如果沒有則執(zhí)行第一步，如果有則執(zhí)行第二步 第二步類加載和初始化(...
