Jedis客戶端以及redis中的pipeline批量操作

来源:https://www.cnblogs.com/yulinfeng/archive/2020/02/24/12358603.html
-Advertisement-
Play Games

關註公眾號:CoderBuff,回覆“redis”獲取《Redis5.x入門教程》完整版PDF。 《Redis5.x入門教程》目錄 "第一章 · 準備工作" "第二章 · 數據類型" "第三章 · ​命令" "第四章 ​· 配置" "第五章 · Java客戶端(上)" 第六章 · 事務 第七章 · ...


關註公眾號:CoderBuff,回覆“redis”獲取《Redis5.x入門教程》完整版PDF。

有關本章的源碼:https://github.com/yu-linfeng/redis5.x_tutorial/tree/master/code/jedis

前面的章節介紹了redis的安裝、還有命令配置等內容,我們在實際使用時大部分情況都是利用現成的Java客戶端對redis進行操作。當然命令並不是沒用,它極有可能在你排查問題時排上用場,因為你有可能會直接連入redis服務端通過命令行來排查是否是redis緩存的問題。

redis的Java客戶端最常用的是jedis開源庫,本章我們也將圍繞jedis的對redis進行一些簡單的操作,jedis的GitHub地址:https://github.com/xetorthio/jedis

package com.coderbuff.jedis.simple;

import redis.clients.jedis.Jedis;

/**
 * @author okevin
 * @date 2020/2/12 23:08
 */
public class Demo {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        jedis.set("redis-client", "jedis");
        System.out.println(jedis.get("redis-client"));
        jedis.close();
    }
}

這是一個簡單的jedis連接示例,使用MySQL的經驗告訴我們:類似有socket連接的,我們最好是通過“池化”技術,一是更好的管理我們的連接;二是能更好的利用連接資源。所以當我們在使用jedis時,最好是使用jedis提供的池化技術。

package com.codrbuff.jedis.client;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * redis客戶端連接
 * @author okevin
 * @date 2020/2/12 23:17
 */
public class RedisClient {

    /**
     * redis伺服器地址
     */
    private static final String HOST = "localhost";

    /**
     * jedis連接池
     */
    private static JedisPool jedisPool = new JedisPool(new JedisPoolConfig(), HOST);

    private RedisClient() {

    }

    /**
     * 從jedispool中獲取一個jedis連接
     * @return jedis連接
     */
    public static Jedis getJedis() {
        return jedisPool.getResource();
    }
}
package com.coderbuff.jedis.util;

import com.codrbuff.jedis.client.RedisClient;
import redis.clients.jedis.Jedis;

/**
 * redis工具類
 * @author okevin
 * @date 2020/2/12 23:13
 */
public class RedisUtil {

    //###########字元串(string)數據類型相關操作############

    /**
     * 字元串寫入
     * @param key key
     * @param value 值
     * @return 寫入的值
     */
    public static String set(String key, String value) {
        try (Jedis jedis = RedisClient.getJedis()){
            jedis.set(key, value);
            return value;
        }
    }

    public static String get(String key) {
        try (Jedis jedis = RedisClient.getJedis()) {
            return jedis.get(key);
        }
    }
}

當然我不准備在這裡把所有的命令都展示出來,關於SDK的使用大可查看官方文檔。

redis中有一個重要的功能——pipeline(管道),我們在操作大量數據時,redis的吞吐量性能可能較低,此時我們可以通過pipeline進行批量操作。這個功能在redis的命令中並沒有,但redis是支持的。所以本章將重點介紹pipeline的使用,這在實際應用中非常常用。

pipeline(管道)

pipeline提供了命令的批量提交,當我們有批量查詢或者寫入操作時,單個命令的“往返時間”是1ms,那麼10個命令就會消耗10ms,如果我們使用pipeline批量操作後可以一次性提交10個命令,redis的響應時間將會大大減小。吞吐量也自然提高。

實際上,之所以採用pipeline批量提交主要是為了控制網路開銷,10個命令就會有10次網路開銷,網路開銷對於處於異地機房的影響尤為明顯。所以在進行批量操作時,儘量使用pipeline管道操作。下麵的例子是1萬次字元串類型的寫入,反映了非pipeline和pipeline的性能對比。

package com.coderbff.jedis.test;

import com.coderbuff.jedis.util.RedisUtil;
import com.codrbuff.jedis.client.RedisClient;
import org.junit.Test;
import redis.clients.jedis.Pipeline;

/**
 * @author okevin
 * @date 2020/2/12 23:32
 */
public class JedisTests {

