Redis 2023面试5题（七）

news2024/11/19 17:22:02

一、Redis redlock 实现原理

Redlock是一种基于Redis的分布式锁实现，它可以解决在分布式系统中由于主从切换、网络延迟等导致的锁竞争问题。

在这里插入图片描述

Redlock的实现原理如下：

  1. 创建多个Redis实例，每个实例都有相同的锁名称。
  2. 使用Redis的SETNX命令尝试获取锁。如果获取成功，说明锁是有效的，可以执行业务逻辑。
  3. 在获取锁之后，使用EXPIRE命令设置锁的过期时间，这样可以防止锁一直有效，导致其他线程无法获取锁。
  4. 在执行业务逻辑之前，需要等待一段时间（例如500毫秒），以确保其他线程无法获取相同的锁。
  5. 在释放锁之前，需要检查锁的过期时间，如果锁已经过期，则说明该锁已经被其他线程释放或者出现了异常情况，需要重新尝试获取锁。
  6. 在释放锁之后，需要检查锁的数量是否达到了Redis实例的数量，如果未达到，则说明该锁可能已经被其他线程释放或者出现了异常情况，需要重新尝试获取锁。
  7. 为了防止多个节点同时获取到相同的锁，Redlock使用了UUID生成算法来生成唯一的标识符，并将其添加到SET命令中。这样可以确保每个节点获取到的锁都是唯一的。

需要注意的是，Redlock并不是一个完美的分布式锁实现，它也存在一些限制和注意事项。例如，它不适用于高并发场景下的读写操作，因为写操作可能会导致锁失效。此外，在使用Redlock时需要确保Redis实例之间的时钟同步，否则可能会出现错误的锁判断。

代码示例：

import redis.clients.jedis.Jedis;  
import redis.clients.jedis.JedisPool;  
import redis.clients.jedis.JedisPoolConfig;  
import redis.clients.jedis.Redlock;  
  
public class DistributedLock {  
    private static final int LOCK_EXPIRE_TIME = 3000; // 锁过期时间，单位为毫秒  
    private static final int LOCK_ACQUIRE_TIMEOUT = 3000; // 获取锁的超时时间，单位为毫秒  
    private static final int NUM_REDIS_INSTANCES = 5; // Redis实例数量  
  
    private JedisPool jedisPool;  
  
    public DistributedLock(String[] redisNodes) {  
        JedisPoolConfig config = new JedisPoolConfig();  
        jedisPool = new JedisPool(config, "localhost", 6379);  
  
        // 创建Redlock实例，需要传入Redis实例的数量和节点列表  
        Redlock redlock = new Redlock(jedisPool, NUM_REDIS_INSTANCES, redisNodes);  
  
        // 获取锁，需要传入锁的名称、锁的过期时间和获取锁的超时时间  
        boolean locked = redlock.lock("my_lock", LOCK_EXPIRE_TIME, LOCK_ACQUIRE_TIMEOUT);  
        if (locked) {  
            try {  
                // 执行业务逻辑  
                // ...  
            } finally {  
                // 释放锁  
                redlock.unlock("my_lock");  
            }  
        } else {  
            // 获取锁失败，处理并发访问的情况  
            // ...  
        }  
    }  
  
    public void close() {  
        jedisPool.close();  
    }  
}

在以上示例中，使用Jedis客户端创建了一个包含5个Redis实例的连接池，并使用Redlock算法实现了分布式锁。

  • 在创建Redlock实例时，需要传入Redis实例的数量和节点列表。
  • 在获取锁时，需要传入锁的名称、锁的过期时间和获取锁的超时时间。
  • 如果获取锁成功，就执行业务逻辑，并在finally块中释放锁。
  • 如果获取锁失败，就处理并发访问的情况。
  • 最后，在程序结束时，需要调用close()方法关闭连接池。

二、Redlock算法在集群中存在哪些问题，如何解决

