Redis+Lua+Java

Java+Redis+Lua

Redis在2.6推出了脚本功能，允许开发者使用Lua语言编写脚本传到Redis中执行。使用脚本的好处如下:

1.减少网络开销：本来5次网络请求的操作，可以用一个请求完成，原先5次请求的逻辑放在redis服务器上完成。使用脚本，减少了网络往返时延。
2.原子操作：Redis会将整个脚本作为一个整体执行，中间不会被其他命令插入。
3.复用：客户端发送的脚本会永久存储在Redis中，意味着其他客户端可以复用这一脚本而不需要使用代码完成同样的逻辑。

高并发原子交互
1 redis执行可以保证lua脚本的执行的原子性
2 减少网络延迟

/**
* [times description]
* @type {[type]}
下标从1开始
*/
local times = redis.call('incr',KEYS[1])

if times == 1 then
redis.call('expire',KEYS[1], ARGV[1])
end

if times > tonumber(ARGV[2]) then
return 0
end
return 1

redis-cli --eval ratelimiting.lua rate.limitingl:127.0.0.1 , 10 3
KEYS ARGV

--eval参数是告诉redis-cli读取并运行后面的Lua脚本，ratelimiting.lua是脚本的位置，
后面跟着是传给Lua脚本的参数。其中","前的rate.limiting:127.0.0.1是要操作的键，可以再脚本中用KEYS[1]获取，
","后面的10和3是参数，在脚本中能够使用ARGV[1]和ARGV[2]获得。注：","两边的空格不能省略，否则会出错。

*********************************分布式限流器*******************************************************

local tokens_key = KEYS[1]
local timestamp_key = KEYS[2]
local rate = tonumber(ARGV[1])
local capacity = tonumber(ARGV[2])
local now = tonumber(ARGV[3])
local requested = tonumber(ARGV[4])
local fill_time = capacity/rate
local ttl = math.floor(fill_time*2)
local last_tokens = tonumber(redis.call("get", tokens_key))
if last_tokens == nil then
last_tokens = capacity
end
local last_refreshed = tonumber(redis.call("get", timestamp_key))
if last_refreshed == nil then
last_refreshed = 0
end
local delta = math.max(0, now-last_refreshed)
local filled_tokens = math.min(capacity, last_tokens+(delta*rate))
local allowed = filled_tokens >= requested
local new_tokens = filled_tokens
local allowed_num = 0
if allowed then
new_tokens = filled_tokens - requested
allowed_num = 1
end
redis.call("setex", tokens_key, ttl, new_tokens)
redis.call("setex", timestamp_key, ttl, now)
return { allowed_num, new_tokens }

String prefix = "rate_limiter.{" + key;
String tokenKey = prefix + "}.tokens";
String timestampKey = prefix + "}.timestamp";
return Arrays.asList(tokenKey, timestampKey);

int burstCapacity = replenishRate;
List<String> keys = getKeys(key);
List<String> scriptArgs = Arrays.asList(String.valueOf(replenishRate), String.valueOf(burstCapacity),
       String.valueOf(System.currentTimeMillis() / 1000L), "1");
Object reply = jedisCluster.eval(rateLimiterScript, keys, scriptArgs);
if (LOGGER.isDebugEnabled()) {
   LOGGER.debug("Redis Response=" + reply);
}
if (reply != null && List.class.isAssignableFrom(reply.getClass())) {
   List list = List.class.cast(reply);
   if (CollectionUtils.isNotEmpty(list)) {
       Object item;
       return NumberUtils.toInt((item = list.get(0)) != null ? item.toString() : null, -1) > 0;
   }
}

***********************************************************************************************************************************************

Redis+Lua+Java相关推荐

Java并发：分布式应用限流 Redis + Lua 实践
任何限流都不是漫无目的的,也不是一个开关就可以解决的问题,常用的限流算法有:令牌桶,漏桶.在之前的文章中,也讲到过,但是那是基于单机场景来写. 之前文章:接口限流算法:漏桶算法&令牌桶算法然 ...
高并发-【抢红包案例】之四:使用Redis+Lua脚本实现抢红包并异步持久化到数据库
文章目录导读概述实现步骤注解方式配置 Redis lua脚本和异步持久化功能的开发 Service层添加Redis抢红包的逻辑 Controller层新增路由方法构造模拟数据,测试代码总 ...
redis+lua实现分布式限流
前言之前我们谈到的限流解决方案中提到了在分布式环境下,可以使用redis结合lua进行限流,与网关层限流不同的是,基于Redis+Lua的分布式限流属于服务端限流使用redis做限流原因在前面的 ...
Redis实现计数器---接口防刷---升级版（Redis+Lua）
[前言] Cash Loan(一):Redis实现计数器---接口防刷中介绍了项目中应用redis来做计数器的实现过程,最近自己看了些关于Redis实现分布式锁的代码后,发现在Redis分布式锁中 ...
redis+lua脚本
1.lua+java 第一种形式直接在代码中 @Autowiredprivate RedisTemplate<String,String> redisTemplate;@PostMappi ...
【干货】Redis在Java开发中的基本使用和巧妙用法
Redis是一款高性能的内存数据结构存储系统,能够支持多种数据结构类型,如字符串.哈希.列表.集合.有序集合等,也能够支持高级功能,如事务.发布/订阅.Lua脚本等,具有高可用性.高并发性和可扩展性的 ...
ratelimit+redis+lua对接口限流
背景:为防止接口QPS太大而造成系统运行卡顿的现象,在这儿以ratelimit+redis+lua对系统接口做了个限流.当时也考虑过使用其他的限流方法,比如微服务生态中使用的sentinel中间件,但 ...
一网打尽Redis Lua脚本并发原子组合操作
1. 前言 Redis 是高性能的 KV 内存数据库,除了做缓存中间件的基本作用外还有很多用途,比如胖哥以前分享的Redis GEO 地理位置信息计算.Redis 提供了丰富的命令来供我们使用以实现一 ...
Redis Lua脚本的详细介绍以及使用入门
Redis Lua脚本的详细介绍以及使用入门. 文章目录 Redis Lua脚本的引入开源软件的可扩展性 Redis的扩展性脚本 Redis Lua脚本的基本使用通过EVAL命令执行Lua脚本通 ...

Redis+Lua+Java

Redis+Lua+Java相关推荐

最新文章

热门文章