CDC 模式介绍

CDC 模式用于实时数据同步，oblogproxy 在 CDC 模式下可以订阅 OceanBase 数据库中的数据变更（需配合 oblogclient 来完成数据订阅），并将这些数据变更实时同步至下游服务，实现数据的实时或准实时复制和同步。

基本原理

首先，介绍您在使用 CDC 模式时需要知道的一些名词解释。

• OceanBase：OceanBase 数据库集群。
• oblogproxy：OceanBase 增量日志代理服务。
• oblogclient：OceanBase 日志客户端。（有关于更多内容请参见 oblogclient）
• CDC 生态工具：泛指基于 oblogclient 已对接 oblogproxy 的 CDC 生态工具，如 Flink-CDC 等。
• oblogreader：oblogproxy 子进程，拉取并解析 clog，再按照一定的数据格式发送至下游（即，oblogclient 或其他基于 oblogclient 的 CDC 生态工具）。

基本架构

由上图可以看出，CDC 模式需要与 OceanBase 数据库和 oblogclient 来一起配合使用，主要分为以下几个步骤：

• 第一步，oblogclient 启动后需要发送消息到 oblogproxy，需指定要订阅的 OceanBase 数据库的账户名密码、库表、增量链路位点等信息（oblogproxy 本身是无状态的，订阅的哪个 OceanBase，哪个库表需要由 oblogclient 来传入）。
• 第二步，oblogproxy 收到来自客户端的请求后，首先对要已订阅的 OceanBase 数据库进行鉴权等操作，若不通过则返回给客户端失败原因，若通过，则启动 oblogreader 子进程，并在启动时将连接等相关信息传递至 oblogreader 子进程。
• 第三步，oblogreader 启动后会拉取并解析 clog，按照一定的数据格式发送至下游来完成数据订阅。