Consul 是一个支持多数据中心分布式高可用的服务发现和配置共享的服务软件,由 HashiCorp 公司用 Go 语言开发,基于 Mozilla Public license 2.0 的协议进行开源. Consul 支持健康检查,并允许 http 和 DNS 协议调用 API 存储键值对.
命令行超级好用的虚拟机管理软件 vgrant 也是 HashiCorp 公司开发的产品.
一致性协议采用 Raft 算法,用来保证服务的高可用. 使用 GOSSIP 协议管理成员和广播消息,并且支持 ACL 访问控制.
综合比较,Consul 作为服务注册和配置管理的新星,比较值得关注和研究.
Consul 的角色clIEnt: 客户端,无状态,将 http 和 DNS 接口请求转发给局域网内的服务端集群.
server: 服务端,保存配置信息,高可用集群,在局域网内与本地客户端通讯,通过广域网与其他数据中心通讯. 每个数据中心的 server 数量推荐为 3 个或是 5 个.
分布式锁，是控制分布式系统之间同步访问共享资源的一种方式。在分布式系统中，常常需要协调他们的动作。如果不同的系统或是同一个系统的不同主机之间共享了一个或一组资源，那么访问这些资源的时候，往往需要互斥来防止彼此干扰来保证一致性，在这种情况下，便需要使用到分布式锁。
目前几乎很多大型网站及应用都是分布式部署的，分布式场景中的数据一致性问题一直是一个比较重要的话题。分布式的CAP理论告诉我们“任何一个分布式系统都无法同时满足一致性（Consistency）、可用性（Availability）和分区容错性（Partition tolerance），最多只能同时满足两项。”所以，很多系统在设计之初就要对这三者做出取舍。在互联网领域的绝大多数的场景中，都需要牺牲强一致性来换取系统的高可用性，系统往往只需要保证“最终一致性”，只要这个最终时间是在用户可以接受的范围内即可。
在很多场景中，我们为了保证数据的最终一致性，需要很多的技术方案来支持，比如分布式事务、分布式锁等。有的时候，我们需要保证一个方法在同一时间内只能被同一个线程执行。
在这里我们使用Consul来管理分布式锁。Consul内置了服务注册与发现框 架、分布一致性协议实现、健康检查、Key/Value存储、多数据中心方案，不再需要依赖其他工具（比如ZooKeeper等）。
Sessionssession是一个远程进程和consUL节点之间的链接，它由一个远程进程和可以显式无效或由于健康检查机制。根据会话配置，创建与已失效会话锁摧毁或释放。
Health checksConsul支持多种检查（如http、TCP等）。在session创建过程中可以定义的健康检查列表。这些检查将用于确定是否sessio需要使之失效。
TTL除了健康检查，会话也具有内置支持的TTL。当TTL过期session被视为无效。远程进程负责更新session之前TTL过期。
Golang APIConsul API client提供一个方便的抽象，session和K/V存储。有是一个锁结构与锁定、解锁和破坏的方法。也有用于帮助创建锁实例方法。API客户端还负责更新会话。
Creating the ConsulclIEnt| 1 | clIEnt,err:=API.NewClIEnt(&API.Config{Address:"127.0.0.1:8500"}) |
| 1 2 3 4 5 6 7 8 9 10 11 12 | typeLockOptionsstruct{ Keystring// Must be set and have write permissions Value[]byte// Optional,value to associate with the lock Sessionstring// Optional,created if not specifIEd Sessionopts*SessionEntry// Optional,options to use when creating a session Sessionnamestring// Optional,defaults to DefaultLockSessionname (ignored if Sessionopts is given) SessionTTLstring// Optional,defaults to DefaultLockSessionTTL (ignored if Sessionopts is given) MonitorRetrIEsint// Optional,defaults to 0 which means no retrIEs MonitorRetryTimetime.Duration// Optional,defaults to DefaultMonitorRetryTime LockWaitTimetime.Duration// Optional,defaults to DefaultLockWaitTime LockTryOncebool// Optional,defaults to false which means try forever } |
LockOptions是所有可能的选项的容器，可以用于设置键和值、定制会话或设置TTL。
| 1 2 3 4 5 6 7 8 9 10 | opts:=&API.LockOptions{ Key:"webhook_receiver/1", Value:[]byte("set by sender 1"), SessionTTL:"10s", Sessionopts:&API.SessionEntry{ Checks:[]string{"check1","check2"}, Behavior:"release", }, } lock,err:=clIEnt.LockOpts(opts) |
另一种常用的方法是LockKey，它创建一个锁与所有选项设置为默认条目名称除外。
| 1 | lock,err:=clIEnt.LockKey("webhook_receiver/1") |
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 | stopCh:=make(chanstruct{}) lockCh,err:=lock.Lock(stopCh) iferr!=nil{ panic(err) } cancelCtx,cancelRequest:=context.WithCancel(context.Background()) req,_:=http.NewRequest("GET","https://example.com/webhook",nil) req=req.WithContext(cancelCtx) gofunc(){ http.DefaultClIEnt.Do(req) select{ case<-cancelCtx.Done(): log.Println("request cancelled") default: log.Println("request done") err=lock.Unlock() iferr!=nil{ log.Println("lock already unlocked") } } }() gofunc(){ <-lockCh cancelRequest() }() |
以上是内存溢出为你收集整理的Golang 通过 Consul 实现分布式锁全部内容，希望文章能够帮你解决Golang 通过 Consul 实现分布式锁所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）