/redisson-spring-boot-starter

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

Primary LanguageJavaGNU Lesser General Public License v3.0LGPL-3.0

redisson-spring-boot-starter

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

升级日志

2019-04-02:1.0.2更新 1.增加spring cache 整合 2.增加session集群 3.增加消息队列 4.增加对象存储

介绍

  1. 我们为什么需要redisson?

redisson目前是官方唯一推荐的java版的分布式锁,他支持 redlock.具体请查看 官方文档

  1. jedis为什么有问题?

目前jedis是只支持单机的.

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

软件架构

  1. redisson
  2. spring boot

安装教程

.1. 引入 pom.xml

<dependency>
    <groupId>com.zengtengpeng</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>1.0.2</version>
</dependency>
  1. 在 application.properties 增加
#单Redis节点模式
redisson.singleServerConfig.address=127.0.0.1:6379

使用说明

1.如何使用分布式锁?

在方法增加 @Lock 注解 lock参数介绍

//支持 spel 表达式 如果后面需要接字符串的话请用`+`连接. 字符串一定要打`单引号`
@Lock(keys = "#user.name+'locks'")
public String test(User user) {
    System.out.println("进来了test");
    return "test";
}

2.如何存储数据?(目前实现了三个对象模板)

1.RedissonObject 这个是比较通用的模板,任何对象都可以存在这里面,在spring 容器中注入对象即可 demo实例

    @Resource
    private RedissonObject redissonObject;

2.RedissonBinary 这个是存储二进制的模板.可以存放图片之内的二进制文件,在spring 容器中注入对象即可 demo实例

    @Resource
    private RedissonBinary redissonBinary;

3.RedissonCollection 这个是集合模板,可以存放Map,List,Set集合元素,在spring 容器中注入对象即可 demo实例

    @Resource
    private RedissonCollection redissonCollection;
  1. 如何session集群?

在启动类标注 @EnableRedissonHttpSession 即可

进阶篇

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

    @Autowired
    private RedissonClient redissonClient;

如何集成spring cache 详细实例

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

如何使用消息队列MQ.(使用起来非常简单.两个注解即可完成操作)

消息队列分为 生产者以及消费者,生产者生产消息供消费者消费 详细实例

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

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);
}

集群模式配置(也可以使用yml写法) 链接地址

属性列表(分为 公共参数,单例模式参数,集群模式参数) 链接地址

996.icu