登录 注册
开源 企业版 高校版 私有云 Gitee AI NEW
扫描微信二维码支付
取消
支付完成
Watch
不关注 关注所有动态 仅关注版本发行动态 关注但不提醒动态
1 Star 0 Fork 0

OceanBase / tutorials-doc

代码 Issues 0 Pull Requests 0 Wiki 统计 流水线
服务
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目，私有仓库也完全免费 ：）
免费加入
该仓库未声明开源许可证文件（LICENSE），使用请关注具体项目描述及其代码上游依赖。
项目仓库所选许可证以仓库主分支所使用许可证为准
克隆/下载
12.4-11-how-to-use-canal-to-synchronize-ob-data-to.md 9.80 KB
一键复制 编辑 原始数据 按行查看 历史
obdev 提交于 2022-11-11 08:10 . 优化

4.11 如何使用 Canal 将 OceanBase 数据实时同步到 MySQL

什么是 CDC

CDC 全称是 Change Data Capture，即变更数据捕获。

为什么需要 CDC 功能

CDC 能够帮助识别上次提取之后发生变化的数据。CDC 提供的数据可以做很多事情，比如：做历史库、做近实时缓存、提供给消息队列（MQ），用户消费 MQ 做分析和审计等。

OceanBase CDC 实现逻辑

oblogproxy 是 OceanBase 数据库的增量日志代理服务。基于 liboblog，以服务的形式提供实时增量链路接入和管理能力，方便应用接入 OceanBase 增量日志。能够解决在网络隔离的情况下，订阅增量日志的需求，并提供多种链路接入方式。

Canal 是开源 MySQL 数据库 Binlog 的增量订阅和消费组件，基于 MySQL 数据库的增量日志解析，可以用于数据同步。

数据链路：

ob_cluster -> oblogreader -> oblogmsg -> canal_server -> canal_client -> mysql

组件介绍：

  • liboblog 是 OceanBase CDC 的基本组件，liboblog 衍生出 oblogproxy，liboblog 依赖 oblogmsg。

  • liboblog 是 C++ 动态库，将从 OceanBase 集群中拉到的增量日志按事务提交顺序向外透出，透出的方式是按 LogMessage 协议创建相关对象给使用方使用。

  • ObLogReader 对 liboblog 的 C++ 封装，在 liboblog 的基础上，对创建出的 LogMessage 对象适配多种序列化输出。

  • logproxy 增量日志代理，并不对增量数据进行转发，而只是对新建连接请求创建对应的 oblogreader 子进程，并由该 oblogreader 子进程通过该连接直接向客户端发送按 LogMessage 序列化后的增量日志记录。LogProxy 用于对同机器上所有 ObLogReader 子进程的生命周期进行管理。

  • logclient 对字节流按 LogMessage 协议反序列化后生成 LogMessage 对象给使用方调用，比如和 canal 对接。

安装 oblogproxy

  • 下载 oblogproxy rpm 包

    下载地址为：https://github.com/oceanbase/oblogproxy/releases/tag/v1.0.0

  • 安装 oblogproxy

    yum install oblogproxy-1.0.0-1.el7.x86_64.rpm

  • 确认 oblogproxy 依赖，重点是确认有 liboblog。

    [root@172.xx.xxx.49 ~]$cd /usr/local/oblogproxy/

[root@172.xx.xxx.49 oblogproxy]$ldd ./bin/logproxy
linux-vdso.so.1 =>  (0x00007fffe68fe000)
liboblog.so.1 => /lib/liboblog.so.1 (0x00002ae0113f1000)
libpthread.so.0 => /lib64/libpthread.so.0 (0x00002ae046bf8000)
libdl.so.2 => /lib64/libdl.so.2 (0x00002ae046e14000)
librt.so.1 => /lib64/librt.so.1 (0x00002ae047018000)
libm.so.6 => /lib64/libm.so.6 (0x00002ae047220000)
libc.so.6 => /lib64/libc.so.6 (0x00002ae047522000)
/lib64/ld-linux-x86-64.so.2 (0x00002ae0111cd000)
libaio.so.1 => /lib64/libaio.so.1 (0x00002ae0478f0000)

启动 oblogproxy

修改 oblogproxy 参数

  • 生成加密用户和对应的密码

    [root@172.xx.xxx.49 bin]$pwd
/usr/local/oblogproxy/bin

[root@172.xx.xxx.49 bin]$./logproxy -x root@sys
EA87*****************E1556E917

[root@172.xx.xxx.49 bin]$./logproxy -x Root@2021
8852D*****************A9D8FD52

  • 修改对应的 conf.json 参数

    [root@172.xx.xxx.49 conf]$pwd
/usr/local/oblogproxy/conf

