redis主从哨兵模式+Lua报错-READONLY You can‘t write against a read

news/2025/2/25 19:40:24

背景

项目试用SpringBoot+redisTemplate执行redislua脚本,实现令牌桶;redis结构使用的是1主2从3哨兵模式+读写分离;

问题分析

READONLY You can't write against a read报这个错的含义在从节点执行了写操作,也就是说我执行Lua脚本是在从节点上执行的,那么问题来了,为什么的我LUA脚本会在从节点执行呢?
我们都知道,redis的主从哨兵模式,再加上配置读写分离,会将读操作优先分配到从节点,也就是说它认为LUA脚本是读操作,看一下具体的报错信息:
在这里插入图片描述
1、我们从这一行开始看起,找找是哪一步给我分配到了从节点

at org.springframework.data.redis.core.script.DefaultScriptExecutor.eval(DefaultScriptExecutor.java:77)

之后一步一步点击调用,到下面这一步,调用了get方法获取前面的返回值,那就继续看前面是怎么调用的,点击RedisScriptingAsyncCommands::evalsha方法继续向下寻找
在这里插入图片描述
2、再继续
在这里插入图片描述
3、再继续,可以看到,命令类型给了一个 EVALSHA
在这里插入图片描述
4、回到第二部看 dispatch 方法的调用,找到处理链接的地方
在这里插入图片描述
5、可以看到write方法中,有一个步骤判断操作类型是读还是写
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
6、经过查找,CommandType类中包含 EVALSHA 类型,所以判断为ReadOlny,由此可以验证,确实是使用了从节点执行lua脚本。

解决问题

既然它使用的是从节点,那我就想办法让他在执行脚本的时候,强制选择主节点就能解决问题了呀。
修改redisTemplate注入配置

@Configuration
public class MyRedisConfig {
    @Value("${spring.redis.sentinel.master}")
    private String masterName;

    @Value("${spring.redis.sentinel.nodes}")
    private String sentinelNodes;

    @Value("${spring.redis.password}")
    private String password;

    @Value("${spring.redis.database}")
    private Integer database;

    @Bean(value = "qpsRedisTemplate")
    public RedisTemplate qpsRedisTemplate() {
        List<String> sentinels = Arrays.asList(sentinelNodes.split(","));
        RedisSentinelConfiguration sentinelConfig = new RedisSentinelConfiguration();
        sentinelConfig.master(masterName);
        Set<RedisNode> sentinelNodes = new HashSet<>();
        for (String sentinel : sentinels) {
            String[] split = sentinel.split(":");
            sentinelNodes.add(new RedisNode(split[0],Integer.parseInt(split[1])));
        }
        sentinelConfig.setSentinels(sentinelNodes);
        sentinelConfig.setDatabase(database);
        sentinelConfig.setPassword(password);
        LettuceConnectionFactory factory = new LettuceConnectionFactory(sentinelConfig);
        factory.afterPropertiesSet();
        RedisTemplate redisTemplate = new RedisTemplate<>();
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashValueSerializer(new JdkSerializationRedisSerializer());
        redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
        redisTemplate.setConnectionFactory(factory);
        return redisTemplate;
    }
    //读写分离配置
    @Bean
    public LettuceClientConfigurationBuilderCustomizer clientConfigurationBuilderCustomizer(){
        return clientConfigurationBuilder -> clientConfigurationBuilder.readFrom(ReadFrom.REPLICA_PREFERRED);
    }
}

http://www.niftyadmin.cn/n/5865892.html

相关文章

AI手机的技术细节

前序&#xff1a;先说各个功能涉及到的技术&#xff0c;再说宏观系统架构。AI手机有这样几个做法&#xff0c;给手机侧边增加一个按键&#xff1b;把手机的语音助手做的很好&#xff0c;能够快速稳定的进行唤醒&#xff1b;通过特殊形式的触摸手机的曲面屏位置等来进行唤醒AI …

信息学奥赛一本通 1522:网络 | OpenJudge 百练 1144:Network

【题目链接】 ybt 1522&#xff1a;网络 OpenJudge 百练 1144:Network 【题目考点】 1. 图论&#xff1a;割点 【解题思路】 每个交换机是一个顶点&#xff0c;如果两地点之间有电话线连接&#xff0c;那么两顶点之间有一条无向边&#xff0c;该图是无向图。 初始时任何地…

TD时间差分算法

TD算法用来估计value-state 给定data/experiece of algorithm&#xff0c; TD算法&#xff1a; 其中TD error&#xff1a; δ t v ( s t ) − [ r t 1 γ v ( s t 1 ) ] v ( s t ) − v t ‾ \delta_t v(s_t) -[r_{t1} \gamma v(s_{t1})]v(s_t) - \overline{v_{t}} δ…

Vue使用Three.js加载glb (gltf) 文件模型及实现简单的选中高亮、测距、测面积

安装&#xff1a; # three.jsnpm install --save three 附中文网&#xff1a; 5. gltf不同文件形式(.glb) | Three.js中文网 附官网&#xff1a; 安装 – three.js docs 完整代码&#xff08;简易demo&#xff09;&#xff1a; <template><div class"siteInspe…

【复习】计算机网络

网络模型 OSI 应用层&#xff1a;给应用程序提供统一的接口表示层&#xff1a;把数据转换成兼容另一个系统能识别的格式会话层&#xff1a;负责建立、管理、终止表示层实体之间的通信会话传输层&#xff1a;负责端到端的数据传输网络层&#xff1a;负责数据的路由、转发、分片…

2024-2025 学年广东省职业院校技能大赛 “信息安全管理与评估”赛项 技能测试试卷(二)

2024-2025 学年广东省职业院校技能大赛 “信息安全管理与评估”赛项 技能测试试卷&#xff08;二&#xff09; 第一部分&#xff1a;网络平台搭建与设备安全防护任务书第二部分&#xff1a;网络安全事件响应、数字取证调查、应用程序安全任务书任务 1&#xff1a;应急响应&…

3. Spring Cloud LoadBalancer 入门与使用

一、什么是 LoadBalancer? LoadBalancer(负载均衡器)是一种网络设备或软件机制&#xff0c;用于分发传入的网络流量负载(请求)到多个后端目标服务器上&#xff0c;从而实现系统资源的均衡利用和提高系统的可用性和性能。 1.1 负载均衡分类 服务器负载均衡是在服务端通过硬件…

Seata分布式事务【详解分布式事务AT模式、2PC两阶段提交协议、Seata Server(TC)环境搭建,附有示例+代码】

文章目录 六.Seata 分布式事务6.1 分布式事务介绍6.2 常见分布式事务解决方案6.3 2PC两阶段提交协议&#xff1a;Prepare&#xff1a;提交事务请求Commit&#xff1a;执行事务提交2PC问题 6.4 AT 模式介绍6.5 Seata是什么&#xff1f;6.6 Seata快速开始Seata Server&#xff08…