首页 > 数据库 >Redis发布订阅

Redis发布订阅

时间:2023-12-06 23:35:22浏览次数:31  
标签:订阅 频道 Redis 发布 消息 channel

是什么

是一种消息通信模式:发送者(PUBLISH)发送消息,订阅者(SUBSCRIBE)接收消息,可以实现进程间的消息传递。

Redis可以实现中间件的MQ功能,通过发布订阅实现消息的引导和分流。

能干嘛

Redis客户端可以订阅任意数量的频道,类似我们微信关注多个公众号。

image-20231206214543745

当有新消息通过PUBLISH命令发送给频道channel1时

image-20231206214630815

概括

发布/订阅其实是一个轻量的队列,只不过数据不会被持久化,一般用来处理 实时性较高的异步消息

image-20231206214822213

常用命令

SUBSCRIBE channel [channel...]:订阅给定的一个或多个频道的信息

推荐先执行订阅后再发布,订阅成功之前发布的消息是收不到的。

订阅的客户端每次可以收到一个3个参数的消息。

image-20231206221009174

  1. 消息的种类

  2. 始发频道的名称

  3. 消息内容

PUBLISH channel message :发布消息到指定的频道

PSUBSCRIBE pattern [pattern...]:按照模式批量订阅,订阅一个或多个符合给定模式(支持*号?号之类的)的频道

PUBSUB subcommand[argument[argument...]]:查看订阅与发布系统状态

  1. PUBSUB CHANNELS 由活跃频道组成的列表 image-20231206230717813

     

  2. PUBSUB NUMSUB [channel[channel...]]:某个频道有几个订阅者 image-20231206230802745

  3. PUBSUB NUMPAT:只统计使用PSUBSCRIBE命令执行的,返回客户端订阅的唯一模式数量

image-20231206230616761

UNSUBSCRIBE [channel[channel...]]:取消订阅

PUNSUBSCRIBE [pattern[pattern]]:退订所有给定模式的频道

总结

  • Redis可以实现消息中间件MQ的功能,通过发布订阅实现消息的引导和分流。

  • Pub/Sub缺点:

    • 发布的消息在Redis系统中不能持久化,因此,必须先执行订阅,再等待消息发布。如果先发布了消息,那么该消息由于没有订阅者,消息将直接丢弃

    • 消息只管发送对于发布者而言是即发即失的,不管接收,且没有ACK机制,无法保证消息消费成功。

    • 以上缺点导致Redis的Pub/Sub模式就像个小玩具,在生产环境中几乎无用武之地,为此Redis5.0版本新增了Stream数据结构,不但支持多播,还支持数据持久化,相比Pub/Sub更加的强大。

标签:订阅,频道,Redis,发布,消息,channel
From: https://www.cnblogs.com/chenyonghua/p/17880771.html

相关文章

  • SpringBoot高级开发(8)SpringBoot使用Lettuce设置多个RedisTemplate实例
    copy from:https://xiaomozhang.github.io/2021/02/07/spring-boot-lettuce-multi-instance/项目pom配置使用SpringBoot集成Redis,只需要将spring-boot-starter-data-redis和commons-pool2加到依赖即可 xml<dependency><groupId>org.springframework.boot</groupId>......
  • Using Redis with FastAPI
    UsingRediswithFastAPIhttps://developer.redis.com/develop/python/fastapi/https://github.com/fanqingsong/fastapi-redis-tutorialFastAPIisaPythonwebframeworkbasedontheStarlettemicroframework.Withdeepsupportforasyncio,FastAPIisindeedv......
  • 苹果iOS 17.2 RC准正式版发布!iPhone 15 Pro系列独占空间视频来了
    今天凌晨,苹果面向开发者和公测用户发布iOS17.2RC版本,内部版本号为21C62。iOS17.2RC也就是iOS17.2准正式版,如果没有大的Bug,这将是iOS17.2正式版发布前最后一次更新。升级日志显示,iOS17.2RC新增iPhone15Pro系列空间视频拍摄功能、iPhone15Pro系列操作按钮新增“翻译......
  • JAVA操作Redis工具类
    importlombok.extern.slf4j.Slf4j;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.data.redis.core.RedisTemplate;importorg.springframework.stereotype.Component;importorg.springframework.util.CollectionUtils;im......
  • 不再支持安卓 7.0!谷歌Chrome浏览器120稳定版发布
    今天,谷歌面向所有支持平台,发布了Chrome浏览器的120稳定版更新,该版本不再支持安卓7.0/7.1系统。在新功能上,Chrome浏览器120稳定版推出一项新的“主动安全检查”功能,该功能会定期运行,检查浏览器是否存在安全问题,并在检查完成之后通知用户。在设置中也为此新增了一个新的“安全检......
  • Socket.D 网络应用协议,首版发布!
    有用户说,“Socket.D之于Socket,尤如Vue之于Js、Mvc之于Http”主要特性基于事件,每个消息都可事件路由所谓语义,通过元信息进行语义描述流关联性,有相关的消息会串成一个流语言无关,使用二进制输传数据(支持tcp,ws,udp)。支持多语言、多平台断线重连,自动连接恢复多路复......
  • 拒绝算法推荐,使用rss订阅消息与新闻!
    算法推荐的弊端就不说了借用RSSHub镜像网站如果你实在不会,又或者觉得麻烦,那你还可以搭其他网友的“便车”。我收集了 9 个公开的 RSShub镜像网站,它们用的都是用自己的服务器,所以在流量方面也不会有问题。服务器1 :https://rsshub.rssforever.com 服务器2 :https://rss......
  • 九、发布确认(高级)
    一、发布确认springboot版本1、确认机制方案2、代码架构图3、配置文件4、添加配置类5、消息生产者6、回调接口7、消息消费者8、结果分析二、回退消息1、Mandatory参数配置文件:2、消息生产者代码3、回调接口4、结果分析三、备份交换机......
  • Spring Boot整合Redis实现订单超时处理
    文章目录为什么使用Redis?准备工作创建订单实体类存储订单到Redis设置订单超时监控订单超时订阅订单超时消息总结......
  • 使用 maven 自动将源码打包并发布
    maven-source-plugin作用:在构建过程中将项目的源代码进行打包,并作为一个jar文件附着在主构件上,在pom.xml中添加如下内容,使用maven生成jar的同时生成sources包在pom中配置如下:<build><plugins><plugin><groupId>org.apache.maven.plugins</g......