使用 Docker 部署 canal,并将消息推送到 RabbitMQ
canal
alibaba/canal: Canal 是由阿里巴巴开源的分布式数据库同步系统,主要用于实现MySQL数据库的日志解析和实时增量数据订阅与消费,广泛应用于数据库变更消息的捕获、数据迁移、缓存更新等场景。
项目地址:https://gitcode.com/gh_mirrors/ca/canal
免费下载资源
·
配置 canal
1. 拉取镜像
docker pull canal/canal-server:latest
2. 启动容器
docker run -d canal/canal-server:latest
3. 从容器中拷贝出配置文件
docker cp 容器名或者容器ID:/home/admin/canalserver/conf/canal.properties ./conf/
docker cp 容器名或者容器ID:/home/admin/canal-server/conf/test/instance.properties ./conf/
4. 修改 canal.properties 文件,配置输出到 RabbitMQ,有以下几处要改:
##################################################
######### RabbitMQ #############
##################################################
rabbitmq.host = 127.0.0.1
rabbitmq.exchange = exchange.canal
rabbitmq.username = guest
rabbitmq.password = guest
5.修改 instance.properties 文件:
# position info
# MySQL 地址 + 端口
canal.instance.master.address=127.0.0.1:3306
# 数据库账号密码
canal.instance.dbUsername=root
canal.instance.dbPassword=root
# 监听的数据库表
canal.instance.filter.regex=test.user
# mq config
# RabbitMQ Routing key
canal.mq.topic=canal-routing-key
6. docker-compose 文件
version: "3.8"
services:
canal-server:
image: canal/canal-server:latest
container_name: canal-server
restart: unless-stopped
# host 网络模式只对 Docker 17.06 以及更高版本的 swarm 服务可用
network_mode: bridge
ports:
- 11111:11111
volumes:
- ./conf/canal.properties:/home/admin/canal-server/conf/canal.properties
- ./conf/instance.properties:/home/admin/canal-server/conf/test/instance.properties
- ./log/:/home/admin/canal-server/logs/
7. 启动服务
ocker-compose up -d
注意:发现启动服务失败,别担心,需要配置一下RabbitMQ
配置 RabbitMQ
1. 新建exchange
2. 新建队列
3. 绑定队列
4. 注意
- 第3步一定要与canal.properties配置文件
rabbitmq.exchange = exchange.canal
一致 - 第4步一定要与instance.properties配置文件
canal.mq.topic=canal-routing-key
一致
完整配置文件
地址:https://gitee.com/dadeity/docker.git
GitHub 加速计划 / ca / canal
28.22 K
7.57 K
下载
alibaba/canal: Canal 是由阿里巴巴开源的分布式数据库同步系统,主要用于实现MySQL数据库的日志解析和实时增量数据订阅与消费,广泛应用于数据库变更消息的捕获、数据迁移、缓存更新等场景。
最近提交(Master分支:2 个月前 )
1e5b8a20 - 2 个月前
ff82fd65
2 个月前
更多推荐
已为社区贡献5条内容
所有评论(0)