Redis 一二事 - 在spring中使用jedis 連接調試單機redis以及集群redis

来源:http://www.cnblogs.com/leechenxiang/archive/2016/04/30/5447927.html
-Advertisement-
Play Games

Redis真是好，其中的鍵值用起來真心強大啊有木有， 之前的文章講過搭建了redis集群 那麼咋們該如何調用單機版的redis以及集群版的redis來使用緩存服務呢？ 先講講單機版的，單機版redis安裝非常簡單，不多說了，直接使用命令： 1 [root@nginx bin]# ./redis-se ...


Redis真是好，其中的鍵值用起來真心強大啊有木有，

之前的文章講過搭建了redis集群

那麼咋們該如何調用單機版的redis以及集群版的redis來使用緩存服務呢？

先講講單機版的，單機版redis安裝非常簡單，不多說了，直接使用命令：

 1 [root@nginx bin]# ./redis-server redis.conf 

啟動就行

在sprig文件中配置如下

 1 <!-- 
 2         TODO:
 3         開發環境使用單機版
 4         生產環境務必切換成集群
 5      -->
 6     <!-- 配置redis客戶端單機版 -->
 7     <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
 8         <constructor-arg name="host" value="${redis.single.client.host}"></constructor-arg>
 9         <constructor-arg name="port" value="${redis.single.client.port}"></constructor-arg>
10     </bean>
11     <!-- 配置redis客戶端實現類 -->
12     <bean id="jedisClientSingle" class="com.lee.rest.component.impl.JedisClientSingle"/>
13     
14     <!-- 配置redis客戶端集群版 單機版和集群版的jedis只能存在一個 -->
15     <!-- <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
16         <constructor-arg>
17             <set>
18                 <bean class="redis.clients.jedis.HostAndPort">
19                     <constructor-arg name="host" value="${redis01.real.cluster.client.host}"/>
20                     <constructor-arg name="port" value="${redis01.real.cluster.client.port}"/>
21                 </bean>
22                 <bean class="redis.clients.jedis.HostAndPort">
23                     <constructor-arg name="host" value="${redis02.real.cluster.client.host}"/>
24                     <constructor-arg name="port" value="${redis02.real.cluster.client.port}"/>
25                 </bean>
26                 <bean class="redis.clients.jedis.HostAndPort">
27                     <constructor-arg name="host" value="${redis03.real.cluster.client.host}"/>
28                     <constructor-arg name="port" value="${redis03.real.cluster.client.port}"/>
29                 </bean>
30                 <bean class="redis.clients.jedis.HostAndPort">
31                     <constructor-arg name="host" value="${redis04.real.cluster.client.host}"/>
32                     <constructor-arg name="port" value="${redis04.real.cluster.client.port}"/>
33                 </bean>
34                 <bean class="redis.clients.jedis.HostAndPort">
35                     <constructor-arg name="host" value="${redis05.real.cluster.client.host}"/>
36                     <constructor-arg name="port" value="${redis05.real.cluster.client.port}"/>
37                 </bean>
38                 <bean class="redis.clients.jedis.HostAndPort">
39                     <constructor-arg name="host" value="${redis06.real.cluster.client.host}"/>
40                     <constructor-arg name="port" value="${redis06.real.cluster.client.port}"/>
41                 </bean>
42             </set>
43         </constructor-arg>
44     </bean>
45     <bean id="jedisClientCluster" class="com.lee.rest.component.impl.JedisClientCluster"/> -->

這是配置的redis-cli的連接池

然後定義一個介面，這個介面供兩個類實現

一個是單機版，一個是集群版

有人會問為啥要2個類實現，因為redis的單機和集群都是不同的實現方法

一般在開發環境會使用單機版來做測試，生產環境直接上集群

 1 #fake cluster
 2 redis.single.client.host=192.168.1.191
 3 redis.single.client.port=6379
 4 
 5 redis01.cluster.client.host=192.168.1.192
 6 redis01.cluster.client.port=7001
 7 
 8 redis02.cluster.client.host=192.168.1.192
 9 redis02.cluster.client.port=7002
