canal的安装请参考:canal系列—Linux下的安装配置(快速开始)
[root@localhost canal]# vim conf/canal.properties
#################################################
######### common argument ############# ################################################# canal.id= 128 # 指定唯一的server id canal.ip= 192.168.134.128 # 指定本机的ip地址,即canal所在机器的ip地址 canal.port= 11111 # 指定监听的端口
[root@localhost canal]# ./bin/startup.sh
查看日志信息:
[root@localhost canal]# vim logs/canal/canal.log
可以看到,服务启动成功,并且监听在我们配置地址上。
下载阿里提供的一个客户端例子:https://github.com/alibaba/canal/archive/canal-1.0.19.zip,导入到Eclipse中。
打开类 com.alibaba.otter.canal.example.SimpleCanalClientTest ,修改 ip 地址为 canal 中配置的 ip 地址
首先启动Canal Server。
启动Canal Client后,从控制台看不到任何输出信息(此时代表当前数据库无变更数据),说明没有报错,并且正在监听。
在 test 数据库中执行如下语句:
CREATE TABLE `xdual` ( `ID` INT (11) NOT NULL AUTO_INCREMENT, `X` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY (`ID`) ) ENGINE = INNODB AUTO_INCREMENT = 3 DEFAULT CHARSET = utf8;
insert into xdual(id,x) values(null,now());
可以从控制台中看到:
****************************************************
* Batch Id: [3] ,count : [1] , memsize : [271] , Time : 2017-12-13 09:43:07
* Start : [mysql-binlog.000003:443:1513129388000(2017-12-13 09:43:08)]
* End : [mysql-binlog.000003:443:1513129388000(2017-12-13 09:43:08)]
****************************************************
----------------> binlog[mysql-binlog.000003:443] , name[test,xdual] , eventType : CREATE , executeTime : 1513129388000 , delay : -934ms
sql ----> CREATE TABLE `xdual` (
`ID` INT (11) NOT NULL AUTO_INCREMENT,
`X` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
PRIMARY KEY (`ID`)
) ENGINE = INNODB AUTO_INCREMENT = 3 DEFAULT CHARSET = utf8
****************************************************
* Batch Id: [4] ,count : [3] , memsize : [155] , Time : 2017-12-13 09:43:13
* Start : [mysql-binlog.000003:714:1513129394000(2017-12-13 09:43:14)]
* End : [mysql-binlog.000003:888:1513129394000(2017-12-13 09:43:14)]
****************************************************
================> binlog[mysql-binlog.000003:714] , executeTime : 1513129394000 , delay : -967ms
BEGIN ----> Thread id: 11
----------------> binlog[mysql-binlog.000003:844] , name[test,xdual] , eventType : INSERT , executeTime : 1513129394000 , delay : -963ms
ID : 3 type=int(11)
X : 2017-12-13 09:43:14 type=timestamp ----------------
END ----> transaction id: 61
================> binlog[mysql-binlog.000003:888] , executeTime : 1513129394000 , delay : -958ms
版权说明 : 本文为转载文章, 版权归原作者所有 版权申明
原文链接 : https://blog.csdn.net/u012758088/article/details/78784337
内容来源于网络,如有侵权,请联系作者删除!