请教大神们这个连接logproxy的问题:
全程操作如下:Docker方式安装oceanbase:https://www.oceanbase.com/docs/common-oceanbase-database-cn-10000000001692850
docker pull oceanbase/oceanbase-ce 4.2.1
docker run -p 2881:2881 -p 2883:2883 -p 2983:2983 --name ob -e MINI_MODE=0 -d oceanbase/oceanbase-ce:4.2.1
docker run -p 2881:2881 --name ob -e MINI_MODE=1 -d oceanbase/oceanbase-ce
docker exec -it ob ob-mysql sys # 连接 sys 租户
create user proxyro identified by ‘Root123@@Root123’;
grant select on oceanbase.* to proxyro;
参考文档:使用安装包安装部署 oblogproxy :https://www.oceanbase.com/docs/common-oceanbase-database-cn-10000000001702387
docker cp C:\Users\18975\Downloads\oblogproxy-ce-for-4x-1.1.3-20230815201457.tar.gz ob:/root
tar -zxf oblogproxy-ce-for-4x-1.1.3-20230815201457.tar.gz -C /usr/local
cd /usr/local/oblogproxy

export PATH=$PATH:/usr/local/oblogproxy/bin
指定依赖的路径。
export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:/usr/local/oblogproxy/liboblog
参考:
./bin/logproxy -x proxyro
/bin/logproxy -x Root123@@Root123
sh run.sh config_sys proxyro Root123@@Root123
./run.sh start
问题1:新建个人连接时,这些应该怎么填呢
问题2:启动时,为何没有任何信息抛出呢
{
ObReaderConfig config = new ObReaderConfig();
config.setRsList(“127.0.0.1:2882:2881”);
config.setUsername(“proxyro@sys”);
config.setPassword(“Root123@@Root123”);
config.setStartTimestamp(0L);
config.setTableWhiteList(“sys..”);
config.setWorkingMode(“memory”);
ClientConf clientConf =
ClientConf.builder()
.transferQueueSize(1000)
.connectTimeoutMs(3000)
.maxReconnectTimes(100)
.ignoreUnknownRecordType(true)
.clientId("test")
.build();
LogProxyClient client = new LogProxyClient("127.0.0.1", 2983, config,clientConf);
// 绑定一个处理日志数据的 RecordListener
client.addListener(new RecordListener() {
@Override
public void notify(LogMessage message){
// 在此添加数据处理逻辑
System.out.println(message.getOpt());
}
@Override
public void onException(LogProxyClientException e) {
System.out.println(e.getMessage());
}
});
client.start();
client.join();
}
cat log/logproxy.INFO
Failed to read packet magic+version, ch:72077026735816712, error:Resource temporarily unavailable
这个是什么原因呢。