Redisson 总结

1. 底子使用

1.1 引入依赖

1. <dependencies>
2.         <dependency>
3.             <groupId>org.redisson</groupId>
4.             <artifactId>redisson-spring-boot-starter</artifactId>
5.         </dependency>
6. </dependencies>

复制代码

包含的依赖如下

1.2 配置文件

其实默认主机就是 127.0.0.1，默认端口是 6379，一致的话可以不用配置

1. spring:
2.   data:
3.     redis:
4.       host: 127.0.0.1
5.       password: redis

复制代码

1.3 测试类

1. import org.redisson.api.RBucket;
2. import org.redisson.api.RedissonClient;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. @RestController
8. public class DemoController {
10.     private final RedissonClient redissonClient;
12.     @Autowired
13.     public DemoController(RedissonClient redissonClient) {
14.         this.redissonClient = redissonClient;
15.     }
17.     @GetMapping("/test")
18.     public void test() {
19.         RBucket<String> bucket = redissonClient.getBucket("test");
20.         bucket.set("hello");
21.     }
23.     @GetMapping("/get")
24.     public String get() {
25.         RBucket<String> bucket = redissonClient.getBucket("test");
26.         return bucket.get();
27.     }
28. }

复制代码

1.4 测试

访问 /test 接口，利用 Redis 管理工具可以看到数据已经添加了进来

在访问 /get 接口，乐成获取到数据

2. 设置序列化

上面可以看到在 Redis 管理工具中查看数据是一串字符，并不直观，可以自界说数据序列化
2.1 配置类

1. import org.redisson.Redisson;
2. import org.redisson.api.RedissonClient;
3. import org.redisson.codec.JsonJacksonCodec;
4. import org.redisson.config.Config;
5. import org.redisson.config.SingleServerConfig;
6. import org.springframework.context.annotation.Bean;
7. import org.springframework.context.annotation.Configuration;
9. @Configuration
10. public class RedissonConfig {
12.     @Bean
13.     public RedissonClient redissonClient() {
14.         Config config = new Config();
15.         // 单机模式
16.         SingleServerConfig singleServerConfig = config.useSingleServer();
17.         singleServerConfig.setAddress("redis://127.0.0.1:6379");
18.         singleServerConfig.setPassword("redis");
19.         // JSON序列化
20.         config.setCodec(new JsonJacksonCodec());
22.         return Redisson.create(config);
23.     }
24. }

复制代码

这里已经配置了主机等相干信息，因此配置文件里的配置可以去除，或者这里直接取配置文件的值，具体根据情况选择，其他的序列化类如下
编码类名称说明org.redisson.codec.JsonJacksonCodecJackson JSON 编码org.redisson.codec.AvroJacksonCodecAvro 一种二进制的 JSON 编码org.redisson.codec.SmileJacksonCodecSmile一种 二进制的 JSON 编码org.redisson.codec.CborJacksonCodecCBOR 一种二进制的 JSON 编码org.redisson.codec.MsgPackJacksonCodecMsgPack 一种 二进制的 JSON 编码org.redisson.codec.IonJacksonCodecAmazon Ion 亚马逊的 Ion 编码，格式与 JSON 类似org.redisson.codec.KryoCodecKryo 二进制对象序列化编码org.redisson.codec.SerializationCodecJDK 序列化编码org.redisson.codec.FstCodecFST 10 倍于 JDK 序列化性能而且 100% 兼容的编码org.redisson.codec.LZ4CodecLZ4 压缩型序列化对象编码org.redisson.codec.SnappyCodecSnappy 另一个压缩型序列化对象编码org.redisson.client.codec.JsonJacksonMapCodec基于 Jackson 的映射类使用的编码，可用于避免序列化类的信息，以及用于办理使用byte[] 碰到的问题org.redisson.client.codec.StringCodec纯字符串编码（无转换）org.redisson.client.codec.LongCodec纯整长型数字编码（无转换）org.redisson.client.codec.ByteArrayCodec字节数组编码org.redisson.codec.CompositeCodec用来组合多种不同编码在一起 2.2 测试

