搭建一个 springboot 的项目，引入 spring-boot-starter-parent父组件，spring-boot-starter-web组件， lombok组件，jedis客户端组件 ，谷歌的guava 组件
创建 Runners 类
@Slf4j
@Component
public class Runners implements ApplicationRunner {
@Override
public void run(ApplicationArguments args) throws Exception {
Jedis jedis = new Jedis("127.0.0.1");
String lua = "return ARGV[1]"; // lua 脚本
String result = (String)jedis.eval(lua,0,"100"); // 0个key 值100
log.info("result:{}",result);
}
}
启动项目 result 打印 100
命令格式
EVAL lua脚本 numkeys key [key ...] arg [arg ...]
-
numkeys指 key 的数量 -
key [key ...]，键，多个，在lua脚本中通过KEYS[1], KEYS[2]获取 -
arg [arg ...]，值，多个，在lua脚本中通过ARGV[1], ARGV[2]获取
ScriptingCommands 类 jedis 对 lua 命令的支持
public interface ScriptingCommands {
Object eval(String script, int keyCount, String... params);
Object eval(String script, List<String> keys, List<String> args);
Object eval(String script);
Object evalsha(String sha1);
Object evalsha(String sha1, List<String> keys, List<String> args);
Object evalsha(String sha1, int keyCount, String... params);
Boolean scriptExists(String sha1);
List<Boolean> scriptExists(String... sha1);
String scriptLoad(String script);
}
Runners 类改造
Jedis jedis = new Jedis("127.0.0.1");
String lua = "redis.call('set', KEYS[1], ARGV[1])";
List<String> keys = new ArrayList<>();
List<String> values = new ArrayList<>();
keys.add("key");
values.add("100");
jedis.eval(lua,keys,values);
打开 redis 客户端
127.0.0.1:6379> get key
"100"
或者 修改
String lua = "local str = redis.call('get', KEYS[1]);return str";
String result = (String) jedis.eval(lua,keys,values);
log.info(result);
控制台打印 100
使用 Spring Data Redis 组件，支持的客户端 Jedis / Lettuce，配置 RedisTemplate
@Configuration
@AutoConfigureAfter(RedisAutoConfiguration.class)
public class RedisConfig {
/**
* 默认情况下的模板只能支持RedisTemplate<String, String>，也就是只能存入字符串，因此支持序列化
*/
@Bean
public RedisTemplate<String, Serializable> redisTemplate(LettuceConnectionFactory redisConnectionFactory) {
RedisTemplate<String, Serializable> template = new RedisTemplate<>();
template.setKeySerializer(new StringRedisSerializer());
template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
template.setConnectionFactory(redisConnectionFactory);
return template;
}
}
@Slf4j
@Component
public class Runners implements ApplicationRunner {
@Autowired
private RedisTemplate redisTemplate;
@Override
public void run(ApplicationArguments args) throws Exception {
String lua = "redis.call('EXPIRE', KEYS[1], ARGV[2]);"; // 这里使用的是第二个参数30， 101未用到
ImmutableList<Object> keys = ImmutableList.of("key");
RedisScript<Number> redisScript = new DefaultRedisScript<>(lua, Number.class);
redisTemplate.execute(redisScript,keys,"101",30);
}
}
key 有效时间为 30 秒，30 秒之后查询 nil
127.0.0.1:6379> get key
"100"
127.0.0.1:6379> get key
(nil)
redis 可视化客户端 https://github.com/qishibo/AnotherRedisDesktopManager，查看有效时间30秒递减
更改 Runners 类
String lua = " redis.call('INCR',KEYS[1]);";
ImmutableList<Object> keys = ImmutableList.of("key");
RedisScript<Number> redisScript = new DefaultRedisScript<>(lua, Number.class);
redisTemplate.execute(redisScript,keys,"100",120);
执行命令，值增加 1
127.0.0.1:6379> get key
"100"
127.0.0.1:6379> get key
"101"
127.0.0.1:6379>
以上例子涉及 redis 四个命令 SET，GET， EXPIRE， INCR
INCR对存储在指定key的数值执行原子的加1操作
如果指定的key不存在，那么在执行incr操作之前，会先将它的值设定为0
EXPIRE设置key的过期时间，超过时间后，将会自动删除该key
查看其它命令 http://www.redis.cn/commands.html
详细lua学习 https://github.com/52fhy/lua-book