10 
11 redis03.cluster.client.host=192.168.1.192
12 redis03.cluster.client.port=7003
13 
14 redis04.cluster.client.host=192.168.1.192
15 redis04.cluster.client.port=7004
16 
17 redis05.cluster.client.host=192.168.1.192
18 redis05.cluster.client.port=7005
19 
20 redis06.cluster.client.host=192.168.1.192
21 redis06.cluster.client.port=7006

在你的資源文件中配好如上信息，供spring調用

說個題外話，資源文件*.properties，在spring的父子容器中不是公用的

也就是說，在service的spring容器中，只能配service層調用

在springMVC容器中只能被springmvc自己調用，因為資源文件不是誇容器的

而spring容器中的對象是可以被springMVC來訪問的

但是springMVC的對象以及資源文件絕對不能被spring來訪問，

舉個慄子：你有見過service訪問controller的嗎？沒有吧，哈哈

咱們先來建一個通用jedis客戶端

（有2個小家伙看不懂最後2個方法什麼意思，就加了註釋，其實規範點來講，所有的介面方法都要加註釋，而實現類就不需要，但是實現類中的私有方法必須加註釋，這是規範）

 1 package com.lee.rest.component;
 2 
 3 /**
 4  * 
 5  * @Title: JedisClient.java
 6  * @Package com.lee.rest.component
 7  * @Description: redis客戶端
 8  * Copyright: Copyright (c) 2016
 9  * Company:Nathan.Lee.Salvatore
10  * 
11  * @author leechenxiang
12  * @date 2016年4月27日 下午4:28:46
13  * @version V1.0
14  */
15 public interface JedisClient {
16 
17     public String set(String key, String value);
18     public String get(String key);
19     public Long hset(String key, String item, String value);
20     public String hget(String key, String item);
21     public Long hdel(String key, String item);
22     public Long incr(String key);
23     public Long decr(String key);
24     
25     /**
26      * 
27      * @Description: 設置存存活時間
28      * @param key
29      * @param second
30      * @return
31      * 
32      * @author leechenxiang
33      * @date 2016年4月27日 下午4:34:35
34      */
35     public Long expire(String key, int second);
36     
37     /**
38      * 
39      * @Description: 判斷key多久過期
40      * @param key
41      * @return 秒 
42      *             >= 0     剩餘秒數
43      *             = -1    永久存活
44      *             = -2    已經消除
45      * 
46      * @author leechenxiang
47      * @date 2016年4月27日 下午4:34:22
48      */
49     public Long ttl(String key);
50 }
 1 /**
 2  * 
 3  * @Title: JedisClientSingle.java
 4  * @Package com.lee.rest.component.impl
 5  * @Description: 單機版的jedis客戶端操作
 6  * Copyright: Copyright (c) 2016
 7  * Company:Nathan.Lee.Salvatore
 8  * 
 9  * @author leechenxiang
10  * @date 2016年4月27日 下午4:36:42
11  * @version V1.0
12  */
13 public class JedisClientSingle implements JedisClient {
14 
15     @Autowired
16     private JedisPool jedisPool;
17 
18     @Override
19     public String set(String key, String value) {
20         Jedis jedis = jedisPool.getResource();
21         String result = jedis.set(key, value);
22         jedis.close();
23         return result;
24     }
25 
26     @Override
27     public String get(String key) {
28         Jedis jedis = jedisPool.getResource();
29         String result = jedis.get(key);
30         jedis.close();
31         return result;
32     }
33 
34     @Override
35     public Long hset(String key, String item, String value) {
36         Jedis jedis = jedisPool.getResource();
37         Long result = jedis.hset(key, item, value);
38         jedis.close();
39         return result;
40     }
41 
42     @Override
43     public String hget(String key, String item) {
44         Jedis jedis = jedisPool.getResource();
45         String result = jedis.hget(key, item);
46         jedis.close();
47         return result;
48     }
49     
50     @Override
51     public Long hdel(String key, String item) {
52         Jedis jedis = jedisPool.getResource();
53         Long result = jedis.hdel(key, item);
54         jedis.close();
55         return result;
56     }
57 
58     @Override
59     public Long incr(String key) {
60         Jedis jedis = jedisPool.getResource();
61         Long result = jedis.incr(key);
62         jedis.close();
63         return result;
64     }
65 
66     @Override
67     public Long decr(String key) {
68         Jedis jedis = jedisPool.getResource();
69         Long result = jedis.decr(key);
70         jedis.close();
71         return result;
72     }
73 
74     @Override
75     public Long expire(String key, int second) {
76         Jedis jedis = jedisPool.getResource();
77         Long result = jedis.expire(key, second);
78         jedis.close();
79         return result;
80     }
81 
82     @Override
83     public Long ttl(String key) {
84         Jedis jedis = jedisPool.getResource();
85         Long result = jedis.ttl(key);
86         jedis.close();
87         return result;
88     }
89 
90 }
 1 /**
 2  * 
 3  * @Title: JedisClientCluster.java
 4  * @Package com.lee.rest.component.impl
 5  * @Description: 集群版的jedis客戶端操作
 6  * Copyright: Copyright (c) 2016
 7  * Company:Nathan.Lee.Salvatore
 8  * 
 9  * @author leechenxiang
10  * @date 2016年4月27日 下午4:44:02
11  * @version V1.0
12  */
13 public class JedisClientCluster implements JedisClient {
14 
15     @Autowired
16     private JedisCluster jedisCluster;
17 
18     @Override
19     public String set(String key, String value) {
20         return jedisCluster.set(key, value);
21     }
22 
23     @Override
24     public String get(String key) {
25         return jedisCluster.get(key);
26     }
27 
28     @Override
29     public Long hset(String key, String item, String value) {
30         return jedisCluster.hset(key, item, value);
31     }
32 
33     @Override
34     public String hget(String key, String item) {
35         return jedisCluster.hget(key, item);
36     }
37 
38     @Override
39     public Long hdel(String key, String item) {
40         return jedisCluster.hdel(key, item);
41     }
42     
43     @Override
44     public Long incr(String key) {
45         return jedisCluster.incr(key);
46     }
47 
48     @Override
49     public Long decr(String key) {
50         return jedisCluster.decr(key);
51     }
52 
53     @Override
54     public Long expire(String key, int second) {
55         return jedisCluster.expire(key, second);
56     }
57 
58     @Override
59     public Long ttl(String key) {
60         return jedisCluster.ttl(key);
61     }
62 
63 }

