第三章 springboot + jedisCluster

来源:http://www.cnblogs.com/java-zhao/archive/2016/04/02/5347703.html
-Advertisement-
Play Games

如果使用的是redis2.x,在項目中使用客戶端分片(Shard)機制。(具體使用方式:第九章 企業項目開發--分散式緩存Redis(1) 第十章 企業項目開發--分散式緩存Redis(2)) 如果使用的是redis3.x中的集群,在項目中使用jedisCluster。 1、項目結構 2、pom.x ...


如果使用的是redis2.x,在項目中使用客戶端分片(Shard)機制。(具體使用方式:第九章 企業項目開發--分散式緩存Redis(1)  第十章 企業項目開發--分散式緩存Redis(2)

如果使用的是redis3.x中的集群,在項目中使用jedisCluster。

1、項目結構

 

2、pom.xml

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 4 
 5     <modelVersion>4.0.0</modelVersion>
 6 
 7     <groupId>com.xxx</groupId>
 8     <artifactId>myboot</artifactId>
 9     <version>1.0-SNAPSHOT</version>
10 
11     <properties>
12         <java.version>1.8</java.version><!-- 官方推薦 -->
13     </properties>
14     <!-- 引入spring-boot-starter-parent做parent是最好的方式, 
15          但是有時我們可能要引入我們自己的parent,此時解決方式有兩種: 
16          1)我們自己的parent的pom.xml的parent設為spring-boot-starter-parent(沒有做過驗證,但是感覺可行) 
17          2)使用springboot文檔中的方式:見spring-boot-1.2.5-reference.pdf的第13頁 
18     -->
19     <parent> 
20         <groupId>org.springframework.boot</groupId> 
21         <artifactId>spring-boot-starter-parent</artifactId> 
22         <version>1.2.5.RELEASE</version> 
23     </parent>
24 
25     <!-- <dependencyManagement>
26         <dependencies>
27             <dependency>
28                 Import dependency management from Spring Boot
29                 <groupId>org.springframework.boot</groupId>
30                 <artifactId>spring-boot-dependencies</artifactId>
31                 <version>1.2.5.RELEASE</version>
32                 <type>pom</type>
33                 <scope>import</scope>
34             </dependency>
35         </dependencies>
36     </dependencyManagement> -->
37 
38     <!-- 引入實際依賴 -->
39     <dependencies>
40         <dependency>
41             <groupId>org.springframework.boot</groupId>
42             <artifactId>spring-boot-starter-web</artifactId>
43         </dependency>
44         <dependency>
45             <groupId>redis.clients</groupId>
46             <artifactId>jedis</artifactId>
47         </dependency>
48         <dependency>
49             <groupId>com.alibaba</groupId>
50             <artifactId>fastjson</artifactId>
51             <version>1.1.15</version>
52         </dependency>
53         <dependency>
54             <groupId>org.apache.commons</groupId>
55             <artifactId>commons-lang3</artifactId>
56             <version>3.3.2</version>
57         </dependency>
58     </dependencies>
59 
60     <build>
61         <plugins>
62             <!-- 用於將應用打成可直接運行的jar(該jar就是用於生產環境中的jar) 值得註意的是,如果沒有引用spring-boot-starter-parent做parent, 
63                 且採用了上述的第二種方式,這裡也要做出相應的改動 -->
64             <plugin>
65                 <groupId>org.springframework.boot</groupId>
66                 <artifactId>spring-boot-maven-plugin</artifactId>
67             </plugin>
68         </plugins>
69     </build>
70 </project>
View Code

說明:相對於上一章的代碼僅僅引入了jedis的依賴jar。

 

3、application.properties

 1 #user info
 2 user.id=1
 3 user.username=zhaojigang
 4 user.password=123
 5 
 6 #redis cluster
 7 redis.cache.clusterNodes=localhost:8080
 8 redis.cache.commandTimeout=5
 9 #unit:second
10 redis.cache.expireSeconds=120
View Code

說明:相對於上一章的代碼僅僅引入了redis cluster的配置信息

 

4、Application.java(springboot啟動類,與上一章一樣)