访问 /test 接口，再查看数据可以看到已经序列化成 JSON 格式

3. 底子数据结构使用

3.1 String

其实上面的示例用的就是字符串操作，通过 RBucket 对象来操作字符串数据结构
创建一个实体类

1. import lombok.Builder;
2. import lombok.Data;
4. import java.io.Serial;
5. import java.io.Serializable;
7. @Data
8. @Builder
9. public class Article implements Serializable {
11.     @Serial
12.     private static final long serialVersionUID = -8862397425409851538L;
13.   
14.     private String title;
16.     private String content;
17. }

复制代码

存储对象，简单示比方下：

1. import org.redisson.api.RBucket;
2. import org.redisson.api.RedissonClient;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. @RestController
8. public class DemoController {
10.     private final RedissonClient redissonClient;
12.     @Autowired
13.     public DemoController(RedissonClient redissonClient) {
14.         this.redissonClient = redissonClient;
15.     }
17.     @GetMapping("/test")
18.     public void test() {
19.         RBucket<Object> bucket = redissonClient.getBucket("test");
20.         bucket.set(Article.builder().title("demo").content("test redisson").build());
21.     }
22. }

复制代码

数据如下：

3.2 Hash

通过 RMap 对象来操作哈希数据结构，简单示比方下：

1. import org.redisson.api.RMap;
2. import org.redisson.api.RedissonClient;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. @RestController
8. public class DemoController {
10.     private final RedissonClient redissonClient;
12.     @Autowired
13.     public DemoController(RedissonClient redissonClient) {
14.         this.redissonClient = redissonClient;
15.     }
17.     @GetMapping("/test")
18.     public void test() {
19.         RMap<String, Article> rMap = redissonClient.getMap("test");
20.         rMap.put("k1", Article.builder().title("demo").content("test redisson").build());
21.     }
22. }

复制代码

数据如下：

3.3 List

3.3.1 无序

通过 RList 对象来操作列表数据结构，简单示比方下：

1. import org.redisson.api.RList;
2. import org.redisson.api.RedissonClient;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. @RestController
8. public class DemoController {
10.     private final RedissonClient redissonClient;
12.     @Autowired
13.     public DemoController(RedissonClient redissonClient) {
14.         this.redissonClient = redissonClient;
15.     }
17.     @GetMapping("/test")
18.     public void test() {
19.         RList<Article> rList = redissonClient.getList("test");
20.         rList.add(Article.builder().title("demo").content("test redisson").build());
21.         rList.add(Article.builder().title("demo").content("test redisson").build());
22.     }
23. }

复制代码

数据如下：

3.3.2 有序

通过 RSortedSet 对象来操作有序集合数据结构
改造一下实体类，实现 Comparable 接口

1. import lombok.Data;
3. import java.io.Serial;
4. import java.io.Serializable;
6. @Data
7. public class Article implements Serializable, Comparable<Article> {
9.     @Serial
10.     private static final long serialVersionUID = -8862397425409851538L;
12.     private Long id;
14.     private String title;
16.     private String content;
18.     @Override
19.     public int compareTo(Article article) {
20.         return this.getId().compareTo(article.getId());
21.     }
22. }

复制代码

简单示比方下：

1. import org.redisson.api.RSortedSet;
2. import org.redisson.api.RedissonClient;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. @RestController
8. public class DemoController {
10.     private final RedissonClient redissonClient;
12.     @Autowired
13.     public DemoController(RedissonClient redissonClient) {
14.         this.redissonClient = redissonClient;
15.     }
17.     @GetMapping("/test")
18.     public void test() {
19.         RSortedSet<Article> rSortedSet = redissonClient.getSortedSet("test");
21.         Article article1 = new Article();
22.         article1.setId(22L);
23.         article1.setTitle("demo");
24.         article1.setContent("test redisson");
25.         rSortedSet.add(article1);
27.         Article article2 = new Article();
28.         article2.setId(11L);
29.         article2.setTitle("demo");
30.         article2.setContent("test redisson");
31.         rSortedSet.add(article2);
32.     }
33. }

