Redis 定长队列的探索和实践

EVAL script numkeys key [key ...] arg [arg ...]    时间复杂度：取决于脚本本身的执行的时间复杂度。 > eval "return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}" 2 key1 key2 first second1) "key1"2) "key2"3) "first"4) "second" Redis uses the same Lua interpreter to run all the commands.Also Redis guarantees that a script is executed in an atomic way:no other script or Redis command will be executed while a script is being executed.This semantic is similar to the one of MULTI / EXEC.From the point of view of all the other clients the effects of a script are either still not visible or already completed.

LLEN key    计算List的长度    时间复杂度：O(1)。 LPOP key [count]    从List的左侧移除元素    时间复杂度：O(N)，N为移除元素的个数。 RPUSH key element [element ...]    从List的右侧保存元素    时间复杂度：O(N)，N为保存元素的个数。

LRANGE key start end    时间复杂度：O(S+N)， S为偏移量start， N为指定区间内元素的数量。      下标(index)参数 start 和 stop 都以 0 为底，也就是说，以 0 表示列表的第一个元素，以 1 表示列表的第二个元素，以此类推。    你也可以使用负数下标，以 -1 表示列表的最后一个元素， -2 表示列表的倒数第二个元素，以此类推。 LTRIM key start stop    时间复杂度：O(N) where N is the number of elements to be removed by the operation.     修剪(trim)一个已存在的 list，这样 list 就会只包含指定范围的指定元素。

SADD key member [member ...]    往Set集合添加数据。    时间复杂度：O(1)。     SISMEMBER key member    判断Set集合是否存在元素。    时间复杂度：O(1)。

定义LUA脚本       CACHE_NPPA_EVENT_LUA =        "local retVal = 0 " +        "local key = KEYS[1] " +        "local num = tonumber(ARGV[1]) " +        "local val = ARGV[2] " +        "local expire = tonumber(ARGV[3]) " +        "if (redis.call('llen', key) < num) then redis.call('rpush', key, val) " +        "else redis.call('lpop', key) redis.call('rpush', key, val) retVal = 1 end " +        "redis.call('expire', key, expire) return retVal";  执行LUA脚本    String data = JSON.toJSONString(nppaBehavior);    Long retVal = (Long)jedisClusterTemplate.eval(CACHE_NPPA_EVENT_LUA, 1, NPPA_PREFIX + nppaBehavior.getGamePackage(), String.valueOf(MAX_GAME_EVENT_PER_GAME), data, String.valueOf(NPPA_TTL_MINUTE * 60)); 执行效果    实现固长队列的数据存储并设置过期时间

定义LUA脚本    QUERY_NPPA_EVENT_LUA =        "local data = {} " +        "local key = KEYS[1] " +        "local num = tonumber(ARGV[1]) " +        "data = redis.call('lrange', key, 0, num) redis.call('ltrim', key, num+1, -1) return data"; 执行LUA脚本    Integer batchSize = NppaConfigUtils.getInteger("nppa.report.batch.size", 1);    Object result = jedisClusterTemplate.eval(QUERY_NPPA_EVENT_LUA, 1,NPPA_PREFIX + gamePackage, String.valueOf(batchSize)); 执行效果    取固定数量的对象，然后保留队列的剩余的消息对象。