5、RedisProperties.java(Redis屬性裝配)

 1 package com.xxx.firstboot.redis;
 2 
 3 import org.springframework.boot.context.properties.ConfigurationProperties;
 4 import org.springframework.stereotype.Component;
 5 
 6 @Component
 7 @ConfigurationProperties(prefix = "redis.cache")
 8 public class RedisProperties {
 9 
10     private int    expireSeconds;
11     private String clusterNodes;
12     private int    commandTimeout;
13 
14     public int getExpireSeconds() {
15         return expireSeconds;
16     }
17 
18     public void setExpireSeconds(int expireSeconds) {
19         this.expireSeconds = expireSeconds;
20     }
21 
22     public String getClusterNodes() {
23         return clusterNodes;
24     }
25 
26     public void setClusterNodes(String clusterNodes) {
27         this.clusterNodes = clusterNodes;
28     }
29 
30     public int getCommandTimeout() {
31         return commandTimeout;
32     }
33 
34     public void setCommandTimeout(int commandTimeout) {
35         this.commandTimeout = commandTimeout;
36     }
37 
38 }
View Code

說明:與上一章的User類似,採用@ConfigurationProperties註解自動讀取application.properties文件的內容並裝配到RedisProperties的每一個屬性中去。

 

6、JedisClusterConfig.java(獲取JedisCluster單例)

 1 package com.xxx.firstboot.redis;
 2 
 3 import java.util.HashSet;
 4 import java.util.Set;
 5 
 6 import org.springframework.beans.factory.annotation.Autowired;
 7 import org.springframework.context.annotation.Bean;
 8 import org.springframework.context.annotation.Configuration;
 9 
10 import redis.clients.jedis.HostAndPort;
11 import redis.clients.jedis.JedisCluster;
12 
13 @Configuration
14 public class JedisClusterConfig {
15 
16     @Autowired
17     private RedisProperties redisProperties;
18 
19     /**
20      * 註意:
21      * 這裡返回的JedisCluster是單例的,並且可以直接註入到其他類中去使用
22      * @return
23      */
24     @Bean
25     public JedisCluster getJedisCluster() {
26         String[] serverArray = redisProperties.getClusterNodes().split(",");//獲取伺服器數組(這裡要相信自己的輸入,所以沒有考慮空指針問題)
27         Set<HostAndPort> nodes = new HashSet<>();
28 
29         for (String ipPort : serverArray) {
30             String[] ipPortPair = ipPort.split(":");
31             nodes.add(new HostAndPort(ipPortPair[0].trim(), Integer.valueOf(ipPortPair[1].trim())));
32         }
33 
34         return new JedisCluster(nodes, redisProperties.getCommandTimeout());
35     }
36 
37 }
View Code

說明:

  • 該類註入了RedisProperties類,可以直接讀取其屬性
  • 這裡沒有對jedis鏈接池提供更多的配置(jedis-2.5.x好像不支持,jedis-2.6.x支持),具體的配置屬性可以查看文章開頭第一篇博客

註意:

  • 該類使用了Java註解,@Configuration與@Bean,
    • 在方法上使用@Bean註解可以讓方法的返回值為單例,
    • 該方法的返回值可以直接註入到其他類中去使用
    • @Bean註解是方法級別的
  • 如果使用的是常用的spring註解@Component,
    • 在方法上沒有註解的話,方法的返回值就會是一個多例,
    • 該方法的返回值不可以直接註入到其他類去使用
    • 該方式的註解是類級別的

 

7、MyRedisTemplate.java(具體redis操作)

 1 package com.xxx.firstboot.redis;
 2 
 3 import org.slf4j.Logger;
 4 import org.slf4j.LoggerFactory;
 5 import org.springframework.beans.factory.annotation.Autowired;
 6 import org.springframework.stereotype.Component;
 7 
 8 import redis.clients.jedis.JedisCluster;
 9 