使用地方，一般都是在service中調用，把需要加緩存的地方都實現介面

取之前查詢有沒有緩存，有直接返回，沒有查資料庫，然後再放入緩存

也有企業會這麼做，所有的緩存都有一個團隊來管理，做一個定時器，每天凌晨固定一個時間點來跑批，把數據放入緩存

這麼做也是可以的

我們採取的是第一種

PS：@Autowired 這邊是用的類型相同，有人喜歡用@resource，這樣的話就得多寫一個，區別點

 1 @Autowired
 2 private JedisClient jedisClient;
 3 
 4 @Value("${REDIS_CONTENT_KEY}")
 5 private String REDIS_CONTENT_KEY;
 6 
 7 @Override
 8 public List<Content> gettList(Long id) {
 9 // TODO 這個地方加緩存和不加緩存，單台或者集群的redis，都要進行壓力測試
10 //添加緩存
11 //查詢資料庫之前先查詢緩存，如果有直接返回
12 try {
13 //從redis中取緩存數據
14 String json = jedisClient.hget(REDIS_CONTENT_KEY, id + "");
15 if (!StringUtils.isBlank(json)) {
16 //把json轉換成List
17 List<Content> list = JsonUtils.jsonToList(json, Content.class);
18 return list;
19 }
20 } catch (Exception e) {
21 e.printStackTrace();
22 }
23 
24 //執行查詢
25 List<？> list = xxxMapper.select(id);
26 // 返回結果之前，向緩存中添加數據
27 try {
28 // 為了規範key可以使用hash
29 // 定義一個保存內容的key，hash中每個項就是cid
30 // value是list，需要把list轉換成json數據。
31 jedisClient.hset(REDIS_CONTENT_KEY, id + "", JsonUtils.objectToJson(list));
32 } catch (Exception e) {
33 e.printStackTrace();
34 }
35 return list;
36 }

 

