av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

SpringBoot整合Redis管道的示例代碼

瀏覽:6日期:2023-02-27 13:40:04
目錄1. Redis 之管道(pipeline)2. SpringBoot 整合 Redis 管道實例1. Redis 之管道(pipeline)

執行一個Redis命令,Redis客戶端和Redis服務器就需要執行以下步驟:

客戶端發送命令到服務器; 服務器接受命令請求,執行命令,產生相應的結果; 服務器返回結果給客戶端; 客戶端接受命令的執行結果,并向用戶展示。

Redis命令所消耗的大部分時間都用在了發送命令請求和接收命令結果上面,把任意多條Redis命令請求打包在一起,然后一次性地將它們全部發送給服務器,而服務器則會把所有命令請求都處理完畢之后,一次性地將它們的執行結果全部返回給客戶端。

注意事項:

Redis服務器并不會限制客戶端在管道中包含的命令數量,但是卻會為客戶端的輸入緩沖區設置默認值為1GB的體積上限:當客戶端發送的數據量超過這一限制時,Redis服務器將強制關閉該客戶端。因此最好不要一下把大量命令或者一些體積非常龐大的命令放到同一個管道中執行。

除此之外,很多客戶端本身也帶有隱含的緩沖區大小限制,如果你在使用流水線特性的過程中,發現某些流水線命令沒有被執行,或者流水線返回的結果不完整,那么很可能就是你的程序觸碰到了客戶端內置的緩沖區大小限制。

2. SpringBoot 整合 Redis 管道實例

SpringBoot 整合 redis 的實例

使用單個的 increment 命令,處理 200w個key:

public class RedisPipelineStudy extends BaseTest { @Autowired private StringRedisTemplate stringRedisTemplate; private static final String PREFIX = 'test0:'; @Test public void test() {StopWatch stopWatch = new StopWatch();stopWatch.start('test0');for (int times = 0; times < 2; times++) { for (int i = 0; i < 1000000; i++) {stringRedisTemplate.opsForValue().increment(PREFIX + i, 1L); }}stopWatch.stop();System.out.println(stopWatch.prettyPrint()); }}

耗時如下所示:是 12 位 ,單位ns

SpringBoot整合Redis管道的示例代碼

使用管道 incrBy 處理 200w個key,每次打包300條命令發送給服務器,如下所示:

public class RedisPipelineStudy extends BaseTest { @Autowired private StringRedisTemplate stringRedisTemplate; private static final String PREFIX = 'test1:'; @Test public void test() {StopWatch stopWatch = new StopWatch();stopWatch.start('test1');List<Integer> recordList = new ArrayList<>();for (int times = 0; times < 2; times++) { for (int i = 0; i < 1000000; i++) {try { recordList.add(i); if (recordList.size() > 300) {incrByPipeline(recordList);recordList = new ArrayList<>(); }} catch (Exception e) { System.out.println(e);} } if (!CollectionUtils.isEmpty(recordList)) {incrByPipeline(recordList);recordList = new ArrayList<>(); }}stopWatch.stop();System.out.println(stopWatch.prettyPrint()); } private void incrByPipeline(List<Integer> recordList) {stringRedisTemplate.executePipelined(new RedisCallback<Object>() { @Override public Object doInRedis(RedisConnection connection) throws DataAccessException {try { for (Integer record : recordList) {byte[] key = (PREFIX + record).getBytes();connection.incrBy(key, 1); }} catch (Exception e) { System.out.println(e);}return null; }}); }}

耗用時間: 11 位 ,單位 :ns,是單個命令耗時的 1/6。

SpringBoot整合Redis管道的示例代碼

到此這篇關于SpringBoot整合Redis管道的示例代碼的文章就介紹到這了,更多相關SpringBoot整合Redis管道內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Spring
相關文章:
主站蜘蛛池模板: 在线看无码的免费网站 | 成人国产精品久久 | 精品国产91亚洲一区二区三区www | 嫩草一区二区三区 | 亚洲麻豆 | 亚洲精品自在在线观看 | 99这里只有精品 | 欧美一级片在线看 | 91玖玖| 四虎精品在线 | 国产在线视频三区 | 国产精品免费一区二区三区四区 | 欧美在线视频不卡 | 国产精品亚洲视频 | 欧美日韩毛片 | 久久久久9999 | 亚洲欧美国产一区二区三区 | 一级黄色片美国 | 国产视频一区在线观看 | 偷拍自拍在线观看 | 国产在线观看免费 | 亚洲a一区| 亚洲精品视频在线看 | 影音先锋欧美资源 | 国产区第一页 | 国产精品久久久久久中文字 | av在线免费网站 | 高清国产一区二区 | 精国产品一区二区三区四季综 | 欧美一级黑人aaaaaaa做受 | 成人网址在线观看 | 日韩在线观看中文字幕 | 91精品国产91久久久久久吃药 | 91麻豆精品国产91久久久更新资源速度超快 | 天堂男人av| 国产乱码高清区二区三区在线 | 四虎影院免费在线 | 久久一| 日韩成人av在线播放 | 亚洲精品无人区 | 久久精品亚洲成在人线av网址 |