关于Redis事务和pipleline

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"));