Redlock算法在集群中存在以下问题：

  1. 潜在的竞争条件：在Redlock算法中，一个客户端会尝试在所有的Redis节点上获取锁。然而，如果两个客户端同时尝试获取一个已存在的锁，由于Redis的SETNX命令是不具备原子性的，所以这两个客户端可能会在不同的节点上成功地获取锁，这就会导致竞争条件。
  2. 网络延迟：如果一个客户端在获取锁的过程中发生了网络延迟，它可能会在同一个节点上重复尝试获取锁，这就有可能导致死锁。
  3. 节点故障：如果获取锁的过程中有一个Redis节点发生了故障，那么客户端可能会陷入等待状态，直到该节点恢复可用，这就会导致性能下降和可用性降低。
  4. 锁的有效期：Redlock算法中，锁的有效期是通过设置Redis键的过期时间来实现的。如果一个客户端在获取锁之后意外崩溃，那么锁的有效期可能会被延长，这就会导致其他客户端无法获取锁。
  5. 慎用于读写操作：由于Redlock算法在实现中需要使用多个Redis节点，所以它可能会对读写操作的性能产生影响。因此，对于需要频繁进行读写操作的场景，需要谨慎使用Redlock算法。

为了解决这些问题，可以采取以下措施：

  1. 竞争条件：为了解决竞争条件问题，可以使用具备原子性的命令，例如SETNX命令的集合操作，来代替单独的SETNX命令。这样，只有一个客户端能够成功地获取锁，其他客户端则会等待。
  2. 网络延迟：为了解决网络延迟问题，可以设置超时时间，确保客户端在获取锁的过程中能够在指定时间内完成操作。此外，可以使用重试机制来避免重复尝试获取锁的问题。
  3. 节点故障：为了解决节点故障问题，可以使用Redis Sentinel或Redis Cluster等高可用集群方案来自动故障转移。这样，当有Redis节点故障时，客户端可以自动切换到其他可用的节点。
  4. 锁的有效期：为了解决锁的有效期问题，可以设置锁的有效期时间，并在获取锁之后进行监控，确保在有效期内完成操作。如果超过有效期，则可以重新获取锁。
  5. 慎用于读写操作：为了解决读写操作的问题，可以在使用Redlock算法时尽量避免频繁的读写操作，或者使用其他更适用于读写操作的分布式锁算法。

三、Redis有什么作用?

Redis（Remote Dictionary Server）是一个高性能的键值对（Key-Value）存储系统，常用于作为数据库、缓存和消息队列使用。它支持多种数据结构，如字符串、哈希表、列表、集合、有序集合等，并提供了丰富的操作命令和数据同步功能。

Redis的主要作用如下：

  1. 缓存数据：Redis可以用作于缓存数据，可以缓存访问频率较高的数据，如商品详情页、热门搜索关键词、热门推荐等。通过缓存提高数据读取效率，减轻数据库压力。
  2. 分布式锁：Redis可以用作分布式锁，如多个服务器之间共享一个资源时，需要通过分布式锁来保证同一时间只有一个服务器可以访问该资源。可以使用Redis的SETNX命令实现分布式锁。
  3. 计数器：Redis可以用作计数器，如用户签到每日领取积分，可以使用Redis的INCR命令实现计数器功能。
  4. 消息队列：Redis可以用作消息队列，如异步处理任务时，可以将任务通过Redis发布到多个消费者上进行处理，从而提高任务处理效率。可以使用Redis的RPUSH命令实现消息队列发布功能，使用BLPOP命令实现消息队列订阅功能。
  5. 排行榜：Redis可以用作排行榜系统，如实时统计网站访问量、文章阅读量等，可以使用Redis的有序集合（Sorted Set）实现。

以上是Redis的一些常见作用，可以根据具体业务需求选择合适的使用方法。需要注意的是，在使用Redis时，需要对数据进行备份和恢复，保证数据的安全性和可靠性。同时，也需要注意Redis的使用成本，避免过度使用导致服务器性能下降。

四、什么是Redis缓存穿透，如何解决?

Redis缓存穿透是指查询一个不存在的数据，由于Redis中没有缓存数据，所以每次请求都会直接查询数据库，导致缓存失效，严重影响系统性能和稳定性。

为了解决Redis缓存穿透，可以采取以下几种方法：

  1. 缓存空对象：在Redis中缓存一个空对象，当查询一个不存在的数据时，先将空对象从缓存中取出，然后再次查询数据库，如果数据库中也没有该数据，则返回空对象。这样可以避免多次查询数据库，同时也可以避免缓存穿透。
import redis.clients.jedis.Jedis;  
  
public class RedisCache {  
    private static Jedis jedis;  
    static {  
        // 连接Redis  
        jedis = new Jedis("localhost");  
    }  
  
