springboot redission 分布式锁

Spring Boot中使用Redisson实现分布式锁的方法如下:

1. 首先,需要在项目中引入Redisson依赖。在pom.xml文件中添加以下依赖:

```xml
<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.16.4</version>
</dependency>
```

2. 在Spring Boot配置文件(如application.yml)中配置Redisson连接信息:

```yaml
redisson:
  config:
    singleServerConfig:
      address: "redis://127.0.0.1:6379"
      timeout: 10000
      pingTimeout: 10000
```

3. 创建一个Redisson配置类,用于初始化RedissonClient实例:

```java
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.config.singleServerConfig.address}")
    private String address;

    @Value("${redisson.config.singleServerConfig.timeout}")
    private int timeout;

    @Value("${redisson.config.singleServerConfig.pingTimeout}")
    private int pingTimeout;

    @Bean
    public RedissonClient redissonClient() {
        Config config = new Config();
        config.useSingleServer()
                .setAddress(address)
                .setTimeout(timeout)
                .setPingTimeout(pingTimeout);
        return Redisson.create(config);
    }
}
```

4. 使用RedissonClient实例获取分布式锁:

```java
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

@Service
public class DistributedLockService {

    @Autowired
    private RedissonClient redissonClient;

    public void lock(String lockKey, Runnable task, long waitTime, long leaseTime) {
        RLock lock = redissonClient.getLock(lockKey);
        try {
            // 尝试获取锁,等待时间waitTime,锁过期时间leaseTime
            if (lock.tryLock(waitTime, leaseTime, TimeUnit.SECONDS)) {
                try {
                    task.run();
                } finally {
                    lock.unlock();
                }
            } else {
                System.out.println("获取锁失败");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }
    }
}
```

5. 在需要使用分布式锁的地方调用DistributedLockService的lock方法:

```java
@Autowired
private DistributedLockService distributedLockService;

public void someMethod() {
    String lockKey = "someLockKey";
    distributedLockService.lock(lockKey, () -> {
        // 需要加锁执行的代码
    }, 10, 60);
}
```

以上代码示例展示了如何在Spring Boot项目中使用Redisson实现分布式锁。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/30258.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

基于SpringBoot的社区医院管理服务系统

开头语&#xff1a;你好呀&#xff0c;我是计算机学姐码农小野&#xff01;如果有相关需求&#xff0c;可以私信联系我。 开发语言&#xff1a;Java 数据库&#xff1a;MySQL 技术&#xff1a;SpringBoot框架 工具&#xff1a;Eclipse&#xff0c;Navicat&#xff0c;Maven…

Python数据分析入门指南

Python作为一种多功能编程语言&#xff0c;因其简洁易读的语法和强大的库支持&#xff0c;已经成为数据分析领域的热门工具。本文将介绍如何使用Python进行基本的数据分析&#xff0c;包括数据的导入、清洗、处理和可视化。 环境搭建 在开始之前&#xff0c;确保你已经安装了…

拉取其他分支的代码

我在slx分支上&#xff0c;如何把master的分支拉取到slx分支上 结论&#xff1a;git pull origin master 详细解释 要将 master 分支的最新更改合并到 slx 分支上&#xff0c;你可以按照以下步骤进行操作&#xff1a; 使用命令行进行合并 确保在 slx 分支上 在开始之前&…

如何提高PMC在异常停线情况下的应急处理能力?

在工业生产中&#xff0c;异常停线是一个常见且令人头疼的问题。它不仅会导致生产进度受阻&#xff0c;还可能造成资源浪费和成本增加。因此&#xff0c;提高PMC&#xff08;生产计划与控制&#xff09;在异常停线情况下的应急处理能力&#xff0c;对于确保生产线的稳定运行和提…

iso27001是什么体系,有什么作用?

ISO27001是什么样的体系&#xff0c;有什么作用&#xff1f; ISO27001认证是指基于国际标准ISO 27001《信息技术-信息安全管理体系要求》对企业或组织的信息安全管理体系进行评估和认证。该标准提供了一套在组织内部实施、监控、维护和改进信息安全管理的要求。 学习ISO27001…

晨持绪科技:抖音小店的前景究竟怎么样

随着移动互联网的迅猛发展&#xff0c;短视频平台快速崛起并逐渐成为人们日常生活中不可或缺的一部分。作为国内领先的短视频平台&#xff0c;抖音在近年推出了“抖音小店”功能&#xff0c;为商家提供了一个新兴的、流量巨大的电商渠道。这一功能的推出不仅改变了传统的购物方…

算法期末整理

一 算法概述 算法的概念 通俗地讲&#xff0c;算法是指解决问题的一种方法或一个过程。更严格地讲&#xff0c;算法是由若干条指令组成的有穷序列。 算法的性质 1.输入&#xff1a;有0个或多个由外部提供的量作为算法的输入。 2.输出&#xff1a;算法产生至少一个量作为输出。…

Java中的JVM是什么?如何调优JVM的性能?

Java中的JVM&#xff08;Java Virtual Machine&#xff09;是一个虚构出来的计算机&#xff0c;是一个规范&#xff0c;它在运行Java程序时扮演着核心角色。调优JVM的性能可以通过内存管理、垃圾回收、编译器优化等方法来提升Java应用程序的性能和稳定性。 Java中的JVM&#x…

