Skip to content

xkeyideal/grpcwatch

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

8 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

gRPC watch

本项目是参考Etcd 的watch client实现的常规业务的简易化watch 用例.

watchclient目录

gRPC watch 的客户端核心程序,代码里有比较详细的中文注释,实现的功能:

  1. 断线重连
  2. gRPC stream 管理
  3. 错误处理

核心功能都是参考Etcd的 clientv3/watch.go 中代码实现。

watchserver目录

gRPC watch 的服务端核心程序,用于mock数据,代码比较简单。

示例中的代码,只采用了定时的方式固定生成数据,然后通过gRPC server stream发送给客户端。 在实际的应用场景中,需要与实际的数据存储程序关联在一起,此处的处理逻辑较为复杂,本例未详细实现, 可参考Etcd watch server代码。

grpclient 目录

gRPC client的负载均衡与分布式锁、选主的封装。

此部分代码也是基于Etcd的clientv3代码中修改。

负载均衡代码只适用于 gRPC 1.24.0版本,现有的1.27.+版本由于API的变化,导致不能使用,后续修改。

测试代码 test目录

  1. go run server.go, 启动服务端
  2. go run client.go, 启动客户端

服务端与客户端测试代码比较简单,可以根据自己需求修改,测试各类功能。

备注

由于个人能力有限,此用例中可能存在若干bug,还请鉴别使用。

最后给出 gRPC Codes的个人理解,仅供参考。

Releases

No releases published

Packages

No packages published

Languages