复制代码

数据如下，可以看到数据根据 id 排序

3.4 Set

通过 RSet 对象来操作集合数据结构，简单示比方下：

1. import org.redisson.api.RSet;
2. import org.redisson.api.RedissonClient;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. @RestController
8. public class DemoController {
10.     private final RedissonClient redissonClient;
12.     @Autowired
13.     public DemoController(RedissonClient redissonClient) {
14.         this.redissonClient = redissonClient;
15.     }
17.     @GetMapping("/test")
18.     public void test() {
19.         RSet<Article> rSet = redissonClient.getSet("test");
20.         rSet.add(Article.builder().title("demo").content("test redisson").build());
21.         rSet.add(Article.builder().title("demo").content("test redisson").build());
22.     }
23. }

复制代码

数据如下，可以看到重复数据被去除了

3.5 Zset

通过 RScoredSortedSet 来操作带分数的有序集合数据结构，简单示比方下：

1. import org.redisson.api.*;
2. import org.springframework.beans.factory.annotation.Autowired;
3. import org.springframework.web.bind.annotation.GetMapping;
4. import org.springframework.web.bind.annotation.RestController;
6. @RestController
7. public class DemoController {
9.     private final RedissonClient redissonClient;
11.     @Autowired
12.     public DemoController(RedissonClient redissonClient) {
13.         this.redissonClient = redissonClient;
14.     }
16.     @GetMapping("/test")
17.     public void test() {
18.         RScoredSortedSet<String> rScoredSortedSet = redissonClient.getScoredSortedSet("test");
19.         rScoredSortedSet.add(600.1, "test1");
20.         rScoredSortedSet.add(500.3, "test2");
21.         rScoredSortedSet.add(900.3, "test3");
22.         rScoredSortedSet.add(200.9, "test1");
23.     }
24. }

复制代码

数据如下，可以看到根据分数来排序，并且重复数据被排除了

4. 布隆过滤器

可以用于检索一个元素是否在一个集合中

1. import org.redisson.api.RBloomFilter;
2. import org.redisson.api.RedissonClient;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. import java.time.Duration;
9. @RestController
10. public class DemoController {
12.     private final RedissonClient redissonClient;
14.     @Autowired
15.     public DemoController(RedissonClient redissonClient) {
16.         this.redissonClient = redissonClient;
17.     }
19.     @GetMapping("/test")
20.     public void test() {
21.         RBloomFilter<String> rBloomFilter = redissonClient.getBloomFilter("test");
22.         // 初始化预期插入的数据量为10000和期望误差率为0.01
23.         rBloomFilter.tryInit(10000, 0.01);
24.         // 插入部分数据
25.         rBloomFilter.add("100");
26.         rBloomFilter.add("200");
27.         rBloomFilter.add("300");
28.         // 设置过期时间
29.         rBloomFilter.expire(Duration.ofSeconds(30));
30.         // 判断是否存在
31.         System.out.println(rBloomFilter.contains("300")); // true
32.         System.out.println(rBloomFilter.contains("200")); // true
33.         System.out.println(rBloomFilter.contains("999")); // false
34.     }
35. }

复制代码

5. 分布式自增 ID

参考代码如下：

1. import org.redisson.api.RAtomicLong;
2. import org.redisson.api.RedissonClient;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. @RestController
8. public class DemoController {
10.     private final RedissonClient redissonClient;
12.     @Autowired
13.     public DemoController(RedissonClient redissonClient) {
14.         this.redissonClient = redissonClient;
15.     }
17.     @GetMapping("/test")
18.     public void test() {
19.         RAtomicLong rAtomicLong = redissonClient.getAtomicLong("test");
20.         System.out.println(rAtomicLong.incrementAndGet());
21.     }
22. }

复制代码

6. 分布式锁