跨境电商必备?揭秘原生IP的作用

一、什么是原生IP&#xff1f; 原生IP&#xff08;Native IP&#xff09;是指由互联网服务提供商&#xff08;ISP&#xff09;或服务器提供商直接分配给用户的IP地址&#xff0c;这种IP地址直接与用户设备或网络相连&#xff0c;也就是指这个IP的注册地址和服务器机房所在的国…

某宝APP参数通过SDK把APP参数转URL参数链接方法

app里参数无法在电脑端或者在没有XX宝的手机里支付, 所以需要转成H5参数进行代付操作 出某xx宝 支付sdk转h5链接方式算法

爆赞!GitHub首本Python开发实战背记手册,标星果然百万名不虚传

Python (发音:[ paiθ(ə) n; (US) paiθɔn ] n. 蟒蛇&#xff0c;巨蛇 )&#xff0c;是一种面向对象的解释性的计算机程序设计语言&#xff0c;也是一种功能强大而完善的通用型语言&#xff0c;已经具有十多年的发展历史&#xff0c;成熟且稳定。Python 具有脚本语言中最丰富…

安防监控视频平台LntonAIServer视频智能分析平台烟火检测

LntonAIServer烟火检测技术是一种先进的技术&#xff0c;它结合了人工智能的强大能力&#xff0c;专门用于识别和检测烟雾或火焰的存在。这种技术在现代社会的许多领域中都发挥着至关重要的作用&#xff0c;尤其是在安全监控和火警预警系统等关键领域&#xff0c;它的应用更是不…

Advanced RAG 08:使用 Self-RAG 打造高质量、可追溯的 RAG System

编者按&#xff1a; RAG 技术通过检索并利用外部知识源&#xff0c;能够较为有效地提升生成内容的准确性和多样性。然而&#xff0c;经典 RAG 流程也存在一些不足&#xff0c;例如不必要的检索会浪费计算资源&#xff0c;并可能引入无关内容或错误信息&#xff0c;影响生成质量…

【ai】如何在ollama中随意使用hugging face上的gguf开源模型

【背景】 ollama的pull命令可以直接pull ollama列表中现有的模型&#xff0c;但是ollama可以直接pull的模型大都是英语偏好&#xff08;llama2有直接可以pull的chinese版本&#xff09;&#xff0c;而hugging face上则有大量多语种训练的模型&#xff0c;如果能直接使用huggin…

香港优才计划申请打分、材料、递交攻略,2024年获批后我来分享

香港优才计划这两年很多人弄啊&#xff0c;糖爸作为获批过来人&#xff0c;我来给大家分享香港优才计划申请攻略。 一、香港优才计划如何计算分数&#xff1f; 香港优才计划申请条件分2部分&#xff1a;第一是基本资格要求&#xff0c;第二是计分制度&#xff1b; 基本条件简…

【PL理论】(33) 类型系统:推导树证明 φ ⊢ e∶t | 继续定义关系:γ ⊢ e∶t

&#x1f4ac; 写在前面&#xff1a;本章我们将讲解推导树证明&#xff0c;推导树实际上就是推理规则的应用。只要学会如何选择并应用适当的推理规则&#xff0c;证明就不是难事了。 目录 0x00 推导树证明 &#x1d753; ⊢ &#x1d486; ∶ &#x1d495; 0x01 继续定义关…

《Linux运维总结:基于ARM64架构CPU使用docker-compose一键离线部署alertmanager v0.27.0高可用集群》

总结&#xff1a;整理不易&#xff0c;如果对你有帮助&#xff0c;可否点赞关注一下&#xff1f; 更多详细内容请参考&#xff1a;《Linux运维篇&#xff1a;Linux系统运维指南》 一、部署背景 由于业务系统的特殊性&#xff0c;我们需要面对不同的客户部署业务系统&#xff0…

Ubuntu 24.04安装zabbix7.0.0图形中文乱码

当zabbix安装完成后&#xff0c;设置中文界面时&#xff0c;打开图形&#xff0c;中文内容会显示方框乱码&#xff0c;是因为服务器字体中没有相关的中文字体&#xff0c;需要更换。 1、找到中文字体&#xff0c;可以在网络上下载《得意黑》开源字体&#xff0c;也可以在windo…

编程精粹—— Microsoft 编写优质无错 C 程序秘诀 01:假想的编译器

这是一本老书&#xff0c;作者 Steve Maguire 在微软工作期间写了这本书&#xff0c;英文版于 1993 年发布。2013 年推出了 20 周年纪念第二版。我们看到的标题是中译版名字&#xff0c;英文版的名字是《Writing Clean Code ─── Microsoft’s Techniques for Developing》&a…

Flink DataSink介绍

Flink DataSink是Apache Flink框架中负责将数据流发送到外部系统或存储介质的关键组件。以下是关于Flink DataSink的详细介绍&#xff1a; 一、概念与功能 Flink DataSink主要负责对经过Flink处理后的流进行一系列操作&#xff0c;并将计算后的数据结果输出到指定的位置&…