10 @Component
11 public class MyRedisTemplate {
12     private static final Logger LOGGER    = LoggerFactory.getLogger(MyRedisTemplate.class);
13 
14     @Autowired
15     private JedisCluster        jedisCluster;
16 
17     @Autowired
18     private RedisProperties     redisProperties;
19 
20     private static final String KEY_SPLIT = ":"; //用於隔開緩存首碼與緩存鍵值 
21 
22     /**
23      * 設置緩存 
24      * @param prefix 緩存首碼(用於區分緩存,防止緩存鍵值重覆)
25      * @param key    緩存key
26      * @param value  緩存value
27      */
28     public void set(String prefix, String key, String value) {
29         jedisCluster.set(prefix + KEY_SPLIT + key, value);
30         LOGGER.debug("RedisUtil:set cache key={},value={}", prefix + KEY_SPLIT + key, value);
31     }
32 
33     /**
34      * 設置緩存,並且自己指定過期時間
35      * @param prefix
36      * @param key
37      * @param value
38      * @param expireTime 過期時間
39      */
40     public void setWithExpireTime(String prefix, String key, String value, int expireTime) {
41         jedisCluster.setex(prefix + KEY_SPLIT + key, expireTime, value);
42         LOGGER.debug("RedisUtil:setWithExpireTime cache key={},value={},expireTime={}", prefix + KEY_SPLIT + key, value,
43             expireTime);
44     }
45 
46     /**
47      * 設置緩存,並且由配置文件指定過期時間
48      * @param prefix
49      * @param key
50      * @param value
51      */
52     public void setWithExpireTime(String prefix, String key, String value) {
53         int EXPIRE_SECONDS = redisProperties.getExpireSeconds();
54         jedisCluster.setex(prefix + KEY_SPLIT + key, EXPIRE_SECONDS, value);
55         LOGGER.debug("RedisUtil:setWithExpireTime cache key={},value={},expireTime={}", prefix + KEY_SPLIT + key, value,
56             EXPIRE_SECONDS);
57     }
58 
59     /**
60      * 獲取指定key的緩存
61      * @param prefix
62      * @param key
63      */
64     public String get(String prefix, String key) {
65         String value = jedisCluster.get(prefix + KEY_SPLIT + key);
66         LOGGER.debug("RedisUtil:get cache key={},value={}", prefix + KEY_SPLIT + key, value);
67         return value;
68     }
69 
70     /**
71      * 刪除指定key的緩存
72      * @param prefix
73      * @param key
74      */
75     public void deleteWithPrefix(String prefix, String key) {
76         jedisCluster.del(prefix + KEY_SPLIT + key);
77         LOGGER.debug("RedisUtil:delete cache key={}", prefix + KEY_SPLIT + key);
78     }
79     
80     public void delete(String key) {
81         jedisCluster.del(key);
82         LOGGER.debug("RedisUtil:delete cache key={}", key);
83     }
84 
85 }
View Code

註意:

這裡只是使用了jedisCluster做了一些字元串的操作,對於list/set/sorted set/hash的操作,可以參考開頭的兩篇博客。

 

8、MyConstants.java(緩存首碼常量定義類)

1 package com.xxx.firstboot.common;
2 
3 /**
4  * 定義一些常量
5  */
6 public class MyConstants {
7     public static final String USER_FORWARD_CACHE_PREFIX = "myboot:user";// user緩存首碼
8 }
View Code

註意:

  • 根據業務特點定義redis的緩存首碼,有助於防止緩存重覆導致的緩存覆蓋問題
  • 緩存首碼使用":"做分隔符,這是推薦做法(這個做法可以在使用redis-desktop-manager的過程看出來)

 

9、UserController.java(測試)

 

 1 package com.xxx.firstboot.web;
 2 
 3 import org.apache.commons.lang3.StringUtils;
 4 import org.springframework.beans.factory.annotation.Autowired;
 5 import org.springframework.web.bind.annotation.RequestMapping;
 6 import org.springframework.web.bind.annotation.RequestParam;
 7 import org.springframework.web.bind.annotation.RestController;
 8 
 9 import com.alibaba.fastjson.JSON;
