Redis7——基礎篇（八）

?前言：此篇文章系本人學習過程中記錄下來的筆記，里面難免會有不少欠缺的地方，誠心期待大家多多給予指教。

基礎篇：

Redis（一）
Redis（二）
Redis（三）
Redis（四）
Redis（五）
Redis（六）
Redis（七）

接上期內容：上期完成了Redis集群的學習。下面開始學習Java集成Redis，話不多說，直接發車。

一、Java連接Redis的四種方式

（一）、底層客戶端庫

1、Jedis

1.1、定義

Jedis是Redis官方推薦的Java客戶端，它提供了一套簡潔易用的 API，用于與Redis 進行交互。Jedis支持同步、異步和管道操作，能夠滿足不同場景下的需求。

1.2、優劣勢

優勢：

使用簡單，學習成本低，對初學者友好。
同步阻塞 I/O，在單線程環境下使用方便。
與 Redis的命令對應性強，容易上手。

劣勢：

在高并發場景下，由于同步阻塞 I/O 的特性，性能會受到一定影響。
多線程環境下，需要手動管理連接池，增加了開發復雜度。

2、Lettuce

2.1、定義

Lettuce是一個基于Netty的可伸縮線程安全的Redis客戶端，它支持同步、異步和響應式編程模型。Lettuce的設計目標是提供高性能和可擴展性，適用于各種復雜的應用場景。

2.2、優劣勢

優勢：

基于Netty實現，支持異步 I/O，在高并發場景下性能表現出色。
線程安全，無需手動管理連接池。
支持多種編程模型，靈活性高。

劣勢：

相比Jedis，學習成本較高。
API相對復雜，對于簡單場景可能顯得過于繁瑣。

（二）、上層框架封裝

1、RedisTemplate

1.1、定義

RedisTemplate是Spring Data Redis 提供的一個高級封裝，它簡化了Java與Redis的交互操作。RedisTemplate提供了豐富的方法，支持各種數據結構的操作，并且可以方便地進行事務管理和序列化配置。

1.2、優劣勢

優勢：

與Spring 框架無縫集成，使用方便。
對各種數據結構的操作進行了封裝，代碼簡潔。
支持事務管理和序列化配置，提高了應用的靈活性和可維護性。

劣勢：

依賴Spring框架，如果項目中沒有使用 Spring，引入RedisTemplate會增加項目的復雜度。
相比底層客戶端庫，性能上可能會有一定損耗。

2、Redisson

2.1、定義

Redisson是一個在Redis的基礎上實現的Java駐內存數據網格（In-Memory Data Grid）。它不僅提供了一系列的分布式的Java常用對象，還提供了許多分布式服務，如分布式鎖、分布式集合、分布式對象等，極大地簡化了分布式系統的開發。

2.2、優劣勢

優勢：

提供了豐富的分布式服務，開箱即用，像分布式鎖、分布式集合等，非常適合構建分布式系統。
對Redis功能進行了高度抽象和擴展，使用起來更加便捷。
支持多種序列化方式，兼容性好。

劣勢：

相比直接使用 Redis 客戶端，增加了一定的學習成本。
由于其功能豐富，依賴的包可能較多，在一些對依賴大小敏感的場景下不太適用。

二、實操

（一）、集成Jedis

1、新建項目

新建步驟略。最終效果圖：

2、導入依賴

        <!--jedis--><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>5.2.0</version></dependency>

3、編寫方法

3.1、連接redis單機

