Redis中Lua脚本的使用场景

Redis 中的 Lua 脚本可以用于多种场景,以下是一些常见的使用场景及其对应的 Java 实现示例。
通过使用 Lua 脚本,可以在 Redis 中实现复杂的逻辑和原子操作,同时利用 Java 客户端(如 Spring Data Redis)方便地执行这些脚本,提升性能并减少网络延迟。

文章目录

    • 1. 原子计数
    • 2. 条件更新
    • 3. 事务性操作
    • 4. 分布式锁
    • 5. 批量处理
    • 6. 计数器与过期管理
    • 7. 条件删除
    • 8. 数据聚合

1. 原子计数

场景:原子性地增加计数器。
Lua 脚本:
local current = redis.call(‘INCR’, KEYS[1])
return current
Java 实现:

String luaScript = "local current = redis.call('INCR', KEYS[1]) return current";
Long count = (Long) redisTemplate.execute(new DefaultRedisScript<>(luaScript, Long.class), Collections.singletonList("counter"));

2. 条件更新

场景:仅在当前值等于特定值时更新。
Lua 脚本:

local current = redis.call('GET', KEYS[1])
if current == ARGV[1] thenredis.call('SET', KEYS[1], ARGV[2])return true
elsereturn false
end
Java 实现:
String luaScript = "local current = redis.call('GET', KEYS[1]) " +"if current == ARGV[1] then " +"    redis.call('SET', KEYS[1], ARGV[2]) return true " +"else return false end";
Boolean updated = (Boolean) redisTemplate.execute(new DefaultRedisScript<>(luaScript, Boolean.class), Collections.singletonList("key"), "oldValue", "newValue");

3. 事务性操作

场景:获取一个键的值并删除该键。
Lua 脚本:

local value = redis.call('GET', KEYS[1])
redis.call('DEL', KEYS[1])
return value
Java 实现:
String luaScript = "local value = redis.call('GET', KEYS[1]) " +"redis.call('DEL', KEYS[1]) return value";
String value = (String) redisTemplate.execute(new DefaultRedisScript<>(luaScript, String.class), Collections.singletonList("key"));

4. 分布式锁

场景:确保某个操作的独占执行。
Lua 脚本:

if redis.call('SETNX', KEYS[1], ARGV[1]) == 1 thenredis.call('EXPIRE', KEYS[1], ARGV[2])return true
elsereturn false
end
Java 实现:
String luaScript = "if redis.call('SETNX', KEYS[1], ARGV[1]) == 1 then " +"    redis.call('EXPIRE', KEYS[1], ARGV[2]) return true " +"else return false end";
Boolean lockAcquired = (Boolean) redisTemplate.execute(new DefaultRedisScript<>(luaScript, Boolean.class), Collections.singletonList("lockKey"), "lockValue", "10");

5. 批量处理

场景:一次性获取多个键的值。
Lua 脚本:

local result = {}
for i = 1, #KEYS doresult[i] = redis.call('GET', KEYS[i])
end
return result
Java 实现:
String luaScript = "local result = {} " +"for i = 1, #KEYS do " +"    result[i] = redis.call('GET', KEYS[i]) " +"end return result";
List<String> values = (List<String>) redisTemplate.execute(new DefaultRedisScript<>(luaScript, List.class), Arrays.asList("key1", "key2", "key3"));

6. 计数器与过期管理

场景:网站访问计数,并设置过期时间。
Lua 脚本:

local current = redis.call('INCR', KEYS[1])
if current == 1 thenredis.call('EXPIRE', KEYS[1], ARGV[1])
end
return current
Java 实现:
String luaScript = "local current = redis.call('INCR', KEYS[1]) " +"if current == 1 then " +"    redis.call('EXPIRE', KEYS[1], ARGV[1]) " +"end return current";
Long visitCount = (Long) redisTemplate.execute(new DefaultRedisScript<>(luaScript, Long.class), Collections.singletonList("pageVisitCounter"), "60");

7. 条件删除

场景:在特定条件下删除键。
Lua 脚本:

local current = redis.call('GET', KEYS[1])
if current == ARGV[1] thenredis.call('DEL', KEYS[1])return true
elsereturn false
end
Java 实现:
String luaScript = "local current = redis.call('GET', KEYS[1]) " +"if current == ARGV[1] then " +"    redis.call('DEL', KEYS[1]) return true " +"else return false end";
Boolean deleted = (Boolean) redisTemplate.execute(new DefaultRedisScript<>(luaScript, Boolean.class), Collections.singletonList("key"), "valueToMatch");

