您好,欢迎来到爱图财经。
搜索
您的当前位置:首页关于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"));

Copyright © 2019- aitruthgpt.com.cn 版权所有

违法及侵权请联系:TEL:199 18 7713 E-MAIL:2724546146@qq.com

本站由北京市万商天勤律师事务所王兴未律师提供法律服务