分享
Golang的分布式锁组件,支持Reids,Pgsql或自定义驱动
letsfire · · 1492 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
通用的Golang分布式锁组件,项目地址:https://github.com/go-locks/d...,更多使用案例详见 examples
Driver列表
若有意向贡献未完成的驱动代码,请通过 ISSUES 或 邮箱 249008728@qq.com 联系我
| Driver | 代码完成度 | 测试完成度 | 依赖包 | 使用说明 |
|---|---|---|---|---|
| redis | 100% | 100% | letsfire/redigo | 详见 README.md |
| pgsql | 100% | 100% | lib/pq | 详见 README.md |
| etcd | 未完成 | 未测试 | etcd/client | 详见 README.md |
| etcdv3 | 未完成 | 未测试 | etcd/clientv3 | 详见 README.md |
方法说明
配置项 mutex.OptFunc 以及返回值锁的使用详见 mutex/README.md
- NewMutex(name string, optFuncs ...mutex.OptFunc) (*mutex.Mutex, error)
创建互斥锁,若 name 已用于创建读写锁则返回 error,本方法单例模式
- NewRWMutex(name string, optFuncs ...mutex.OptFunc) (*mutex.RWMutex, error)
创建读写锁,若 name 已用于创建互斥锁则返回 error,本方法单例模式
注意事项
- 不可重入(如果您有强烈的需求场景,请通过 ISSUES 提供反馈)
- 非公平锁(Golang的本地锁
sync.Locker视乎也不是公平锁,若您有需求或建议,请通过 ISSUES 提供反馈) - 有互斥锁
mutex和 读写锁rwmutex两种类型,具体支持程度详见各个Driver对应的README.md - 本人项目经验少,实现过程难保欠缺一些场景的考虑,望大家见谅,若能通过 ISSUES 提供反馈则感激涕零
- 虽有完整的单元测试,但暂未经过实际项目考验,故慎用于生产环境,如有问题请通过 ISSUES 来共同完善
项目结构
- 主线调用层级为
distlock.go->mutex.go->driver.go -
distlock.go提供了创建锁的工厂类,单例模式(相同名称的锁有且仅有一个,有且仅为一种) -
mutex.go提供了各类锁的实现,欢迎各位同学贡献其他类型锁,详见 mutex/README.md -
driver.go提供驱动接口的定义,欢迎各位同学贡献其他驱动,详见 driver/README.md
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信1492 次点击
下一篇:2019年01月27日
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
通用的Golang分布式锁组件,项目地址:https://github.com/go-locks/d...,更多使用案例详见 examples
Driver列表
若有意向贡献未完成的驱动代码,请通过 ISSUES 或 邮箱 249008728@qq.com 联系我
| Driver | 代码完成度 | 测试完成度 | 依赖包 | 使用说明 |
|---|---|---|---|---|
| redis | 100% | 100% | letsfire/redigo | 详见 README.md |
| pgsql | 100% | 100% | lib/pq | 详见 README.md |
| etcd | 未完成 | 未测试 | etcd/client | 详见 README.md |
| etcdv3 | 未完成 | 未测试 | etcd/clientv3 | 详见 README.md |
方法说明
配置项 mutex.OptFunc 以及返回值锁的使用详见 mutex/README.md
- NewMutex(name string, optFuncs ...mutex.OptFunc) (*mutex.Mutex, error)
创建互斥锁,若 name 已用于创建读写锁则返回 error,本方法单例模式
- NewRWMutex(name string, optFuncs ...mutex.OptFunc) (*mutex.RWMutex, error)
创建读写锁,若 name 已用于创建互斥锁则返回 error,本方法单例模式
注意事项
- 不可重入(如果您有强烈的需求场景,请通过 ISSUES 提供反馈)
- 非公平锁(Golang的本地锁
sync.Locker视乎也不是公平锁,若您有需求或建议,请通过 ISSUES 提供反馈) - 有互斥锁
mutex和 读写锁rwmutex两种类型,具体支持程度详见各个Driver对应的README.md - 本人项目经验少,实现过程难保欠缺一些场景的考虑,望大家见谅,若能通过 ISSUES 提供反馈则感激涕零
- 虽有完整的单元测试,但暂未经过实际项目考验,故慎用于生产环境,如有问题请通过 ISSUES 来共同完善
项目结构
- 主线调用层级为
distlock.go->mutex.go->driver.go -
distlock.go提供了创建锁的工厂类,单例模式(相同名称的锁有且仅有一个,有且仅为一种) -
mutex.go提供了各类锁的实现,欢迎各位同学贡献其他类型锁,详见 mutex/README.md -
driver.go提供驱动接口的定义,欢迎各位同学贡献其他驱动,详见 driver/README.md