在系统中用etcd实现服务注册和发现
系统中实现服务注册与发现所需的基本功能有
服务注册:同一service的所有节点注册到相同目录下,节点启动后将自己的信息注册到所属服务的目录中。
健康检查:服务节点定时发送心跳,注册到服务目录中的信息设置一个较短的TTL,运行正常的服务节点每隔一段时间会去更新信息的TTL。
服务发现:通过名称能查询到服务提供外部访问的 IP 和端口号。比如网关代理服务时能够及时的发现服务中新增节点、丢弃不可用的服务节点,同时各个服务间也能感知对方的存在。
在分布式系统中,如何管理节点间的状态一直是一个难题,etcd 是由开发并维护的,它使用 Go 语言编写,并通过Raft 一致性算法处理日志复制以保证强一致性。etcd像是专门为集群环境的服务发现和注册而设计,它提供了数据 TTL 失效、数据改变监视、多值、目录监听、分布式锁原子操作等功能,可以方便的跟踪并管理集群节点的状态。
我们写两个 Demo 程序,一个服务充当service,一个客户端程序充当网关代理。服务运行后会去etcd 以自己服务名命名的目录中注册服务节点,并定时续租(更新 TTL)。客户端从 etcd查询服务目录中的节点信息代理服务的请求,并且会在协程中实时监控服务目录中的变化,维护到自己的服务节点信息列表中。
// 将服务注册到etcd上
func RegisterServiceToETCD(ServiceTarget string, value string) {dir = strings.TrimRight(ServiceTarget, "/") + "/"client, err := clientv3.New(clientv3.Config{Endpoints: []string{"localhost:2379"},DialTimeout: 5 * time.Second,})if err != nil {panic(err)}kv := clientv3.NewKV(client)lease := clientv3.NewLease(client)var curLeaseId clientv3.LeaseID = 0for {if curLeaseId == 0 {leaseResp, err := lease.Grant(context.TODO(), 10)if err != nil {panic(err)}key := ServiceTarget + fmt.Sprintf("%d", leaseResp.ID)if _, err := kv.Put(context.TODO(), key, value, clientv3.WithLease(leaseResp.ID)); err != nil {panic(err)}curLeaseId = leaseResp.ID} else {// 续约租约,如果租约已经过期将curLeaseId复位到0重新走创建租约的逻辑if _, err := lease.KeepAliveOnce(context.TODO(), curLeaseId); err == rpctypes.ErrLeaseNotFound {curLeaseId = 0continue}}time.Sleep(time.Duration(1) * time.Second)}
}
type HelloService struct {}
func (p *HelloService) Hello(request string, reply *string) error {*reply = "hello:" + requestreturn nil
}
var serviceTarget = "Hello"
var port = ":1234"
var host = "remote_host"// 伪代码
func main() {rpc.RegisterName("HelloService", new(HelloService))listener, err := net.Listen("tcp", port)if err != nil {log.Fatal("ListenTCP error:", err)}conn, err := listener.Accept()if err != nil {log.Fatal("Accept error:", err)}go RegisterServiceToETCD(serviceTarget, host + port)rpc.ServeConn(conn)
}
网关通过 etcd获取到服务目录下的所有节点的信息,将他们初始化到自身维护的可访问服务节点列表中。然后使用Watch机制监听etcd上服务对应的目录的更新,根据通道发送过来的PUT和DELETE事件来增加和删除服务的可用节点列表。
var serviceTarget = "Hello"
type remoteService struct {name stringnodes map[string]stringmutex sync.Mutex
}
// 获取服务目录下所有key初始化到服务的可用节点列表中
func getService(etcdClient clientv3.Client) *remoteService {service = &remoteService {name: serviceTarget} kv := clientv3.NewKV(etcdClient)rangeResp, err := kv.Get(context.TODO(), service.name, clientv3.WithPrefix())if err != nil {panic(err)}service.mutex.Lock()for _, kv := range rangeResp.Kvs {service.nodes[string(kv.Key)] = string(kv.Value)}service.mutex.Unlock()go watchServiceUpdate(etcdClient, service)
}
// 监控服务目录下的事件
func watchServiceUpdate(etcdClient clientv3.Client, service *remoteService) {watcher := clientv3.NewWatcher(client)// Watch 服务目录下的更新watchChan := watcher.Watch(context.TODO(), service.name, clientv3.WithPrefix())for watchResp := range watchChan {for _, event := range watchResp.Events {service.mutex.Lock()switch (event.Type) {case mvccpb.PUT://PUT事件,目录下有了新keyservice.nodes[string(event.Kv.Key)] = string(event.Kv.Value)case mvccpb.DELETE://DELETE事件,目录中有key被删掉(Lease过期,key 也会被删掉)delete(service.nodes, string(event.Kv.Key))}service.mutex.Unlock()}}
}
func main () {client, err := clientv3.New(clientv3.Config{Endpoints: []string{"remote_host:2379"},DialTimeout: 5 * time.Second,})service := getService(client)// 获取服务的可用节点......// 每次有请求过来从服务节点中选取一个连接,然后给节点发送请求rpcClient, _ = rpc.Dial("tcp", service.nodes[i])var reply stringrpcClient.Call("HelloService.hello", &reply)......
}
除了上面说的客户端或者网关发现系统中的已存服务外,系统中的各个服务之间也需要感知到其他角色的存在,服务间的发现方法与上面的例子类似,每个服务都能作为客户端在 etcd 中发现其他服务的存在。
说明:程序为便于理解有很多伪代码,主要是说明思路,想要实际运行起来还需要很多编码工作,欢迎有这方面经验的朋友交流想法。
在系统中用etcd实现服务注册和发现相关推荐
- etcd 访问 锁_在系统中用etcd实现服务注册和发现
系统中实现服务注册与发现所需的基本功能有 服务注册:同一service的所有节点注册到相同目录下,节点启动后将自己的信息注册到所属服务的目录中. 健康检查:服务节点定时发送心跳,注册到服务目录中的信息 ...
- 用etcd实现服务注册和发现
系统中实现服务注册与发现所需的基本功能有 服务注册:同一service的所有节点注册到相同目录下,节点启动后将自己的信息注册到所属服务的目录中. 健康检查:服务节点定时发送心跳,注册到服务目录中的信息 ...
- 【Java】用etcd做服务注册和发现
最近尝试了一下etcd来做服务的注册发现 [etcd服务] 从etcd官网下载二进制文件即可,分配了三台机器做集群 10.0.1.98 etcd-001 10.0.1.205 etcd-002 ...
- python eureka服务发现_Spring Cloud版——电影售票系统—Eureka微服务注册与发现
一.服务提供者与服务消费者 使用微服务构建的是分布式系统,微服务之间通过网络进行通信.我们使用服务提供者与服务消费者来描述微服务之间的调用关系. 名称 定义 服务提供者 服务的被调用方(为其他服务提供 ...
- ETCD 十六 服务注册与发现
微服务架构中的服务注册与发现 在微服务架构中,多个微服务间的通信需要依赖服务注册与发现组件获取指定服务实例的地址信息,才能正确地发起 RPC 调用,保证分布式系统的高可用.高并发.服务注册与发现主要包 ...
- 从零开始搭建系统3.2——微服务注册中心开发及部署
从零开始搭建系统3.2--微服务注册中心开发及部署 转载于:https://www.cnblogs.com/provence666/p/8638586.html
- go语言高并发与微服务实战_go-micro+gin+etcd微服务实战之服务注册与发现
在构建微服务时,使用服务发现可以减少配置的复杂性,本文以go-micro为微服务框架,使用etcd作为服务发现服务,使用gin开发golang服务. 使用gin 的原因是gin能够很好的和go-mic ...
- 第一篇:SpringCloud 构建微服务系统之服务注册和发现(consul)
版权声明:本文为博主原创文章,未经博主允许不得转载. https://blog.csdn.net/u010046908/article/details/85260629 今天我们要学习的是consul ...
- C# net6微服务架构之服务注册与发现工具Consul的下载与安装(for windows)
C# net6微服务架构之服务注册与发现工具Consul的下载与安装(for windows) 0.背景 1.Consul简介 2.Consul的主要功能 3.Consul下载与安装 4.Consul ...
最新文章
- JAVA实现 springMVC方式的微信接入、实现消息自动回复
- Java新手小程序之三
- C - 思考使用差分简化区间操作
- moodle架构分析---表现层的设计(一)
- 一篇夯实一个知识点系列--python实现十大排序算法
- BZOJ 2754: [SCOI2012]喵星球上的点名
- 简单的Android Camera2与BoofCV
- Java语言程序设计(一)选择题
- php hprose,基于 hprose/hprose-php开发的Laravel扩展:laravel-hprosed的介绍
- 【万字专栏总结】离线强化学习(OfflineRL)总结(原理、数据集、算法、复杂性分析、超参数调优等)...
- windows10系统如何设置开机自启动
- 三面微软,四面雅虎,外企面经复盘总结,那些你不知道的面试技巧
- VuePress 博客之 SEO 优化(一) sitemap 与搜索引擎收录
- 单片机C语言仿真图,单片机C语言程序设计代码和仿真图.doc
- Coin-row problem
- mac 远程桌面连接工具 Microsoft Remote Desktop for Mac 的安装与使用
- C/C++黑魔法-不会出错的http
- 中国的教育缺少什么?
- 从0开始学习C语言————数组、进制转换、函数
- 82c55单片机c语言,8255/82C55中文资料简介