這篇文章主要介紹“SpringBoot中如何通過(guò)整合Redis實(shí)現(xiàn)管道”的相關(guān)知識(shí)，小編通過(guò)實(shí)際案例向大家展示操作過(guò)程，操作方法簡(jiǎn)單快捷，實(shí)用性強(qiáng)，希望這篇“SpringBoot中如何通過(guò)整合Redis實(shí)現(xiàn)管道”文章能幫助大家解決問(wèn)題。

我們提供的服務(wù)有：成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站建設(shè)、微信公眾號(hào)開(kāi)發(fā)、網(wǎng)站優(yōu)化、網(wǎng)站認(rèn)證、山城ssl等。為上千家企事業(yè)單位解決了網(wǎng)站和推廣的問(wèn)題。提供周到的售前咨詢(xún)和貼心的售后服務(wù)，是有科學(xué)管理、有技術(shù)的山城網(wǎng)站制作公司

1. Redis 之管道（pipeline)

執(zhí)行一個(gè)Redis命令，Redis客戶(hù)端和Redis服務(wù)器就需要執(zhí)行以下步驟：

• 客戶(hù)端發(fā)送命令到服務(wù)器；

• 服務(wù)器接受命令請(qǐng)求，執(zhí)行命令，產(chǎn)生相應(yīng)的結(jié)果；

• 服務(wù)器返回結(jié)果給客戶(hù)端；

• 客戶(hù)端接受命令的執(zhí)行結(jié)果，并向用戶(hù)展示。

Redis命令所消耗的大部分時(shí)間都用在了發(fā)送命令請(qǐng)求和接收命令結(jié)果上面，把任意多條Redis命令請(qǐng)求打包在一起，然后一次性地將它們?nèi)堪l(fā)送給服務(wù)器，而服務(wù)器則會(huì)把所有命令請(qǐng)求都處理完畢之后，一次性地將它們的執(zhí)行結(jié)果全部返回給客戶(hù)端。

注意事項(xiàng)：

Redis服務(wù)器并不會(huì)限制客戶(hù)端在管道中包含的命令數(shù)量，但是卻會(huì)為客戶(hù)端的輸入緩沖區(qū)設(shè)置默認(rèn)值為1GB的體積上限：當(dāng)客戶(hù)端發(fā)送的數(shù)據(jù)量超過(guò)這一限制時(shí)，Redis服務(wù)器將強(qiáng)制關(guān)閉該客戶(hù)端。因此好不要一下把大量命令或者一些體積非常龐大的命令放到同一個(gè)管道中執(zhí)行。

除此之外，很多客戶(hù)端本身也帶有隱含的緩沖區(qū)大小限制，如果你在使用流水線(xiàn)特性的過(guò)程中，發(fā)現(xiàn)某些流水線(xiàn)命令沒(méi)有被執(zhí)行，或者流水線(xiàn)返回的結(jié)果不完整，那么很可能就是你的程序觸碰到了客戶(hù)端內(nèi)置的緩沖區(qū)大小限制。

2. SpringBoot 整合 Redis 管道實(shí)例

SpringBoot 整合 redis 的實(shí)例

使用單個(gè)的 increment 命令，處理 200w個(gè)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());
    }

}

耗時(shí)如下所示：是 12 位 ，單位ns

使用管道 incrBy 處理 200w個(gè)key，每次打包300條命令發(fā)送給服務(wù)器，如下所示：

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

耗用時(shí)間： 11 位 ，單位 ：ns，是單個(gè)命令耗時(shí)的 1/6。

關(guān)于“SpringBoot中如何通過(guò)整合Redis實(shí)現(xiàn)管道”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，小編每天都會(huì)為大家更新不同的知識(shí)點(diǎn)。

新聞名稱(chēng)：SpringBoot中如何通過(guò)整合Redis實(shí)現(xiàn)管道-創(chuàng)新互聯(lián)
文章地址：http://www.yijiale78.com/article24/dicije.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站排名、網(wǎng)站策劃、網(wǎng)站收錄、網(wǎng)站營(yíng)銷(xiāo)、電子商務(wù)、微信小程序

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話(huà)：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)