canal-client和canal-server

Posted 2021-02-21 softidea

 

概述

canal client将从canal server获取的binlog数据以json格式发送到各种MQ中(rabbitmq，redis，kafka)。
部署

第一步：下载解压项目，使用的是与canal-server 1.0.22版本对应的client（canal-client-1.0.22.tar.gz）：

项目git地址：https://github.com/BooksCup/canal-client

第二步：配置项目

conf/canal.properties

    # canal server的IP
    canal.server.host = 192.168.0.51
    # canal server的port
    canal.server.port = 11111
    # canal server的实例
    canal.server.instance = example
    # canal binlog的地址
    canal.binlog.dir = data
     
    # mq选项(rabbitmq,redis,kafka),这边使用的是rabbitmq
    canal.mq = rabbitmq
     
    #rabbitmq
    rabbitmq.host = 192.168.0.51
    rabbitmq.port = 5672
    rabbitmq.user = guest
    rabbitmq.pass = guest
    # 队列名
    rabbitmq.queuename = canal_binlog_data
    # 是否持久化
    rabbitmq.durable = y
    # 是否ack
    rabbitmq.ack = n
    # 交换机类型
    rabbitmq.exchange.type = fanout
    # 交换机名
    rabbitmq.exchange.name = wd.basic.data.sync.exchange
    rabbitmq.routing.key=

第三步：启动client

sh bin/client.sh start
————————————————
版权声明：本文为CSDN博主「Python_5S」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/Python_5S/java/article/details/90374123