public class JedisDemoTest {public static void main(String[] args) {Jedis jedis = new Jedis("192.168.112.129", 6379);jedis.auth("root");jedis.set("k1", "你好jedis");System.out.println(jedis.get("k1"));//keySet<String> keys = jedis.keys("*");for (String key : keys) {System.out.println(key);}System.out.println("jedis.exists====>" + jedis.exists("k2"));System.out.println(jedis.ttl("k1"));//StringSystem.out.println(jedis.get("k1"));jedis.set("k4", "k4_redis");System.out.println("----------------------------------------");jedis.mset("str1", "v1", "str2", "v2", "str3", "v3");System.out.println(jedis.mget("str1", "str2", "str3"));//listSystem.out.println("----------------------------------------");jedis.lpush("myList", "v1", "v2", "v3", "v4", "v5");List<String> list = jedis.lrange("myList", 0, -1);for (String element : list) {System.out.println(element);}//setjedis.sadd("orders", "jd001");jedis.sadd("orders", "jd002");jedis.sadd("orders", "jd003");Set<String> set1 = jedis.smembers("orders");for (String string : set1) {System.out.println(string);}jedis.srem("orders", "jd002");System.out.println(jedis.smembers("orders").size());//hashjedis.hset("hash1", "userName", "lisi");System.out.println(jedis.hget("hash1", "userName"));Map<String, String> map = new HashMap<>();map.put("telephone", "138xxxxxxxx");map.put("address", "fatigue");map.put("email", "sxxxx@qq.com");//jedis.hmset("hash2", map);List<String> result = jedis.hmget("hash2", "telphone", "email");for (String element : result) {System.out.println(element);}//zSetjedis.zadd("zSet01", 60d, "v1");jedis.zadd("zSet01", 70d, "v2");jedis.zadd("zSet01", 80d, "v3");jedis.zadd("zSet01", 90d, "v4");List<String> zSet01 = jedis.zrange("zSet01", 0, -1);zSet01.forEach(System.out::println);// 關閉連接jedis.close();}
}

3.2、連接redis集群

public class JedisColonyDemoTest {public static void main(String[] args) {// 添加主節點HashSet<HostAndPort> jedisClusterNodes = new HashSet<>();jedisClusterNodes.add(new HostAndPort("192.168.112.129", 6379));jedisClusterNodes.add(new HostAndPort("192.168.112.130", 6381));jedisClusterNodes.add(new HostAndPort("192.168.112.129", 6380));// 連接redis集群JedisCluster cluster = new JedisCluster(jedisClusterNodes,"default","root");// 清除單機Redis設置的key// 如果用Jedis連接Redis集群模式下，// flushAll這類全局操作不能直接使用，在集群模式下對于一些全局操作命令（如 KEYS）的處理不夠完善，// 沒有內置的邏輯來處理 KEYS 命令在集群環境下的復雜性。for (HostAndPort node : jedisClusterNodes) {try (Jedis jedis = new Jedis(node.getHost(), node.getPort())) {jedis.auth("root");// 對每個節點執行 flushDB 命令jedis.flushDB();System.out.println("Flushed database on node: " + node);}}cluster.set("k1", "你好redis集群");System.out.println(cluster.get("k1"));System.out.println("cluster.exists====>" + cluster.exists("k2"));System.out.println(cluster.ttl("k1"));//StringSystem.out.println(cluster.get("k1"));cluster.set("k4", "k4_redis");System.out.println("----------------------------------------");cluster.mset("str1{x}", "v1", "str2{x}", "v2", "str3{x}", "v3");System.out.println(cluster.mget("str1{x}", "str2{x}", "str3{x}"));//listSystem.out.println("----------------------------------------");cluster.lpush("myList", "v1", "v2", "v3", "v4", "v5");List<String> list = cluster.lrange("myList", 0, -1);for (String element : list) {System.out.println(element);}//setcluster.sadd("orders", "jd001");cluster.sadd("orders", "jd002");cluster.sadd("orders", "jd003");Set<String> set1 = cluster.smembers("orders");for (String string : set1) {System.out.println(string);}cluster.srem("orders", "jd002");System.out.println(cluster.smembers("orders").size());//hashcluster.hset("hash1", "userName", "lisi");System.out.println(cluster.hget("hash1", "userName"));Map<String, String> map = new HashMap<>();map.put("telephone", "138xxxxxxxx");map.put("address", "fatigue");map.put("email", "sxxxx@qq.com");//cluster.hmset("hash2", map);List<String> result = cluster.hmget("hash2", "telphone", "email");for (String element : result) {System.out.println(element);}//zSetcluster.zadd("zSet01", 60d, "v1");cluster.zadd("zSet01", 70d, "v2");cluster.zadd("zSet01", 80d, "v3");cluster.zadd("zSet01", 90d, "v4");List<String> zSet01 = cluster.zrange("zSet01", 0, -1);zSet01.forEach(System.out::println);cluster.close();}
}

4、測試用例?

4.1、單機測試結果

?直接main方法啟動，

redis客戶端：

4.2、redis集群測試結果

控制臺輸入：

redis客戶端：

（二）、集成Lettuce

1、導入依賴

