[Question]kubernetes/registry.go的discovery问题 #2203

guihouchang · 2022-07-16T16:23:02Z

请问kubernetes/registry.go (http|grpc).WithEndpoint要怎么写？ discovery://namespace/appname 这样子？还是 discovery:///appname 或者直接是appname？有什么快速的办法验证吗

rogerogers · 2022-07-17T06:43:20Z

server跟client一样就好了，感觉最好加上namespace避免client获取到其他其他同名的项目的pod
我做了一个demo #go-kratos/examples#19

guihouchang · 2022-07-17T06:54:54Z

server跟client一样就好了，感觉最好加上namespace避免client获取到其他其他同名的项目的pod 我做了一个demo #go-kratos/examples#19

我现在遇到一个问题r.GetService能获取到服务节点，但是直接使用discovery:///service-name 拨号的时候就会超时。

rogerogers · 2022-07-17T07:05:55Z

yaml方便贴一下吗

guihouchang · 2022-07-17T07:14:13Z

yaml方便贴一下吗

apiVersion: v1
kind: List
items:
- apiVersion: apps/v1
  kind: Deployment
  metadata:
    name: authorizer
    labels:
      app: authorizer
      system: test
  spec:
    replicas: 2
    selector:
      matchLabels:
        app: authorizer
    template:
      metadata:
        name: authorizer
        namespace: default
        labels:
          app: authorizer
          system: test
      spec:
        serviceAccountName: default
        containers:
          - name: authorizer
            image: ${IMAGE}
            imagePullPolicy: IfNotPresent
            resources:
              requests:
                cpu: '250m'
                memory: '512Mi'
            ports:
              - name: grpc
                containerPort: 4001
                protocol: TCP
              - name: http
                containerPort: 4000
                protocol: TCP
            readinessProbe:
              tcpSocket:
                port: 4001
              initialDelaySeconds: 10     # 延迟探测时间(秒)【 在k8s第一次探测前等待秒 】
              periodSeconds: 2            # 执行探测频率(秒) 【 每隔秒执行一次 】
              timeoutSeconds: 1           # 超时时间
              successThreshold: 1         # 健康阀值
              failureThreshold: 3         # 不健康阀值
            livenessProbe:
              tcpSocket:
                port: 4001
              initialDelaySeconds: 10     # 延迟探测时间(秒)【 在k8s第一次探测前等待秒 】
              periodSeconds: 2            # 执行探测频率(秒) 【 每隔秒执行一次 】
              timeoutSeconds: 1           # 超时时间
              successThreshold: 1         # 健康阀值
              failureThreshold: 3         # 不健康阀值

rogerogers · 2022-07-17T07:38:52Z

pod的yaml，注册信息在pod的注解里

guihouchang · 2022-07-17T08:03:14Z

你要的看的是Pod的labels对吧？

labels:
  app: member
  kratos-service-app: test-member
  kratos-service-id: member-57dddbf94-d6b66
  kratos-service-version: 1b91d9e
  pod-template-hash: 57dddbf94
  system: test

guihouchang · 2022-07-17T08:24:07Z

guihouchang · 2022-07-17T08:25:08Z

pod的yaml，注册信息在pod的注解里

现在的问题是，GetService能获取到endpoints。很奇怪拿去拨号就不行

rogerogers · 2022-07-17T08:36:44Z

上面端口不对吧，这里是4021

guihouchang · 2022-07-17T08:47:53Z

这个是服务A 请求服务B的 4021接口，端口没问题的，毕竟直连 podIP:4021 能请求到的

rogerogers · 2022-07-17T10:49:35Z

不是很理解，client跟server的pod yaml都贴下。

guihouchang · 2022-07-17T11:59:03Z

guihouchang · 2022-07-17T11:59:20Z

不是很理解，client跟server的pod yaml都贴下。

member 是server authorizer 是client

rogerogers · 2022-07-17T13:06:55Z

看上去没什么问题，client连接就是超时吗

shenqidebaozi · 2022-07-17T15:08:16Z

discovery:///appname

shenqidebaozi · 2022-07-17T15:08:27Z

是三个斜杠不是两个

guihouchang · 2022-07-18T01:56:57Z

是三个斜杠不是两个

好像还是连接超时

rogerogers · 2022-07-18T02:53:04Z

这要看代码了，curl结果先看下。

guihouchang · 2022-07-18T03:23:04Z

jeager 上面错误的信息

pc.system	"grpc"
rpc.service	"api.authorizer.v1.Authorizer"
rpc.method	"Test"
send_msg.size	0
rpc.status_code	504
recv_msg.size	0
otel.library.name	"kratos"
span.kind	"client"
error	true
otel.status_code	"ERROR"
otel.status_description	"rpc error: code = DeadlineExceeded desc = context deadline exceeded"

snoad · 2022-07-18T08:25:33Z

我也遇见过这种情况，不过我是consul做的服务注册，我通过一个麻烦的办法解决了你可以参考一下

`

c := api.DefaultConfig()
clients, _ := api.NewClient(c)

dis := consul.New(clients)
//第一次请求，拿到服务列表
conn, _ := grpc.Dial(context.Background(), grpc.WithEndpoint("discovery:///grpctester"), grpc.WithDiscovery(dis))

service, _ := dis.GetService(context.Background(), "grpctester")

defer conn.Close()
//第二次请求，获取数据
var endpoint string
for i := 0; i < len(service[0].Endpoints); i++ {
	if strings.HasPrefix(service[0].Endpoints[i], "grpc://") {
		endpoint = service[0].Endpoints[i]
	}
}
//截取服务ip地址
endpoint = strings.Split(endpoint, "grpc://")[1]
fmt.Println("解析后：", endpoint)
connTrue, _ := grpc.DialInsecure(context.Background(), grpc.WithEndpoint(endpoint), grpc.WithDiscovery(dis))

defer connTrue.Close()
client := hpb.NewTesterClient(connTrue)
reply, err := client.CreateTester(context.Background(), &hpb.CreateTesterRequest{Name: NBCODE})
if err != nil {
	return err
}

`

