springboot redis存读数据_cursor> hasnext 一直为true

引入依赖：

maven:

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-redis</artifactId>
    <version>1.4.7.RELEASE</version>
</dependency>

gradle:

implementation 'org.springframework.data:spring-data-redis'
implementation 'redis.clients:jedis'

直接使用：

@Autowired
private StringRedisTemplate stringRedisTemplate;

从redis读取数据：

private HashMap<String ,String> getRedisMap(String template){

        HashMap<String ,String> map = new HashMap<>();

        try {

            Cursor<Map.Entry<Object,Object>> cursor = stringRedisTemplate.opsForHash().scan(template,ScanOptions.NONE);

            Map.Entry<Object,Object> entry;

            while (cursor.hasNext()){

                entry = cursor.next();

                if(entry==null || entry.getKey()==null || entry.getValue()==null){

                    continue;

                }

                map.put(entry.getKey().toString(),entry.getValue().toString());

            }

            cursor.close();

        }catch (Exception e){

            LOGGER.error("获取redis数据异常",e);

        }

        return map;

}

 

向redis 存入数据：

long timeout =300;

        stringRedisTemplate.executePipelined(new SessionCallback<Object>() {

            @Override

            public Object execute(RedisOperations ro) {

                String userIndex;

                BoundHashOperations<String,String,String> hashOps = stringRedisTemplate.boundHashOps(templateKey);

                for(User user: userList){

                    if(user.getPos()==null){

                        continue;

                    }

                    userIndex = user.getIndex();

                    hashOps.put("name"+userIndex, Optional.ofNullable(user.getName()).orElse(""));

                    hashOps.put("age"+userIndex, String.valueOf(Optional.ofNullable(user.getAge ()).orElse(999)));

                }

//设置过期

                stringRedisTemplate.expire(templateKey, timeout, TimeUnit.SECONDS);

                return null;

            }

        }

        );