在这个示例中，我们将使用Redis和Lua脚本来实现一个分布式令牌桶限流器。这里的解决方案将使用Redis的EVAL命令来运行Lua脚本，以确保操作的原子性。
import redis.clients.jedis.Jedis;
public class RateLimiter {
private static final String LUA_SCRIPT =
"local key = KEYS[1] " +
"local limit = tonumber(ARGV[1]) " +
"local current = tonumber(redis.call('get', key) or '0') " +
"if current + 1 > limit then return 0 else " +
"redis.call('INCRBY', key, '1') " +
"redis.call('EXPIRE', key, '10') " +
"return 1 end";
private Jedis jedis;
private String key;
private int limit;
public RateLimiter(Jedis jedis, String key, int limit) {
this.jedis = jedis;
this.key = key;
this.limit = limit;
}
public boolean isAllowed() {
Long isAllowed = (Long) jedis.eval(LUA_SCRIPT, 1, key, String.valueOf(limit));
return isAllowed == 1L;
}
public static void main(String[] args) {
Jedis jedis = new Jedis("localhost");
RateLimiter rateLimiter = new RateLimiter(jedis, "rate_limit", 10);
for (int i = 0; i < 20; i++) {
if (rateLimiter.isAllowed()) {
System.out.println("Request allowed");
} else {
System.out.println("Request not allowed, hit the limit");
}
}
jedis.close();
}
}在这个Java代码示例中，我们定义了一个RateLimiter类，它有一个isAllowed方法，该方法使用了Redis的EVAL命令来运行Lua脚本。Lua脚本会检查当前令牌桶的令牌数是否超过限制，并相应地增加令牌或返回不允许的信号。
这个简单的例子展示了如何使用Redis和Lua脚本来实现分布式系统中的请求限流，这对于防止恶意请求、防止系统被暴力攻击等场景非常有用。