1.mq原則 數(shù)據(jù)不能多,也不能少,不能多是說(shuō)消息不能重復(fù)消費(fèi),這個(gè)我們上一節(jié)已解決;不能少,就是說(shuō)不能丟失數(shù)據(jù)。如果mq傳遞的是非常核心的消息,支撐核心的業(yè)務(wù),那么這種場(chǎng)景...
1.mq原則 數(shù)據(jù)不能多,也不能少,不能多是說(shuō)消息不能重復(fù)消費(fèi),這個(gè)我們上一節(jié)已解決;不能少,就是說(shuō)不能丟失數(shù)據(jù)。如果mq傳遞的是非常核心的消息,支撐核心的業(yè)務(wù),那么這種場(chǎng)景...
jstack用法 jstack查看輸出 jstack統(tǒng)計(jì)線程數(shù) jstack檢測(cè)死鎖 死鎖代碼 死鎖日志 jstack檢測(cè)cpu高 步驟一:查看cpu占用高進(jìn)程 步驟二:查看...
為什么要手動(dòng)創(chuàng)建Topic 看過(guò)Spring-Kafka(二)這篇文章的三秒真男人會(huì)發(fā)現(xiàn),我們從到到尾都沒(méi)有創(chuàng)建過(guò)"topic.quick.demo"這個(gè)Topic,這是因?yàn)?..
目的 軟件需要使用什么技術(shù)都是按照業(yè)務(wù)邏輯來(lái)的嘛,那自動(dòng)轉(zhuǎn)發(fā)相對(duì)應(yīng)的業(yè)務(wù)可以是什么呢? 可以使用轉(zhuǎn)發(fā)功能實(shí)現(xiàn)業(yè)務(wù)解耦,系統(tǒng)A從Topic-A中獲取到消息,進(jìn)行處理后轉(zhuǎn)發(fā)到To...
定時(shí)啟動(dòng)的意義何在 如果只學(xué)習(xí)技術(shù)不討論其應(yīng)用范圍那就是在耍流氓啊,為了不做那個(gè)流氓,我還是犧牲一下色相吧在這里我舉一個(gè)定時(shí)啟動(dòng)的應(yīng)用場(chǎng)景:比如現(xiàn)在單機(jī)環(huán)境下,我們需要利用K...
消息監(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)...
1.并發(fā)編程領(lǐng)域的關(guān)鍵問(wèn)題 1.1 線程之間的通信 線程的通信是指線程之間以何種機(jī)制來(lái)交換信息。在編程中,線程之間的通信機(jī)制有兩種,共享內(nèi)存和消息傳遞。在共享內(nèi)存的并發(fā)模型里...
在上一章節(jié)中,我們配置啟動(dòng)了canal server,本節(jié)我們使用Java語(yǔ)言編寫(xiě)啟動(dòng)client端消費(fèi)server端同步過(guò)來(lái)的binlog數(shù)據(jù)。 1.添加依賴 2.核心Ap...
自學(xué)畫(huà)畫(huà)第九個(gè)月啦,已是深秋,所以這個(gè)月里,關(guān)于秋天的題材畫(huà)得多一些。 有友友問(wèn)我,是怎么學(xué)的。 無(wú)他,以勤補(bǔ)拙,多練習(xí)爾。現(xiàn)在依然保持每天畫(huà)畫(huà)的習(xí)慣,少則兩三小時(shí),多則五六...