详解Redis与Redisson的lock和tryLock功能实现机制
最编程
2024-07-28 18:38:05
...
package com.meta.mall.common.utils;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.concurrent.TimeUnit;
/**
* redisson 分布式工具类
*
* @author gaoyang
* @date 2022-05-14 08:58
*/
@Slf4j
@Component
public class RedissonUtils {
@Resource
private RedissonClient redissonClient;
/**
* 加锁
*
* @param lockKey
*/
public void lock(String lockKey) {
RLock lock = redissonClient.getLock(lockKey);
lock.lock();
}
/**
* 带过期时间的锁
*
* @param lockKey key
* @param leaseTime 上锁后自动释放锁时间
*/
public void lock(String lockKey, long leaseTime) {
RLock lock = redissonClient.getLock(lockKey);
lock.lock(leaseTime, TimeUnit.SECONDS);
}
/**
* 带超时时间的锁
*
* @param lockKey key
* @param leaseTime 上锁后自动释放锁时间
* @param unit 时间单位
*/
public void lock(String lockKey, long leaseTime, TimeUnit unit) {
RLock lock = redissonClient.getLock(lockKey);
lock.lock(leaseTime, unit);
}
/**
* 尝试获取锁
*
* @param lockKey key
* @return
*/
public boolean tryLock(String lockKey) {
RLock lock = redissonClient.getLock(lockKey);
return lock.tryLock();
}
/**
* 尝试获取锁
*
* @param lockKey key
* @param waitTime 最多等待时间
* @param leaseTime 上锁后自动释放锁时间
* @return boolean
*/
public boolean tryLock(String lockKey, long waitTime, long leaseTime) {
RLock lock = redissonClient.getLock(lockKey);
try {
return lock.tryLock(waitTime, leaseTime, TimeUnit.SECONDS);
} catch (InterruptedException e) {
log.error("RedissonUtils - tryLock异常", e);
}
return false;
}
/**
* 尝试获取锁
*
* @param lockKey key
* @param waitTime 最多等待时间
* @param leaseTime 上锁后自动释放锁时间
* @param unit 时间单位
* @return boolean
*/
public boolean tryLock(String lockKey, long waitTime, long leaseTime, TimeUnit unit) {
RLock lock = redissonClient.getLock(lockKey);
try {
return lock.tryLock(waitTime, leaseTime, unit);
} catch (InterruptedException e) {
log.error("RedissonUtils - tryLock异常", e);
}
return false;
}
/**
* 释放锁
*
* @param lockKey key
*/
public void unlock(String lockKey) {
RLock lock = redissonClient.getLock(lockKey);
lock.unlock();
}
/**
* 是否存在锁
*
* @param lockKey key
* @return
*/
public boolean isLocked(String lockKey) {
RLock lock = redissonClient.getLock(lockKey);
return lock.isLocked();
}
}
推荐阅读
-
详解Redis与Redisson的lock和tryLock功能实现机制
-
详解Redisson分布式锁：lock和tryLock实现机制解析 - 结论部分
-
详解Redis与Redisson的lock和tryLock功能实现机制
-
【2022新手指南】Java编程进阶之路 - 六、技术架构篇 ### MySQL索引底层解析与优化实战 - 你会讲解MySQL索引的数据结构吗？性能调优技巧知多少？ - Redis深度揭秘：你知道多少？从基础到哨兵、主从复制全梳理 - Redis持久化及哨兵模式详解，还有集群搭建和Leader选举黑箱打开 - Zookeeper是个啥？特性和应用场景大公开 - ZooKeeper集群搭建攻略及 Leader选举、读写一致性、共享锁实现细节 - 探究ZooKeeper中的Leader选举机制及其在分布式环境中的作用 - Zab协议深入剖析：原理、功能与在Zookeeper中的核心地位 - RabbitMQ全方位解读：工作模式、消费限流、可靠投递与配置策略 - 设计者视角：RabbitMQ过期时间、死信队列与延时队列实践指南 - RocketMQ特性和应用场景揭示：理解其精髓与差异化优势 - Kafka详细介绍：特性及广泛应用于实时数据处理的场景解析 - ElasticSearch实力揭秘：特性概述与作为搜索引擎的广泛应用 - MongoDB认知升级：非关系型数据库的优势阐述，安装与使用实战教学 - BIO/NIO/AIO网络模型对比：掌握它们的区别与在网络编程中的实际应用 - Netty带你飞：理解其超快速度背后的秘密，包括线程模型分析 - 网络通信黑科技：Netty编解码原理与常用编解码器的应用，Protostuff实战演示 - 解密Netty粘包与拆包现象，怎样有效应对这一常见问题 - 自定义Netty心跳检测机制，轻松调整检测间隔时间的艺术 - Dubbo轻骑兵介绍：核心特性概览，服务降级实战与其实现益处 - Dubbo三大神器解读：本地存根与本地伪装的实战运用与优势呈现 ----------------------- 七、结语与回顾
-
玩转Java底层：JMX详解 - jconsole与自定义MBean监控工具的实际应用与区别" 在日常JVM调优中，我们熟知的jconsole工具通过JMX包装的bean以图形化形式展示管理数据，而像jstat和jmap这类内建监控工具则由JVM直接支持。本文将以jconsole为例，深入讲解其实质——基于JMX的MBean功能，包括可视化界面上的bean属性查看和操作调用。 MBeans在jconsole中的体现是那些可观察的组件属性和方法，如上图所示，通过名为"Verbose"的属性能看到其值为false，同时还能直接操作该bean的方法，例如"closeJerryMBean"。 尽管jconsole给我们提供了直观的可视化界面，但请注意，这里的MBean并非固定不变，开发者可根据JMX提供的接口将自己的自定义bean展示到jconsole。以下步骤展示了如何创建并注册一个名为"StudyJavaMBean"的自定义MBean： 1. 首先定义接口`StudyJavaMBean`，接口需遵循MBean规范，即后缀为"MBean"且包含getter方法代表属性，如`getApplicationName`，和无返回值的setter方法代表操作，如`closeJerryMBean`。 ```java public interface StudyJavaMBean { String getApplicationName(); void closeJerryMBean(); } ``` 2. 编写接口的实现类`StudyJavaMBeanImpl`，实现接口中的方法： ```java public class StudyJavaMBeanImpl implements StudyJavaMBean { @Override public String getApplicationName() { return "每天学Java"; } @Override public void closeJerryMBean() { System.out.println("关闭Jerry应用"); } } ``` 3. 在代码中注册自定义MBean，涉及的关键步骤包括： - 获取平台MBeanServer - 定义ObjectName，指定唯一的MBean标识符 - 注册MBean到服务器 - 启动RMI连接器服务，以便jconsole能够访问 ```java public void registerMBean() throws Exception { // ... 具体实现省略 ... } ``` 实际运行注册后的MBean，您将在jconsole中发现并查看自定义bean的属性和调用相关方法。然而，这种方式相较于传统的属性/日志查看和HTTP接口，实用性相对有限，可能存在潜在的安全风险。但不可否认的是，JMX及其MBean机制对于获取操作系统信息、内存状态等关键性能指标仍然具有重要价值。例如： 1. **获取操作系统信息**：通过JMX MBean，可以直接获取到诸如CPU使用率、操作系统版本等系统级信息，这对于资源管理和优化工作具有显著帮助。