访问RPC服务返回service discovery error: no service found

[wes-xia]

问题描述

在线上RPC服务中（k8s pod中运行）调用PingMetricsClient返回service discovery error: no service found
单独写脚本在pod中执行返回正常

var (
	MetricsClient metricsservice.Client
)

func InitMetricsClient(ctx context.Context, consul_host string, consul_port string) (err error) {
	addr := fmt.Sprintf("%s:%s", consul_host, consul_port)
	r, err := consul.NewConsulResolver(addr)
	if err != nil {
		Debuger(ctx, "NewConsulResolver err:%s", err.Error())
		return
	}

	MetricsClient, err = metricsservice.NewClient(
		"ops.infra.metrics",
		client.WithMuxConnection(1),              // mux
		client.WithRPCTimeout(2*time.Second),     // rpc timeout
		client.WithConnectTimeout(2*time.Second), // conn timeout
		// client.WithFailureRetry(retry.NewFailurePolicy()), // retry
		client.WithResolver(r), // resolver
	)
	if err != nil {
		Debuger(ctx, "InitMetricsClient err:%s", err.Error())
		return
	}
	Debuger(ctx, "InitMetricsClient Success consul_host: %s consul_port: %s ", consul_host, consul_port)
	return nil
}

func PingMetricsClient(ctx context.Context) bool {
	req := &stock.Req{}
	option := callopt.WithRPCTimeout(1 * time.Second)
	_, err := MetricsClient.Ping(context.Background(), req, option)
	if err != nil {
		Debuger(ctx, "PingMetricsClient err:%s", err.Error()) //这里返回service discovery error: no service found
		return false
	}
	return true

}

[wes-xia]

pod单独执行

线上服务调用

[baiyutang]

针对报错，意思是 找不到可用实例。
这里最好参考下 服务提供者，在注册时的代码，比如注册的地址、或者服务实例的健康检查等等。