        <!--lettuce--><dependency><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId><version>6.5.4.RELEASE</version></dependency>

?*注意：如果你的Springboot版本為3.4.3，那么導入這個依賴后，可能需要清除IDEA緩存，不然一直無法new RedisURI類。刷新過maven也沒用，只有清除緩存重啟后才成功，就很奇怪( ╯□╰ )。

2、編寫方法

2.1、連接Redis單機

public class LettuceDemoTest {public static void main(String[] args) {// 構建 RedisURI 對象RedisURI uri = RedisURI.builder(RedisURI.create("redis://192.168.112.129")).withPort(6379).withAuthentication("default", "root").withDatabase(0).build();// 創建連接客戶端RedisClient client = RedisClient.create(uri);StatefulRedisConnection<String, String> conn = client.connect();// 操作命令apiRedisCommands<String, String> commands = conn.sync();// 清空Jedis設置的keycommands.flushdb();//keysList<String> list = commands.keys("*");for (String s : list) {System.out.println(s);}//Stringcommands.set("k1", "hello Lettuce");String s1 = commands.get("k1");System.out.println("String s ===" + s1);//listcommands.lpush("myList2", "v1", "v2", "v3");List<String> list2 = commands.lrange("myList2", 0, -1);for (String s : list2) {System.out.println("list ssss===" + s);}//setcommands.sadd("mySet2", "v1", "v2", "v3");Set<String> set = commands.smembers("mySet2");for (String s : set) {System.out.println("set ssss===" + s);}//hashMap<String, String> map = new HashMap<>();map.put("k1", "138xxxxxxxx");map.put("k2", "fatigue");map.put("k3", "zzyybs@126.com");//課后有問題請給我發郵件commands.hmset("myHash2", map);Map<String, String> retMap = commands.hgetall("myHash2");for (String k : retMap.keySet()) {System.out.println("hash  k=" + k + " , v==" + retMap.get(k));}//zSetcommands.zadd("myzSet2", 100.0, "s1", 110.0, "s2", 90.0, "s3");List<String> list3 = commands.zrange("myzSet2", 0, 10);for (String s : list3) {System.out.println("zSet ssss===" + s);}//sortSortArgs sortArgs = new SortArgs();sortArgs.alpha();sortArgs.desc();List<String> list4 = commands.sort("myList2", sortArgs);for (String s : list4) {System.out.println("sort ssss===" + s);}//關閉conn.close();client.shutdown();}
}

2.2、連接Redis集群

public class LettuceColonyDemoTest {public static void main(String[] args) {HashSet<RedisURI> uris = new HashSet<>();uris.add(RedisURI.builder().withHost("192.168.112.129").withPort(6379).withAuthentication("default", "root").build());uris.add(RedisURI.builder().withHost("192.168.112.130").withPort(6381).withAuthentication("default", "root").build());uris.add(RedisURI.builder().withHost("192.168.112.129").withPort(6380).withAuthentication("default", "root").build());RedisClusterClient client = RedisClusterClient.create(uris);StatefulRedisClusterConnection<String, String> con = client.connect();RedisAdvancedClusterCommands<String, String> clusterCommands = con.sync();// 清除單機Redis設置的key// Lettuce連接Redis集群模式下，能使用flushAll命令// 因為Lettuce內部實現了智能的路由機制，能夠自動將 KEYS 命令分發到集群中的各個節點，并將結果聚合返回clusterCommands.flushallAsync();//keysList<String> list = clusterCommands.keys("*");for (String s : list) {System.out.println(s);}//StringclusterCommands.set("k1", "hello Lettuce");String s1 = clusterCommands.get("k1");System.out.println("redis集群===" + s1);//listclusterCommands.lpush("myList2", "v1", "v2", "v3");List<String> list2 = clusterCommands.lrange("myList2", 0, -1);for (String s : list2) {System.out.println("list ssss===" + s);}//setclusterCommands.sadd("mySet2", "v1", "v2", "v3");Set<String> set = clusterCommands.smembers("mySet2");for (String s : set) {System.out.println("set ssss===" + s);}//hashMap<String, String> map = new HashMap<>();map.put("k1", "138xxxxxxxx");map.put("k2", "fatigue");map.put("k3", "zzyybs@126.com");//課后有問題請給我發郵件clusterCommands.hmset("myHash2", map);Map<String, String> retMap = clusterCommands.hgetall("myHash2");for (String k : retMap.keySet()) {System.out.println("hash  k=" + k + " , v==" + retMap.get(k));}//zSetclusterCommands.zadd("myzSet2", 100.0, "s1", 110.0, "s2", 90.0, "s3");List<String> list3 = clusterCommands.zrange("myzSet2", 0, 10);for (String s : list3) {System.out.println("zSet ssss===" + s);}//sortSortArgs sortArgs = new SortArgs();sortArgs.alpha();sortArgs.desc();List<String> list4 = clusterCommands.sort("myList2", sortArgs);for (String s : list4) {System.out.println("sort ssss===" + s);}//關閉con.close();client.shutdown();client.close();}
}

3、測試用例

3.1、單機測試結果

?控制臺輸出:

redis客戶端：

3.2、redis集群測試結果

控制臺輸出：

redis客戶端：

（三）、集成RedisTemplate

1、新建配置文件

新建application.properties文件：

server.port=8080
spring.application.name=RedisDemo
# ========================logging=====================
logging.level.root=info
logging.level.xxx.xx.xxx=info
logging.pattern.console=%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger- %msg%nlogging.file.name=D:/myLogs/RedisDemo.log
logging.pattern.file=%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger- %msg%n# ========================redis單機=====================
spring.data.redis.database=0
#修改為自己的真實IP
spring.data.redis.host=xxx.xxx.xxx.xxx
spring.data.redis.port=6379
spring.data.redis.password=xxxx
spring.data.redis.lettuce.pool.max-active=8
spring.data.redis.lettuce.pool.max-wait=-1ms
spring.data.redis.lettuce.pool.max-idle=8
spring.data.redis.lettuce.pool.min-idle=0

2、導入依賴

