集群方式下的java Redis锁 lua脚本

下面说一下集群方式redis 下的原子锁 带超时时间java 代码如下：

List<String> keys =Collections.singletonList("test_key1");

System.out.println("打印前 ：："+jedisCluster.get("test_key1"));

//获取lua 脚本这里你可以所以 我是放在META-INF/scripts/redis/test.lua 路径下，

//获取到之后放到字符串String LUA 里边

URL url = Resources.getResource("META-INF/scripts/redis/test.lua");

List<String> lines = Resources.asCharSource(url, Charsets.UTF_8).readLines();

List<String> args = new ArrayList<>(2);

// 以当前时间戳作为value

args.add(DateUtil.dateToString(new Date(), DateUtil.DEFAULT_TIMESTAMP_FORMAT));

// 超时时间(单位秒)

long lockTimeMs = 5;

args.add(String.valueOf(lockTimeMs));

LUA = "";

lines.forEach(line->{

LUA += (line + "\n");

});

Object result =jedisCluster.eval(LUA, keys, args);

//这是另一种方式 作为一个 补充

jedisCluster.set("lockKey", "lockVal", "NX", "PX", 1000);

//注意这里是用另外一种方式，因为我们redis 大部分是集群方式，很少有单机

//我们这里可以灵活判断 具体走单机还是集群 进行 redis 家所

String result1 = (String)stringRedisTemplate.execute(new RedisCallback<String>() {

public String doInRedis(RedisConnection connection) throws DataAccessException {

Object nativeConnection = connection.getNativeConnection();

// 集群模式和单点模式虽然执行脚本的方法一样，但是没有共同的接口，所以只能分开执行

// 集群

if (nativeConnection instanceof JedisCluster) {

return (String) ((JedisCluster) nativeConnection).eval(LUA, keys,args);

}

// 单点

else if (nativeConnection instanceof Jedis) {

return (String) ((Jedis) nativeConnection).eval(LUA, keys, args);

}

return null;

}

});

System.out.println("打印：：result "+result.toString());

System.out.println("打印getValueByKey：："+jedisCluster.get("test_key1"));

long tll =jedisCluster.ttl("test_key1");

System.out.println("打印：：超时时间 单位秒"+tll);

Thread.sleep(6000);

System.out.println("打印：："+jedisCluster.get("test_key1"));

Lua脚本如下：

if redis.pcall('GET',KEYS[1]) == false then

if redis.pcall("SET", KEYS[1], ARGV[1]) =='OK' then

end

return redis.pcall("EXPIRE", KEYS[1], ARGV[2])

else

return redis.pcall('TTL',KEYS[1])

end

另一种写法：

if redis.pcall('EXISTS',KEYS[1]) == 0 then

return redis.pcall('SET', KEYS[1], ARGV[1], 'EX', ARGV[2])

else

return redis.pcall('TTL',KEYS[1])

end