消息队列终极解决方案——Stream（下）
在开始使用消息分组之前，我们必须手动创建分组才行，以下是几个和 Stream 分组有关的命令，我们先来学习一下它的使用。
消息分组命令
创建消费者群组
127.0.0.1:6379> xgroup create mq group1 0-0
OK
相关语法：
xgroup create stream-key group-key ID
其中：
- mq 为 Stream 的 key；
- group1 为分组的名称；
- 0-0 表示从第一条消息开始读取。
如果要从当前最后一条消息向后读取，使用 $ 即可，命令如下：
127.0.0.1:6379> xgroup create mq group2 $
OK
读取消息
127.0.0.1:6379> xreadgroup group group1 c1 count 1 streams mq >
1) 1) "mq"2) 1) 1) "1580959593553-0"2) 1) "name"2) "redis"3) "age"4) "10"
相关语法：
xreadgroup group group-key consumer-key streams stream-key
其中：
消息队列终极解决方案——Stream（下）相关推荐
- 消息队列终极解决方案——Stream（上）
在 Redis 5.0 Stream 没出来之前,消息队列的实现方式都有着各自的缺陷,例如: 发布订阅模式 PubSub,不能持久化也就无法可靠的保存消息,并且对于离线重连的客户端不能读取历史消息的缺 ...
- 别再用 Redis List 实现消息队列了，Stream 专为队列而生
使用 Redis 的 List 实现消息队列有很多局限性,比如: 没有良好的 ACK 机制: 没有 ConsumerGroup 消费组概念: 消息堆积. List 是线性结构,想要查询指定数据需要遍历 ...
- 消息队列如何使用java,想使用消息队列，先考虑下这些问题！，消息队列如何使用...
想使用消息队列,先考虑下这些问题!,消息队列如何使用原创:Java派(微信公众号:Java派),欢迎分享,转载请保留出处. 消息队列优势 消息队列(Message Queue,简称MQ),其主要用于在 ...
- 腾讯云CMQ消息队列在Windows环境下的使用
版权声明:本文由李少华原创文章,转载请注明出处: 文章原文链接:https://www.qcloud.com/community/article/100 来源:腾云阁 https://www.qcl ...
- 李少华 linux内核,腾讯云CMQ消息队列在Linux环境下的使用
环境配置: 操作系统 Ubuntu 内存 8G 选择自己语言版本的 SDK(下载地址),这里我选择的是 C++版本 SDK. 1. 环境依赖 安装 curl: Ubuntu 安装 curl 可以用如下 ...
- linux启动队列mq,腾讯云CMQ消息队列在Linux环境下的使用
环境配置: 操作系统Ubuntu 内存 8G 选择自己语言版本的 SDK(下载地址),这里我选择的是 C++版本 SDK. 1. 环境依赖 安装 curl: Ubuntu 安装 curl 可以用如下命 ...
- springboot使用redis实现消息队列功能，redis使用list和stream实现消息队列功能，redis实现消息队列的风险点分析
文章目录 写在前面 基于list的消息队列解决方案 使用list基本实现消息队列 阻塞式消费,避免性能损失 替换while(true) 实现消息幂等 保证消息可靠性 基于stream的消息队列解决方案 ...
- redis灵魂拷问：如何使用stream实现消息队列
redis在很早之前就支持消息队列了,使用的是PUB/SUB功能来实现的.PUB/SUB有一个缺点就是消息不能持久化,如果redis发生宕机,或者客户端发生网络断开,历史消息就丢失了. redis5. ...
- Redis进阶-Stream多播的可持久化的消息队列
文章目录 Pre Stream简介 Stream特性 消息 ID 消息内容 命令预览 独立消费 创建消费组 消费 Stream 消息积压怎么处理 消息如果忘记 ACK 会怎样? PEL 如何避免消息丢 ...
最新文章
- 中国楼宇自控系统发展规划现状及未来前景预测报告2022-2028年版
- BZOJ 4070 [Apio2015]雅加达的摩天楼 ——分块 SPFA
- java构造函数调用其他程序的顺序_java初始化构造函数调用顺序
- java 二维数组倒置_Java数组反转及二维数组
- linux --开机自动挂载硬盘【转】
- 插入排序（直接插入 、希尔）
- python 判断线程是否执行完毕_判断线程池中的线程是否全部执行完毕
- Redis百万级别数据迁移
- 如何对CentOS FTP服务配置 - 51CTO.COM
- 【HDOJ】2809 God of War
- SDUT——打印数字图形
- 最老程序员创业札记：全文检索、数据挖掘、推荐引擎应用19
- 王佩丰VBA学习笔记
- 基于深度学习的人脸表情识别实现
- 各国语言缩写以及国际域名缩写
- 大学计算机技术导论,北京邮电大学计算机学院网络技术导论第一章资料.ppt
- jquery实现类似以前凡客诚品右侧图文切换结合效果
- 破解tumblr背景音乐
- 大数据工程师和数据分析师有什么区别
- mysql多条新增字段sql合并为一条新增