clogproxy 使用疑问

OceanBase 技术问题
#1

image
image1659×452 32.8 KB

我用clogproxy 1.13jar 去链接
我想知道setUsername 是什么
setSysUsername 又是什么
image
这个binlog 配置文件 明文？
ObReaderConfig config = new ObReaderConfig();
config.setRsList(“172.16.18.26:2882:2881”);
config.setClusterId(“1”);
config.setUsername("");
config.setPassword("");
config.setSysUsername(“root”);
config.setSysPassword(“e1YbS”);
config.setStartTimestamp(0L);
config.setTableWhiteList(“root..”);

3 个赞
#3

我也不知道，同问

#4

mysql -hxxxx.xxxx.xxx.xx -P2983

2 个赞
#5

然后呢

#6

image
image1142×676 53.6 KB

我读了一上午文档。不知道从哪下手了

1 个赞
#7

Channel closed with ClientId: 192.168.43.6_44256_1781751844, LogProxy: 172.16.10.204:2983
程序的异常信息
image
我用调试助手看过 网络是通的 哪问题就在用户上了
setClusterId
image
是这个吗

1 个赞
#8

11:07:56.347 [Thread-0] INFO com.oceanbase.clogproxy.client.connection.ClientStream – Try to connect
11:07:56.410 [Thread-0] INFO com.oceanbase.clogproxy.client.connection.ClientStream – Connect successfully
11:07:56.410 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler – ClientId: 192.168.43.6_19328_1781752073: rootserver_list=172.16.18.26:2882:2881, cluster_id=nhas0f6h5f, cluster_user=yang, cluster_password=, , sys_user=root, sys_password=, tb_white_list=yang.., tb_black_list=|, start_timestamp=0, start_timestamp_us=0, timezone=+08:00, working_mode=storage connecting LogProxy: 172.16.10.204:2983
11:07:56.452 [log-proxy-client-worker-1-thread-1] ERROR com.oceanbase.clogproxy.client.connection.ClientHandler – Exception occurred ClientId: 192.168.43.6_19328_1781752073: rootserver_list=172.16.18.26:2882:2881, cluster_id=nhas0f6h5f, cluster_user=yang, cluster_password=, , sys_user=root, sys_password=, tb_white_list=yang.., tb_black_list=|, start_timestamp=0, start_timestamp_us=0, timezone=+08:00, working_mode=storage, with LogProxy: 172.16.10.204:2983
java.net.SocketException: Connection reset
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(SocketChannelImpl.java:401)
at java.base/sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:434)
at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:258)
at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132)
at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:357)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:722)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:658)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:584)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:496)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.base/java.lang.Thread.run(Thread.java:1583)
11:07:56.452 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler – Channel closed with ClientId: 192.168.43.6_19328_1781752073, LogProxy: 172.16.10.204:2983
11:07:57.427 [Thread-0] INFO com.oceanbase.clogproxy.client.connection.ClientStream – Try to connect
11:07:57.427 [Thread-0] ERROR com.oceanbase.clogproxy.client.connection.ClientStream – Failed to connect, exceed max reconnect retry time: 2
我感觉我连上了。又断了。我猜测是用户问题

1 个赞
#9

LogProxy Unexpected seq num, expected value is 1, actual value is 51 说明客户端和服务端的协议版本不兼容 。服务端期望的序列号是 1，但客户端发送的是 51（0x33 ），这是不同版本之间协议握手格式不同导致的。
是不是版本的兼容问题？

1 个赞
#10

连接binlog实例不需要租户密码。
你试试ob集群ip，端口用2883

#11

失败了

#12

image
image1666×199 16.4 KB
我的感觉 我是不是应该链接 这个实力 2983端口

#13

内部也没有clogproxy案例这边再咨询下

#14

麻烦你了

#15

或者你们使用的方式分享下。

#16

了解一下。clogproxy

#17

连不上你又经验啊？

#18

LogProxy的连接Endpoint配置提供一份看下

#19

image
image1570×461 30.5 KB

这个吗？

#20

image
image1656×453 32.8 KB

#21

config.setUsername(“username”);
config.setPassword(“password”);
这里填sys的root和密码试试