    public static Object getData(String key) {  
        Object result = jedis.get(key);  
        if (result == null) {  
            result = "";  
            // 查询数据库  
            // ...  
            // 将空对象存入缓存  
            jedis.set(key, result, "EX", 3600);  
        }  
        return result;  
    }  
}
  1. 布隆过滤器：布隆过滤器是一种数据结构，可以用于检测一个元素是否在一个集合中。在使用Redis缓存时，可以将所有缓存过的key和value都存储在一个布隆过滤器中，当查询一个不存在的数据时，先通过布隆过滤器进行过滤，如果过滤掉了，则说明该数据没有被缓存过，可以直接返回空结果。这样可以有效地减少Redis缓存穿透的影响。
import redis.clients.jedis.Jedis;  
import redis.clients.jedis.params.PFCountParams;  
  
public class RedisCache {  
    private static Jedis jedis;  
    static {  
        // 连接Redis  
        jedis = new Jedis("localhost");  
    }  
  
    public static Object getData(String key) {  
        if (jedis.exists("my_bloom_filter")) {  
            if (!jedis.pfcount("my_bloom_filter", key)) {  
                return "";  
            }  
        }  
        // 查询数据库  
        // ...  
        return result;  
    }  
}
  1. 限流和熔断：对于恶意请求，可以通过限流和熔断等方式来减轻系统压力。可以使用Redis的Lua脚本进行限流，或者使用Spring Cloud的Feign和Hystrix等组件进行熔断。通过限制请求的频率和数量，可以避免恶意请求对系统造成过大的压力和影响。

五、什么是Redis缓存击穿，如何解决?

Redis缓存击穿是指当一个热点key在缓存中失效时，大量的请求直接访问数据库，导致数据库压力瞬间增大，甚至导致数据库崩溃。

为了解决Redis缓存击穿，可以采取以下几种方法：

  1. 添加互斥锁：当一个热点key失效时，添加互斥锁来限制并发请求的数量，避免瞬间大量的请求访问数据库。具体实现可以使用Redis的SETNX命令来实现。
import redis.clients.jedis.Jedis;  
  
public class RedisCache {  
    private static Jedis jedis;  
    static {  
        // 连接Redis  
        jedis = new Jedis("localhost");  
    }  
  
    public static Object getData(String key) {  
        Object result = jedis.get(key);  
        if (result == null) {  
            result = "";  
            // 查询数据库  
            // ...  
            // 添加互斥锁  
            boolean locked = jedis.setnx(key, "locked");  
            if (locked) {  
                // 更新缓存  
                jedis.set(key, result, "EX", 3600);  
                // 解锁  
                jedis.del(key);  
            } else {  
                // 缓存更新失败，返回空结果  
                return "";  
            }  
        }  
        return result;  
    }  
}
  1. 添加延时：在缓存失效后，添加一个延时时间，让缓存继续服务一段时间，避免热点key的缓存刚刚失效就被大量的请求直接访问数据库。具体实现可以在缓存失效时，添加一个定时任务，在定时任务中更新缓存。
import redis.clients.jedis.Jedis;  
import redis.clients.jedis.params.SetParams;  
  
public class RedisCache {  
    private static Jedis jedis;  
    static {  
        // 连接Redis  
        jedis = new Jedis("localhost");  
    }  
  
    public static Object getData(String key) {  
        Object result = jedis.get(key);  
        if (result == null) {  
            result = "";  
            // 查询数据库  
            // ...  
            // 添加延时更新缓存  
            SetParams params = new SetParams("EX", 3600);  
            jedis.set(key, result, params);  
        }  
        return result;  
    }  
}
  1. 分布式锁：使用分布式锁来避免多个节点同时对数据库进行操作，避免缓存击穿的问题。可以使用Redis本身来实现分布式锁，也可以使用其他的分布式锁实现方式，如Zookeeper。
import redis.clients.jedis.Jedis;  
import redis.clients.jedis.params.SetParams;  
  
public class RedisCache {  
    private static Jedis jedis;  
    static {  
        // 连接Redis  
        jedis = new Jedis("localhost");  
    }  
  
    public static Object getData(String key) {  
        Object result = jedis.get(key);  
        if (result == null) {  
            result = "";  
            // 查询数据库  
            // ...  
            // 添加分布式锁  
            String lockKey = "lock_" + key;  
            long timeout = 3000; // 锁的过期时间，单位为毫秒  
            boolean locked = jedis.set(lockKey, "locked", "NX", "PX", timeout);  
            if (locked) {  
                // 更新缓存  
                jedis.set(key, result, "EX", 3600);  
                // 解锁  
                jedis.del(lockKey);  
            } else {  
                // 缓存更新失败，返回空结果  
                return "";  
            }  
        }  
        return result;  
    }  
}

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

