Java实现读取canal中binlog数据

104 阅读 0 评论 69 点赞

我是靠谱客的博主迷人往事，这篇文章主要介绍Java实现读取canal中binlog数据，现在分享给大家，希望可以做个参考。

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
package we.com.canal;

import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.client.CanalConnectors;
import com.alibaba.otter.canal.common.utils.AddressUtils;
import com.alibaba.otter.canal.protocol.CanalEntry.RowData;
import com.alibaba.otter.canal.protocol.CanalEntry.EventType;
import com.alibaba.otter.canal.protocol.CanalEntry.RowChange;
import com.alibaba.otter.canal.protocol.CanalEntry.EntryType;
import com.alibaba.otter.canal.protocol.CanalEntry.Entry;
import com.alibaba.otter.canal.protocol.CanalEntry.Column;
import com.alibaba.otter.canal.protocol.Message;
import java.net.InetSocketAddress;
import java.util.List;

/**
 * @author yangxin_ryan
 * 代码实现了读取canal中采集过来的mysql的binlog日志
 */
public class SimpleCanalClientExample {

    public static void main(String[] args) {
        // 参数分别为IP，port, 对应的destination(数据库的名字)，username, password
        CanalConnector connector = CanalConnectors.