    @Test
    public void testPipeline() {
        long setStart = System.currentTimeMillis();
        for (int i = 0; i < 10000; i++) {
            RedisUtil.set("key_" + i, String.valueOf(i));
        }
        long setEnd = System.currentTimeMillis();
        System.out.println("非pipeline操作10000次字元串數據類型set寫入,耗時:" + (setEnd - setStart) + "毫秒");

        long pipelineStart = System.currentTimeMillis();
        Pipeline pipeline = RedisClient.getJedis().pipelined();
        for (int i = 0; i < 10000; i++) {
            pipeline.set("key_" + i, String.valueOf(i));
        }
        pipeline.sync();
        long pipelineEnd = System.currentTimeMillis();
        System.out.println("pipeline操作10000次字元串數據類型set寫入,耗時:" + (pipelineEnd - pipelineStart) + "毫秒");
    }
}

控制台輸出結果:

非pipeline操作10000次字元串數據類型set寫入,耗時:1843毫秒
pipeline操作10000次字元串數據類型set寫入,耗時:205毫秒

可以看到,通過pipeline管道批量操作,吞吐量性能大大提到。

重要

使用pipeline有幾個值得註意的地方:

  1. 它相比較於redis原生的字元串數據類型的批量操作命令,pipeline是非原子性的,mset原子性的。mset批量操作要麼都成功要麼都失敗,而pipeline則不能保證。
  2. mset只是set一個命令的批量操作,而pipeline則可以批量發送多個命令,這裡就存在事務的問題。

針對問題一,我們在進行批量操作時應儘可能的把批量操作拆分成小粒度的pipeline。

針對問題二,要保證多個命令的事務,就需要使用redis提供的事務相關的命令,但redis中的事務是“假事務”,因為它仍然不能保證原子性。在下一章中,會詳細介紹redis原生的簡單事務(不保證原子性),以及如何在redis中保證事務的原子性。

關註公眾號:CoderBuff,回覆“redis”獲取《Redis5.x入門教程》完整版PDF。
這是一個能給程式員加buff的公眾號 (CoderBuff)


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 5種PHP生成圖片驗證碼實例,包括數字驗證碼、數字+字母驗證碼、中文驗證碼、仿google驗證碼和算術驗證碼,PHP生成驗證碼的原理:通過GD庫,生成一張帶驗證碼的圖片,並將驗證碼保存在Session中。 js驗證 1 $(function() { 2 $("#getcode_num").click ...
  • 一、前言 Xlinx的ZYNQ系列SOC集成了APU、各種專用外設資源和傳統的FPGA邏輯,為ARM+FPGA的應用提供助力,降低功耗和硬體設計難度的同時極大提高兩者間傳輸的帶寬。之前在研究生課題中使用過ZYNQ搭建環路系統對演算法進行板級驗證,但並沒有深入使用和理解這個異構平臺,今天算是對入門的總結 ...
  • 文件的基本操作 文件讀寫: 文件的讀寫滿足以下3個步驟: 1).打開文件 2).操作數據(讀、寫) 3).關閉文件 --> 不要忘記 1).打開文件: python的open() 方法用於打開一個文件,並返迴文件對象,在對文件進行處理過程都需要使用到這個函數,如果該文件無法被打開,會拋出 OSErr ...
  • 一.filter函數簡介 filter函數主要用來篩選數據,過濾掉不符合條件的元素,並返回一個迭代器對象,如果要轉換為列表list或者元祖tuple,可以使用內置函數list() 或者內置函數tuple()來轉換; filter函數接收兩個參數,第一個為函數,第二個為序列,序列的每個元素作為參數傳遞 ...
  • 一、反射: 1、反射指可以在運行時載入、探知、使用編譯期間完全未知的類。 2、程式在運行狀態中,可以動態載入一個只有名稱的類,對於任意一個已載入的類,都能夠知道這個類的所有屬性和方法; 對於任意一個對象,都能調用它的任意一個方法和屬性。 3、載入完類後,在堆記憶體中產生一個Class類型的對象(一個類 ...
  • 我們說的環境變數,一般是指的是Path環境變數。 第一步:點擊“我的電腦”,右鍵,“屬性” 第二步:點擊“高級系統設置”,彈出的視窗選“高級”選項卡,點擊“環境變數” 第三步:找到“系統變數”,滾動環境變數列表,找到“Path”這個環境變數,點擊“編輯” 第四步:添加你要讓cmd去搜尋的路徑,比如你 ...
  • 原創文章首發於公眾號:「碼農富哥」,歡迎收藏和關註,如轉載請註明出處! 什麼是HTTP緩存 HTTP 緩存可以說是HTTP性能優化中簡單高效的一種優化方式了,緩存是一種保存資源副本併在下次請求時直接使用該副本的技術,當 web 緩存發現請求的資源已經被存儲,它會攔截請求,返回該資源的拷貝,而不會去源 ...
  • 我碰到有很多測試同事,操作命令行界面的東西,總是不夠嫻熟, 操作過程中,經常出現找不到此文件,No such file or directory, 我認為這種問題,主要是路徑問題導致的, 就要從理解到當前路徑這個知識點入手。。。 當前路徑 也稱為當前工作路徑(文件夾), 一般來說,用戶只能操作當前路 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...