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