        <!--SpringBoot通用依賴模塊--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--SpringBoot與Redis整合依賴--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency><!--日志--><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-core</artifactId><version>2.24.3</version></dependency><!-- swagger3生成接口文檔依賴--><dependency><groupId>org.springdoc</groupId><artifactId>springdoc-openapi-starter-webmvc-ui</artifactId><version>2.3.0</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.30</version></dependency>

3、編寫業務類

3.1、新建controller

@RestController
@Tag(name = "訂單管理", description = "訂單的創建和查詢操作")
public class OrderController {@Resourceprivate OrderService orderService;/*** redis單機*/@RequestMapping(value = "/order/add", method = RequestMethod.POST)public void addOrder() {orderService.addOrder();}@RequestMapping(value = "/order/{id}", method = RequestMethod.GET)public String findUserById(@PathVariable Integer id) {return orderService.getOrderById(id);}/*** redis集群*/@RequestMapping(value = "/cluster/order/add", method = RequestMethod.POST)public void clusterAddOrder() {orderService.clusterAddOrder();}@RequestMapping(value = "cluster/order/{id}", method = RequestMethod.GET)public String clusterFindUserById(@PathVariable Integer id) {return orderService.clusterFindUserById(id);}
}

3.2、新建service

*注意：只編寫String類型的數據操作，其他類型的API操作，私底下練習

@Service
@Slf4j
public class OrderService {public static final String ORDER_KEY = "order:";@Resourceprivate RedisTemplate<String, String> redisTemplate;public void addOrder() {int keyId = ThreadLocalRandom.current().nextInt(1000) + 1;String orderNo = UUID.randomUUID().toString();redisTemplate.opsForValue().set(ORDER_KEY + keyId, "訂單編號" + orderNo);log.info("redis單機=====>編號{}的訂單流水生成:{}", keyId, orderNo);}public String getOrderById(Integer id) {System.out.println(redisTemplate.opsForList().range("myList", 0, -1));HashMap<String, String> map = new HashMap<>();map.put("k1", "k2");map.put("k3", "k4");map.put("k5", "k6");redisTemplate.opsForValue().multiSet(map);return redisTemplate.opsForValue().get(ORDER_KEY + id);}public void clusterAddOrder() {int keyId = ThreadLocalRandom.current().nextInt(1000) + 1;String orderNo = UUID.randomUUID().toString();redisTemplate.opsForValue().set(ORDER_KEY + keyId, "訂單編號" + orderNo);log.info("redis集群=====>編號{}的訂單流水生成:{}", keyId, orderNo);}public String clusterFindUserById(Integer id) {return redisTemplate.opsForValue().get(ORDER_KEY + id);}
}

3.3、新建config

這個配置主要是生成接口文檔。

@Configuration
public class OpenAPIConfig {@Beanpublic OpenAPI customOpenAPI() {String currentDate = DateTimeFormatter.ofPattern("yyyy-MM-dd").format(LocalDateTime.now());return new OpenAPI().info(new Info().title("springBoot利用swagger3構建api接口文檔 " + "\t" + currentDate).description("springboot+redis整合").version("1.0").termsOfService("https://www.baidu.com/"));}
}

3.4、連接redis單機

3.5、連接redis集群

4、測試接口

啟動項目，訪問http://localhost:8080/swagger-ui/index.html

4.1、單機測試結果

控制臺輸出：

redis客戶端：

Q：數據是存進去了，但是為啥是亂碼的？在連接redis客戶端的時候加上了--raw的參數還是亂碼？為啥通過接口獲取的數據是正常的，但是通過redis客戶端去查看的又是亂碼？

A：是因為序列化方式不一致造成。鍵(key)和值(value)都是通過spring提供的Serializer序列化到數據庫的。RedisTemplate默認使用的是JdkSerializationRedisSerializer。解決辦法就是統一序列化方式。

新建RedisConfig類：

@Configuration
public class RedisConfig {/***設置存儲key的序列化方式* @param redisConnectionFactory 創建與Redis連接的工廠類*/@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);//設置StringredisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(new StringRedisSerializer());// 設置hash、set、zSet、list.....redisTemplate.afterPropertiesSet();return redisTemplate;}
}

重啟項目，重新測試：

問題解決。

4.2、redis集群測試結果

修改application.properties文件，注釋redis單機配置：

重啟項目，進行測試：

redis客戶端：

初步看來，連接redis集群沒毛病。

Q：假設集群中，有主機服務宕機了，從機上位后，程序是否還能正常從redis集群獲取與寫入數據呢？

A：讀能正常，但是寫不正常

手動關閉6379，模擬測試一下。

是需要手動開啟刷新節點拓撲網落的，

#支持集群拓撲動態感應刷新,自適應拓撲刷新是否使用所有可用的更新，默認false關閉
spring.data.redis.lettuce.cluster.refresh.adaptive=true
#定時刷新 毫秒
spring.data.redis.lettuce.cluster.refresh.period=2000

不然，當某個Master主機宕機后，雖然從機上位了，但還是不可用的（針對于這個key剛好落在宕機的Master上）。

（四）、集成Redisson

1、導入依賴

