代码段
RedisAtomicInteger counter = counter = new RedisAtomicInteger("mykey");
counter.expire(1, TimeUnit.MINUTES);
我使用redis-cli工具检查了密钥的可用性
钥匙*
而且
ttl密钥名
redis.conf具有默认值。
有什么建议吗?
编辑1:
完整代码:
功能在一个方面
public synchronized Object checkLimit(ProceedingJoinPoint joinPoint) throws Exception, Throwable {
boolean isKeyAvailable = false;
List<String> keysList = new ArrayList<>();
Object[] obj = joinPoint.getArgs();
String randomKey = (String) obj[1];
int randomLimit = (Integer) obj[2];
// for RedisTemplate it is already loaded as
// @Autowired
// private RedisTemplate template;
// in this class
Set<String> redisKeys = template.keys(randomKey+"_"randomLimit+"*");
Iterator<String> it = redisKeys.iterator();
while (it.hasNext()) {
String data = it.next();
keysList.add(data);
}
if (keysList.size() > 0) {
isKeyAvailable = keysList.get(0).contains(randomKey + "_" + randomLimit);
}
RedisAtomicInteger counter = null;
// if the key is not there
if (!isKeyAvailable) {
long expiryTimeStamp = 0;
int timePeriodInMintes = 1;
expiryTimeStamp = new Date(System.currentTimeMillis() + timePeriodInMintes * 60 * 1000).getTime();
counter = new RedisAtomicInteger(randomKey+ "_"+ randomLimit + "_" + expiryTimeStamp,template.getConnectionFactory());
counter.incrementAndGet();
counter.expire(timePeriodInMintes, TimeUnit.MINUTES);
break;
} else {
String[] keys = keysList.get(0).split("_");
String rLimit = keys[1];
counter = new RedisAtomicInteger(keysList.get(0), template.getConnectionFactory());
int count = counter.get();
// If count exceeds throw error
if (count != 0 && count >= Integer.parseInt(rLimit)) {
throw new Exception("Error");
}
else {
counter.incrementAndGet();
}
}
return joinPoint.proceed();
}
当这些线路运行时
RedisAtomicInteger计数器=计数器=新RedisAtomicInteger(“MyKey”);Counter.Expire(1,TimeUnit.Minutes);
我能看见
75672562.380127 [0 10.0.3.133:65462] "KEYS" "mykey_1000*"
75672562.384267 [0 10.0.3.133:65462] "GET" "mykey_1000_1475672621787"
75672562.388856 [0 10.0.3.133:65462] "SET" "mykey_1000_1475672621787" "0"
75672562.391867 [0 10.0.3.133:65462] "INCRBY" "mykey_1000_1475672621787" "1"
75672562.395922 [0 10.0.3.133:65462] "PEXPIRE" "mykey_1000_1475672621787" "60000"
...
75672562.691723 [0 10.0.3.133:65462] "KEYS" "mykey_1000*"
75672562.695562 [0 10.0.3.133:65462] "GET" "mykey_1000_1475672621787"
75672562.695855 [0 10.0.3.133:65462] "GET" "mykey_1000_1475672621787"
75672562.696139 [0 10.0.3.133:65462] "INCRBY" "mykey_1000_1475672621787" "1"
在Redis日志中,当我在
编辑:现在,随着更新的代码,我相信你的方法从根本上来说是有缺陷的,除了你所报告的。
您实现它的方式需要在生产中运行keys
-这是很糟糕的。当您向外扩展时,您将在服务器上造成不断增长的、不必要的系统阻塞负载。正如上面的文档所说,不要在生产中使用keys
。请注意,在密钥名称中编码过期时间不会给您带来任何好处。如果您将键名的那一部分设置为创建时间戳,或者甚至是一个随机数,那么什么都不会改变。事实上,如果你移除了那一位,什么也不会改变。
更明智的方法是使用不依赖于时间的密钥名。过期的使用为您处理了该功能。让我们把你的限价活动称为“会话”。您的密钥名(没有时间戳)是“会话ID”。通过在其上设置60秒的过期时间,它将不再在61秒标记处可用。因此您可以安全地递增并将结果与您的限制进行比较,而不需要知道当前时间或过期时间。您所需要的只是一个静态密钥名称和一个适当的到期设置。
如果incr
是一个不存在的键,Redis将返回“1”,这意味着它在一个步骤/调用中创建了该键并增加了它。所以基本上逻辑是这样的:
步骤3.1很重要。计数为1意味着这是Redis中的一个新密钥,并且您希望在它上设置您的到期时间。任何其他内容都意味着过期时间应该已经设置好了。如果您在3.2中设置它,您将中断该进程,因为它将保留计数器60秒以上。
这样,您就不需要根据过期时间拥有动态密钥名称,因此也就不需要使用keys
来查找速率受限对象是否存在“会话”。它还使您的代码变得更加简单和可预测,并且减少到Redis的往返行程--这意味着它在Redis上的负载更低,性能更好。至于如何使用您正在使用客户机库,我不能说,因为我不太熟悉它。但是基本的序列应该是可以翻译的,因为它是相当基本和简单的。
但是,您没有显示任何东西来支持过期没有发生的断言。您所做的只是表明Redis确实被告知并设置了一个到期时间。为了支持您的声明,您需要显示密钥没有过期。这意味着您需要在过期时间后显示密钥的检索,并且计数器没有在过期后通过重新创建而“重置”。您可以看到过期正在发生的一种方法是使用键空间通知。这样你就可以看到Redis说一把钥匙过期了。
如果您使用多个窗口进行速率限制,或者如果您有一个更大的窗口(即10分钟),那么如果需要,排序集可能是一个更明智的选项来防止请求的前加载,那么这个过程就会失败一点。但是在编写示例时,上面的操作将会很好。
问题内容: 当生存时间达到0时,我的Redis服务器不会删除密钥。 这是一个示例代码: 如果我通过redis检查信息返回,它说0个密钥已过期。 任何想法? 谢谢。 问题答案: 由于您正在执行“ …”,因此很难确定,但是我要说的是您在该部分设置了mykey,这将有效地消除过期。 从EXPIRE手册 仅当使用DEL命令删除密钥或使用SET或GETSET命令覆盖密钥时,才清除超时 另外,关于TTL的-1
在这个expire方法中,我们需要提供而不是。但是我需要过期而不是。 那么,请帮助我如何处理过期?
我正在用jackson jr作为jackson databind的轻量级替代品进行实验。我的目标是解析JSON字符串,如果遇到重复的键,则让解析器失败。据我所知,库可能会引发以下异常: 作为比较,如果我尝试使用jackson-data ind进行类似的操作,我会得到预期的IOException: 我能发现的唯一区别是使用了和。但是,我仍然希望在这两种情况下都会引发异常。我错过了什么还是这只是一个错
我最近一直在致力于实现一个web服务,该服务可以签署和发布JWT,还可以出于JWT验证的目的公开JWKsendpoint。 根据IETF规范,JWT/JWK非常简单,但我注意到一些奇怪的事情,我现在还无法解释: TL;DR:为什么EC P-256源密钥适用于使用RSA algo签名JWT? 说来话长: 我正在使用预先存在的私钥文件对JWT进行签名,并将JWK导入密钥库。 密钥库: JWT公司: 看
问题内容: 当我的密钥在Redis数据存储区中过期时,我正在尝试使用Redis实施过期密钥通知。redis网站提供了一些有关http://redis.io/topics/notifications的描述,但是我无法找到任何示例,例如使用Jedis的redis java客户端如何做到这一点? 任何可能的带有插图的代码都将非常有用,因为它们是redis的新功能。 问题答案: 您只能使用 pub-sub
当我的密钥在redis数据存储中过期时,我试图用redis实现过期密钥通知。redis网站提供了一些如何http://redis.io/topics/notifications,但我找不到任何像Jedis这样使用redis java客户端的例子? 任何可能的带有插图的代码都会非常有用,因为我是redis的新手。