connect = factory.newConnection();

channel = connect.createChannel();

} catch (IOException | TimeoutException e) {

throw new CanalClientException(“Start RabbitMQ producer error”, e);

}

}

不過也是，截止2021年10月26日，canal官方推薦的正式版本仍然是1.1.4，對客戶端支持rabbitmq還沒有做足夠的支持。

二、最終方案

參考canal-client-springboot-starter自己構(gòu)建了一個easy-canal-client的項目。

源碼已開源：https://gitee.com/cowboy2014/easy-canal-client.git

架構(gòu)示意圖如下：

2-1 canal server升級1.1.5

canal需要升級為1.1.5，canal把binlog數(shù)據(jù)解析完成后，就把數(shù)據(jù)直接投遞給rabbitmq了——1.1.5可以把數(shù)據(jù)直接投遞給rabbitmq。

canal.properties參考配置：

tcp, kafka, rocketMQ, rabbitMQ

canal.serverMode = rabbitMQ

##################################################

######### RabbitMQ #############

##################################################

rabbitmq.host = 172.16.150.11

rabbitmq.virtual.host = /

rabbitmq.exchange = canal-exchange

rabbitmq.username = canal

rabbitmq.password = canal%123

rabbitmq.deliveryMode =

conf/example/instance.properties參考配置：

position info

canal.instance.master.address=172.16.150.12:3306

username/password

canal.instance.dbUsername=canal

canal.instance.dbPassword=canal%123

table regex

canal.instance.filter.regex=lpm-center\.lpm_(park|company|store|route)

mq config

canal.mq.topic=shangwt

2-2 業(yè)務(wù)模塊集成Rabbitmq

業(yè)務(wù)模塊直接集成rabbitmq，作為消費者進行數(shù)據(jù)的解析、同步。

2-2 使用方法

1. 新建Handler，用@CanalTable注解標(biāo)注

@Component

@CanalTable(value = “l(fā)pm_park”)

@Slf4j

public class ParkHandler implements EntryHandler {

@Resource

private ElSearchParkServiceImpl elSearchParkService;

@Resource

private EsIndexes esIndexes;

@Override

public void insert(Park park) {

log.info(“insert message {}”, park);

try {

elSearchParkService.synchronous(esIndexes.getPark(), park.getId());

} catch (IOException e) {

log.error(“es insert wrong!”);

}

}

@Override

public void update(Park before, Park park) {

try {

if (ObjectUtil.isNotEmpty(before.getDeleted()) && !before.getDeleted().equals(park.getDeleted()) && park.getDeleted() == 1){

this.delete(park);

}

if (ObjectUtil.isNotEmpty(before.getDeleted()) && !before.getDeleted().equals(park.getDeleted()) && park.getDeleted() == 0){

this.insert(park);

}

elSearchParkService.synchronous(esIndexes.getPark(), park.getId());

} catch (IOException e) {

log.error(“es insert wrong!”);

}

log.info(“update after {}”, park);

}

@Override

public void delete(Park park) {

log.info(“delete {}”, park);

elSearchParkService.deleteById(esIndexes.getPark(), park.getId().intValue());

}

}

自我介紹一下，小編13年上海交大畢業(yè)，曾經(jīng)在小公司待過，也去過華為、OPPO等大廠，18年進入阿里一直到現(xiàn)在。

深知大多數(shù)Java工程師，想要提升技能，往往是自己摸索成長或者是報班學(xué)習(xí)，但對于培訓(xùn)機構(gòu)動則幾千的學(xué)費，著實壓力不小。自己不成體系的自學(xué)效果低效又漫長，而且極易碰到天花板技術(shù)停滯不前！

因此收集整理了一份《2024年Java開發(fā)全套學(xué)習(xí)資料》，初衷也很簡單，就是希望能夠幫助到想自學(xué)提升又不知道該從何學(xué)起的朋友，同時減輕大家的負(fù)擔(dān)。

既有適合小白學(xué)習(xí)的零基礎(chǔ)資料，也有適合3年以上經(jīng)驗的小伙伴深入學(xué)習(xí)提升的進階課程，基本涵蓋了95%以上Java開發(fā)知識點，真正體系化！

由于文件比較大，這里只是將部分目錄截圖出來，每個節(jié)點里面都包含大廠面經(jīng)、學(xué)習(xí)筆記、源碼講義、實戰(zhàn)項目、講解視頻，并且會持續(xù)更新！

如果你覺得這些內(nèi)容對你有幫助，可以掃碼獲?。。。▊渥ava獲?。?/strong>

總結(jié)

其他的內(nèi)容都可以按照路線圖里面整理出來的知識點逐一去熟悉，學(xué)習(xí)，消化，不建議你去看書學(xué)習(xí)，最好是多看一些視頻，把不懂地方反復(fù)看，學(xué)習(xí)了一節(jié)視頻內(nèi)容第二天一定要去復(fù)習(xí)，并總結(jié)成思維導(dǎo)圖，形成樹狀知識網(wǎng)絡(luò)結(jié)構(gòu)，方便日后復(fù)習(xí)。

這里還有一份很不錯的《Java基礎(chǔ)核心總結(jié)筆記》，特意跟大家分享出來

目錄：

部分內(nèi)容截圖：

《一線大廠Java面試題解析+核心總結(jié)學(xué)習(xí)筆記+最新講解視頻+實戰(zhàn)項目源碼》，點擊傳送門即可獲取！
意跟大家分享出來

目錄：

[外鏈圖片轉(zhuǎn)存中…(img-MM2uKKGP-1712445281026)]

部分內(nèi)容截圖：

[外鏈圖片轉(zhuǎn)存中…(img-gQLoCbdp-1712445281026)]

[外鏈圖片轉(zhuǎn)存中…(img-s7oiW0m2-1712445281027)]
《一線大廠Java面試題解析+核心總結(jié)學(xué)習(xí)筆記+最新講解視頻+實戰(zhàn)項目源碼》，點擊傳送門即可獲取！文章來源地址http://www.zghlxwxcb.cn/news/detail-849932.html

到了這里，關(guān)于接過火炬，升級canal-client-springboot-starter，一個支持rabbitmq的CanalClient(1)的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！