2. 程式人生 > >【Redis】深入淺出Redis（三）——在專案中使用Jedis對Redis操作

【Redis】深入淺出Redis（三）——在專案中使用Jedis對Redis操作

阿新 • • 發佈：2018-12-24

一、前言

      在前幾篇部落格中小編向大家介紹了搭建單機版和叢集版的redis。雖然叢集搭建起來了，但是如何在專案中使用呢？在這篇部落格中，小編向大家介紹Jedis，用Jedis來對Redis進行增加、刪除、設定有效時間等操作。

二、什麼是Jedis？

      使用Jedis連線redis伺服器，Java客戶端在github上start最高的是Jedis和Redisson。Jedis提供了完整Redis命令，而Redisson有更多分散式的容器實現。

      Jedis類是整個客戶端的入口，通過Jedis可以建立與Redis Server的連線併發送命令。Jedis繼承自BinaryJedis，同時Jedis和BinaryJedis都實現了很多介面，通過一張類圖來描述：

這裡寫圖片描述

      每一個介面都代表了一類Redis命令，例如JedisCommands中包含了SET GET等命令，MultiKeyCommands中包含了針對多個Key的MSET MGET等命令。一部分命令有兩個版本的介面，如JedisCommands和BinaryJedisCommands。JedisCommands是字串引數版本命令，會在Jedis內部將引數轉換成UTF-8編碼的位元組陣列。BinaryJedisCommands提供的是位元組引數版本，允許使用者自己決定編碼等細節。ClusterCommands和SentinelCommands與叢集、高可用等相關的命令只有一個版本。

三、具體實現

3.1 環境搭建

  • Redis

  • java maven專案

3.2 引入Jedis的jar包

      向maven專案的pom.xml檔案中插入Jedis的座標：

<!-- Redis客戶端 -->
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.7.2</version>
</dependency>

3.2 建立redis客戶端實現類

這裡寫圖片描述

      建立的這個類就是為了抽象redis的操作，我們都知道的redis有很多操作，這裡就封裝了redis的新增雜湊值、獲取雜湊值、增加1、減少1、設定有效時間、檢視有效時間、刪除等操作。並通過JedisClientSingle和JedisClientCluster，單機和叢集版分別實現了操作，不同的設定，使用不同的實現，系統很靈活。

      JedisClient：

package com.taotao.rest.component;

public interface JedisClient {
    public String set(String key,String value);
    public String get(String key);
    //新增雜湊值
    public Long hset(String key,String item,String value);
    //獲取雜湊
    public String hget(String key,String item);
    //增加1
    public Long incr(String key);
    //減少1
    public Long decr(String key);
    //設定有效時間
    public Long expire(String key,int second);
    //檢視當前有效時間
    public Long ttl(String key);
    //刪除
    public Long hdel(String key,String item);
}

      叢集版JedisClientCluster：

package com.taotao.rest.component.impl;

import org.springframework.beans.factory.annotation.Autowired;

import redis.clients.jedis.JedisCluster;

import com.taotao.rest.component.JedisClient;
/**
 * 叢集版
 * @author Ares
 *
 */
public class JedisClientCluster implements JedisClient {

    @Autowired
    private JedisCluster jedisCluster;

    @Override
    public String set(String key, String value) {
        return jedisCluster.set(key, value);
    }

    @Override
    public String get(String key) {
        return jedisCluster.get(key);
    }

    @Override
    public Long hset(String key, String item, String value) {
        return jedisCluster.hset(key, item, value);
    }

    @Override
    public String hget(String key, String item) {
        return jedisCluster.hget(key, item);
    }

    @Override
    public Long incr(String key) {
        return jedisCluster.incr(key);
    }

    @Override
    public Long decr(String key) {
        return jedisCluster.decr(key);
    }

    @Override
    public Long expire(String key, int second) {
        return jedisCluster.expire(key, second);
    }

    @Override
    public Long ttl(String key) {
        return jedisCluster.ttl(key);
    }

    @Override
    public Long hdel(String key, String item) {
        return jedisCluster.hdel(key, item);
    }

}

      單機版JedisClientSingle：