        <dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>3.45.0</version></dependency>

2、編寫業務類

2.1、新建controller

@RestController
@Tag(name = "Redisson訂單管理", description = "訂單的創建和查詢操作")
public class RedissonOrderController {@Resourceprivate RedissonOrderService redissonOrderService;/*** redisson連接redis單機*/@RequestMapping(value = "/redisson/order/add", method = RequestMethod.POST)public void redissonAddOrder() {redissonOrderService.redissonAddOrder();}@RequestMapping(value = "/redisson/order/{id}", method = RequestMethod.GET)public String redissonFindUserById(@PathVariable Integer id) {return redissonOrderService.redissonFindUserById(id);}/*** redisson連接redis集群*/@RequestMapping(value = "/redisson/cluster/order/add", method = RequestMethod.POST)public void redissonClusterAddOrder() {redissonOrderService.redissonClusterAddOrder();}@RequestMapping(value = "/redisson/cluster/order/{id}", method = RequestMethod.GET)public String redissonClusterFindUserById(@PathVariable Integer id) {return redissonOrderService.redissonClusterFindUserById(id);}}

2.2、新建service

*注意：只編寫String類型的數據操作，其他類型的API操作，私底下練習。

@Service
@Slf4j
public class RedissonOrderService {public static final String ORDER_KEY = "order:";private final RedissonClient redissonSingleClient;private final RedissonClient redissonColonyClient;@Autowiredpublic RedissonOrderService(@Qualifier("redissonColonyClient") RedissonClient redissonColonyClient,@Qualifier("redissonSingleClient") RedissonClient redissonSingleClient) {this.redissonColonyClient = redissonColonyClient;this.redissonSingleClient = redissonSingleClient;}public void redissonAddOrder() {int keyId = ThreadLocalRandom.current().nextInt(1000) + 1;String orderNo = UUID.randomUUID().toString();redissonSingleClient.getBucket(ORDER_KEY + keyId).set("訂單編號" + orderNo);log.info("redisson連接redis單機=====>編號{}的訂單流水生成:{}", keyId, orderNo);}public String redissonFindUserById(Integer id) {RBucket<Object> bucket = redissonSingleClient.getBucket(ORDER_KEY + id);return (String) bucket.get();}public void redissonClusterAddOrder() {int keyId = ThreadLocalRandom.current().nextInt(1000) + 1;String orderNo = UUID.randomUUID().toString();redissonColonyClient.getBucket(ORDER_KEY + keyId).set("訂單編號" + orderNo);log.info("redisson連接redis集群=====>編號{}的訂單流水生成:{}", keyId, orderNo);}public String redissonClusterFindUserById(Integer id) {RBucket<Object> bucket = redissonColonyClient.getBucket(ORDER_KEY + id);return (String) bucket.get();}
}

2.3、新建config

@Configuration
public class RedissonConfig {/*** redisson連接redis單機*/@Bean(name = "redissonSingleClient")@Primarypublic RedissonClient redissonSingleClient() {Config config = new Config();// 單機模式config.useSingleServer().setAddress("redis://192.168.112.131:6381").setPassword("root");// 設置 JSON 序列化編解碼器config.setCodec(new JsonJacksonCodec(new ObjectMapper()));return Redisson.create(config);}/*** redisson連接redis集群*/@Bean(name = "redissonColonyClient")public RedissonClient redissonColonyClient() {Config config = new Config();// 設置JSON序列化編解碼器config.setCodec(new JsonJacksonCodec(new ObjectMapper()));// 集群模式config.useClusterServers().addNodeAddress("redis://192.168.112.129:6379","redis://192.168.112.129:6380","redis://192.168.112.130:6381","redis://192.168.112.130:6382","redis://192.168.112.131:6383","redis://192.168.112.131:6384").setScanInterval(2000)// 集群狀態掃描間隔時間，單位是毫秒.setPassword("root");return Redisson.create(config);}
}