AI 助理
文档备案控制台
开发者社区 数据库 文章 正文

Redisson实现方案

2022-12-14 483
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： Redisson方式1引入依赖

Redisson

方式1

引入依赖

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.15.1</version>
</dependency>

配置文件application.properties

自定义配置

redisson.url=redis://127.0.0.1:6379

配置类

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RedissonConfig {
    @Value("${redisson.url}")
    private String redisUrl;
    @Bean
    public RedissonClient getRedissonClient(){
        Config config = new Config();
        config.useSingleServer().setAddress(redisUrl);
        return Redisson.create(config);
    }
}

使用

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class DemoService {
    @Autowired
    private RedissonClient redissonClient;
    public void doSomething(){
        RLock lock = redissonClient.getLock("lock_key");
        try {
            lock.lock();
            // TODO 业务逻辑
        } finally {
            lock.unlock();
        }
    }
}

方式2：

依赖

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

配置文件application.properties（这种方式完全兼容SpringBoot配置）

spring.redis.host=127.0.0.1

spring.redis.port=6379

使用

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class DemoService {
    @Autowired
    private RedissonClient redissonClient;
    public void doSomething(){
        RLock lock = redissonClient.getLock("lock_key");
        try {
            lock.lock();
            // TODO 业务逻辑
        } finally {
            lock.unlock();
        }
    }
}

spring-integration-redis

依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-redis</artifactId>
</dependency>

配置文件application.properties

spring.redis.host=127.0.0.1

spring.redis.port=6379

配置类

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.integration.redis.util.RedisLockRegistry;
@Configuration
public class RedisLockConfig {
    @Bean
    public RedisLockRegistry redisLockRegistry(RedisConnectionFactory redisConnectionFactory) {
        return new RedisLockRegistry(redisConnectionFactory, "registry_key");
    }
}

使用

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.redis.util.RedisLockRegistry;
import org.springframework.stereotype.Service;
import java.util.concurrent.locks.Lock;
@Service
public class DemoService {
    @Autowired
    private RedisLockRegistry redisLockRegistry;
    public void doSomething(){
        Lock lock = redisLockRegistry.obtain("lock_key");
        try {
            lock.lock();
            // TODO 业务逻辑
        } finally {
            lock.unlock();
        }
    }
}

追加方式：两种方式测试方便合在一块，实际独立的

org.redisson redisson 3.15.1

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RedissonConfig {
    @Bean
    public RedissonClient getRedissonClient() {
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        return Redisson.create(config);
    }
}

@Slf4j
@RunWith(SpringRunner.class)
@SpringBootTest(classes = TaskApplication.class)
public class ExceptionTest {
    //way of first
    //redisson-spring-boot-starter-3.13.6.jar
    @Autowired
    private RedissonClient redissonClient;
//    //way of second
//    //lock4j-redisson-spring-boot-starter-2.2.2.jar
//    @Resource
//    private LockTemplate lockTemplate;
    //way of first
    @Test
    public void redisTest() {
        RLock lock = redissonClient.getLock("this_is_key");
        try {
            lock.lock();
            //模拟业务
            Thread.sleep(5000);
        } catch (Exception e) {
            log.warn("e:{}", e);
        } finally {
            lock.unlock();
        }
    }
//    //way of second
//    @Test
//    public void secondTest(){
//        LockInfo lockInfo = null;
//        try {
//            lockInfo = lockTemplate.lock("this_is_second_key", 5000L, 0);
//
//            Thread.sleep(5000);
//        } catch (Exception e) {
//            log.warn("e:{}", e);
//        }
//
//        lockTemplate.releaseLock(lockInfo);
//    }
}

==========第二种



com.baomidou

lock4j-redisson-spring-boot-starter

2.2.2

spring:
  redis:
    host: 127.0.0.1
    port: 6379



@Slf4j
@RunWith(SpringRunner.class)
@SpringBootTest(classes = TaskApplication.class)
public class ExceptionTest {
//    //way of first
//    //redisson-spring-boot-starter-3.13.6.jar
//    @Autowired
//    private RedissonClient redissonClient;
    //way of second
    //lock4j-redisson-spring-boot-starter-2.2.2.jar
    @Resource
    private LockTemplate lockTemplate;
//    //way of first
//    @Test
//    public void redisTest() {
//        RLock lock = redissonClient.getLock("this_is_key");
//        try {
//            lock.lock();
//            //模拟业务
//            Thread.sleep(5000);
//        } catch (Exception e) {
//            log.warn("e:{}", e);
//        } finally {
//            lock.unlock();
//        }
//    }
    //way of second
    @Test
    public void secondTest(){
        LockInfo lockInfo = null;
        try {
            lockInfo = lockTemplate.lock("this_is_second_key", 5000L, 0);
            Thread.sleep(5000);
        } catch (Exception e) {
            log.warn("e:{}", e);
        }
        lockTemplate.releaseLock(lockInfo);
    }
}

参考：http://t.zoukankan.com/LUA123-p-14516530.html

