refactoring

pull/3848/head
Nikita Koksharov 4 years ago
parent ca3e45bc20
commit 8c059383d8

@ -182,9 +182,8 @@ public class RedissonRateLimiter extends RedissonExpirable implements RRateLimit
} }
private <T> RFuture<T> tryAcquireAsync(RedisCommand<T> command, Long value) { private <T> RFuture<T> tryAcquireAsync(RedisCommand<T> command, Long value) {
ByteBuf buf = Unpooled.copyLong(ThreadLocalRandom.current().nextLong()); byte[] random = new byte[8];
byte[] random = buf.array(); ThreadLocalRandom.current().nextBytes(random);
buf.release();
return commandExecutor.evalWriteAsync(getRawName(), LongCodec.INSTANCE, command, return commandExecutor.evalWriteAsync(getRawName(), LongCodec.INSTANCE, command,
"local rate = redis.call('hget', KEYS[1], 'rate');" "local rate = redis.call('hget', KEYS[1], 'rate');"

Loading…
Cancel
Save