网站建设费是宣传费用吗,wordpress手机端主题插件下载,微商软件下载,WordPress音乐歌单播放器目录
Redis实现分布式锁
分布式锁的工作流程
Redis实现分布式锁
Redission的watch dog
Redis分布式锁的合理应用 Redis实现分布式锁
在单节点的服务器中#xff0c;java中的synchronized机制是处于JVM层面的#xff0c;只能保证线程之间的同步。而实际的服务部署中java中的synchronized机制是处于JVM层面的只能保证线程之间的同步。而实际的服务部署中我们通常会使用多节点的集群部署方式而要保证多个节点中的不同进程对数据的同步操作就需要使用分布式锁。
使用分布式锁的主要目的是在分布式环境中确保多个节点之间的协同操作避免由于并发访问而导致的数据不一致、竞态条件等问题。以下是使用分布式锁的一些常见原因 避免并发问题 在分布式系统中多个节点可能同时对共享资源进行访问。使用分布式锁可以确保对关键资源的访问在同一时刻只有一个节点拥有避免并发问题如数据不一致、丢失更新等。 保护共享资源 分布式系统中的共享资源例如数据库、缓存、文件等可能同时被多个节点访问。通过使用分布式锁可以保护这些共享资源确保在任何时刻只有一个节点能够修改它们。 防止死锁 在分布式系统中由于网络分区、节点故障等原因可能发生死锁。通过使用分布式锁可以避免因为多节点间的协同操作导致的死锁问题。 控制访问顺序 在某些场景下需要对共享资源的访问进行有序控制确保一些操作的执行顺序。分布式锁可以用于实现对资源的顺序访问。 实现分布式协调 分布式锁是实现分布式协调和同步的一种重要机制。例如在分布式任务调度、分布式事务等场景中分布式锁可以用于协调不同节点的操作。 防止重复执行 在一些需要幂等性操作的场景下分布式锁可以用于防止同一操作被重复执行。 避免“多写”问题 当多个节点同时写入同一数据时可能导致“多写”问题即最后写入的值覆盖了之前的写入。分布式锁可以用于保护写入操作确保只有一个节点能够写入。
分布式锁的工作流程 Redis实现分布式锁
Redis实现分布式锁主要利用的是Redis的setnx命令。setnx是Set if no exists的简写。
CenOs7:0setnx lock 1 # 首次设置lock值1
1 # 设置成功返回1
CenOs7:0setnx lock 1 # lock已存在给lock赋值
0 # 设置失败返回0不做任何操作
CenOs7:0get lock # 获取lock的值
1 # lock值为1
CenOs7:0del lock # 删除lock释放锁
1 # 删除成功返回1
CenOs7:0get lock # 获取lock的值
null # lock为空
CenOs7:0setnx lock 1 # 设置lock值为1
1 # 设置成功
需要注意的是setnx的方式是不支持重入锁的。而且锁的持有时间很难控制。单纯地依赖expire设置过期时间是不现实的。
Redission的watch dog
Redission引入了“看门狗”的机制目的是处理锁的续期问题。 代码示例
import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import java.util.concurrent.TimeUnit;
public class RedissonWatchdogExample {
public static void main(String[] args) throws InterruptedException {// 创建 Redisson 客户端Config config new Config();config.useSingleServer().setAddress(redis://127.0.0.1:6379);RedissonClient redisson Redisson.create(config);
// 获取分布式锁RLock lock redisson.getLock(myLock);
try {// 尝试获取锁并设置锁的过期时间为10秒// boolean isLocked lock.tryLock(10, 30, TimeUnit.SECONDS);// 如果设置了第二个参数[锁的持续时间]就默认不使用watchdog// redission中的lock是依赖了底层lua脚本的原子性实现的boolean isLocked lock.tryLock(10, TimeUnit.SECONDS);
if (isLocked) {// 获取锁成功执行业务逻辑System.out.println(Lock acquired. Executing business logic...);
// 模拟业务逻辑执行时间Thread.sleep(5000);
// 业务逻辑执行完毕不需要手动释放锁Watchdog会自动续期或者释放锁
} else {System.out.println(Failed to acquire the lock within the specified time);}
} finally {// 关闭 Redisson 客户端redisson.shutdown();}}
}
创建了一个名为myLock的分布式锁并使用tryLock方法尝试获取锁设置锁的过期时间为10秒。在获取锁成功后执行了一段模拟的业务逻辑并且无需手动释放锁因为Watchdog会在锁过期时自动续期或释放锁。
Redission实现可重入锁
Redission通过Hash结构实现重入锁的key对应的是lockvalue存放的是线程信息。 需要注意的是Redisson Watchdog是默认开启的你不需要额外的配置。在正式的生产环境中建议你根据实际需求进行更详细的配置比如设置Watchdog的检查间隔、锁的失效时间等参数。
红锁RedLock
Redis集群是主从复制结构Master负责写Slave负责读。setnx是在Master实例上进行加锁。 Java应用通过setnx在Master节点获取锁。 Master节点异常Redis通过哨兵机制选举出新的Master。 Java应用通过setnx在新的Master节点获取锁。 此时集群中存在两把锁违背了锁的互斥性。
针对这种情况Redis提供了RedLock它的主要机制是在(n/21)个节点实例上同时创建锁。 RedLock解决了锁的互斥性问题同时缺点也很明显实现复杂性能差同时运维繁琐。针对分布式中的CAP现象不同的业务应该选择对应的方案 AP思想(高可用性分区容错)使用Redis实现分布式锁 CP思想(强一致性分区容错)使用Zookeeper实现分布式锁
需要注意的是Redisson Watchdog是默认开启的你不需要额外的配置。在正式的生产环境中建议你根据实际需求进行更详细的配置比如设置Watchdog的检查间隔、锁的失效时间等参数。
Redis分布式锁的合理应用
Redis分布式锁是在多个节点之间实现互斥访问共享资源的一种机制。它可以应用于各种场景以下是一些合理的应用场景 分布式任务调度 当有多个节点需要执行定时任务或者周期性任务时可以使用分布式锁确保同一时刻只有一个节点在执行任务避免重复执行或者竞态条件。 分布式缓存更新 当多个节点需要同时更新某个缓存或者共享的数据时可以使用分布式锁确保只有一个节点能够进行更新操作防止并发问题。 分布式事务 在分布式事务场景下可能需要对一些关键资源进行加锁以确保在事务执行期间其他事务不会修改这些资源从而保证事务的隔离性。 防止重复操作 在一些场景下可能需要防止某个操作被重复执行。通过使用分布式锁可以确保同一时刻只有一个节点能够执行这个操作防止重复操作。 分布式限流 在某些情况下需要对请求进行限流确保系统不被过度请求。通过使用分布式锁可以控制某个时间窗口内只有一个节点能够处理请求实现简单的限流效果。 分布式协同 当多个节点需要协同工作时可以使用分布式锁确保各个节点之间的操作按照规定的顺序进行防止不一致或混乱的情况发生。 分布式任务队列 在分布式环境中多个节点可能需要消费同一个任务队列。通过使用分布式锁可以确保只有一个节点能够成功获取并消费队列中的任务避免重复消费。 资源竞争 当多个节点需要竞争某个资源时可以使用分布式锁来进行竞争确保只有一个节点能够成功占用资源如分布式锁用于实现分布式秒杀场景。
需要注意的是在使用分布式锁时要注意锁的超时策略、锁的释放等问题以确保系统的稳定性和性能。此外选择成熟的分布式锁实现库如Redisson、Curator等可以减少潜在的问题提高开发效率。
