MySQL Canal 是一款開(kāi)源的基于 MySQL 數(shù)據(jù)庫(kù)增量日志解析和轉(zhuǎn)發(fā)的工具。它可以將 MySQL 數(shù)據(jù)庫(kù)的 Binlog 解析成指定的格式，支持多種輸出方式，比如 Kafka、RocketMQ、MQTT、ActiveMQ 等。

binlog 日志產(chǎn)生 → canal 獲取 binlog → 解析 binlog → 發(fā)送到指定的 MQ

使用 MySQL Canal 可以實(shí)現(xiàn)對(duì) MySQL 數(shù)據(jù)庫(kù)中數(shù)據(jù)的實(shí)時(shí)監(jiān)控，比如實(shí)時(shí)感知數(shù)據(jù)庫(kù)中的新增、修改、刪除等操作，并將這些操作同步到業(yè)務(wù)系統(tǒng)中。

下面是 MySQL Canal 常用的配置文件：

canal.instance.master.address = 127.0.0.1:3306
canal.instance.dbUsername = root
canal.instance.dbPassword = 123456
canal.instance.filter.regex = .*\\..*
canal.instance.filter.table.blacklist = demo\\.test1,demo\\.test2
canal.mq.topic = example
canal.mq.partition = 0

可以看到，MySQL Canal 的配置文件非常簡(jiǎn)單明了，其中 canal.instance.master.address 指定了 MySQL 數(shù)據(jù)庫(kù)的地址和端口號(hào)，canal.instance.dbUsername 和 canal.instance.dbPassword 指定了連接數(shù)據(jù)庫(kù)的用戶名和密碼。

使用 MySQL Canal 進(jìn)行監(jiān)控 MySQL 數(shù)據(jù)庫(kù)時(shí)，需要在 MySQL 中添加對(duì)應(yīng)的用戶權(quán)限，具體方法可以參照 MySQL Canal 的官方文檔。

MySQL Canal 作為一款成熟的業(yè)界解決方案，可以實(shí)現(xiàn)對(duì) MySQL 數(shù)據(jù)庫(kù)的高效監(jiān)控，針對(duì)大多數(shù)場(chǎng)景都可以直接使用。