redisson-spring-boot-starter

KO | EN

gitlite — search

#react #ai #typescript #llm #golang #machine-learning #rust #deep-learning #linux #docker #cli #kubernetes #ios #open-source

redisson-spring-boot-starter

(★ 68)

redisson的spring-boot-starter.redisson是redis redlock分布式锁java的唯一实现.目前大多数项目采用的jedis的分布式锁是有问题的,redisson支持集群模式,云托管模式,单Redis节点模式,哨兵模式,主从模式. 只需一个@Lock注解.快速实现可重入锁,公平锁,联锁,红锁,读写锁分布式锁

redisson-spring-boot-starter Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# redisson-spring-boot-starter

目前有很多项目还在使用jedis的 `setNx` 充当分布式锁,然而这个锁是有问题的,redisson是java支持redis的redlock的`唯一`实现,
集成该项目后只需要极少的配置.就能够使用redisson的全部功能. 目前支持
`集群模式`,`云托管模式`,`单Redis节点模式`,`哨兵模式`,`主从模式` 配置. 支持 `可重入锁`,`公平锁`,`联锁`,`红锁`,`读写锁` 锁定模式

#### 升级日志

##### 2024-04-15

增加基于jvm的本地缓存,大大降低了网络开销

```
    @Autowired
    private RedissonObjectLocalCache redissonObjectLocalCache;
```

```
    @Autowired
    private RedissonCollectionLocalCache redissonCollectionLocalCache;
```

其他更新 [请点击这里](readme/up.md)

#### 介绍
1. 我们为什么需要`redisson`?

>`redisson`目前是官方唯一推荐的java版的分布式锁,他支持 `redlock`.具体请查看 [官方文档](https://redis.io/topics/distlock)

1. jedis为什么有问题?

> 目前jedis是只支持单机的.

> jedis setNx 和设置过期时间是不同步的,在某些极端的情况下会发生死锁.导致程序崩溃.如果没有设置value,
线程1可能会释放线程2的锁

#### 软件架构
1. [redisson](https://github.com/redisson/redisson) 
2. spring boot

#### 安装教程

>.1. 引入 pom.xml

```xml
<dependency>
    <groupId>com.zengtengpeng</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>1.0.18</version>
</dependency>
```
如果是spring3X

```xml
<dependency>
    <groupId>com.zengtengpeng</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.1.3</version>
</dependency>
```

2. 在  `application.properties` 增加

```
#单Redis节点模式
redisson.singleServerConfig.address=127.0.0.1:6379
```

#### 使用说明

---

>1.如何使用`分布式锁`?

在方法增加 `@Lock` 注解 [lock参数介绍](readme/lock.md)
```
//1.支持spel表达式,keyConstant是常量(可选)
@Lock(keys = "#user.name",keyConstant = "常量"))
public String test(User user) {
    System.out.println("进来了test");
    return "test";
}

```
---

>2.如何存储数据?

1.RedissonObject 这个是比较通用的模板,任何对象都可以存在这里面,在spring 容器中注入对象即可 [demo实例](readme/object.md)
```
    @Autowired
    private RedissonObject redissonObject;
```

2.RedissonCollectionLocalCache 相比 RedissonCollection 增加了基于jvm的内存缓存.大大降低了网络开销
```
    @Autowired
    private RedissonCollectionLocalCache redissonCollectionLocalCache;
```

3.RedissonObjectLocalCache 相比 RedissonObject 增加了基于jvm的内存缓存.大大降低了网络开销
```
    @Autowired
    private RedissonObjectLocalCache redissonObjectLocalCache;
```

4.RedissonBinary 这个是存储二进制的模板.可以存放图片之内的二进制文件,在spring 容器中注入对象即可 [demo实例](readme/binary.md)
```
    @Autowired
    private RedissonBinary redissonBinary;
```
5.RedissonCollection 这个是集合模板,可以存放`Map`,`List`,`Set`集合元素,在spring 容器中注入对象即可 [demo实例](readme/collection.md)
```
    @Autowired
    private RedissonCollection redissonCollection;
```

5.RedissonCollectionCache 此集合与上面的 RedissonCollection 基本相同,但是增加单个元素的淘汰机制 详见 
[WIKI](https://github.com/redisson/redisson/wiki/7.-%E5%88%86%E5%B8%83%E5%BC%8F%E9%9B%86%E5%90%88#711-%E6%98%A0%E5%B0%84map%E7%9A%84%E5%85%83%E7%B4%A0%E6%B7%98%E6%B1%B0eviction%E6%9C%AC%E5%9C%B0%E7%BC%93%E5%AD%98localcache%E5%92%8C%E6%95%B0%E6%8D%AE%E5%88%86%E7%89%87sharding)

```
    @Autowired
    private RedissonCollectionCache redissonCollectionCache;
```

---

>3. 如何session集群?

> 在启动类标注 `@EnableRedissonHttpSession` 即可

# 进阶篇

---

#### 1.如何使用`redisson` 客户端实现自定义操作,只需要在spring 容器中注入redisson客户端就行,如下:

```
    @Autowired
    private RedissonClient redissonClient;
```

---

#### 2.如何集成spring cache  [详细实例](readme/cache.md)

> 启动类加上 `@EnableCache(value = {"cache1","cache2"})` ,@Cacheable,@CachePut,@CacheEvict的value必须包含在这里面

---

#### 3.如何使用消息队列MQ.

> 使用起来非常简单.两个注解即可完成操作

消息队列分为 `生产者`以及`消费者`,`生产者`生产消息供`消费者`消费 [详细实例](readme/mq.md)

>`生产者` 配置,发送消息有两种模式,二选一即可

1.`代码模式`
```
RTopic testMq = redissonClient.getTopic("testMq");
User message = new User();
message.setAge("12");
message.setName("的身份为");
testMq.publish(message);
```

2.`注解模式`
```
@RequestMapping("testMq1")
@ResponseBody
@MQPublish(name = "test")
public User testMq1(){
    User user=new User();
    user.setName("garegarg");
    user.setAge("123");
    return user;
}
```

>`消费者` 配置

1.启动类加上 `@EnableMQ` 开启消费者

2.使用注解`@MQListener(name = "testMq")`配置消费者
```
@MQListener(name = "testMq")
public void test1(CharSequence charSequence,User o,Object object){
    System.out.println("charSequence="+charSequence);
    System.out.println("收到消息2"+o);
}
```
---

#### 4.集群模式配置(也可以使用yml写法) [链接地址](readme/mode.md)

---

#### 5.属性列表(分为 `公共参数`,`单例模式参数`,`集群模式参数`) [链接地址](readme/attr.md)

redisson-spring-boot-starter

redisson-spring-boot-starter Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

redisson-spring-boot-starter

redisson-spring-boot-starter Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README