2.4.1、Canal + TCP 集成

Canal 配置和启动

Canal Server下载

• 官方文档：https://github.com/alibaba/canal/wiki
• 项目地址：https://github.com/alibaba/canal
• 下载地址：https://github.com/alibaba/canal/releases

进入下载地址，选择 canal.deployer-1.1.5.tar.gz

Canal Server配置

需要配置的东西就两项，一个是监听数据库配置，另一个是 RocketMQ 连接配置。
改动的两个文件分别是 Canal 配置文件 canal.properties 和 实例配置文件 instance.properties

注意：一个 Server 可以配置多个实例监听 ，Canal 功能默认自带的有个 example 实例，本篇就用 example 实例 。如果增加实例，复制 example 文件夹内容到同级目录下，然后在 canal.properties 指定添加实例的名称。

配置 Canal 服务方式为 TCP 和 并配置 RocketMQ 连接信息：

# tcp, kafka, rocketMQ, rabbitMQ, pulsarMQ
canal.serverMode = tcp

修改 instance 配置文件 conf/example/instance.properties ，配置监听数据库信息：

# position info
canal.instance.master.address=192.168.3.25:4408
canal.instance.master.journal.name=mysql-bin.000003
canal.instance.master.position=68977681
canal.instance.master.timestamp=
canal.instance.master.gtid=

# username/password
canal.instance.dbUsername=canal
canal.instance.dbPassword=canal
canal.instance.connectionCharset = UTF-8

这里注意如下几个东西，其他的不用管

• master.address ：Mysql的地址，我的端口是3307，默认是3306
• dbUsername ：上面开通的Mysql用户
• dbPassword ： 密码
• ccanal.instance.filter.regex ： 要同步的表，多个表用逗号隔开