爱图财经
您的当前位置:首页关于Redis事务和pipleline

关于Redis事务和pipleline

来源:爱图财经


2、jedis代码

1、配置支持事务

template.setEnableTransactionSupport(true);

2、代码:


 redisTemplate.opsForValue().set("aaa", 321);
redisTemplate.watch("aaa");
redisTemplate.multi();
redisTemplate.opsForValue().set("aaa", 123);
redisTemplate.opsForValue().set("bbb", 123);
redisTemplate.exec();

3、pipleline

jedis 代码:


Map<String, Object> map = new HashMap<>();
map.put("aaa", 111);
map.put("bbb", 222);
map.put("ccc", 3333);

List list = redisTemplate.executePipelined(new RedisCallback<Object>() {
 @Override
 public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {
 redisConnection.openPipeline(); for (Map.Entry<String, Object> mapEntry : map.entrySet()) {
 redisConnection.set(redisTemplate.getKeySerializer().serialize(mapEntry.getKey()), redisTemplate.getValueSerializer().serialize(mapEntry.getValue()));
 } return null;
 }
}, redisTemplate.getValueSerializer());

System.out.println(redisUtil.get("aaa"));
System.out.println(redisUtil.get("bbb"));
System.out.println(redisUtil.get("ccc"));
显示全文