redisson-spring-boot-starter

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

升级日志

请点击这里

介绍

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.5</version>
</dependency>

2. 在 application.properties 增加

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

使用说明

1.如何使用分布式锁?

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

//1.支持spel表达式,keyConstant是常量(可选)
@Lock(keys = "#user.name",keyConstant = "常量"))
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;

3. 如何session集群?

在启动类标注 @EnableRedissonHttpSession 即可

进阶篇

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

    @Autowired
    private RedissonClient redissonClient;

2.如何集成spring cache 详细实例

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

3.如何使用消息队列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);
}

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

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