参考文档

阿里Canal部署安装小白教程
canal原理的一些学习-1（canal的一些原理性介绍）

修改mysql配置

对于自建 MySQL , 需要先开启 Binlog 写入功能，配置 binlog-format 为 ROW 模式，修改mysql的my.cnf文件

找到 mysql的my.cnf文件：

 mysql –help | grep my.cnf 

修改 /etc/my.cnf 文件 ：

vim /etc/my.cnf

添加一下配置：

log-bin=mysql-bin # 开启 binlog
binlog-format=ROW # 选择 ROW 模式
server_id=1 # 配置 MySQL replaction 需要定义，不要和 canal 的 slaveId 重复

mysql添加canal用户

mysql用户创建可查看mysql创建用户

CREATE USER canal IDENTIFIED BY 'canal';  
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'canal'@'%';
FLUSH PRIVILEGES;

安装canal

下载canal

点击 canal 下载canal

上传 canal.deployer-1.1.5-SNAPSHOT.tar.gz 到linux服务器，解压文件

mkdir /tmp/canal
tar zxvf canal.deployer-$version.tar.gz  -C /tmp/canal

解压后可以看到一下目录：
conf 配置文件
logs 日志
bin 启动，停止，重启等sh,bat文件
…

配置修改

vim /tmp/canal/conf/example/instance.properties

## mysql serverId ，唯一就行
canal.instance.mysql.slaveId = 1234
#position info，需要改成自己的数据库信息
canal.instance.master.address = 127.0.0.1:3306 
canal.instance.master.journal.name = 
canal.instance.master.position = 
canal.instance.master.timestamp = 
#canal.instance.standby.address = 
#canal.instance.standby.journal.name =
#canal.instance.standby.position = 
#canal.instance.standby.timestamp = 
#username/password，需要改成自己的数据库信息
canal.instance.dbUsername = canal  
canal.instance.dbPassword = canal
canal.instance.defaultDatabaseName =
canal.instance.connectionCharset = UTF-8
#table regex
canal.instance.filter.regex = .\*\\\\..\*

启动

sh  /tmp/canal/bin/startup.sh

查看日志

 tail -n 500 /tmp/canal/logs/canal/canal.log

没报错就是启动成功。但canal启动成功，不代表 example 启动成功。还需要查看 example 的运行日志。

 tail -n 500 /tmp/canal/logs/example/example.log

没报错就代表启动成功了

开发canal的防火墙端口

firewall-cmd --zone=public --add-port=11111/tcp --permanent
firewall-cmd --reload

java简单实例

import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.client.CanalConnectors;
import com.alibaba.otter.canal.protocol.CanalEntry.Entry;
import com.alibaba.otter.canal.protocol.CanalEntry.EntryType;
import com.alibaba.otter.canal.protocol.CanalEntry.RowChange;
import com.alibaba.otter.canal.protocol.Message;import java.net.InetSocketAddress;
import java.util.List;public class CanalClient {public static void main(String[] args) {new Thread(() -> initConnector("example")).start();}private static void initConnector(String destination) {CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress("192.168.16.128", 11111), destination, "", "");try {System.out.println("初始化成功");connector.connect();connector.subscribe(".*\\..*");connector.rollback();while (true) {Message message = connector.getWithoutAck(1000);if (message.getId() != -1 && message.getEntries().size() > 0) {printEntry(message.getEntries());}connector.ack(message.getId());}} finally {connector.disconnect();}}private static void printEntry(List<Entry> entries) {for (Entry entry : entries) {if (entry.getEntryType() == EntryType.TRANSACTIONBEGIN || entry.getEntryType() == EntryType.TRANSACTIONEND) {continue;}try {RowChange rowChange = RowChange.parseFrom(entry.getStoreValue());System.out.println(rowChange.getSql());} catch (Exception e) {throw new RuntimeException("ERROR ## parser error, data:" + entry.toString(), e);}}}
}