文章标签：
云数据库 Tair（兼容 Redis）
Java
NoSQL
Redis
学习微站
目录
相关文章
站大爷
|
数据采集 存储 测试技术
Python生成随机数插件Faker的用法
Python生成随机数插件Faker的用法
站大爷
820 0
游客slr2dnwauqc5g
|
6月前
|
存储 SQL 监控
SpringBoot- 整合Logback，滚动记录+多文件
`logback-spring.xml` 是 Spring Boot 项目中的日志配置文件，用于定义日志输出格式、级别及存储路径。支持控制台与文件双输出，按时间滚动日志，并分类记录如 SQL、错误、请求参数等信息，便于问题排查与系统监控。
游客slr2dnwauqc5g
192 0
热烈的马
|
Java Spring
Spring Boot利用Spring Data JPA实现排序与分页查询实战(附源码，超详细）
Spring Boot利用Spring Data JPA实现排序与分页查询实战(附源码，超详细）
热烈的马
882 0
听风的鱼鱼儿
|
SQL 存储 数据挖掘
深入了解SQLite3命令：小巧强大的数据库工具
SQLite3是轻量级数据库工具，适用于嵌入式设备和数据分析。它提供交互式shell，无需服务器，易于部署。常用命令如`.schema`显示表结构，`.mode`设置输出格式。示例包括创建数据库`mydatabase.db`，创建表`users`，插入数据并查询。注意动态类型系统、性能限制及SQL注入安全。适合轻量级数据存储和管理。
听风的鱼鱼儿
1137 7
聚娃科技开发者团队
|
Java Spring
解析Spring Boot中的配置文件与外部化配置
解析Spring Boot中的配置文件与外部化配置
聚娃科技开发者团队
589 0
渐暖
|
Java 文件存储 Spring
【springboot】logback配置
【springboot】logback配置
渐暖
638 1
愿天堂没有BUG（公众号同名）
|
存储 JavaScript Java
【已开源】针对 jar 和 vue 一键自动化部署工具，界面好，操作简单！
easy-jenkins是一款对vue和jar的部署工具，操作简单，实行一键部署，内部结构采用流水线形式架构，每次部署，时时提供部署过程，部署记录，界面友好简洁，使用方便，符合用户常规操作
愿天堂没有BUG（公众号同名）
863 0
程序员朱永胜
|
XML 数据格式
记一下Shiro重构之ShiroConfig配置文件
记一下Shiro重构之ShiroConfig配置文件
程序员朱永胜
275 0
章为忠学架构
|
XML 消息中间件 架构师
SpringBoot从小白到精通（十二）logback日志配置
Springboot的日志的框架比较丰富，而且Springboot本身就内置了日志功能，不过实际项目中会出现：只记录想要的日志，日志输出到磁盘，按天归档，日志信息同步到其他系统等功能。这些是Springboot本身就内置了日志功能不具备的。所以我推荐使用logback。下面我们就以logback讲讲Spring Boot中的日志收集。
章为忠学架构
1378 0
SpringBoot从小白到精通（十二）logback日志配置

热门文章

最新文章

  • 1
    阿里云快照怎么收费？云服务器快照收费标准了解一下
  • 2
    浅谈GPU虚拟化技术（五）：GPU图形渲染虚拟化的业界难题-VDI的用户体验
  • 3
    jsQR 一个完全独立的javascript 二维码识别库
  • 4
    非“典型”向量数据库AnalyticDB PostgreSQL及RAG服务实践
  • 5
    为什么haveged不适合在虚拟机上使用
  • 6
    Effective C++ 2e Item39
  • 7
    java 数组插入元素
  • 8
    微信调试器
  • 9
    微信公众平台开发（51）会员卡
  • 10
    [转贴]ParameterizedThreadStart，ThreadStart的使用，线程Thread传参数
  • 1
    阿里云Linux服务器PHP项目完整部署指南：从环境搭建到安全上线
    40
  • 2
    Hermes Agent 核心必学：SubAgent 子代理的 5 个实战技巧，多任务处理效率翻倍
    50
  • 3
    【剪映小助手】添加音频接口（Add Audios）
    41
  • 4
    无人机战场侦察6类军事目标检测数据集分享（适用于YOLO系列深度学习分类检测任务）
    37
  • 5
    Understand-Anything：不用硬啃源码，把项目变成一张能追问的知识图谱
    56
  • 6
    CodeGraph 爆火：编程 Agent 需要的不是更多上下文，而是一张提前画好的代码地图
    144
  • 7
    基于ResNet50的鱼类识别系统设计 图像分类识别
    35
  • 8
    基于PyTorch的EfficientDet进行水下目标检测 水下目标检测
    33
  • 9
    阿里云百炼CLI全解 命令行工具接入AI Agent实操与能力指南
    42
  • 10
    基于OpenCV的图像拼接系统
    33

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    阿里云正式发布 Agentic 代码安全：AI驱动的双Agent协同引擎