obkv-table-client-go 连接docker部署的OCeanbase的configUrl该如何配置

huanghai · 2024 年6 月 24 日 10:47

【使用环境】docker部署
【 OB or 其他组件】
【使用版本】4.3.1
【问题描述】obkv-table-client-go 连接docker部署的OCeanbase的configUrl该如何配置
【复现路径】

    const (
		configUrl    = "ob-configserver-url"
		fullUserName = "user@tenant#cluster"
		passWord     = ""
		sysUserName  = "root"
		sysPassWord  = ""
		tableName    = "test"
	)

	cfg := config.NewDefaultClientConfig()
	cli, err := client.NewClient(configUrl, fullUserName, passWord, sysUserName, sysPassWord, cfg)
	if err != nil {
		panic(err)
	}

官方示例代码如上，想问一下在docker部署模式下，能否使用obkv-table模式，如果可以，该如何具体配置NewClient内的参数，尤其是configUrl该怎么设置？

旭辉 · 2024 年6 月 24 日 12:30

感谢咨询，你的问题已反馈研发同学分析，有结果会及时回复你。

旭辉 · 2024 年6 月 24 日 17:21

首先需要集群有configurl，部署的时候如果没有url的话就用不了，这个参数的值，后面加上&database=使用数据库

huanghai · 2024 年6 月 24 日 17:45

我这是用docker部署的，是不是没有config server？
如果我想在docker内测试obkv-table应该怎么操作？比如应该运行什么样的docker命令，谢谢回复！

旭辉 · 2024 年6 月 25 日 10:18

1.我这是用docker部署的，是不是没有config server？
是的，你这里ob-configserver需要单独部署，参考
https://open.oceanbase.com/blog/2853733888
https://open.oceanbase.com/blog/2017885440

2.如果我想在docker内测试obkv-table应该怎么操作？比如应该运行什么样的docker命令，谢谢回复！
目前尚没有用在docker部署测试，我反馈下你的问题，谢谢。

huanghai · 2024 年6 月 25 日 16:21

这次用odb demo部署，我换成odp连接方式，代码如下：

package main

import (
	"github.com/oceanbase/obkv-table-client-go/client"
	"github.com/oceanbase/obkv-table-client-go/config"
	//"github.com/oceanbase/obkv-table-client-go/table"
)

func main() {
	const (
		odpIP        = "192.168.124.18"
		odpRpcPort   = 2883
		database     = "test"
		fullUserName = "root@sys#obcluster"
		passWord     = ""
	)

	cfg := config.NewDefaultClientConfig()
	_, err := client.NewOdpClient(fullUserName, passWord, odpIP, odpRpcPort, database, cfg)
	if err != nil {
		panic(err)
	}
	println("ok")
}

然后返回如下报错：

{"level":"warn","ts":"2024-06-25T14:34:41.590+0800","caller":"log/logger.go:136","msg":"connection closed.","error":"connection decode header error: magic header flag not match","connection uniqueId":546688144538702}
{"level":"info","ts":"2024-06-25T14:34:41.591+0800","caller":"log/logger.go:132","msg":"close connection start, remote addr:192.168.124.18:2883"}
{"level":"info","ts":"2024-06-25T14:34:41.591+0800","caller":"log/logger.go:132","msg":"close connection success, remote addr:192.168.124.18:2883"}
{"level":"info","ts":"2024-06-25T14:34:41.591+0800","caller":"log/logger.go:132","msg":"close connection start, remote addr:192.168.124.18:2883"}
{"level":"info","ts":"2024-06-25T14:34:41.591+0800","caller":"log/logger.go:132","msg":"close connection success, remote addr:192.168.124.18:2883"}
panic: init client, client:obClient{config:ClientConfig{ConnPoolMaxConnSize:1, ConnConnectTimeOut:1s, ConnLoginTimeout:1s, OperationTimeOut:10s, LogLevel:1, TableEntryRefreshLockTimeout:4s, TableEntryRefreshTryTimes:3, TableEntryRefreshIntervalBase:100ms, TableEntryRefreshIntervalCeiling:1.6s, MetadataRefreshInterval:1m0s, MetadataRefreshLockTimeout:8s, RsListLocalFileLocation:, RsListHttpGetTimeout:1s, RsListHttpGetRetryTimes:3, RsListHttpGetRetryInterval:100ms, EnableRerouting:false, MaxConnectionAge:0s, EnableSLBLoadBalance:false}, configUrl:, fullUserName:root@sys#obcluster, userName:root, tenantName:sys, clusterName:obcluster, database:test, sysUA:nil}: init ob table, obTable:ObTable{ip:192.168.124.18, port:2883, tenantName:sys, userName:root@sys#obcluster, password:, database:test, isClosed:false}: new rpc client, opt:RpcClientOption{ip:192.168.124.18, port:2883, connPoolMaxConnSize:1, connectTimeout:1s, loginTimeout:1s, tenantName:sys, databaseName:test, userName:root@sys#obcluster, password:, maxConnectionAge:0s, enableSLPS D:\odb> go run .
{"level":"warn","ts":"2024-06-25T16:17:53.396+0800","caller":"log/logger.go:136","msg":"connection closed.","error":"connection decode header error: magic header flag not match","connection uniqueId":501994714856526}
{"level":"info","ts":"2024-06-25T16:17:53.396+0800","caller":"log/logger.go:132","msg":"close connection start, remote addr:192.168.124.18:2883"}
{"level":"info","ts":"2024-06-25T16:17:53.396+0800","caller":"log/logger.go:132","msg":"close connection success, remote addr:192.168.124.18:2883"}
{"level":"info","ts":"2024-06-25T16:17:53.396+0800","caller":"log/logger.go:132","msg":"close connection start, remote addr:192.168.124.18:2883"}
{"level":"info","ts":"2024-06-25T16:17:53.396+0800","caller":"log/logger.go:132","msg":"close connection success, remote addr:192.168.124.18:2883"}
panic: init client, client:obClient{config:ClientConfig{ConnPoolMaxConnSize:1, ConnConnectTimeOut:1s, ConnLoginTimeout:1s, OperationTimeOut:10s, LogLevel:1, TableEntryRefreshLockTimeout:4s, TableEntryRefreshTryTimes:3, TableEntryRefreshIntervalBase:100ms, TableEntryRefreshIntervalCeiling:1.6s, MetadataRefreshInterval:1m0s, MetadataRefreshLockTimeout:8s, RsListLocalFileLocation:, RsListHttpGetTimeout:1s, RsListHttpGetRetryTimes:3, RsListHttpGetRetryInterval:100ms, EnableRerouting:false, MaxConnectionAge:0s, EnableSLBLoadBalance:false}, configUrl:, fullUserName:root@sys#obcluster, userName:root, tenantName:sys, clusterName:obcluster, database:test, sysUA:nil}: init ob table, obTable:ObTable{ip:192.168.124.18, port:2883, tenantName:sys, userName:root@sys#obcluster, password:, database:test, isClosed:false}: new rpc client, opt:RpcClientOption{ip:192.168.124.18, port:2883, connPoolMaxConnSize:1, connectTimeout:1s, loginTimeout:1s, tenantName:sys, databaseName:test, userName:root@sys#obcluster, password:, maxConnectionAge:0s, enableSLBLoadBalance:false}: create connection pool: create connection: connection login: execute login, uniqueId: 501994714856526 remote addr: 192.168.124.18:2883 tenantname: sys databasename: test: receive packet, trace: Y1C88FC0A87C4E-0000000000000001: connection close

obd cluster display demo ：