shenqidebaozi · 2022-07-18T11:53:28Z

我也遇见过这种情况，不过我是consul做的服务注册，我通过一个麻烦的办法解决了你可以参考一下

`

c := api.DefaultConfig()
clients, _ := api.NewClient(c)

dis := consul.New(clients)
//第一次请求，拿到服务列表
conn, _ := grpc.Dial(context.Background(), grpc.WithEndpoint("discovery:///grpctester"), grpc.WithDiscovery(dis))

service, _ := dis.GetService(context.Background(), "grpctester")

defer conn.Close()
//第二次请求，获取数据
var endpoint string
for i := 0; i < len(service[0].Endpoints); i++ {
	if strings.HasPrefix(service[0].Endpoints[i], "grpc://") {
		endpoint = service[0].Endpoints[i]
	}
}
//截取服务ip地址
endpoint = strings.Split(endpoint, "grpc://")[1]
fmt.Println("解析后：", endpoint)
connTrue, _ := grpc.DialInsecure(context.Background(), grpc.WithEndpoint(endpoint), grpc.WithDiscovery(dis))

defer connTrue.Close()
client := hpb.NewTesterClient(connTrue)
reply, err := client.CreateTester(context.Background(), &hpb.CreateTesterRequest{Name: NBCODE})
if err != nil {
	return err
}

`

这样失去了使用服务发现的意义

snoad · 2022-07-18T12:15:44Z

我也遇见过这种情况，不过我是consul做的服务注册，我通过一个麻烦的办法解决了你可以参考一下
`

c := api.DefaultConfig()
clients, _ := api.NewClient(c)

dis := consul.New(clients)
//第一次请求，拿到服务列表
conn, _ := grpc.Dial(context.Background(), grpc.WithEndpoint("discovery:///grpctester"), grpc.WithDiscovery(dis))

service, _ := dis.GetService(context.Background(), "grpctester")

defer conn.Close()
//第二次请求，获取数据
var endpoint string
for i := 0; i < len(service[0].Endpoints); i++ {
	if strings.HasPrefix(service[0].Endpoints[i], "grpc://") {
		endpoint = service[0].Endpoints[i]
	}
}
//截取服务ip地址
endpoint = strings.Split(endpoint, "grpc://")[1]
fmt.Println("解析后：", endpoint)
connTrue, _ := grpc.DialInsecure(context.Background(), grpc.WithEndpoint(endpoint), grpc.WithDiscovery(dis))

defer connTrue.Close()
client := hpb.NewTesterClient(connTrue)
reply, err := client.CreateTester(context.Background(), &hpb.CreateTesterRequest{Name: NBCODE})
if err != nil {
	return err
}

`

这样失去了使用服务发现的意义

是的，不过当时没有深入去研究。现在看起来没法通过服务名直接请求但是ip可以请求，像是dns的问题？

guihouchang · 2022-07-19T02:38:25Z

oint = service[0].Endpoints[i]

嗯，这个方案我也想过，不过如果能加上负载均衡的算法那就更好了

guihouchang added the question Further information is requested label Jul 16, 2022

guihouchang closed this as completed Aug 12, 2022

guihouchang reopened this Aug 12, 2022

shenqidebaozi closed this as completed May 16, 2023

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[Question]kubernetes/registry.go的discovery问题 #2203

[Question]kubernetes/registry.go的discovery问题 #2203

guihouchang commented Jul 16, 2022 •

edited

Loading

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022

guihouchang commented Jul 17, 2022

guihouchang commented Jul 17, 2022

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022 •

edited

Loading

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022

guihouchang commented Jul 17, 2022

rogerogers commented Jul 17, 2022

shenqidebaozi commented Jul 17, 2022

shenqidebaozi commented Jul 17, 2022

guihouchang commented Jul 18, 2022

rogerogers commented Jul 18, 2022

guihouchang commented Jul 18, 2022

snoad commented Jul 18, 2022

shenqidebaozi commented Jul 18, 2022

snoad commented Jul 18, 2022

guihouchang commented Jul 19, 2022

[Question]kubernetes/registry.go的discovery问题 #2203

[Question]kubernetes/registry.go的discovery问题 #2203

Comments

guihouchang commented Jul 16, 2022 • edited Loading

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022

guihouchang commented Jul 17, 2022

guihouchang commented Jul 17, 2022

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022 • edited Loading

rogerogers commented Jul 17, 2022

guihouchang commented Jul 17, 2022

guihouchang commented Jul 17, 2022

rogerogers commented Jul 17, 2022

shenqidebaozi commented Jul 17, 2022

shenqidebaozi commented Jul 17, 2022

guihouchang commented Jul 18, 2022

rogerogers commented Jul 18, 2022

guihouchang commented Jul 18, 2022

snoad commented Jul 18, 2022

shenqidebaozi commented Jul 18, 2022

snoad commented Jul 18, 2022

guihouchang commented Jul 19, 2022

guihouchang commented Jul 16, 2022 •

edited

Loading

guihouchang commented Jul 17, 2022 •

edited

Loading