【产品名称】
ObServer: 3.1.0
logproxy-client: 1.0.1
oblogproxy: 1.0.0
【问题描述】
测试的代码参照官网文档写的：OceanBase 社区
package com.clougence.cloudcanal.oceanbase.worker.reader.incre; import com.clougence.cloudcanal.base.service.task.util.JacksonUtil; import com.oceanbase.clogproxy.client.LogProxyClient; import com.oceanbase.clogproxy.client.config.ObReaderConfig; import com.oceanbase.clogproxy.client.exception.LogProxyClientException; import com.oceanbase.clogproxy.client.listener.RecordListener; import com.oceanbase.clogproxy.client.message.LogMessage; /** * @author wanshao create time is 2022/3/14 **/ public class ObLogProxyTestTest { public static void main(String[] args) { ObReaderConfig config = new ObReaderConfig(); // 设置OceanBase root server 地址列表，格式为（可以支持多个，用’;'分隔）：ip1:rpc_port1:sql_port1;ip2:rpc_port2:sql_port2 config.setRsList(“192.168.0.254:2882:2881”); // 设置用户名和密码（非系统租户） config.setUsername(“root”); config.setPassword(“root”); // 设置启动位点（UNIX时间戳，单位s）, 0表示从当前时间启动。 config.setStartTimestamp(0L); // 设置订阅表白名单，格式为：tenant.db.table, '*'表示通配. config.setTableWhiteList(“sys.cloudcanal_console.*”); // 指定oblogproxy服务地址，创建实例. LogProxyClient client = new LogProxyClient(“192.168.0.254”, 2983, config); // 添加 RecordListener client.addListener(new RecordListener() { @Override public void notify(LogMessage message) { // 处理消息 System.out.println("Receive msg "+ JacksonUtil.toJson(message)); } @Override public void onException(LogProxyClientException e) { // 处理错误 if (e.needStop()) { // 不可恢复异常，需要停止Client client.stop(); } } }); // 启动 client.start(); client.join(); } }
输出的结果看起来一直在reconnect
10:43:37.286 [Thread-0] WARN com.oceanbase.clogproxy.client.connection.ClientStream - start to reconnect… 10:43:37.290 [Thread-0] WARN com.oceanbase.clogproxy.client.connection.ClientStream - reconnect SUCC 10:43:37.290 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - ClientId: 192.168.10.119_17207_1647311851: rootserver_list=192.168.0.254:2882:2881, cluster_user=root, cluster_password=******, tb_white_list=sys.cloudcanal_console.*, start_timestamp=0 connecting LogProxy: 192.168.0.254:2983 10:43:37.298 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Connected to LogProxyServer, ip:192.168.0.254, version:1.0.0 10:43:38.973 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Connect broken of ClientId: 192.168.10.119_17207_1647311851: rootserver_list=192.168.0.254:2882:2881, cluster_user=root, cluster_password=******, tb_white_list=sys.cloudcanal_console.*, start_timestamp=0 with LogProxy: 192.168.0.254:2983 10:43:39.291 [Thread-0] WARN com.oceanbase.clogproxy.client.connection.ClientStream - start to reconnect… 10:43:39.295 [Thread-0] WARN com.oceanbase.clogproxy.client.connection.ClientStream - reconnect SUCC 10:43:39.295 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - ClientId: 192.168.10.119_17207_1647311851: rootserver_list=192.168.0.254:2882:2881, cluster_user=root, cluster_password=******, tb_white_list=sys.cloudcanal_console.*, start_timestamp=0 connecting LogProxy: 192.168.0.254:2983 10:43:39.303 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Connected to LogProxyServer, ip:192.168.0.254, version:1.0.0 10:43:40.808 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Connect broken of ClientId: 192.168.10.119_17207_1647311851: rootserver_list=192.168.0.254:2882:2881, cluster_user=root, cluster_password=******, tb_white_list=sys.cloudcanal_console.*, start_timestamp=0 with LogProxy: 192.168.0.254:2983