package com.taotao.rest.component.impl;

import org.springframework.beans.factory.annotation.Autowired;

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

import com.taotao.rest.component.JedisClient;
/**
 * 單機版
 * 
 * @author Ares
 *
 */
public class JedisClientSingle implements JedisClient {

    @Autowired
    private JedisPool jedisPool;

    /**
     * 設定值K-V
     */
    @Override
    public String set(String key, String value) {
        //建立連線
        Jedis jedis = jedisPool.getResource();
        //設定陣列
        String result = jedis.set(key, value);
        //關閉連線
        jedis.close();
        return result;
    }

    /**
     * 獲取陣列
     */
    @Override
    public String get(String key) {
        //建立連線
        Jedis jedis = jedisPool.getResource();
        //設定陣列
        String result = jedis.get(key);
        //關閉連線
        jedis.close();
        return result;
    }

    @Override
    public Long hset(String key, String item, String value) {
        //建立連線
        Jedis jedis = jedisPool.getResource();
        //設定雜湊
        Long result = jedis.hset(key, item, value);
        //關閉連線
        jedis.close();
        return result;
    }

    @Override
    public String hget(String key, String item) {
        //建立連線
        Jedis jedis = jedisPool.getResource();
        //讀取雜湊
        String result = jedis.hget(key, item);
        //關閉連線
        jedis.close();
        return result;
    }

    @Override
    public Long incr(String key) {
        //建立連線
        Jedis jedis = jedisPool.getResource();
        //+1
        Long result = jedis.incr(key);
        //關閉連線
        jedis.close();
        return result;
    }

    @Override
    public Long decr(String key) {
        //建立連線
        Jedis jedis = jedisPool.getResource();
        //-1
        Long result = jedis.decr(key);
        //關閉連線
        jedis.close();
        return result;
    }

    @Override
    public Long expire(String key, int second) {
        //建立連線
        Jedis jedis = jedisPool.getResource();
        //設定有效時間
        Long result = jedis.expire(key,second);
        //關閉連線
        jedis.close();
        return result;
    }

    @Override
    public Long ttl(String key) {
        //建立連線
        Jedis jedis = jedisPool.getResource();
        //檢視有效時間
        Long result = jedis.ttl(key);
        //關閉連線
        jedis.close();
        return result;
    }

    @Override
    public Long hdel(String key, String item) {
        //建立連線
        Jedis jedis = jedisPool.getResource();
        //檢視有效時間
        Long result = jedis.hdel(key, item);
        //關閉連線
        jedis.close();
        return result;
    }

}

3.2 託付給Spring管理

      這裡我們把Redis客戶端託付給Spring管理，配置Redis的主機地址以及埠。

      然後配置redis客戶端的實現類，這裡小編列出了單機版和叢集版兩種。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
    http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd">

    <!-- 包掃描器，掃描帶@Service註解的類 -->
    <context:component-scan base-package="com.taotao.rest.service"></context:component-scan>
    <!-- 配置redis客戶端單機版 -->
    <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
        <constructor-arg name="host" value="192.168.137.12"></constructor-arg>
        <constructor-arg name="port" value="6379"></constructor-arg>
    </bean>
    <!-- 配置redis客戶端實現類 -->
    <bean id="jedisClientSingle" class="com.taotao.rest.component.impl.JedisClientSingle"/>

    <!-- 配置redis客戶端叢集版 -->
    <!--<bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
        <constructor-arg>
            <set>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.137.12"/>
                    <constructor-arg name="port" value="7001"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.137.12"/>
                    <constructor-arg name="port" value="7002"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.137.12"/>
                    <constructor-arg name="port" value="7003"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.137.12"/>
                    <constructor-arg name="port" value="7004"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.137.12"/>
                    <constructor-arg name="port" value="7005"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.137.12"/>
                    <constructor-arg name="port" value="7006"/>
                </bean>
            </set>
        </constructor-arg>
    </bean>
    <bean id="jedisClientCluster" class="com.taotao.rest.component.impl.JedisClientCluster"/> --> 

</beans>

3.5 業務邏輯中新增快取

      注意：新增快取時不要影響正常的業務邏輯

