0

0

Redis怎样利用发布订阅机制更新多级本地缓存

P粉602998670

P粉602998670

发布时间:2026-03-14 11:03:11

|

265人浏览过

|

来源于php中文网

原创

不能。Redis发布订阅仅传递字符串消息,无数据语义与可靠性保障,需手动解析消息并调用本地缓存的invalidate/put方法;多实例通过各自订阅同一channel实现通知,但存在断线丢消息等问题。

redis怎样利用发布订阅机制更新多级本地缓存

Redis 发布订阅能直接更新本地缓存吗?

不能。Redis 的 PUBLISHSUBSCRIBE 是纯消息通道,不带数据结构语义,也不保证送达、不支持重放、不记录历史——它只负责把字符串消息“扔出去”。你不能靠它自动刷新 guava cacheCaffeine 里的某个 key,更没法触发 Spring Cache 的 @CacheEvict

真正可行的路径是:用订阅收到消息 → 解析出变更的业务标识(比如 "user:123")→ 主动调用本地缓存的 invalidate()put() 方法。

怎么让多个服务实例都收到缓存失效通知?

靠 Redis 的 PUB/SUB 天然支持多消费者:每个服务实例起一个独立的 ConnectionSUBSCRIBE 到同一个 channel(比如 cache-invalidate),消息一发,所有在线 subscriber 都会收到。

但要注意几个现实约束:

  • 连接断开期间的消息完全丢失 —— 没有 ack,没有 offset,不支持断线重连后补推
  • 如果用 Jedis,JedisPubSub 是阻塞式回调,必须在单独线程里跑,否则卡死主线程
  • Lettuce 更合适,它的 StatefulRedisPubSubConnection 支持异步监听,还能复用 Netty 连接池
  • 别用通配符 PSUBSCRIBE 做通用监听,channel 名设计要收敛(如 cache:usercache:order),避免误触和性能抖动

消息体该怎么设计才不容易翻车?

最简方案是传 JSON 字符串,但必须包含两个字段:type(操作类型,如 "DELETE""UPDATE")和 key(对应本地缓存的 key,如 "user:456")。别省略 type —— 否则无法区分是删还是刷,也难做幂等。

常见错误包括:

Peppertype.ai
Peppertype.ai

高质量AI内容生成软件,它通过使用机器学习来理解用户的需求。

下载
  • 只传原始 ID(如 "456"),导致不同 service 对同一 ID 解释不一致(用户 ID 还是订单 ID?)
  • 把完整对象序列化后发过去,徒增网络压力,且本地缓存可能根本不需要全量数据
  • 没加时间戳或版本号,遇到重复消息时无法判重,引发缓存反复刷新甚至错乱

建议格式:

{"type":"DELETE","key":"user:456","ts":1718234567,"v":"2"}

本地缓存更新时机选 invalidate 还是 refresh

优先选 invalidate(即删掉本地缓存项),而不是收到消息后立刻查 DB 再 put。原因很实在:

  • 避免雪崩:多个实例同时收到同一条消息,若都去查 DB,瞬间并发打穿数据库
  • 避免脏写:如果 DB 查询慢、超时或报错,put 可能写入 null 或旧值,污染缓存
  • 延迟可控:下一次请求自然触发加载,配合本地缓存的 refreshAfterWriteexpireAfterAccess 就够用

只有极少数场景适合主动 refresh:比如该 key 被高频访问、且 DB 查询极快(毫秒级)、且你能确保各实例不会同时发起加载(例如加分布式锁或用 Caffeine 的 refreshAfterWrite + 异步 load)。

复杂点在于:消息可能比 DB 写入还快(尤其是主从延迟时),所以 invalidate 后首次加载仍可能读到旧值。这个 gap 无法靠发布订阅消除,得靠业务容忍或额外机制(如延迟双删、binlog 监听)来缓解。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
spring框架介绍
spring框架介绍

本专题整合了spring框架相关内容,想了解更多详细内容,请阅读专题下面的文章。

161

2025.08.06

Java Spring Security 与认证授权
Java Spring Security 与认证授权

本专题系统讲解 Java Spring Security 框架在认证与授权中的应用,涵盖用户身份验证、权限控制、JWT与OAuth2实现、跨站请求伪造(CSRF)防护、会话管理与安全漏洞防范。通过实际项目案例,帮助学习者掌握如何 使用 Spring Security 实现高安全性认证与授权机制,提升 Web 应用的安全性与用户数据保护。

89

2026.01.26

什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

411

2023.08.11

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

251

2023.10.07

json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

457

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

549

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

337

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

82

2025.09.10

TypeScript类型系统进阶与大型前端项目实践
TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开,深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析,帮助开发者构建类型安全、结构清晰、易维护的前端工程体系,提高团队协作效率与代码质量。

26

2026.03.13

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号