[root@172.xx.xxx.49 conf]$ls -l
总用量 4
-rw-r--r-- 1 root root 1081 10月 25 18:00 conf.json

# 修改conf.json的内容  
"ob_sys_username": "EA87*****************E1556E917",
"ob_sys_password": "8852D*****************A9D8FD52",

  • 启动 oblogproxy

    [root@172.xx.xxx.49 oblogproxy]$./run.sh start
work path : /usr/local/oblogproxy
is_running : (8252)/usr/local/oblogproxy logproxy is running !
logproxy started!

  • 启停 obproxy 和查看状态

    • 启动 oblogproxy

      [root@172.xx.xxx.49 oblogproxy]$pwd
/usr/local/oblogproxy
[root@172.xx.xxx.49 oblogproxy]$./run.sh start

    • 停止 oblogproxy

      [root@172.xx.xxx.49 oblogproxy]$pwd
/usr/local/oblogproxy
[root@172.xx.xxx.49 oblogproxy]$./run.sh stop

    • 查看 oblogproxy 状态

      [root@172.xx.xxx.49 oblogproxy]$pwd
/usr/local/oblogproxy
[root@172.xx.xxx.49 oblogproxy]$./run.sh status

说明：

oblogproxy 启动成功后进程确认。

[root@172.xx.xxx.49 ~]$ps -ef | grep logproxy | grep -v grep
root     26379 26373  0 10:45 pts/1    00:00:00 ./bin/logproxy -f ./conf/conf.json
[root@172.xx.xxx.49 ~]$

当有一个 client 连接成功后会 fork 一个子进程。

[root@172.xx.xxx.49 ~]$ps -ef | grep oblogreader | grep -v grep
root     26386 26379  2 10:45 pts/1    00:00:17 oblogreader    -f ./conf/conf.json

canal server

下载 canal-for-ob。canal-for-ob 详细信息请参考 canal-for-ob GitHub 仓库。

修改 /opt/canal_ob/canal.deployer-for-ob-rc1/conf/canal.properties。

canal.zkServers = 172.xx.xxx.47:12181,172.xx.xxx.48:12181,172.xx.xxx.49:12181
canal.serverMode = tcp
canal.destinations = obtest2
canal.instance.global.spring.xml = classpath:spring/ob-default-instance.xml

canal instance

[root@172.xx.xxx.49 conf]$ll
总用量 28
-rwxr-xr-x 1 root root  319 10月 21 16:15 canal_local.properties
-rwxr-xr-x 1 root root 6577 10月 26 16:21 canal.properties
-rwxr-xr-x 1 root root 3592 10月 21 16:15 logback.xml
drwxrwxrwx 2 root root 4096 10月 21 16:15 metrics
drwxr-xr-x 2 root root 4096 12月  7 13:29 obtest2  -- 将 example 修改为 obtest2
drwxrwxrwx 3 root root 4096 11月  2 10:51 spring
[root@172.xx.xxx.49 obtest2]$pwd
/opt/canal_ob/canal.deployer-for-ob-rc1/conf/obtest2
[root@172.xx.xxx.49 obtest2]$ll
total 16
-rwxrwxrwx 1 root root 1147 Jan 13 17:15 ca.crt
-rwxrwxrwx 1 root root 1241 Jan 13 17:15 client.crt
-rwxrwxrwx 1 root root 1708 Jan 13 17:15 client.key
-rwxr-xr-x 1 root root 1743 Feb 13 17:15 instance.properties
-rwxr-xr-x 1 root root 1743 Feb 13 17:15 ob-instance.properties

# 删除 instance.properties，将 ob-instance.properties 重命名为 instance.properties

[root@172.xx.xxx.49 obtest2]$cat instance.properties
# oceanbase集群参数
canal.instance.oceanbase.rsList=172.xx.xxx.49:2882:2881;172.xx.xxx.47:2882:2881
canal.instance.oceanbase.username=root@tenant#obcluster
canal.instance.oceanbase.password=Ro******21
canal.instance.oceanbase.startTimestamp=0

# oceanbase logproxy参数
canal.instance.oceanbase.logproxy.address=127.0.0.1:2983
canal.instance.oceanbase.logproxy.sslEnabled=false
canal.instance.oceanbase.logproxy.serverCert=../conf/${canal.instance.destination:}/ca.crt
canal.instance.oceanbase.logproxy.clientCert=../conf/${canal.instance.destination:}/client.crt
canal.instance.oceanbase.logproxy.clientKey=../conf/${canal.instance.destination:}/client.key

# 是否要在库名中去掉租户前缀。logproxy 输出的日志中库名默认为 [tenant].[db]
canal.instance.parser.excludeTenantInDbName=true
canal.instance.oceanbase.tenant=test_tenant

