讲师中心 微信公众号

工具推荐

视频效率加速
立刻MV
立刻MV

低成本歌曲 MV、视频生成

updream

一键生成高质量推广成片

Laper
Laper

剧本策划到成片协作

剧云
剧云

中文短剧剧本制作平台

Redis如何构建基于发布订阅的实时协同过滤推荐_实时推送用户兴趣点更新

梦雪吖_7745

梦雪吖_7745

发布时间:2026-04-12 09:09:27

|

936人浏览过

|

来源于php中文网

原创

不能直接用。Redis Pub/Sub无持久化、无ACK、不保证投递,无法支撑协同过滤所需的可靠兴趣更新;应采用“Pub/Sub触发+Stream持久化+ZSet存状态”的分层架构,确保实时性与一致性。

redis如何构建基于发布订阅的实时协同过滤推荐_实时推送用户兴趣点更新

Redis Pub/Sub 能否支撑实时协同过滤推荐?

不能直接用。Redis 的 PUB/SUB 本身不存历史消息、无 ACK、不保证投递,一旦订阅者断连就丢数据——而协同过滤的用户兴趣点更新(比如“用户 A 刚对商品 X 打了高分”)必须可靠触达所有在线推荐服务节点,否则实时性与一致性全崩。

它只适合做「轻量广播信令」:比如通知各推荐模块「用户兴趣模型已更新,请从 hash 或 zset 里重新拉取最新向量」,而不是把原始行为事件当消息体发出去。

如何设计可靠的用户兴趣点更新链路?

用 PUB/SUB 做触发器 + 持久化存储做事实源,是唯一稳妥组合:

  • 用户行为(点击/评分/停留)先写入 stream(如 user:behavior:stream),带 ID 和时间戳,支持重放
  • 一个常驻消费者组(CONSUMER GROUP)从 stream 拉取、计算兴趣向量、写入 zset user:A:interest(成员=物品ID,score=兴趣权重)
  • 该消费者在完成一次批量更新后,向频道 channel:interest:update 发布一条极简消息:{"user_id":"A","version":12345}
  • 所有推荐服务实例都 SUBSCRIBE 该频道;收到后立刻去查 zset user:A:interest,比对本地缓存 version,不一致则全量同步

为什么不用 PUBLISH 直接发兴趣向量?

三个硬伤:

Sentinal Redis
Sentinal Redis

监控Redis服务器健康状况、内存、性能及BullMQ队列。检查队列深度、失败任务,分析慢查询并诊断问题。

下载
  • PUBLISH 消息大小受限(默认 512MB,但实际网络和客户端缓冲会更早爆),用户兴趣 zset 动辄上千项,序列化后远超安全阈值
  • 订阅者无法知道消息是否被处理成功——如果推荐服务在反序列化时出错,这个向量就永久丢失,且无从追溯
  • 不同服务实例可能因网络抖动收到重复或乱序消息,而 PUB/SUB 不提供去重/顺序保障,导致兴趣状态错乱

所以,真正承载数据的是 zset 或 hash,PUB/SUB 只传指针——这是关键分层。

实际部署要注意哪些坑?

几个真实踩过的点:

  • 别用 PSUBSCRIBE 做通配符监听(如 channel:interest:*),高并发下 Redis 会退化为 O(N) 匹配,CPU 瞬间拉满;固定频道名 + 多 SUBSCRIBE 更稳
  • stream 消费者组记得设 MAXLEN ~1000000 并启用 ~ 修剪,否则磁盘悄无声息吃光
  • 推荐服务重启时,要先完成本地 zset 同步,再执行 SUBSCRIBE,否则可能漏掉刚发布的那条 update 消息
  • 如果推荐服务有多个副本,每个副本必须用不同 GROUP 名消费 stream,否则互相争抢消息,导致部分副本永远收不到更新

最易被忽略的是:你写的「实时」,其实是「流式计算 + 原子状态读取 + 信令驱动」三段拼出来的——少一段,就不是实时,只是看起来快。

热门AI工具

更多
DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

相关专题

更多
C++ 智能指针与现代内存管理
C++ 智能指针与现代内存管理

深入讲解 C++ 现代内存管理的核心工具——智能指针,涵盖 unique_ptr 独占所有权语义、shared_ptr 引用计数机制与循环引用问题、weak_ptr 弱引用的应用场景、make_unique/make_shared 工厂函数的性能优势、自定义删除器的编写、RAII 资源管理思想的实践,以及从裸指针迁移到智能指针的重构策略,帮助开发者编写安全无泄漏的现代 C++ 代码。

379

2026.04.23

Golang channel原理
Golang channel原理

本专题整合了Golang channel通信相关介绍,阅读专题下面的文章了解更多详细内容。

454

2025.11.14

golang channel相关教程
golang channel相关教程

本专题整合了golang处理channel相关教程,阅读专题下面的文章了解更多详细内容。

639

2025.11.17

Go语言 channel用法详解
Go语言 channel用法详解

本专题整合了go语言中channel的各种使用方法,阅读专题下面的文章了解更多详细步骤。

503

2026.04.03

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4889

2023.11.02

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4455

2023.11.14

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

8592

2024.04.02

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

663

2024.04.07

Postman身份认证怎么配置
Postman身份认证怎么配置

本专题从实际API接口调试场景出发,讲解Postman身份认证的完整配置流程,包括常见认证协议介绍、授权参数设置、访问令牌填写、OAuth 2.0授权及认证失败排查,帮助用户正确完成接口授权与访问验证。

40

2026.11.06

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn