求教 Etcd 它没有顺序节点, 如何在实现分布式锁的时候防止惊群效应呢?

[BBCCBB]

RT.

[BBCCBB]

google 了一波, 清一色 说通过 revision 机制.. 有大佬能具体解释下这个怎么做么...

[BBCCBB]

=_=

[owt5008137]

它所有的 modify 都是 leader 干的。单点的而且 revision 是单调递增的。本来所有的写操作也就是要广播的惊不惊群有啥区别。
如果是选举过程的话它是通过选举不通过随机重试时间的方式搞得，revision 版本落后就直接不批准。不知道你问得是不是这个

[BBCCBB]

@owt5008137 老哥我是想问有没有像 zookeeper 实现分布式锁只用监听顺序节点的前一个节点, 前一个节点删除只用通知一个客户端, 而不是像 etcd 这样所有的都监听这个节点, 这个节点删除的时候需要通知所有监听它的客户端.

[AzadCypress]

跟 zookeeper 一样的吧
进程有个全局唯一的 id
拿锁是写入 /lock/id
然后获取 /lock 下的所有值
没有 revision 比自己小的就获得锁
否则监听 revision 比自己小的前一个 key

好像区别就是 revision 是 kv 对象的一个属性而不在路径中

[BBCCBB]

@AzadCypress 我没看到 etcd 有顺序节点这个概念或者相关的概念, 是我看漏了啥么??

你这个意思是在 /lock 下写入自己的节点, 但每个节点 key 保证唯一, 然后按他们的 revision 来实现 zk 有序节点的概念么?
照你这么说我想了想是可以实现了.

但还有个问题就是这个 key 得客户端保证在所有客户端中全局唯一, 还有没有不用客户端去生成这个全局唯一得 key 的方案呀?

[AzadCypress]

@BBCCBB
etcd 是没有顺序节点的概念
但是 etcd 有个全局的顺序 revision，不是对某个节点而是对 etcd 中所有的写入操作。

客户端 id 的话...一个客户就对应一个 id。
反正客户端数量有限，可以提前分好写在配置文件中。或者在启动的时候往 etcd 随便写入一个什么值拿它的 revision 肯定是唯一的。

[BBCCBB]

@AzadCypress 对的,revision 是全局递增的.

的确可以随便写一个值到目录下, 比如 uuid. 简单方便.

这样看下来 etcd 没法自动生成顺序节点名称了, 只能客户端写入一个唯一名称的节点了

[xkeyideal]

源码即文档，看一下 etcd go 的 clientv3 的代码不就行了么，官方都已经把你实现好了

[BBCCBB]

@xkeyideal 大哥你看过源码 clientv3 的 mutex 源码么??? 他那个锁只是一个 cas 乐观锁,连重试都没有. cas 一下, 没获取到就返回一个 error

[xkeyideal]

@BBCCBB 我还真看过，你居然会说出 etcd clientv3 里的 mutex 是乐观锁，那么建议你再重新看看代码吧，记着是 golang 版本的客户端，etcd 版本 v3.3+

[BBCCBB]

@xkeyideal 我看的这个, https://github.com/etcd-io/etcd/blob/master/clientv3/concurrency/mutex.go , 大佬带带我, 我疑惑了大半天了

[xkeyideal]

@BBCCBB 就是这个代码，自己先弄懂几个 revision 的含义，还有个死循环，再对比一下网上某些实现，会发现官方的分布式锁帮你把各个方面的问题全部考虑到了，至少有两种情况使用场景中出现的概率几乎为 0，人家都帮你处理了。自己动手写个使用的 demo，你就会明白了，锁的机制：大家一起抢，谁抢到算谁的，其他人不停的在等待，锁释放了，剩下的人再继续抢。看代码要仔细看，不要轻易就下结论

[xkeyideal]

@BBCCBB 另外再补充一下，如果怀疑我说的，那么就动手实践，自己理解的更透彻，etcd 的大部分代码我都看过，而且还提过 pr，分布式锁和选主机制，在生产环境中都使用过，也做过多次测试，给到你的结论应该不会有问题的

[BBCCBB]

@xkeyideal 😱 我再看看吧, 我就简单看了下.. 3q

[owt5008137]

etcd 的 watch 是按字典序和按目录层级。比如客户端只要只 watch 某个目录就不会收到其他目录的变更通知呀

[BBCCBB]

@owt5008137 同一个锁是加在同一个目录下的哈

[BBCCBB]

@xkeyideal 老哥,还是没看到==, 求赐教

[szkoda]

hdr, werr := waitDeletes(ctx, client, m.pfx, m.myRev-1)

[BBCCBB]

@szkoda 看到了, 我仔细研究下, 之前就过了一眼.. 3q3q.