# 日志过滤。格式为 [tenant].[database].[table]，支持正则
canal.instance.filter.regex=test_tenant.db1.*

启动 canal server

[root@172.xx.xxx.49 ~]$cd /opt/canal_ob
[root@172.xx.xxx.49 canal_ob]$cd canal.deployer-for-ob-rc1
[root@172.xx.xxx.49 canal.deployer-for-ob-rc1]$cd bin
[root@172.xx.xxx.49 bin]$ls -lrt
总用量 20
-rwxr-xr-x 1 root root 1244 10月 21 16:15 startup.bat
-rwxr-xr-x 1 root root 1356 10月 21 16:15 stop.sh
-rwxr-xr-x 1 root root 3167 10月 21 16:15 startup.sh
-rwxr-xr-x 1 root root  226 10月 21 16:15 restart.sh
-rw-r--r-- 1 root root    6 12月  7 10:42 canal.pid
[root@172.xx.xxx.49 bin]$./startup.sh

canal client

下载 canal-for-ob。更多信息，参考 canal-for-ob GitHub 仓库。

[root@172.xx.xxx.49 conf]$pwd
/opt/canal_ob/canal_adapter_for_ob/conf
[root@172.xx.xxx.49 conf]$ls -lrt
总用量 44
-rwxr-xr-x 1 root root 2172 10月 21 16:15 logback.xml
drwxrwxrwx 2 root root 4096 10月 21 16:15 tablestore
drwxr-xr-x 2 root root 4096 10月 21 16:15 hbase
drwxr-xr-x 2 root root 4096 10月 21 16:15 kudu
drwxrwxrwx 2 root root 4096 10月 21 16:15 META-INF
drwxr-xr-x 2 root root 4096 10月 21 16:15 es6
-rwxr-xr-x 1 root root  170 10月 21 16:15 bootstrap.yml
-rwxr-xr-x 1 root root  552 10月 21 16:15 mytest_user.yml
drwxr-xr-x 2 root root 4096 10月 21 16:15 es7
-rwxr-xr-x 1 root root 3240 10月 26 16:26 application.yml
drwxrwxrwx 2 root root 4096 12月  7 10:27 rdb
[root@172.xx.xxx.49 conf]$cat application.yml
canalAdapters:
  - instance: obtest2# canal instance Name or mq topic name
    groups:
    - groupId: g1
      outerAdapters:
      - name: logger
      - name: rdb
        key: mysql1
        properties:
          jdbc.driverClassName: com.mysql.jdbc.Driver
          jdbc.url: jdbc:mysql://172.xx.xxx.49:3367/mysql?useUnicode=true&useSSL=false
          jdbc.username: root
          jdbc.password: Ro******21

修改适配器库/表映射（以库映射为例）

[root@172.xx.xxx.49 conf]$pwd
/opt/canal_ob/canal_adapter_for_ob/conf
[root@172.xx.xxx.49 conf]$ls -l rdb
总用量 4
-rwxr-xr-x 1 root root 186 12月  6 21:11 mytest_user.yml
## Mirror schema synchronize config
dataSourceKey: defaultDS
destination: obtest2
groupId: g1
outerAdapterKey: mysql1
concurrent: true
dbMapping:
  mirrorDb: true
  database: db1

启动 canal client

[root@172.xx.xxx.49 bin]$pwd
/opt/canal_ob/canal_adapter_for_ob/bin

[root@172.xx.xxx.49 bin]$ls -lrt
总用量 16
-rwxr-xr-x 1 root root 2289 10月 21 16:15 startup.sh
-rwxr-xr-x 1 root root  793 10月 21 16:15 startup.bat
-rwxr-xr-x 1 root root  205 10月 21 16:15 restart.sh
-rwxr-xr-x 1 root root 1370 10月 21 16:15 stop.sh
[root@172.xx.xxx.49 bin]$./startup.sh

在 OceanBase 源端写入数据，在 MySQL 目标端查看数据同步。

1
https://gitee.com/oceanbase/tutorials-doc.git
git@gitee.com:oceanbase/tutorials-doc.git
oceanbase
tutorials-doc
tutorials-doc
V1.0.0
点此查找更多帮助

搜索帮助

Git 命令在线学习 如何在 Gitee 导入 GitHub 仓库
Git 仓库基础操作
企业版和社区版功能对比
SSH 公钥设置
如何处理代码冲突
仓库体积过大，如何减小？
如何找回被删除的仓库数据
Gitee 产品配额说明
GitHub仓库快速导入Gitee及同步更新
什么是 Release（发行版）
将 PHP 项目自动发布到 packagist.org
评论
仓库举报
回到顶部