如何选择消息中间件

如何选择消息中间件

一、 分布式系统消息通信技术简介 分布式系统消息通信技术主要包括以下几种： 1. RPC(Remote Procedure Call Protocol). 一般是C/S方式，同步的，跨语言跨平台，面向过程 2. CORBA(Common Object Request Broker Architecture). CO…
阅读更多...
Vlan与ARP讲解

Vlan与ARP讲解

目录 Vlan讲解 Vlan标签 二层接口类型 ARP ARP的作用 ARP地址解析报文讲解 免费ARP报文讲解 ARP缓存表 Vlan讲解 Vlan（Virtual Local Area Network）虚拟局域网，将一个物理的LAN在逻辑上划分为多个广播域；可以理解为一个V…
阅读更多...
RT-Thread-11-事件集

RT-Thread-11-事件集

事件集 举例说明事件集： 1、A坐公交车去某地，只有一趟公交车去该地，等此公交车即可出发； 2、A坐公交车去某地，有三趟公交车去该地，等其中任意一辆公交车即可出发； 3、A约B一起去某地&#xff0…
阅读更多...
点亮你的创意，使用Python与树莓派制作呼吸灯的详细教程

点亮你的创意，使用Python与树莓派制作呼吸灯的详细教程

文章目录 前言PWM的介绍实现PWM控制LED亮度结果与分析 前言 在上一篇文章中，我们介绍了如何在树莓派上点亮一个LED灯，并让它以时间间隔为1秒进行闪烁。闪亮登场！在树莓派上点亮LED灯的简单详细方法_☞黑心萝卜三条杠☜的博客-CSDN博客。现在&…
阅读更多...
【剑指offer刷题记录 java版】数组双指针 之 其它题目

【剑指offer刷题记录 java版】数组双指针 之 其它题目

本系列文章记录labuladong的算法小抄中剑指offer题目 【剑指offer刷题记录 java版】数组双指针 之 其它题目 剑指 Offer II 018. 有效的回⽂剑指 Offer 58 - I. 翻转单词顺序剑指 Offer 21. 调整数组顺序使奇数位于偶数前⾯剑指 Offer 57. 和为s的两个数字剑指 Offer II 007. 数…
阅读更多...
【裸机开发】IRQ 中断服务函数（三）—— 中断处理逻辑实现

【裸机开发】IRQ 中断服务函数（三）—— 中断处理逻辑实现

实现了 IRQ 中断服务函数的汇编部分以后，接下来我们要使用C代码实现IRQ中断服务函数的具体逻辑，主要包含初始化和中断处理两部分。 全局中断初始化（全局中断使能、IRQ中断使能）具体中断处理逻辑实现 我们这里的中断是由按键产生…
阅读更多...
springboot+mybatisplus复习笔记

springboot+mybatisplus复习笔记

1.环境搭建 依赖配置 <dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>com.mysql</groupId><artifa…
阅读更多...
「2024」预备研究生mem- MBA大师APP-逻辑错题记录

「2024」预备研究生mem- MBA大师APP-逻辑错题记录

一、形式逻辑
阅读更多...
【Twitter爬虫】Twitter网络爬虫

【Twitter爬虫】Twitter网络爬虫

利用selenium爬取Twitter 从2月9日起&#xff0c;Twitter不再支持免费访问Twitter API&#xff0c;继续使用Twitter API支付较高的费用。下面将介绍一种绕过Twitter API爬取推文的方式 Selenium Webdriver框架 首先介绍一下Selenium Webdriver&#xff0c;这是一款web自动化…
阅读更多...
软件工程实践总结

软件工程实践总结

前言 这次我们学校花了很多心血在这次的课设上&#xff0c;真的是特别感动和感谢&#xff0c;当你遇到真心为你好对你好的老师的时候&#xff0c;真的是会觉得人间值得&#xff01; 之前在学软件工程的时候我就会觉得这些理论的东西有什么用啊&#xff0c;什么UML&#xff0c;…
阅读更多...
冒泡排序、选择排序、插入排序

冒泡排序、选择排序、插入排序

冒泡排序 思路&#xff1a; 每次循环比较相邻两个元素&#xff0c;如果左边元素>右边元素&#xff0c;则交换位置。结果&#xff1a;将最大值放到最右边&#xff1b;一次循环过后&#xff0c;左边无序区域减少一个数&#xff0c;右边有序取增加一个数&#xff1b;序列长度…
阅读更多...
【C++】AVL树的插入实现

