码迷,mamicode.com
首页 > 其他好文 > 详细

jedis中scan的实现

时间:2018-03-01 20:15:43      阅读:4505      评论:0      收藏:0      [点我收藏+]

标签:als   error   tco   mat   设置   while   说明   服务端   exception   

我的版本说明:

redis服务端版本:redis_version:2.8.19

jedis:

<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.8.0</version>
</dependency>

1、网上关于scan的资料很少,我把自己遇到的先总结下:

scan时间复杂度:O(1)

遍历一次所有的key:O(N),N代表次数

先贴下jedis实现代码:

    // 遍历redis所有key
    public static void scanSM() {
        Jedis jedis = null;
        ScanParams scanParams = new ScanParams();
        // 设置每次scan个数
        scanParams.count(scanCount); 
        String scanRet = "0";
        try {
            jedis = RedisUtil.getConn();
            do {
                List<String> retList = new ArrayList<>();
                ScanResult ret = jedis.scan(scanRet, scanParams.match(ConstantDefinition.SM + "*"));
                scanRet = ret.getStringCursor();
                retList.addAll(ret.getResult());
                ScanParseThread scanParseThread = Application.scanParseThreadMap.get(ConstantDefinition.SCAN_PARSE_NAME);
                LinkedBlockingQueue<List<String>> lbq = scanParseThread.getLbq();
                lbq.put(retList);
            } while (!scanRet.equals("0"));
        } catch (Exception e) {
            logger.error(e);
        } finally {
            if (null != jedis) {
                jedis.close();
            }
        }
    }    

 

jedis中scan的实现

标签:als   error   tco   mat   设置   while   说明   服务端   exception   

原文地址:https://www.cnblogs.com/xubiao/p/8489522.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!