Redis 过期事件监听器

Redis 过期事件监听器完整实现

要使用 Redis 过期事件监听器来更新数据库状态,我们需要确保 Redis 的事件通知已启用,并实现监听器来捕获过期的键,并根据需要更新数据库。


步骤 1:启用 Redis 过期事件通知

需要在 Redis 配置文件中启用键事件通知。可以在 Redis 配置文件 redis.conf 中添加以下配置:

notify-keyspace-events Ex

如果使用 Docker 运行 Redis,可以在启动时传入参数:

docker run -d redis redis-server --notify-keyspace-events Ex

步骤 2:Redis 过期事件监听器代码

下面是完整的 Redis 监听器实现,用于捕获过期的键并更新用户状态:

import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;@Component
public class RedisExpiredListener implements MessageListener {@Overridepublic void onMessage(Message message, byte[] pattern) {String expiredKey = message.toString();// 判断是否为用户信息缓存的键if (expiredKey.startsWith("userInfo:")) {try {Long userId = Long.valueOf(expiredKey.split(":")[1]);updateUserStatus(userId);} catch (NumberFormatException e) {System.err.println("解析用户 ID 失败:" + expiredKey);}}}/*** 更新数据库中的用户状态** @param userId 用户 ID*/private void updateUserStatus(Long userId) {System.out.println("用户 " + userId + " 的 token 已过期,更新状态...");// TODO: 在这里编写更新数据库的逻辑// 示例:userService.updateUserStatusToExpired(userId);}
}

步骤 3:在 Spring Boot 中启用监听

需要将 Redis 监听器注册到 Redis 连接工厂中。

在你的 Redis 配置类中进行如下配置:

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;@Configuration
public class RedisConfig {@Beanpublic RedisMessageListenerContainer redisContainer(RedisConnectionFactory connectionFactory,RedisExpiredListener expiredListener) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);// 监听所有键空间事件(包括过期事件)container.addMessageListener(expiredListener, new ChannelTopic("__keyevent@0__:expired"));return container;}
}

步骤 4:示例数据库更新逻辑

在监听器中,你可以调用用户服务(userService)来更新数据库中的用户状态:

@Autowired
private UserService userService;private void updateUserStatus(Long userId) {System.out.println("用户 " + userId + " 的 token 已过期,更新状态...");userService.updateUserStatusToExpired(userId);
}

UserService 中实现状态更新:

@Service
public class UserService {public void updateUserStatusToExpired(Long userId) {// 更新数据库中的用户状态为已过期System.out.println("正在将用户 " + userId + " 的状态更新为已过期...");// 执行数据库更新操作(如使用 MyBatis 或 JPA)}
}

总结