10 import com.xxx.firstboot.common.MyConstants;
11 import com.xxx.firstboot.domain.User;
12 import com.xxx.firstboot.redis.MyRedisTemplate;
13 import com.xxx.firstboot.service.UserService;
14 
15 /**
16  * @RestController:spring mvc的註解,
17  * 相當於@Controller與@ResponseBody的合體,可以直接返回json
18  */
19 @RestController
20 @RequestMapping("/user")
21 public class UserController {
22 
23     @Autowired
24     private UserService userService;
25     
26     @Autowired
27     private MyRedisTemplate myRedisTemplate;
28 
29     @RequestMapping("/getUser")
30     public User getUser() {
31         return userService.getUser();
32     }
33     
34     @RequestMapping("/testJedisCluster")
35     public User testJedisCluster(@RequestParam("username") String username){
36         String value =  myRedisTemplate.get(MyConstants.USER_FORWARD_CACHE_PREFIX, username);
37         if(StringUtils.isBlank(value)){
38             myRedisTemplate.set(MyConstants.USER_FORWARD_CACHE_PREFIX, username, JSON.toJSONString(getUser()));
39             return null;
40         }
41         return JSON.parseObject(value, User.class);
42     }
43 
44 }
View Code

 

說明:相對於上一章,只是添加了測試緩存的方法testJedisCluster。

 

測試:

在Application.properties右擊-->run as-->java application,在瀏覽器輸入"localhost:8080/user/testJedisCluster?username=xxx"即可。

 

附:對於redis的測試,我們有時需要查看執行set後,緩存是否存入redis的db中了,有兩種方式

  • 執行set後,get數據,之後修改數據,在get數據,比較兩次get的數據是否相同即可
  • 有時,這些數據是無法修改的(假設該數據是我們從第三方介面得來的),這個時候可以使用redis-desktop-manager這個軟體來查看緩存是否存入redis(該軟體的使用比較簡單,查看官網)

 


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

-Advertisement-
Play Games
更多相關文章
  • "Microsoft Build 2016 Day 1 記錄" Microsoft Build 2016 進行到了第二天,我覺得這一天的內容非常精彩,因為主要和開發者相關
  • WordPress編輯器對SVG的支持一向是非常的不友好,首先它不能上傳SVG文件,也不能自動的嵌入到內容中讓它正常顯示。同時,對內聯SVG代碼根本不識別,會無情的將SVG代碼自動刪除。 在上一篇文章中我介紹瞭如何讓Wordpress支持上傳SVG圖片的方法,似乎是部分的解決了這個問題。最近在開發過 ...
  • 註:本文參考自 http://www.jianshu.com/p/0465a2b837d2 swagger用於定義API文檔。 好處: 前後端分離開發 API文檔非常明確 測試的時候不需要再使用URL輸入瀏覽器的方式來訪問Controller 傳統的輸入URL的測試方式對於post請求的傳參比較麻煩 ...
  • 最近這幾天,一直在思考寫伺服器的時候怎麼做資料庫的讀寫服務,用什麼架構來做這個事情,現在終於有了一個大概的想法,用redis+mysql的方法。 目前業內有兩種思路,一種是full-mem模式,即全用redis存儲這種方式。另外一種是redis只存熱數據,大部分數據放到mysql里。具體選哪種還是要 ...
  • 在 PHP 中,預設的錯誤處理很簡單。一條錯誤消息會被髮送到瀏覽器,這條消息帶有文件名、行號以及描述錯誤的消息。 PHP 錯誤處理 在創建腳本和 Web 應用程式時,錯誤處理是一個重要的部分。如果您的代碼缺少錯誤檢測編碼,那麼程式看上去很不專業,也為安全風險敞開了大門。 本教程介紹了 PHP 中一些 ...
  • 當對字元串進行修改的時候,需要使用StringBuffer和StringBuilder類。 和String類不同的是,StringBuffer和StringBuilder類的對象能夠被多次的修改,並且不產生新的未使用對象。 StringBuilder類在Java 5中被提出,它和StringBuff ...
  • import com.sun.image.codec.jpeg.JPEGCodec; 在Eclipse中處理圖片,需要引入兩個包: import com.sun.image.codec.jpeg.JPEGCodec; import com.sun.image.codec.jpeg.JPEGImage ...
  • 一、協程簡介 什麼是協程? 協程,又稱微線程,線程,英文名Coroutine。協程是一種用戶態的輕量級線程 協程擁有自己的寄存器上下文和棧。 簡單來說,協程就是來回切換,當遇到IO操作,如讀寫文件,網路操作時,就跳到另一個線程執行,再遇到IO操作,又跳回來。不斷的跳過去跳過來執行,因為速度很快,所以 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...