6.1 未加锁情况

模仿一个库存扣减操作

1. import org.redisson.api.RBucket;
2. import org.redisson.api.RedissonClient;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. @RestController
8. public class DemoController {
10.     private final RedissonClient redissonClient;
12.     @Autowired
13.     public DemoController(RedissonClient redissonClient) {
14.         this.redissonClient = redissonClient;
15.     }
17.     @GetMapping("/test")
18.     public void test() {
19.         RBucket<Integer> bucket = redissonClient.getBucket("num");
20.         Integer num = bucket.get();
21.         if (num > 0) {
22.             System.out.println("扣减库存, 当前库存: " + --num);
23.             bucket.set(num);
24.         } else {
25.             System.out.println("库存不足");
26.         }
27.     }
28. }

复制代码

使用 Jemter 模仿并发场景

点击运行后可以看到明显出现了并发问题

6.2 加锁情况

修改下库存扣减代码

1. import org.redisson.api.RBucket;
2. import org.redisson.api.RLock;
3. import org.redisson.api.RedissonClient;
4. import org.springframework.beans.factory.annotation.Autowired;
5. import org.springframework.web.bind.annotation.GetMapping;
6. import org.springframework.web.bind.annotation.RestController;
8. @RestController
9. public class DemoController {
11.     private final RedissonClient redissonClient;
13.     @Autowired
14.     public DemoController(RedissonClient redissonClient) {
15.         this.redissonClient = redissonClient;
16.     }
18.     @GetMapping("/test")
19.     public void test() {
20.         RLock rLock = redissonClient.getLock("test");
21.         try {
22.             rLock.lock();
23.             RBucket<Integer> bucket = redissonClient.getBucket("num");
24.             Integer num = bucket.get();
25.             if (num > 0) {
26.                 System.out.println("扣减库存, 当前库存: " + --num);
27.                 bucket.set(num);
28.             } else {
29.                 System.out.println("库存不足");
30.             }
31.         } finally {
32.             rLock.unlock();
33.         }
34.     }
35. }

复制代码

再次模仿并发请求，可以看到问题已包办理

6.3 加锁操作耗时长

当加锁操作耗时较长时，假如多个请求进来，其他的请求会不停堵塞，可以使用 tryLock 来尝试获取锁，获取不到先返回相应

1. import org.redisson.api.RBucket;
2. import org.redisson.api.RLock;
3. import org.redisson.api.RedissonClient;
4. import org.springframework.beans.factory.annotation.Autowired;
5. import org.springframework.web.bind.annotation.GetMapping;
6. import org.springframework.web.bind.annotation.RestController;
8. @RestController
9. public class DemoController {
11.     private final RedissonClient redissonClient;
13.     @Autowired
14.     public DemoController(RedissonClient redissonClient) {
15.         this.redissonClient = redissonClient;
16.     }
18.     @GetMapping("/test")
19.     public void test() {
20.         RLock rLock = redissonClient.getLock("test");
21.         try {
22.             if (rLock.tryLock()) {
23.                 RBucket<Integer> bucket = redissonClient.getBucket("num");
24.                 Integer num = bucket.get();
25.                 Thread.sleep(5000);
26.                 if (num > 0) {
27.                     System.out.println("扣减库存, 当前库存: " + --num);
28.                     bucket.set(num);
29.                 } else {
30.                     System.out.println("库存不足");
31.                 }
32.             } else {
33.                 System.out.println("请稍后再试");
34.             }
35.         } catch (InterruptedException e) {
36.             System.out.println(e.getMessage());
37.             Thread.currentThread().interrupt();
38.         } finally {
39.             // 是否是锁定状态且是当前执行线程的锁
40.             if (rLock.isLocked() && rLock.isHeldByCurrentThread()) {
41.                 rLock.unlock();
42.             }
43.         }
44.     }
45. }

复制代码

模仿并发请求，这里将时间设置长一点，可以看到获取到锁的请求则去举行库存扣减，获取不到先返回相应

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。