1500字范文,内容丰富有趣,写作好帮手!
1500字范文 > Redis生产环境你还敢用keys?我劝你放下屠刀 回头是岸!

Redis生产环境你还敢用keys?我劝你放下屠刀 回头是岸!

时间:2020-07-18 13:25:29

相关推荐

Redis生产环境你还敢用keys?我劝你放下屠刀 回头是岸!

来源:/xiaolyuh/blog/3169203

SCAN 命令及其相关的 SSCAN 命令、 HSCAN 命令和 ZSCAN 命令都用于增量地迭代(incrementally iterate)一集元素(a collection of elements):

SCAN 命令用于迭代当前数据库中的数据库键。

SSCAN 命令用于迭代集合键中的元素。

HSCAN 命令用于迭代哈希键中的键值对。

ZSCAN 命令用于迭代有序集合中的元素(包括元素成员和元素分值)。

基本用法可以参考:/key/scan.html

SCAN和KEYS的区别

当 KEYS 命令被用于处理一个大的数据库时, 又或者 SMEMBERS 命令被用于处理一个大的集合键时, 它们会锁定redis库, 可能会阻塞服务器达数秒之久。在高并发下会导致请求大量堆积进而导致服务雪崩。有些公司在生产环境直接禁用kyes *命令。但是在redis服务器key的数量不大的情况下,使用keys也是没啥问题的。

SCAN 命令及其相关的 SSCAN 命令、 HSCAN 命令和 ZSCAN 命令都用于增量地迭代 ,它们每次执行都只会返回少量元素,不会阻塞服务器, 所以这些命令可以用于生产环境, 而不会出现像 KEYS 命令、 SMEMBERS 命令带来的问题。

SCAN一样有它自己的问题:

因为是分段获取key,所以它会多次请求redis服务器,这样势必取同样的key,scan耗时更长。

在对键进行增量式迭代的过程中, 键可能会被修改, 所以增量式迭代命令只能对被返回的元素提供有限的保证。

SCAN cursor [MATCH pattern] [COUNT count]

使用SCAN代替KEYS

/***redis扩展工具**@authoryuhao.wang3*@since/2/2123:35*/publicabstractclassRedisHelper{privatestaticLoggerlogger=LoggerFactory.getLogger(RedisHelper.class);/***scan实现**@paramredisTemplateredisTemplate*@parampattern 表达式,如:abc*,找出所有以abc开始的键*/publicstaticSet<String>scan(RedisTemplate<String,Object>redisTemplate,Stringpattern){returnredisTemplate.execute((RedisCallback<Set<String>>)connection->{Set<String>keysTmp=newHashSet<>();try(Cursor<byte[]>cursor=connection.scan(newScanOptions.ScanOptionsBuilder().match(pattern).count(10000).build())){while(cursor.hasNext()){keysTmp.add(newString(cursor.next(),"Utf-8"));}}catch(Exceptione){logger.error(e.getMessage(),e);thrownewRuntimeException(e);}returnkeysTmp;});}}

源码分析

我看到网上很多文章说这种实现方式cursor 只会被执行一次,其实这是错误的,使用这种方式cursor 会将所有的符合条件的key都返回回来,他只是将游标的移动给封装了起来而已,真正执行查询的语句起始在cursor.hasNext()里面,源码如下:

/**(non-Javadoc)*@seejava.util.Iterator#hasNext()*/@OverridepublicbooleanhasNext(){assertCursorIsOpen();//存放结果集的容器没有值,并且游标状态是未完成的时候进行Scan动作while(!delegate.hasNext()&&!CursorState.FINISHED.equals(state)){scan(cursorId);}//如果结果容器还有值直接返回true,进行循环if(delegate.hasNext()){returntrue;}//如果结果容器没有值,但是游标不为0则表示还有值,需要进行下一次循环if(cursorId>0){returntrue;}returnfalse;}privatevoidscan(longcursorId){//进行scan操作ScanIteration<T>result=doScan(cursorId,this.scanOptions);//结果集处理processScanResult(result);}privatevoidprocessScanResult(ScanIteration<T>result){if(result==null){//重置结果集容器resetDelegate();//设置游标状态为完成state=CursorState.FINISHED;return;}//获取当前游标位置cursorId=Long.valueOf(result.getCursorId());if(isFinished(cursorId)){//游标返回0,设置游标状态为完成state=CursorState.FINISHED;}if(!CollectionUtils.isEmpty(result.getItems())){//将查询结果放到容器中delegate=result.iterator();}else{resetDelegate();}}

由上面源码我们可以看到游标的移动是在processScanResult()方法中完成。通过state来记录当前游标状态,大致过程为:

当存放结果集的容器没有值,并且游标状态是未完成的时候进行Scan动作

如果结果容器还有值直接返回true,进行循环

如果结果容器没有值,但是游标不为0则表示还有值,需要进行下一次循环

推荐好文强大,10k+点赞的 SpringBoot 后台管理系统竟然出了详细教程!分享一套基于SpringBoot和Vue的企业级中后台开源项目,代码很规范!能挣钱的,开源 SpringBoot 商城系统,功能超全,超漂亮!

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。