在韶关做网站,永久建站空间购买,南京市公共工程建设 中心网站,wordpress什么环境工作过程中需要用到环形结构#xff0c;确保环上的各个节点数据唯一#xff0c;如果有新的不同数据到来#xff0c;则将最早入环的数据移除#xff0c;每次访问环形结构都自动刷新有效期#xff1b;可以基于lua 的列表list结构来实现这一功能#xff0c;lua脚本可以节省网… 工作过程中需要用到环形结构确保环上的各个节点数据唯一如果有新的不同数据到来则将最早入环的数据移除每次访问环形结构都自动刷新有效期可以基于lua 的列表list结构来实现这一功能lua脚本可以节省网络开销、确保操作的原子性。 一个对springboot redis框架进行重写支持lettuce、jedis、连接池、同时连接多个集群、多个redis数据库、开发自定义属性配置的开源SDK
dependencygroupIdio.github.mingyang66/groupIdartifactIdemily-spring-boot-redis/artifactIdversion4.3.9/version
/dependencyGitHub地址https://github.com/mingyang66/spring-parent
一、lua脚本实现环形结构代码
-- 判定列表中是否包含指定的value
local function contains_value(key, value)-- 获取列表指定范围内的所有元素local elements redis.call(LRANGE, key, 0, -1)-- 泛型for迭代器for k, v in pairs(elements) doif v value thenreturn trueendendreturn false
end-- 列表键名
local key KEYS[1]
-- 列表值
local value ARGV[1]
-- 列表限制长度阀值
local threshold tonumber(ARGV[2])
-- 超时时间单位秒
local expire tonumber(ARGV[3] or 0)-- pcall函数捕获多条指令执行时的异常
local success, result pcall(function(key, value, threshold, expire)-- 获取列表长度local len tonumber(redis.call(LLEN, key))-- 判定列表中是否包含valueif not contains_value(key, value) then-- 根据列表长度与阀值比较if len threshold then-- 移出并获取列表的第一个元素redis.call(LPOP, key)end-- 在列表中添加一个或多个值到列表尾部redis.call(RPUSH, key, value)end-- 超时时间必须大于0否则永久有效if expire 0 then-- 设置超时时间redis.call(EXPIRE, key, expire)end-- 返回列表长度return redis.call(LLEN, key)
end, key, value, threshold, expire)-- 执行成功直接返回列表长度
if success thenreturn result
else-- 异常则直接将异常信息返回return result
end上述代码采用redis的pcall指令在lua多条指令执行过程中如果有异常发生则立马终端执行返回异常 二、spring data redis实现脚本执行逻辑 /*** 基于列表List的环* 1. 支持一直有效threshold 设置为0或null* 2. 支持设置有效时长动态刷新interval大于0** param redisTemplate redis 模板工具* param key 环的键值* param value 列表值* param threshold 阀值列表长度即环上数据个数* param expire 有效时长, 为null则永久有效* return 当前环列表长度*/public static long circle(RedisTemplate redisTemplate, String key, Object value, long threshold, Duration expire) {RedisScriptLong script RedisScript.of(new ClassPathResource(META-INF/scripts/list_circle.lua), Long.class);if (expire null) {expire Duration.ZERO;}return (Long) redisTemplate.execute(script, singletonList(key), value, threshold, expire.getSeconds());}上述代码首先将lua脚本加载到内存中然后将脚本进行解析并将key及相关参数一起通过eval指令发送给redis服务器这里遗留两个问题一、lua脚本是如何加载到内存中的二、每次访问同一个脚本是否需要重复读取。 三、lua脚本执行发生异常
user_script: 44: Unknown Redis command called from Lua script上述异常是通过redis pcall指令捕获lua脚本执行错误信息这些错误信息会被抛出到java代码之中可以根据这些异常信息排查脚本错误。 四、lua脚本是如何加载到内存中的
首先通过如下代码创建RedisScript对象实际是一个DefaultRedisScript对象
RedisScriptLong script RedisScript.of(new ClassPathResource(META-INF/scripts/list_circle.lua), Long.class);进入RedisTemplate#execute方法追踪发现会调用DefaultRedisScript的getSha1方法 protected T T eval(RedisConnection connection, RedisScriptT script, ReturnType returnType, int numKeys,byte[][] keysAndArgs, RedisSerializerT resultSerializer) {...result connection.evalSha(script.getSha1(), returnType, numKeys, keysAndArgs);...}DefaultRedisScript#getSha1方法实现如下 public String getSha1() {synchronized (shaModifiedMonitor) {if (sha1 null || scriptSource.isModified()) {// 计算SHA1哈希值并转换为十六进制字符串this.sha1 DigestUtils.sha1DigestAsHex(getScriptAsString());}return sha1;}}public String getScriptAsString() {try {//获取lua脚本字符串通过ResourceScriptSource实现类return scriptSource.getScriptAsString();} catch (IOException e) {throw new ScriptingException(Error reading script text, e);}}
ResourceScriptSource#getScriptAsString读取方法实现 public String getScriptAsString() throws IOException {synchronized(this.lastModifiedMonitor) {this.lastModified this.retrieveLastModifiedTime();}Reader reader this.resource.getReader();//从lua脚本中读取出脚本转换为字符串返回return FileCopyUtils.copyToString(reader);}通过上述代码可以清除的理顺lua脚本加载到内存中的整个过程但是每次访问时都需要重复读取脚本 五、如何实现读取一次脚本以后直接从脚本中加载
上述方法是通过RedisScript的of方法获取脚本对象 static T RedisScriptT of(Resource resource, ClassT resultType) {Assert.notNull(resource, Resource must not be null);Assert.notNull(resultType, ResultType must not be null);DefaultRedisScriptT script new DefaultRedisScript();script.setResultType(resultType);script.setLocation(resource);return script;}RedisScript类其实还有另外一个接受lua脚本字符串的of方法如下 static T RedisScriptT of(String script, ClassT resultType) {Assert.notNull(script, Script must not be null);Assert.notNull(resultType, ResultType must not be null);return new DefaultRedisScript(script, resultType);}可以将脚本读取出来之后存到静态变量中以后每次直接从变量中获取就可以了 /*** 基于lua列表的环形结构实现脚本*/public static String LUA_SCRIPT_CIRCLE;public static long circle(RedisTemplate redisTemplate, String key, Object value, long threshold, Duration expire) {try {if (StringUtils.isEmpty(LUA_SCRIPT_CIRCLE)) {LUA_SCRIPT_CIRCLE getLuaScript(META-INF/scripts/list_circle.lua);}RedisScriptLong script RedisScript.of(LUA_SCRIPT_CIRCLE, Long.class);}
