Alibaba Canal 组件

[TOC]

Canal Server 部署

canal server 安装包下载,当前(2019-10-10)最新稳定版本为1.1.4

我们直接下载 canal.deployer

直接在 Aliyun ECS 中下载,有神秘下载速度加成

wget https://github.com/alibaba/canal/releases/download/canal-1.1.4/canal.deployer-1.1.4.tar.gz

解压 canal.deployer 到指定目录:

mkdir /data/canal/canal.deployer-1.1.4
tar -zcvf canal.deployer-1.1.4.tar.gz -C /data/canal/canal.deployer-1.1.4

更改 /etc/my.cnf 配置,开启 MySQL bin-log 功能。

(因为我用的是 wamp,在配置文件my.ini中,默认的项目是[wampmysqld],应该新建[mysqld]后再配置)

[mysqld]
# 用于mysql主从复制功能,注意要与 canal 的 slave_id 区分
server_id=1

# Enable MySQL Binlog
log-bin=mysql-bin
binlog-format=ROW

# 可选项,指定要开启 binlog 的db。比如这里我想只对 ffss 库开启binlog
binlog-do-db=ffss

重启 service mysqld restart,查看更新后的状态

show variables like 'log_bin'; # `ON` 表示开启了binlog
show variables like 'binlog_format'; # `ROW`
select version();

canal 的原理是将自己模拟为 MySQL 的 slave,所以一定需要提前做好一个 MySQL slave 的相关权限配置

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

# 针对已有的账户可通过grants查询权限
show grants for 'canal';

canal.deployer 目录结构:

drwxr-xr-x 2 root root 4096 Oct 10 09:02 bin
drwxr-xr-x 5 root root 4096 Oct 10 09:02 conf
drwxr-xr-x 2 root root 4096 Oct 10 09:02 lib
drwxrwxrwx 2 root root 4096 Sep  2 15:26 logs

canal/conf 目录结构(tree 命令):

├── canal_local.properties
├── canal.properties
├── example
│   └── instance.properties
├── logback.xml
├── metrics
│   └── Canal_instances_tmpl.json
└── spring
    ├── base-instance.xml
    ├── default-instance.xml
    ├── file-instance.xml
    ├── group-instance.xml
    ├── memory-instance.xml
    └── tsdb
        ├── h2-tsdb.xml
        ├── mysql-tsdb.xml
        ├── sql
        │   └── create_table.sql
        └── sql-map
            ├── sqlmap-config.xml
            ├── sqlmap_history.xml
            └── sqlmap_snapshot.xml

Canal.Admin 可视化 WebUI 组件

下载

wget https://github.com/alibaba/canal/releases/download/canal-1.1.4/canal.admin-1.1.4.tar.gz

解压缩

mkdir /data/canal/canal-admin
tar zxvf canal.admin-1.1.4.tar.gz  -C /data/canal/canal-admin

修改配置

vi conf/application.yml

application.yml

server:
  port: 8089
spring:
  jackson:
    date-format: yyyy-MM-dd HH:mm:ss
    time-zone: GMT+8

spring.datasource:
  address: 127.0.0.1:3306
  database: canal_manager
  username: canal
  password: canal
  driver-class-name: com.mysql.jdbc.Driver
  url: jdbc:mysql://${spring.datasource.address}/${spring.datasource.database}?useUnicode=true&characterEncoding=UTF-8&useSSL=false
  hikari:
    maximum-pool-size: 30
    minimum-idle: 1

canal:
  adminUser: admin
  adminPasswd: admin

初始化 Canal Admin manager SQL脚本

mysql -h127.0.0.1 -uroot -p
source conf/canal_manager.sql

访问

http:/127.0.0.1:8089/

默认账号:admin/123456

canal admin 配合 canal server 使用

在 canal-server 端,使用 canal_local.properties 覆盖 canal.properties

# register ip
canal.register.ip =

# canal admin config
canal.admin.manager = 127.0.0.1:8089
canal.admin.port = 11110
canal.admin.user = admin
canal.admin.passwd = 4ACFE3202A5FF5CF467898FC58AAB1D615029441
# admin auto register
canal.admin.register.auto = true
canal.admin.register.cluster =

如果不想更改 canal.properties 配置,也可以使用启动参数

sh canal/bin/startup.sh local
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 定位 基于数据库增量日志解析,提供增量数据订阅和消费 工作原理 canal 模拟 MySQL slave 的交互协...
    EmmaQin阅读 7,480评论 0 4
  • canal: 1.配置mysql canal的原理是基于mysql binlog技术,所以这里一定需要开启mysq...
    AppleBiscuits阅读 8,785评论 8 6
  • 一 高可用架构设计 配置说明:zookeeper x 3 + canal x 2 + mysql x 2 组件说明...
    GuangHui阅读 2,392评论 1 7
  • 业务场景描述 在我们的项目中有些配置信息持久化在数据库中,这些配置信息又是在系统启动后自动加载并缓存在local或...
    点融黑帮阅读 14,588评论 2 20
  • 最近几天一直在感冒 头疼, 嗜睡, 腰疼,后背也疼 而且咳嗽,痰少 昏昏沉沉睡了两天,入夜依旧困乏 照照镜子,感觉...
    紫陌97阅读 323评论 0 0