个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
28
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Redis实现分布式锁(setnx、getset、incr)以及如何处理超时情况由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
如果你通过网络搜索分布式锁，最多的就是基于redis的了。基于redis的分布式锁得益于redis的单线程执行机制，单线程在执行上就保证了指令的顺序化，所以很大程度上降低了开发人员的思考设计成本.
当且仅当key不存在，将key的值设置为value，并且返回1；若是给定的key已经存在，则setnx不做任何动作，返回0.
|
1
2
3
4
5
6
7
8
9
|
public
static
Boolean setnx(
final
String key,
final
String value,
final
long
seconds) {
return
getShardedJedisClient().execute(
new
ShardedJedisAction<Boolean>() {
public
Boolean doAction(ShardedJedis shardedJedis) {
Jedis jedis = (Jedis) shardedJedis.getShard(key);
String result = jedis.set(key, value,
"NX"
,
"EX"
, seconds);
return
"OK"
.equalsIgnoreCase(result);
}
});
}
|
获取key对应的value值，如果不存在该key，返回0.
|
1
2
3
4
5
6
7
8
|
public
String get(
final
String key) {
this
.checkIsInMulti();
return
(String)
this
.execute(
new
SmartJedis.Action<String>() {
public
String doAction(Jedis jedis) {
return
jedis.get(key);
}
}, SmartJedis.RW.R, key);
}
|
获取key的旧值，将新value放入 。
|
1
2
3
4
5
6
7
8
|
public
static
String getset(
final
String key,
final
String value) {
return
getShardedJedisClient().execute(
new
ShardedJedisAction<String>() {
@Override
public
String doAction(ShardedJedis shardedJedis) {
return
shardedJedis.getSet(key, value);
}
});
}
|
至此，我们先举个手机三要素验证的列子：(A渠道系统，业务B系统，外部厂商C系统) (1)B业务系统调用A渠道系统，验证传入的手机、身份证、号码三要素是否一一致。 (2)A渠道系统再调用外部厂商C系统。 (3)A渠道系统将结果返回给B业务系统。 这3个过程中，(2)过程，外部厂商的调用时是需要计费的。 当B业务系统并发量很高时，有100笔相同的三要素校验，由于是相同的三要素，A渠道只要调用一次厂商即可知道结果。那么A渠道系统如何控制不让100笔请求全部去访问外部厂商C系统呢?
在A系统中， 当100个线程同时请求过来，进行redis.setnx(“LOCK_KEY_phone&idNo&name”,”demo”)，这样第一笔线程率先拿到锁，其他的线程等待，当thread(0)处理结束后，thread(0)进行delete(“LOCK_KEY_phone&idNo&name”),把锁放开，thread(i)进行get(“LOCK_KEY_phone&idNo&name”)拿到0，说明上一笔已经处理完成，这个时候，我们可以去查询上一笔的记录.
|
1
2
3
4
5
6
7
8
9
10
11
|
RedisUtils.setnx(
"LOCK_KEY_phone&idNo&name"
,
"demo"
);
JSONObject result = A.request(B);
AssetUtils.notNull(result,ResponseCodeEnum.Success,
"拿到结果"
);
ResultDmo resultDmo = (ResultDmo)BeanUtils.maptoBean(result);
resultDao.insert(resultDmo);
if
(result!=
0
){
//上一笔同样的请求还未处理完成，轮训等待(具体如何轮训在此不展开)
}
else
{
//上一笔同样的请求处理完成，进行查库操作
resultDao.select(
"参数"
);
}
|
问题：当100笔线程中一些线程超时或者系统宕机等意外情况发现，锁会一直被某些线程持有，造成死锁状态。 应该给缓存key设置一个超时时间。比如:200ms 。
|
1
|
RedisUtils.setnx(
"LOCK_KEY_phone&idNo&name"
,
"demo"
,
200
);
|
这种情况是，大致判断了外部厂商C系统业务处理时间大概为200ms， 。
|
1
2
3
4
5
6
7
8
|
RedisUtils.setnx(
"LOCK_KEY_phone&idNo&name"
,currentTime,
200
);
Long old = RedisUtils.get(
"LOCK_KEY_phone&idNo&name"
);
Long
new
= System.currentTimeMillis();
Long time =
new
- old;
if
(time>
0
){
//处理已经超时
RedisUtils.delete(
"LOCK_KEY_phone&idNo&name"
);
}
|
（B）这种情况不严谨：当a获取setnx锁，a线程崩溃或超时，b、c线程同时get到old，且判断超时，可能出现b线程delete a线程的锁，并且setnx后；c线程又将b线程的锁delete,并且setnx。这种情况完全锁不住线程了.
（B）方案的升级版—->>（C）方案:
当a获取setnx锁，a线程崩溃或超时，b线程getset，获取old且判断超时，c线程getset，获取old（此时这个值是b刚刚set进去的），判断未超时，c继续等待。b线程delete a线程的锁，并且setnx后。这种情况是安全的.
需要注意的地方： ①不要轻易将get和getset混用，笔者认为getset单独使用比较好。 有一种情况，a、b、c、三个线程，a、b同时get，a立即返回了old，突然来了个c，卡在b之前getset了，且删除锁，那么b的get只能返回nil了。此时再根据时间戳对比： a.get != (a.set) b.get ! = (b.set) 这样a、b都没拿到锁，但是a其实已经获取到了锁。 ②多个服务器时间的同步问题.
总结： 锁超时了该如何处理，通过getset方式判断时间戳差的方式，多比同时getset都得到超时，同时去setnx。总会有一个更快地去setnx.
将 key 中储存的数字值增一。如果 key 不存在，那么 key 的值会先被初始化为 0 ，然后再执行 INCR 操作。如果值包含错误的类型，或字符串类型的值不能表示为数字，那么返回一个错误.
|
1
2
3
4
5
6
7
8
9
|
public
static
Long incr(
final
String key) {
return
shardedClient.execute(
new
ShardedJedisAction<Long>() {
@Override
public
Long doAction(ShardedJedis shardedJedis) {
shardedJedis.expire(key,
200
);
return
shardedJedis.incr(key);
}
});
}
|
还是上面的三要素的例子 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
Long result = RedisUtils.incr(
"LOCK_KEY_phone&idNo&name"
);
if
(result >
1
) {
//如果计数器>1,说明已经有请求进来
throw
new
AppException(ResponseCode.FAIL.getCode(),
"操作频繁"
);
}
JSONObject result = A.request(B);
Long endTime = System.currentTimeMillis();
Long time = endTime - startTime;
//如果处理时间大于incr的key存活时间,说明该笔请求已经超时
if
(time >
200
) {
//全局ID,统计超时次数
String key =
"LOCK_KEY_phone&idNo&name"
+ source;
RedisUtils.incr(key);
int
total = Integer.valueOf(RedisUtils.get(key));
//断言若超时10次,进行报警(报警不在次展开)
AssertUtils.isTrue(total <
10
, ResponseCode.FAIL,
"调用"
+ source +
"渠道超时"
);
}
|
这里设置了计数器的超时时间为200ms，如果请求超时，会有大量的线程同时访问，笔者这里有10笔同时过来，就启动报警。人为排查渠道。和setnx的不同是，某个线程超时，setnx的方式需要手动去判断，再去加锁，防止大量线程进入(这里可以通过轮训实现)；而incr的方式超时了，大量线程进来，我不做处理，但是这里的time>200是具有误差的.
到此这篇关于Redis实现分布式锁(setnx、getset、incr)以及如何处理超时情况的文章就介绍到这了,更多相关Redis setnx、getset、incr内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我！ 。
原文链接：https://blog.csdn.net/weixin_39471249/article/details/79121291 。
最后此篇关于Redis实现分布式锁(setnx、getset、incr)以及如何处理超时情况的文章就讲到这里了,如果你想了解更多关于Redis实现分布式锁(setnx、getset、incr)以及如何处理超时情况的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
28
4
0
在memcached(appengine api实现)中，expiration是如何与incr()交互的？ incr() 没有时间参数，但是如果我在另一个调用中添加 key 会发生什么而不是像这样使用
我曾经使用 PostgreSQL 序列 SELECT nextval('number'); 来确保我得到一个新号码，即使有多个客户端也是如此，因为 nextval 保证返回不同且递增的值。 我想对 R
在 incr Tcl 中的继承没有按预期工作。考虑下面的代码。 package require Itcl ::itcl::class Base \ { public { proc functi
Guava 非常有用。 现在，我想对一段时间内的访问计数器实现限制。(例如，人们在一小时内最多可以执行 3 次) 使用Guava的mapMarker或缓存非常容易......(就像使用memcache
我正在使用 Redis 的 INCR 为对象生成一个 ID。然后使用 ZADD 以 ID 作为键添加对象。 我是否需要担心是否有多个连接执行同一代码块？在 id:12 之后说如果两个连接同时连接并且都
g.V().has(label,"request_job").order().by("submit_time",incr).valueMap("submit_time") ==>[submit_tim
我正在使用 Redis 构建 Rails 网络应用程序。我正在尝试创建每个键增加一个的键 ID， 附加一个类型。例如:HMSET user:2 name 'John' age '22'。然后下一个将是
我打开了 CLI 和一个 .NET 虚拟解决方案。我想创建一个用户并一次性插入一些数据。我是如何在 CLI/REPL 中写这个的 redis 127.0.0.1:6379> incr userCoun
我很难让 node、redis 和 async 做我想做的事。我正在尝试非常基本的事情来掌握重定向控制流的模式。在这里，我持有一个计数器变量“success”，如果比较 key0 > key1 为真，
我想增加一个 Redis 计数器，但我想不是从零开始计数，而是从定义的起始数字(例如 -5)开始计数。 我知道如何通过 Lua 脚本中的 SET/INCR 实现这一点，但我想知道我是否只能使用 INC
我有一个有很多客户端的应用程序可能会在同一个键上并发调用 incr。我应该担心吗？ 谢谢 最佳答案 如果只是在键上调用 incr，而不是同时调用 get+set，则不需要加锁。 Redis 序列化所有
我想知道 Mongodb findAndmodify 与 redis increment 命令在速度方面有多好。我知道 Mongodb findAndModify 会对文档进行读/写锁定，但如果我有
目录 1、通过setnx实现 1、setnx key value 2、get key 3、getset key value
Memcached incr 命令用于对已存在的 key(键) 的数字值进行自增操作 语法 incr key increment_value key ： 键值 key-value 结构
Memcached decr 命令用于对已存在的 key(键) 的数字值进行自减操作 语法 decr key decrement_value key : 键值 key-value 结构
我正在尝试使用 spymemcached-2.8.4 客户端在 memcached 中设置一个非常基本的命中率监视器，但是存储在 memcached 中的值实际上似乎从未增加过......这是一个错误
我正在尝试使用 Redis INCR 和使用 StackExchange.Redis 的 C# 中用作哈希字段的递增值。 此 question点与我需要的相似，但在 Node.js 中。 下面是我需要
我在我的Java项目中使用spymemcached 2.6rc1，我想在其中使用Long类作为可存储对象。不幸的是，当我存储例如new Long(0) 对象，get(...) 和 incr(...)
我刚下载 KDevelop因为它会扫描头文件以提供更好的代码完成建议。 当根本不包含头文件时，我正在查看它建议的所有关键字: 为什么推荐“incr”？ 那不是 C++ 关键字。 它是什么，有什么用？
我目前使用的是 Jedis 2.9.0 版，根据 Redis Jedis 文档，方法 long jedis.incr(byte[] key) 接受字节数组作为其键。问题是，我使用哈希值 (Messag
我是一名优秀的程序员,十分优秀！