Jedis与Lua脚本结合

local key=KEYS[1]?
local args=ARGV?
//说明：设置一个key = userName,value=Jack,20s过期时间
return redis.call("setex",key,unpack(args))

public?class?RedisClient?{
????private?static?JedisPool????jedisPool????=?null;
????private?static?String????????addr????????=?"127.0.0.1";
????private?static?int????????????port????????=?6379;
????static?{
????????try?{
????????????JedisPoolConfig?config?=?new?JedisPoolConfig();
????????????//?连接耗尽时是否阻塞,?false报异常,ture阻塞直到超时,?默认true
????????????config.setBlockWhenExhausted(true);
????????????//?设置的逐出策略类名,?默认DefaultEvictionPolicy(当连接超过最大空闲时间,或连接数超过最?大空闲连接数)
????????????config.setEvictionPolicyClassName("org.apache.commons.pool2.impl.DefaultEvictionPolicy");
????????????//?是否启用pool的jmx管理功能,?默认true
????????????config.setJmxEnabled(true);
????????????//?MBean?ObjectName?=?new
????????????//?ObjectName("org.apache.commons.pool2:type=GenericObjectPool,name="
????????????//?+?"pool"?+?i);?默认为"pool",?JMX不熟,具体不知道是干啥的...默认就好.
????????????config.setJmxNamePrefix("pool");
????????????//?是否启用后进先出,?默认true
????????????config.setLifo(true);
????????????//?最大空闲连接数,?默认8个?
????????????config.setMaxIdle(8);
????????????//?最大连接数,?默认8个
????????????config.setMaxTotal(8);
????????????//?获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常,?小于零:阻塞不确定的时间,????????????//?默认-1
????????????config.setMaxWaitMillis(-1);
????????????//?逐出连接的最小空闲时间?默认1800000毫秒(30分钟)
????????????config.setMinEvictableIdleTimeMillis(1800000);
????????????//?最小空闲连接数,?默认0
????????????config.setMinIdle(0);
????????????//?每次逐出检查时?逐出的最大数目?如果为负数就是?:?1/abs(n),?默认3
????????????config.setNumTestsPerEvictionRun(3);
????????????//?对象空闲多久后逐出,?当空闲时间>该值?且?空闲连接>最大空闲数
????????????//?时直接逐出,不再根据MinEvictableIdleTimeMillis判断?(默认逐出策略)
????????????config.setSoftMinEvictableIdleTimeMillis(1800000);
????????????//?在获取连接的时候检查有效性,?默认false
????????????config.setTestOnBorrow(false);
????????????//?在空闲时检查有效性,?默认false
????????????config.setTestWhileIdle(false);
????????????//?逐出扫描的时间间隔(毫秒)?如果为负数,则不运行逐出线程,?默认-1
????????????config.setTimeBetweenEvictionRunsMillis(-1);
????????????jedisPool?=?new?JedisPool(config,?addr,?port,?3000);
????????}?catch?(Exception?e)?{
????????????e.printStackTrace();
????????}
????}
????
????public?synchronized?static?Jedis?getJedis()?{
????????try?{
????????????if?(jedisPool?!=?null)?{
????????????????Jedis?resource?=?jedisPool.getResource();
????????????????return?resource;
????????????}?else?{
????????????????return?null;
????????????}
????????}?catch?(Exception?e)?{
????????????e.printStackTrace();
????????????return?null;
????????}
????}
????public?static?void?close(final?Jedis?jedis)?{
????????if?(jedis?!=?null)?{
????????????jedis.close();
????????}
????}
????
????/*---------------------测试---------------------------*/
????public?static?void?main(java.lang.String[]?args)?{
????????Jedis?jedis?=?RedisClient.getJedis();
????????//?do?something
????????RedisClient.testCallLua(jedis);
????????RedisClient.close(jedis);
????}
????
????public?static?void?testCallLua(Jedis?jedis){
????????String?luaStr?=?"return?{KEYS[1],KEYS[1],ARGV[2]}";
????????Object?result?=?jedis.eval(luaStr,?Lists.newArrayList("userName","age"),?Lists.newArrayList("Jack","20"));
????????System.out.println(result);
????}
}

/**
?????*?调用lua脚本
?????*?@param?jedis
?????*/
????public?static?void?testCallLuaFile(Jedis?jedis){
????????String?luaStr?=?null;
????????
????????//带反斜杠，路径为classPath，不带反斜杠，路径为类的同一目录
????????Reader?r?=?new?InputStreamReader(RedisClient.class.getResourceAsStream("/jedisCallLuaTest.lua"));
????????try?{
????????????luaStr?=?CharStreams.toString(r);
????????????Object?result?=?jedis.eval(luaStr,?Lists.newArrayList("userName"),?Lists.newArrayList("20","Tom"));
????????????System.out.println(result);
????????}?catch?(IOException?e)?{
????????????e.printStackTrace();
????????}
????}

@Test
public void apcheIo() throws IOException{
    String luaStr=null;
    //带反斜杠，路径为classPath，不带反斜杠，路径为类的同一目录
    Reader r= new InputStreamReader(Reader2StrDemo.class.getResourceAsStream("/jedisCallLuaTest.lua"));

    luaStr = org.apache.commons.io.IOUtils.toString(r);
    System.out.println(luaStr);
}

@Test
public void java8() throws IOException{
    String luaStr=null;
    String path = "F:xxxxideaProjectsjava8-proresourcejedisCallLuaTest.lua";

    luaStr = Files.lines(Paths.get(path),Charset.defaultCharset()).collect(Collectors.joining());
    System.out.println(luaStr);
}