@Override
    public List<TbContent> getContentList(Long cid) {
        //新增快取
        //查詢資料庫之前先查詢快取，如果有直接返回
        try {
            //從redis中取快取資料
            String json = jedisClient.hget(REDIS_CONTENT_KEY, cid+"");
            if (!StringUtils.isBlank(json)) {
                //把json轉換成List
                List<TbContent> list = JsonUtils.jsonToList(json, TbContent.class);
                return list;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        // 根據cid查詢內容列表
        TbContentExample example = new TbContentExample();
        Criteria criteria = example.createCriteria();
        criteria.andCategoryIdEqualTo(cid);
        //執行查詢
        List<TbContent> list = contentMapper.selectByExampleWithBLOBs(example);

        //返回結果之前，向快取中新增資料
        try {
            //為了規範key可以使用hash
            //定義一個儲存內容的key，hash中每個項就是cid
            //value是list，需要把list轉換成json資料。
            jedisClient.hset(REDIS_CONTENT_KEY, cid+"", JsonUtils.objectToJson(list));
        } catch (Exception e) {
            e.printStackTrace();
        }
        return list;
    }

四、小結

      通過使用Jedis，可以對redis進行操作。這樣快取我們就可以很好的使用了，另外就是對快取使用的時候不能影響業務邏輯。還要設定超時時間，如果連結超時也要進行資料庫查詢了。

      下一篇部落格將向大家介紹redis的快取同步問題。

相關推薦

【Mybatis】深入淺出Mybatis（三）——環境搭建

一、前言       前一篇部落格向大家介紹了Mybatis的架構——【Mybatis】深入淺出Mybatis（二）——Mybatis的框架，在這篇我們就開始通過一個例子來搭建一下Mybatis的環境。 二、環境要求 mybatis-3.2.7.ja

【轉】JMeter學習（三）元件的作用域與執行順序

ces ner 處理器 規則 fig 子節點 控制器 conf 節點 1.元件的作用域 JMeter中共有8類可被執行的元件（測試計劃與線程組不屬於元件），這些元件中，取樣器是典型的不與其它元件發生交互作用的元件，邏輯控制器只對其子節點的取樣器有效，而其它元件（config

【函式】C語言（三）

函式是一組一起執行一個任務的語句。每個 C 程式都至少有一個函式，即主函式 main() ，所有簡單的程式都可以定義其他額外的函式。  定義函式 return_type function_name( parameter list ) { body of the

【MVC】.NET實踐（三）—對資料庫的資料進行刪除與修改

在主介面新增修改和刪除的超連結（Index.cshtml） <table id="tbList"> <tr> <th>id&l

【React】歸納篇（三）模組與元件以及模組化與元件化-概念與基本使用

慨念 模組：向外提供特定功能的JS檔案，便於複用JS，簡化JS，提升JS效率 資料、對資料的操作（函式）、將想暴露的私有的函式向外暴露（暴露的資料型別是物件） 模組化：形容專案編碼方式，即按

【MVC】深入淺出MVC（一）——MVC是什麼？

一、前言       最近在做圖書館管理系統，是一個BS的系統，這個系統的基本結構是ASP.NET MVC，EF框架，Jquery EasyUI，Log4Net，VSS，微軟T4模版。前幾天介紹了EF

【Mybatis】深入淺出Mybatis（八）——動態SQL

一、前言       前一篇部落格中介紹了Mybatis的別名的使用，這個方法也是非常方便的。下面小編向大家介紹一下Mybatis的最精彩的亮點——動態SQL。通過mybatis提供的各種標籤方法實現

【Django】使用模型（三）

模型： 任何應用程式的基本，不管是不是Web應用，都是它所展現、手機和修改的資訊。因此，若將應用程式分層，模型（model）將是最底層的一層，它是基礎，檢視和末班可以根據資料進出模型的方式以及表現的形式任意替換，但模型卻相對穩定得多。 從設計整個Web應用的角度來說，模型

【Mybatis】深入淺出Mybatis（十）——逆向工程

一、前言       前一篇部落格中，小編向大家介紹了一下Mybatis和hibernate的對比，在這一篇部落格說說mybatis的逆向工程，展示一下，一個非常讓你驚訝的技術，只要你有一個數據庫，你的持久層，你的D層從此不用你自己手寫了。 二、什麼是逆向工

【MySql】Sql優化（三）——效能優化

一、前言       當資料庫資料達到一定數量的時候，結合資料庫連線池Druid的視覺化監控介面，對系統中執行的sql語句進行檢測，對使用頻繁、執行時間長的sql語句進行優化。 二、優化方案原則 [原則一:選擇需要優化的SQL] 1,選擇需要優化

【譯】Async/Await（三）——Aysnc/Await模式

原文標題：Async/Await 原文連結：https://os.phil-opp.com/async-await/#multitasking 公眾號： Rust 碎碎念 翻譯 by： Praying Async/Await 模式（The Async/Await Pattern） async/awa

【從下而上學習Redis】資料結構篇（一）：跳躍表（skiplist）

描述 跳躍表（skiplist）是對有序的連結串列增加上附加的前進連結，在列表中的查詢可以快速的跳過部分列表，因此取名跳躍表。跳躍表大概就長得如下圖所示 再舉個形象點的栗子，就像我們如果要去國外，如果徒步去當然會累死，於是我們先坐飛機，下飛機後乘坐汽車，然後再走一段路最

Redis 小白指南（三）- 事務、過期、消息通知、管道和優化內存空間

如何 入門 系列 code 場景 消息 運算 封裝 c# Redis 小白指南（三）- 事務、過期、消息通知、管道和優化內存空間 簡介 　　《Redis 小白指南（一）- 簡介、安裝、GUI 和 C# 驅動介紹》 講的是 Redis 的介紹，以及如何在 Windows

【C語言天天練（三）】typedef具體解釋

tar 原因 外部 指向 可用 引入 解釋 trac 兩個 引言： typedef能夠看作type define的縮寫，顧名思義就是類型定義，也就是說它僅僅是給已有的類型又一次定義了一個方便使用的別名。並沒有產生新的數據類型。 typed

Redis 設計與實現 （三）

check 就會 鍵值 鍵值對 是否 second 變化 write 次數 RDB 持久化 　一、生成RDB 　　cmd：SAVE --阻塞進程，執行完，才能有效接收客戶端命令。 　　cmd: BGSAVE --非阻塞，開啟子進程保存。 　　　　　　　　　　客

Redis深入學習筆記（三）RDB及AOF流程

del 每秒調用 查看 單個 一個 重寫 use 物理內存 深入學習 RDB是Redis持久化數據的一種方式，是執行時間點的Redis內存快照，redis數據還原時加載rdb文件，Redis的主從數據同步也是基於RDB實現的。 RDB流程：

【海亮集訓DAY12（三）】對揹包的補充二的補充——第k優解

專輯：海量集訓-動態規劃-揹包 分三次更新 對第三次更新的補充 對於上次的更新，由於我還沒將第k優解的演算法研究透，所以就暫時沒有寫，在這裡不上 揹包的第k優解 第k優解，顧名思義，就是讓我們求出一個揹包問題的第k優解

Redis底層詳解（三） 記憶體管理

一、記憶體分配概述         redis 的記憶體分配，實質上是對 tcmalloc / jemalloc 的封裝。記憶體分配本質就是給定需要分配的大小，以位元組為單位，然後返回一個指向一段分配好的連續的記憶體空間的首指標。   &n

【web框架】【 Cloud-Admin學習筆記（三）】【ace-gate閘道器】

Cloud-Admin專案裡的api閘道器專案是ace-gate，採用的是Spring Cloud Gateway元件，對外提供一個統一的api入口，並實現了api鑑權的功能。 從前端專案的配置裡可以看到，所有的api請求首先都轉到localhost：8765閘道器伺服器  

【第16天】Java集合（三）---Set介面實現的HashSet集合

1 HashSet簡介 2 基本用法與特點 3 HashSet的唯一性 4 增刪改時需要注意 1 HashSet簡介        作為Set介面的一個實現類，特