相关概念

resolver是一种DNS解析器#xff0c;用于将域名转换为etcd集群中的具体地址#xff0c;以便应用程序可以与et…服务注册与发现ETCD

1直接调包

resolver是一种DNS解析器用于将域名转换为etcd集群中的具体地址以便应用程序可以与etcd集群进行通信。

etcd是一个分布式键值存储系统常用于服务发现、配置共享和分布式锁等应用场景。

通过使用etcd

endpoints

用于指定集群的地址列表.例如etcd1.example.com:2379,

etcd2.example.com:2379。

应用程序将通过这些地址与etcd集群的各个节点进行通信以读取和更新数据。

直接看例子就能大致明白

etcd.NewEtcdResolver([]string{127.0.0.1:2379})if

err

context.WithTimeout(context.Background(),

time.Second*3)resp,

{log.Fatal(err)}log.Println(resp)time.Sleep(time.Second)}

}server

etcd.NewEtcdRegistry([]string{127.0.0.1:2379})if

err

hello.NewServer(new(HelloImpl),

server.WithServerBasicInfo(rpcinfo.EndpointBasicInfo{ServiceName:

Hello,}))err

handler层接受到app发来的参数如token、latest_time根据文档规范封装为一个向后端发起的请求FeedRequest.rpc远程调用server的Feed接口返回目标结果

rpc调用的Feed实际上先调用了kitex自动生成的client通过client与server通信实现调用server的接口。

kitex自动生成的client需要在使用前初始化比如进行服务与发现

具体来说client又需要注册中心的resolver拿到resolver的办法就

etcd.NewEtcdResolver([]string{etcdAddr})传入endpoint就可以直接拿到reslover

InitVideo

viperConfig.Viper.GetString(etcd.host),

viperConfig.Viper.GetString(etcd.port))resolver,

err2

etcd.NewEtcdResolver([]string{etcdAddr})if

err2

viperConfig.Viper.GetString(server.name)

err

videoservice.NewClient(serverName,//client.WithMiddleware(middleware.CommonMiddleware),//client.WithInstanceMW(middleware.ClientMiddleware),

//实例级别的中间件。

这个中间件可能会对客户端的每个请求进行预处理或后处理client.WithMuxConnection(1),

muxclient.WithRPCTimeout(300*time.Second),

rpc

timeoutclient.WithConnectTimeout(300000*time.Millisecond),

conn

timeoutclient.WithFailureRetry(retry.NewFailurePolicy()),

retryclient.WithSuite(tracing.NewClientSuite()),

tracer

添加了一个追踪器用于跟踪客户端的请求和响应client.WithResolver(resolver),

resolver//

provider.WithServiceNameclient.WithClientBasicInfo(rpcinfo.EndpointBasicInfo{ServiceName:

serverName}),)if

思考应该直接panic吗log.Fatal(err)}videoClient

newClient

在一个server运行的时候main是入口所以需要在main中将自己的服务注册到etcd中

先通过viper的init方法搜索到对于的配置文件加载到对象config中

var

config.Viper.GetString(server.name)serviceAddr

fmt.Sprintf(%s:%d,

config.Viper.GetString(server.host),

config.Viper.GetInt(server.port))etcdAddr

fmt.Sprintf(%s:%d,

config.Viper.GetString(etcd.host),

config.Viper.GetInt(etcd.port))signingKey

config.Viper.GetString(JWT.signingKey)logger

zap.InitLogger()

etcd.NewEtcdRegistry([]string{etcdAddr})将得到一个Registry类型的对象

调kitex自动生成的service的NewServer方法,注意使用上面拿到的Registry对象上面的启动main方法已经将VideoServiceImpl注册好了现在可以在脚手架中写具体的各个Impl的接口实现。