- 通過set(final String key, final String value, final String nxxx, final String expx, final int time)
/**
*
* @param key
* @param value
* @param nxxx NX = 僅當(dāng)key不存在時設(shè)置痊班;XX = 僅當(dāng)key存在時設(shè)置
* @param expx EX = 秒;PX = 毫秒
* @param time 過期時間
* @return 設(shè)置成功返回“OK”
*/
public String set(final String key, final String value, final String nxxx, final String expx,
final int time) {
checkIsInMultiOrPipeline();
client.set(key, value, nxxx, expx, time);
return client.getStatusCodeReply();
}
- 通過過期時間和值加1
/**
* 每分鐘限制訪問數(shù)
*/
private static final long limitPerMinute = 200;
public boolean limitQps(final String key) {
if(redis.exists(key)) {
long count = redis.incr(key);
if(count > limitPerMinute) {
return false;
}
} else {
redis.setex(key, 60, "1");
}
return true;
}
最后編輯于 :
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者