8. 数据聚合

场景:计算多个值的总和。
Lua 脚本:

local sum = 0
for i = 1, #KEYS dosum = sum + tonumber(redis.call('GET', KEYS[i]) or 0)
end
return sum
Java 实现:
String luaScript = "local sum = 0 " +"for i = 1, #KEYS do " +"    sum = sum + tonumber(redis.call('GET', KEYS[i]) or 0) " +"end return sum";
Long total = (Long) redisTemplate.execute(new DefaultRedisScript<>(luaScript, Long.class), Arrays.asList("key1", "key2", "key3"));

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

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

相关文章

使用 Qt GRPC 构建高效的 Trojan-Go 客户端:详细指南

使用 Qt GRPC 构建高效的 Trojan-Go 客户端&#xff1a;详细指南 初识 Qt 和 gRPC 什么是 Qt&#xff1f;什么是 gRPC&#xff1f; 项目结构概述创建 proto 文件定义 API 下载 api.proto 文件解析 proto 文件 1. package 与 option 语句2. 消息类型定义 TrafficSpeedUserUserSt…

CI/CD 的原理

一、CI/CD 的概念 CI/CD是一种软件开发流程&#xff0c;旨在通过自动化和持续的集成、测试和交付实现高质量的软件产品。 CI(Continuous Integration)持续集成 目前主流的开发方式是协同开发&#xff0c;即多位开发人员同事处理同意应用不同模块或功能。 如果企业在同一时间将…

LabVIEW开发的控制阀监控与维护系统

LabVIEW开发一套自动测试软件&#xff0c;用于控制阀的实时监控、数据采集、维护管理以及报警通知。此系统的目标是通过便捷的操作界面、可靠的通信接口和高效的数据管理&#xff0c;为工厂设备管理提供全面的支持。 1. 项目需求 目标是实现一个控制阀管理系统&#xff0c;能够…

采用STM32CubeMX和HAL库的外部中断设计实例

目录 STM32F1外部中断的硬件设计 STM32F1外部中断的软件设计 通过Keil MDK实现工程 通过Keil MDK实现工程的步骤如下&#xff1a; 中断在嵌入式应用中占有非常重要的地位&#xff0c;几乎每个控制器都有中断功能。中断对保证紧急事件在第一时间处理是非常重要的。 设计使用外…

AUTOSAR从入门到精通-BswM模块

前言 BSW模式管理器是实现驻留在BSW中的部分车辆模式管理和应用程序模式管理概念的模块。它的职责是根据简单的规则对来自应用层SW-C或其他BSW模块的模式请求进行仲裁,并根据仲裁结果执行动作。 BswM即BSW Mode Manager,用一句概括BSW的功能就是接收其他模块的模式请求,判断…

Python酷库之旅-第三方库Pandas(173)

目录 一、用法精讲 796、pandas.Float32Dtype类 796-1、语法 796-2、参数 796-3、功能 796-4、返回值 796-5、说明 796-6、用法 796-6-1、数据准备 796-6-2、代码示例 796-6-3、结果输出 797、pandas.Float64Dtype类 797-1、语法 797-2、参数 797-3、功能 797-…

Bi-LSTM-CRF实现中文命名实体识别工具(TensorFlow)

项目源码获取方式见文章末尾&#xff01; 回复暗号&#xff1a;13&#xff0c;免费获取600多个深度学习项目资料&#xff0c;快来加入社群一起学习吧。 **《------往期经典推荐------》**项目名称 1.【MobileNetV2实现实时口罩检测tensorflow】 2.【卫星图像道路检测DeepLabV3P…

AI 聊天机器人的兴起:GPT-3 和 BERT 如何重新定义对话体验

一、说明 当我们深入研究 AI 世界时&#xff0c;了解自然语言处理 &#xff08;NLP&#xff09; 领域取得的巨大进步非常重要。NLP 是 AI 的一个分支&#xff0c;专注于使计算机能够理解、解释和生成人类语言。GPT-3 和 BERT 等语言模型的开发是这一旅程中的一个重要里程碑&…

1FreeRTOS学习(队列、二值信号量、计数型信号量之间的相同点和不同点)