【C++】AVL树的插入实现

目录 AVL树的概念AVL树节点的定义AVL树的插入AVL树的旋转左单旋(parent->_bf 2 && cur->_bf 1)a,b,c当高度为0a,b,c当高度为1a,b,c当高度为2a,b,c当高度为...... 右单旋(parent->_bf -2 && cur->_bf -1)a,b,c当高度为0a,b,c当高度为1a,b,c当高…
阅读更多...
【群智能算法】基于浣熊优化算法的工程应用问题优化【Matlab代码#43】

【群智能算法】基于浣熊优化算法的工程应用问题优化【Matlab代码#43】

文章目录 【可更换其他算法&#xff0c;获取资源请见文章第5节&#xff1a;资源获取】1. 原始COA算法1.1 开发阶段1.2 探索阶段 2. 工程应用问题优化2.1 压力容器设计2.2 拉压弹簧设计 3. 部分代码展示4. 仿真结果展示5. 资源获取 【可更换其他算法&#xff0c;获取资源请见文章…
阅读更多...
Spring事件机制让你的代码更优雅

Spring事件机制让你的代码更优雅

今天为大家分享一下Spring的事件机制的使用&#xff0c;它是spring中一个非常好用也很实用的机制。 1. spring事件机制的概念 Spring的事件机制是基于观察者模式实现的&#xff0c;它可以在我们的实际应用程序中实现代码之间的解耦&#xff0c;提高代码的可维护性和可扩展性。…
阅读更多...
ShardingSphere-Proxy 分库分表

ShardingSphere-Proxy 分库分表

安装ShardingSphere-Proxy 中间件封装 定位为透明化的数据库代理端&#xff0c;提供封装了数据库二进制协议的服务端版本&#xff0c;用于完成对异构语言的支持。 目前提供 MySQL 和 PostgreSQL版本&#xff0c;它可以使用任何兼容 MySQL/PostgreSQL 协议的访问客户端&#x…
阅读更多...
面试必问：四种经典限流算法

面试必问：四种经典限流算法

今天给大家分享一下限流方面的&#xff0c;大家都知道&#xff0c;在分布式系统中&#xff0c;高并发场景下&#xff0c;为了防止系统因突然的流量激增而导致的崩溃&#xff0c;同时保证服务的高可用性和稳定性&#xff0c;限流是最常用的手段。希望能够给大家带来帮助&#xf…
阅读更多...
STM32常见面试题

STM32常见面试题

一、STM32F1和F4的区别&#xff1f; 内核不同&#xff1a;F1是Cortex-M3内核&#xff0c;F4是Cortex-M4内核&#xff1b; 主频不同&#xff1a;F1主频72MHz&#xff0c;F4主频168MHz&#xff1b; 浮点运算&#xff1a;F1无浮点运算单位&#xff0c;F4有&#xff1b; 功能性能&…
阅读更多...
【无标题】vue中表单绑定v-model

【无标题】vue中表单绑定v-model

表单绑定v-model 表单控件在实际开发中是非常常见的。特别是对于用户信息的提交&#xff0c;需要大量的表单。 Vue中使用v-model指令来实现表单元素和数据的双向绑定。 案例的解析&#xff1a; 当我们在输入框输入内容时 因为input中的v-model绑定了message&#xff0c;所以会…
阅读更多...
Vue-搭建Vuex开发环境

Vue-搭建Vuex开发环境

1 安装Vuex 安装之前需要了解一个版本问题&#xff0c;在vue2中&#xff0c;要用vuex的3版本&#xff0c;在vue3中&#xff0c;要用vuex的4版本&#xff0c;要严格遵循这个版本要求&#xff0c;不然就会出现各种意想不到的问题&#xff0c;例如下方安装报错&#xff0c;就算因…
阅读更多...
ubuntu修改应用图表|任务栏收藏|快捷方式|收藏夹

ubuntu修改应用图表|任务栏收藏|快捷方式|收藏夹

需要知道应用程序对应的.desktop文件的位置&#xff0c;然后使用sudo gedit打开。修改对应位置的信息就可以了。 参考&#xff1a;Linux下Desktop文件入门 1.desktop文件位置 一般存放在/usr/share/applications这个位置里面。 以vscode为例&#xff0c;使用sudo gedit code…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023