Java Redis Template批量查询指定键值对的实现

private RedisTemplate redisTemplate;

@SuppressWarnings({ "rawtypes", "unchecked" })
    public List executePipelined(Collection<String> keySet) {
        return redisTemplate.executePipelined(new SessionCallback<Object>() {
            @Override
            public <K, V> Object execute(RedisOperations<K, V> operations) throws DataAccessException {
                HashOperations hashOperations = operations.opsForHash();
                for (String key : keySet) {
                    hashOperations.entries(key);
                }
                return null;
            }
        });
    }

/**
     * 获取批量keys对应的列表中，指定的hash键值对列表
     * @param keys redis 键
     * @param hashKeys 哈希表键的集合（你需要获取的那些键）
     * @return
     */
    @SuppressWarnings("unchecked")
    public List<Map<String, String>> getSelectiveHashsList(List<String> keys, List<String> hashKeys) {
        List<Map<String, String>> hashList = new ArrayList<Map<String, String>>();
        List<List<String>> pipelinedList = redisTemplate.executePipelined(new RedisCallback<Object>() {
            @Override
            public Object doInRedis(RedisConnection connection) throws DataAccessException {
                StringRedisConnection stringRedisConnection = (StringRedisConnection) connection;
                for (String key : keys) {
                    stringRedisConnection.hMGet(key, hashKeys.toArray(new String[hashKeys.size()]));
                }
                return null;
            }

        });
        for (List<String> hashValueList : pipelinedList) {
            Map<String, String> map = new LinkedHashMap<String, String>();
            for (int i = 0; i < hashValueList.size(); i++) {
                map.put(hashKeys.get(i), hashValueList.get(i));
            }
            hashList.add(map);
        }
        return hashList;
    }

getSelectiveHashsList(Arrays.asList("tom","jack"),Arrays.asList("name","age"));