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

Redisson实现方案

2022-12-14 396
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
Redis 开源版，标准版 2GB
推荐场景：
搭建游戏排行榜
简介： 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
学习微站
目录
相关文章
青欢
|
Java Spring
在Spring Boot中，可以通过控制`@PostConstruct`注解方法的执行顺序来实现初始化时的顺序控制
在Spring Boot中，可以通过控制`@PostConstruct`注解方法的执行顺序来实现初始化时的顺序控制
青欢
1170 1
DOKER
|
NoSQL Java Redis
Redisson集群管理工具、对Redis节点的操作
Redisson集群管理工具、对Redis节点的操作
DOKER
564 1
软件求生
|
NoSQL Shell Redis
Redis热升级秘诀：保证高可用性的技术方案
Redis热升级方案允许在不中断业务的情况下，实现数千级别Redis的无缝更新。通过构建Redis Shell程序保存数据库状态，封装动态连接库，以及在运行时加载新版本库，保持客户端连接，该方法确保了业务连续性和高可用性，且升级仅需几毫秒，显著提升了系统效率。
软件求生
991 6
yangnk42
|
Arthas Java 测试技术
Arthas 排查JVM问题总结
Arthas 排查JVM问题总结
yangnk42
828 0
Arthas 排查JVM问题总结
yangnk42
|
缓存 算法 Java
JVM问题排查
JVM问题排查
yangnk42
316 0
好逸恶劳
|
SQL 监控 Oracle
MySQL发现sql语句执行很慢排查建议
MySQL发现sql语句执行很慢排查建议
好逸恶劳
706 0
Demo
|
Prometheus 监控 Cloud Native
[基础服务] Grafana/Prometheus/node-exporter 的安装和部署
[基础服务] Grafana/Prometheus/node-exporter 的安装和部署
Demo
1437 0
[基础服务] Grafana/Prometheus/node-exporter 的安装和部署
孟威
|
存储 监控 数据可视化
日志服务 SLS 全新发布按写入数据量计费模式
日志服务 SLS 全新推出的按写入数据量计费模式让 SLS 更普惠、更易用！仅收取原始数据（非压缩）写入费用、存储费用以及外网数据流量费用，帮助用户购买更简单、费用可预期、轻松拓展更丰富场景。
孟威
2466 0
snowball_win
|
小程序 开发工具
小程序：uniapp解决 vendor.js 体积过大的问题
小程序：uniapp解决 vendor.js 体积过大的问题
snowball_win
2628 0
痴者工良
|
消息中间件 存储 算法
1.5万字长文：从 C# 入门 Kafka
1, 搭建 Kafka 环境 安装 docker-compose 单节点 Kafka 的部署 Kafka 集群的部署 2, Kafka 概念 基本概念 关于 Kafka 脚本工具 主题管理 使用 C# 创建分区 分区与复制 生产者消费者 修改配置 3, Kafka .NET 基础 生产者 批量生产 使用 Tasks.WhenAll 如何进行性能测试 消费 4,生产者 连接 Broker Key 分区 评估消息发送时间 生产者配置 acks bootstrap.servers retries enable.idempotence max.in.flight.requests.per.connec
痴者工良
1089 0

热门文章

最新文章

  • 1
    当Terraform遇上ECS（一）——DataSource篇
  • 2
    Foxmail 配置公司邮箱
  • 3
    嵌入式：一文看懂ASIC和FPGA的区别
  • 4
    饿了么大数据计算引擎实践与应用
  • 5
    SpringBoot+kafka+ELK分布式日志收集
  • 6
    pycharm使用pytest运行测试用例，无法在控制台输出print语句、log语句的解决办法
  • 7
    表格存储物联网时序模型介绍
  • 8
    GTD桌面2.0
  • 9
    思科推出全新IP和云解决方案：不断完善视频安全产品组合
  • 10
    【Web API系列教程】3.9 — 实战：处理数据（添加新条目到数据库）
  • 1
    掌握timedatectl命令：Ubuntu 系统时间管理指南
    162
  • 2
    当安全事件不再“靠人吼”：一文带你搞懂 SOAR 自动化响应实战
    55
  • 3
    JAX核心设计解析：函数式编程让代码更可控
    155
  • 4
    当业务遇上基础设施：聊聊“可观测性联邦”这门联姻术
    46
  • 5
    大数据指标和 SLA，那些你以为懂了其实没懂的事
    52
  • 6
    前端UI框架介绍 iView ElementUI ICE
    33
  • 7
    AI 十大论文精讲（九）：无损失量化革命——LLM.int8 () 破解千亿大模型内存困局
    56
  • 8
    《DNS解析+HTTPS配置：网站加密访问从0到1深度解析》
    48
  • 9
    《告别配置迷茫：云服务器+域名搭建网站实战攻略》
    29
  • 10
    GEO优化核心：高权重新闻信源筛选与AI收录实战指南
    58

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    对象存储OSS快速上手——如何使用ossbrower2