dislock

README

go-distributed-lock

• golang 实现的基于GRPC的分布式锁

使用方法

• 1 部署服务：https://github.com/calmw/go-distributed-lock-server

• 2 使用

  • demo dislock.go

Documentation

Index

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

Functions

func NewLockServiceClient

func NewLockServiceClient(serverAddr string) service.LockServiceClient

Types

type Lock

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

func NewLock

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

func (*Lock) ForceLock

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

ForceLock

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

func (*Lock) ForceUnLock

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

ForceUnLock

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

func (*Lock) Lock

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

Lock

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

func (*Lock) UnLock

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

UnLock

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