  1. 启用 Redis 的键事件通知:确保 Redis 配置中启用了 notify-keyspace-events Ex 选项。
  2. 实现 Redis 监听器:捕获过期事件并更新用户状态。
  3. 注册监听器到 Spring 容器:通过 RedisMessageListenerContainer 监听键的过期事件。
  4. 更新数据库状态:在监听器中调用服务层逻辑,完成数据库更新。

这样,当 Redis 中的用户缓存键过期时,监听器会自动触发,并更新数据库中的用户状态。

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

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

相关文章

HBuilder X 中Vue.js基础使用2(三)

一、条件渲染 1、条件判断 v-if : 表达式返回真值时才被渲染 v-else :表达式返回为假时不被渲染 2、 分支条件判断 v-else-if :使用v-if , v-else-if 和 v-else 来表示其他的条件分支 3、显示隐藏 v-show v-show true 把节点显示 …

PortQry下载安装使用教程(超详细),Windows测试UDP端口

《网络安全自学教程》 PortQry是微软官方提供的一款TCP/IP连接「排障工具」,用来「检查」TCP/UDP「端口状态」。 平时检查端口状态,最常用的是telnet,但它是基于TCP协议的,无法检测「UDP端口」,这篇文章教大家如何在W…

Axure随机验证码高级交互

亲爱的小伙伴,在您浏览之前,烦请关注一下,在此深表感谢! 课程主题:字母数字随机验证码高级交互 主要内容:4位字母数字随机验证码生成、错误提示与State状态同步 应用场景:登录验证码、其他类…

面试宝典(五):用三个线程按顺序循环打印123三个数字,比如123123123

要使用三个线程按顺序循环打印123三个数字,势必要控制线程的执行顺序,可以使用java.util.concurrent包中的Semaphore类来控制线程的执行顺序。 代码示例 import java.util.concurrent.Semaphore;public class SequentialPrinting123 {private static Se…

管家婆工贸ERP BB036.销售退货单生成销售单

最低适用版本: 工贸系列 22.0 插件简要功能说明: 销售退货单生成销售单,支持联查上下游,并反写已生单数量更多细节描述见下方详细文档插件操作视频: 进销存类定制插件--销售退货单生成销售单 插件详细功能文档: 1. 单据字段占用: a. 销售单: ⅰ. 占用自由项11、12、…

leetcode:34. 在排序数组中查找元素的第一个和最后一个位置(python3解法)

#1024程序员节 | 征文# 难度:中等 给你一个按照非递减顺序排列的整数数组 nums,和一个目标值 target。请你找出给定目标值在数组中的开始位置和结束位置。 如果数组中不存在目标值 target,返回 [-1, -1]。 你必须设计并实现时间复杂度为 O(lo…

Vue中的过渡与动画:提升用户体验的秘籍

Vue中的过渡与动画:提升用户体验的秘籍 在现代Web开发中,用户体验(UX)的重要性不言而喻。Vue.js作为一个渐进式JavaScript框架,提供了一套简单而强大的过渡和动画系统,使得开发者能够轻松地为应用添加平滑的过渡效果和动画。本文…

短信验证码发送实现(详细教程)

短信验证码 接口防刷强检验以及缓存验证码阿里云短信服务操作步骤验证码发送实现 好久没发文啦!最近也是在工作中遇到我自认为需要记录笔记的需求,本人只求日后回顾有迹可寻,不喜勿喷! 废话不多说,直接上代码&#xff…

初识算法 · 前缀和(1)

目录 前言: 一维数组的前缀和 题目解析 算法原理 算法编写 二维数组的前缀和 题目解析 算法原理 算法编写 前言: ​本文的主题是前缀和,通过两道题目讲解,一道是一维数组的模板,一道是二维数组的模板。 链接…

504 Gateway Time-outopenresty

504 Gateway Time-out openresty 问题背景: 当自己点开知乎页面以后,发现官网没有出现任何问题,点击官网以后开始出现各种各样的报错! 一下是来源ai的介绍:(通过搜索这种形式帮助自己进行记忆)…

spring整体框架+IOC+Bean 学习笔记

1.spring包含了多个功能模块,其中最重要的是spring-core,主要提供ioc依赖注入功能的支持,spring中的其他模块功能都需要依赖该模块。 spring整体框架 最底层: 1.core:spring框架的核心工具类 2.bean:提供…

【WebGIS实例】(18)MapboxGL 绘制矢量——线、面

前言 Mapbox GL JS 版本:3.6.0 该博客仅供学习参考,如果您是计划在实际项目中实现该功能,也推荐您直接使用已有的功能库: 官方案例:Draw a polygon and calculate its areamapbox-gl-draw:mapbox/mapbox-g…

基于Django+python的酒店客房入侵检测系统设计与实现

项目运行 需要先安装Python的相关依赖:pymysql,Django3.2.8,pillow 使用pip install 安装 第一步:创建数据库 第二步:执行SQL语句,.sql文件,运行该文件中的SQL语句 第三步:修改源…

HTTPS讲解

前瞻 HTTP与HTTPS的关系 HTTPS也是一个在应用层的协议,是在HTTP协议基础上的一个加密解密层 明文 密文 秘钥 明文->秘钥 加密 秘钥->明文 解密 例如:明文为7 秘钥为2 7^21015; 5就是密文例子: 因为http的内容是明文传输的,明文…

危险物品图像分割系统:一键训练

危险物品图像分割系统源码&数据集分享 [yolov8-seg-GFPN&yolov8-seg-CSwinTransformer等50全套改进创新点发刊_一键训练教程_Web前端展示] 1.研究背景与意义 项目参考ILSVRC ImageNet Large Scale Visual Recognition Challenge 项目来源AAAI Global…

LabVIEW共享变量通信故障

问题概述: 在LabVIEW项目中,使用IO服务器创建共享变量,并通过LabVIEW作为从站进行数据通信。通讯在最初运行时正常,但在经过一段时间或几个小时后,VI前面板出现错误输出,导致数据传输失败。虽然“分布式系统…

折扣影票接口对接渠道如何选择?

选择折扣影票接口对接渠道需要综合多方面因素考虑,以下是一些建议: 1.合法性和合规性: 确认供应商资质:优先选择具有相关票务经营资质的渠道。比如一些大型的在线票务平台,它们通常经过官方认证和监管,在…

[JAVAEE] 多线程的案例(二) - 阻塞队列 生产者消费者模型

目录 一. 什么是阻塞队列 二. java中的阻塞队列 三. 生产者消费者模型 3.1 生产者消费者模型与阻塞队列密不可分的关系 3.2 阻塞队列在生产者消费者模型的作用 a. 解耦合 b. 削峰填谷 四. 模拟实现阻塞队列 4.1 实现put方法 4.2 实现take方法 4.3 生产者消费者模型​…

Ansys APDL 语法

APDL 语法 1. 数组的定义例子2. 循环1. 数组的定义 *DIM, Par, Type, IMAX, JMAX, KMAX, Var1, Var2, Var3, CSYSID Par:用户指定的数组参数名。 Type:数组类型。有八种不同的类型: 1、ARRAY:数值型数组,与标准FORTRAN中的数组相类似,其下标只能是整数(默认方式),行标号、列…

了解C# 程序结构

本节我们将学习 C# 编程语言的结构,为了让大家能够对 C# 程序结构有个更好的理解,我们会先演示一个最小的、最简单的 C# 程序结构,以便作为接下来的章节的参考。 C# Hello World 实例 一个 C# 程序主要包括以下部分: 命名空间声明…