那麼service就好了，集群版的也通用

那麼集群的配置如何呢？

放開註釋

使用資源文件的配置

 

好了，啟動一下就可以運行了

配置好Test或者controller都可以調用

但是要做好緩存同步，也就是在增加，修改，刪除數據後，要同步緩存，把原有的del，在放入新的

這樣就可以了`~

 


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

-Advertisement-
Play Games
更多相關文章
  • selenium學習筆記（HTMLTestRunner測試報告）
    之前提到selenium加入unittest框架、可以引入HTMLTestRunner擴展、以此來生成測試報告 首先是分享下載的百度雲地址 http://pan.baidu.com/s/1pKUItWR 文件名：HTMLTestRunner.py 下載成功後放入相應的python目錄下如： “C:\ ...
  • [javaSE] 看博客學習多線程的創建方式和優劣比較和PHP多線程
    通過實現Runnable介面創建線程 獲取Thread對象，new出來，構造函數參數：Runnable對象 Runnable是一個介面，定義一個類MyRunnable實現Runnable介面，實現run()方法， 重寫run()方法，編寫業務邏輯 調用Thread.currentThread()方法 ...
  • JAVA多線程編程——JAVA記憶體模型
    一、何為“記憶體模型” 記憶體模型描述了程式中各個變數（實例域、靜態域和數組元素）之間的關係，以及在實際電腦系統中將變數存儲到記憶體和從記憶體中取出變數這樣的底層細節，對象最終是存儲在記憶體裡面的，但是編譯器、運行庫、處理器或者系統緩存可以有特權在變數指定記憶體位置存儲或者取出變數的值。 二、JMM（Java ...
  • TextRank演算法提取關鍵詞的Java實現
    談起自動摘要演算法，常見的並且最易實現的當屬TF-IDF，但是感覺TF-IDF效果一般，不如TextRank好。 TextRank是在 Google的PageRank演算法啟發下，針對文本里的句子設計的權重演算法，目標是自動摘要。它利用投票的原理，讓每一個單詞給它的鄰居（術語稱視窗） 投贊成票，票的權重取 ...
  • Servlet和JSP讀書筆記(一)
    Java Servlet 技術，簡稱Servlet，是Java中用於開發web應用程式的基本技術。 Servlet實際上也就是一個Java程式。一個Servlet應用程式通常包含很多Servlet。而我們熟知的JSP頁面最終也是要被編譯為Servlet。 Servlet應用程式是不能像一個普通類直接 ...
  • Python批量修改文本文件內容
    Python批量替換文件內容，支持嵌套文件夾 ...
  • django redisVSmemcache
    https://www.v2ex.com/t/142644 http://stackoverflow.com/questions/10558465/memcached-vs-redis 待整理 r.get() cache.get() ...
  • java大數據 高併發 系統框架 springmvc mybatis Bootstrap html5 shiro maven SSM
    獲取【下載地址】 【免費支持更新】三大資料庫 mysql oracle sqlsever 更專業、更強悍、適合不同用戶群體【新錄針對本系統的視頻教程，手把手教開發一個模塊，快速掌握本系統】 A集成代碼生成器 [正反雙向(單表、主表、明細表、樹形表，開發利器)+快速構建表單;freemaker模版技術 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 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 ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類