dislock

README

go-distributed-lock

• golang 实现的基于GRPC的分布式锁
• 服务端：https://github.com/calmw/go-distributed-lock-server

使用方法

Documentation

Index

• func NewLockServiceClient(serverAddr string) service.LockServiceClient
• type Lock
  • func NewLock(ServerAddr string, retryMillisecondDur, maxRetryTimes int) *Lock
  • func (l *Lock) ForceUnLock(lockName string) (bool, error)
  • func (l *Lock) Lock(lockName, clientId string) (bool, error)
  • func (l *Lock) UnLock(lockName, clientId string) (bool, error)

Functions

func NewLockServiceClient

func NewLockServiceClient(serverAddr string) service.LockServiceClient

Types

type Lock

type Lock struct {
	RetryMillisecondDur int // 尝试加锁的时间间隔 单位毫秒
	RetryMaxTimes       int // 最大加锁失败次数,超过后将强制释放锁，然后再枷锁。因为某个节点可能在加锁未释放的情况下异常退出
	Lk                  service.LockServiceClient
}

func NewLock

func NewLock(ServerAddr string, retryMillisecondDur, maxRetryTimes int) *Lock

func (*Lock) ForceUnLock

func (l *Lock) ForceUnLock(lockName string) (bool, error)

ForceUnLock

lockName 必选参数，锁的名称，可根据业务使用多种锁

func (*Lock) Lock

func (l *Lock) Lock(lockName, clientId string) (bool, error)

Lock

lockName 必选参数，锁的名称，可根据业务使用多种锁 clientId 必选参数，加锁的节点ID，分布式的每个节点ID必须唯一

func (*Lock) UnLock

func (l *Lock) UnLock(lockName, clientId string) (bool, error)

UnLock

lockName 必选参数，锁的名称，可根据业务使用多种锁 clientId 必选参数，加锁的节点ID，分布式的每个节点ID必须唯一