%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
% import (
% “redigo/redis”
% )
% const (
% SET_IF_NOT_EXIST = “NX” // 不存在则执行
% SET_WITH_EXPIRE_TIME = “EX” // 过期时间(秒) PX 毫秒
% SET_LOCK_SUCCESS = “OK” // 操作成功
% DEL_LOCK_SUCCESS = 1 // lock 删除成功
% DEL_LOCK_NON_EXISTENT = 0 // 删除lock key时,并不存在
% )
% var (
% RdPool *redis.Pool
% Conn redis.Conn
% )
% // NewRedisPool
% func init(){
% pool := &redis.Pool{
% Dial: func() (conn redis.Conn, e error) {
% return redis.Dial(“tcp”,”localhost:6379″)
% },
% MaxIdle: 10,
% MaxActive: 20,
% IdleTimeout: 100,
% }
% RdPool = pool
% Conn = pool.Get()
% }
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%s
%添加lock锁
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%
% redis 类型 字符串设置一个分布式锁 (哈希内部字段不支持过期判断,redis只支持顶级key过期)
% @param key: 锁名,格式为 用户id_操作_方法
% @param requestId: 客户端唯一id 用来指定锁不被其他线程(协程)删除
% @param ex: 过期时间
% func AddLock(key,requestId string,ex int) bool {
% msg,_ := redis.String(
% Conn.Do(“SET”,key,requestId,SET_IF_NOT_EXIST,SET_WITH_EXPIRE_TIME,ex),
% )
% if msg == SET_LOCK_SUCCESS {
% return true
% }
% return false
% }
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%s
%添加lock锁
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
addLock(Key) ->
Key1 = “LOCK:” ++ binary_to_list(Key),
Value = easemob_redis:q(mute, [“SET”,Key1, true, “NX”,”EX”, 50]),
io:format(“Value..AddLock…~p~n”,[Value]),
Value.
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%s
%查
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%
% 获得redis分布式锁的值
% @param key:redis类型字符串的key值
% @param return: redis类型字符串的value
%
% func GetLock(key string) string {
% msg,_ := redis.String(Conn.Do(“GET”,key))
% return msg
% }
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%s
%查,获得redis分布式锁的值
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
getLock(Key) ->
Key1 = “LOCK:” ++ binary_to_list(Key),
{ok,Value} = easemob_redis:q(mute, [“GET”,Key1]),
io:format(“Value…GetLock..~p~n”,[Value]),
Value.
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%s
%删除
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%% 删除redis分布式锁
%% @param key:redis类型字符串的key值
%% @param requestId: 唯一值id,与value值对比,避免在分布式下其他实例删除该锁
% func DelLock(key ,requestId string) bool{
% if GetLock(key) == requestId {
% msg,_ := redis.Int64(Conn.Do(“DEL”,key))
% %% 避免操作时间过长,自动过期时再删除返回结果为0
% if msg == DEL_LOCK_SUCCESS || msg == DEL_LOCK_NON_EXISTENT{
% return true
% }
% return false
% }
% return false
% }
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%s
%删除redis分布式锁
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
delLock(Key) ->
Key1 = “LOCK:” ++ binary_to_list(Key),
easemob_redis:q(mute, [“DEL”,Key1]).
%添加lock锁
addLock(Key) ->
Key1 = “LOCK:” ++ binary_to_list(Key),
Value = easemob_redis:q(mute, [“SET”,Key1, true, “NX”,”EX”, 3]),
Value.
%查询,获得redis分布式锁的值
getLock(Key) ->
Key1 = “LOCK:” ++ binary_to_list(Key),
{ok,Value} = easemob_redis:q(mute, [“GET”,Key1]),
Value.
%删除redis分布式锁
delLock(Key) ->
Key1 = “LOCK:” ++ binary_to_list(Key),
easemob_redis:q(mute, [“DEL”,Key1]).
Original: https://www.cnblogs.com/unqiang/p/15248007.html
Author: 孤独信徒
Title: redis的 分布式锁 golang/erlang 简单实现
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/529410/
转载文章受原作者版权保护。转载请注明原作者出处！