相同点&#xff1a; &#xff08;1&#xff09;传递区间 队列、二值信号量、计数型信号量均可用在任务与任务&#xff0c;任务与中断之间进行消息传递 &#xff08;2&#xff09; 传递方式 创建队列--发送队列--接受队列 创建二值信号量--发送二值信号量--接受二值信号量 创建计…

15.三数之和 18.四数之和

题目:15. 三数之和 - 力扣&#xff08;LeetCode&#xff09; 思路: 此题无法沿用两数之和的哈希的方法&#xff0c;因为要考虑到结果去重的问题&#xff0c;这里采用双指针算法。 先将数组排序&#xff0c;然后有一层for循环&#xff0c;i从下标0的地方开始&#xff0c;同时…

UDP(用户数据报协议)端口监控

随着网络的扩展&#xff0c;确保高效的设备通信对于优化网络功能变得越来越重要。在这个过程中&#xff0c;端口发挥着重要作用&#xff0c;它是实现外部设备集成的物理连接器。通过实现数据的无缝传输和交互&#xff0c;端口为网络基础设施的顺畅运行提供了保障。端口使数据通…

React 前端框架开发入门案例

以下是一个使用 React 进行前端框架开发的入门案例&#xff0c;实现一个简单的待办事项列表应用。 一、准备工作 安装 Node.js&#xff1a;React 需要 Node.js 环境来运行。你可以从 Node.js 官方网站下载并安装适合你操作系统的版本。 创建项目目录&#xff1a;在你的电脑上…

技术成神之路:设计模式(二十三)解释器模式

相关文章&#xff1a;技术成神之路&#xff1a;二十三种设计模式(导航页) 介绍 解释器模式&#xff08;Interpreter Pattern&#xff09;是一种行为设计模式&#xff0c;用于定义一种语言的文法表示&#xff0c;并提供一个解释器来处理这种文法。它用于处理具有特定语法或表达…

STM32G4 双ADC模式之同时注入模式

目录 概述 1 认识双ADC模式 2 功能实现 2.1 功能介绍 2.2 实现原理 概述 本文主要介绍STM32G4 双ADC模式之同时注入模式的相关内容&#xff0c;包括ADC模块的功能介绍&#xff0c;实现框架结构&#xff0c;以及注入模式ADC的转换的实现原理。 1 认识双ADC模式 双ADC模式可…

函数与c风格字符串

c风格字符串表达形式 const char* str "mamamiya"; char ghost[] "youpomian"; c风格字符串作为参数 #define _CRT_SECURE_NO_WARNINGS#include <iostream> #include<string>unsigned int c_in_str(const char* str, char ch); int main(…

安卓中ViewModel的常用方法

在安卓中使用ViewModel确实方便很多&#xff0c;可以将数据层和UI层分开&#xff0c;同时还不同担心线程异步和接口异步请求回来 Activity被Finish的情况&#xff0c;同时ViewModel中的数据还可以实现多界面数据共享&#xff0c;甚至使用ViewModel查询数据库&#xff0c;只要数…

java类静态变量初始化在openjdk17源码中体现

##有请志愿者OtherClass.java public class OtherClass {private static int CONSTANT_O9876;public int o1234;public void dddd(){String dddd "dddd";System.out.println(ddddCONSTANT_O);}} 类字节码 Classfile /home/yym/debug-java/OtherClass.classLast m…

Django入门教程——动态表格分页展示数据

第五章 动态表格分页展示数据 教学目的 初步了解layui的使用理解table组件在layui中的应用了解数据添加、删除、编辑操作引入JavaScript框架的优势 layUI动态表格 表格组件 table 是 Layui 中使用率极高的一个组件&#xff0c;它以表格的承载方式对数据进行渲染、重载、排序…

Python数据分析NumPy和pandas(十五、pandas 数据加载、存储和文件格式)

大多数时候&#xff0c;我们要处理分析的数据是存储在不同格式的文件中的&#xff0c;有txt、csv、excel、json、xml以及二进制等磁盘文件格式&#xff0c;还有时候是从数据库以及从Web API中交互获取要处理的数据。现在开始学习如何用pandas从以上内容中输入和输出数据。 读取…

CRC校验 生成多项式选取奇次偶次的问题讨论

目录 问题一&#xff1a;为什么CRC校验码不支持偶次校验码&#xff1f; 问题二&#xff1a;如何判断一个生成多项式是否为偶次多项式&#xff1f; 步骤&#xff1a; 示例&#xff1a; 注意&#xff1a; 问题三&#xff1a;CRC32的生成多项式是什么&#xff1f;是偶次还是…