分布式消息服务 DMS分布式消息服务 DMS

计算
弹性云服务器 ECS
云耀云服务器 HECS
裸金属服务器 BMS
弹性伸缩 AS
镜像服务 IMS
专属主机 DeH
函数工作流 FunctionGraph
云手机 CPH
VR云渲游平台 CVR
特惠算力专区
存储
对象存储服务 OBS
云硬盘 EVS
云备份 CBR
内容分发网络 CDN
存储容灾服务 SDRS
弹性文件服务 SFS
云服务器备份 CSBS
云硬盘备份 VBS
数据快递服务 DES
专属企业存储服务
智能边缘
智能边缘云 IEC
EI 企业智能
EI安视服务
AI开发平台ModelArts
数据湖治理中心 DGC
数据仓库服务 GaussDB(DWS)
企业级AI应用开发专业套件 ModelArts Pro
数据湖探索 DLI
华为HiLens
云搜索服务 CSS
数据接入服务 DIS
表格存储服务 CloudTable
数据湖工厂 DLF
图引擎服务 GES
推荐系统 RES
文字识别 OCR
内容审核 Moderation
图像识别 Image
图像搜索 ImageSearch
人脸识别服务 FRS
对话机器人服务 CBS
视频分析服务 VAS
数据可视化 DLV
视频接入服务 VIS
自然语言处理 NLP
语音交互服务 SIS
知识图谱 KG
医疗智能体 EIHealth
可信智能计算服务 TICS
园区智能体 CampusGo
实时流计算服务 CS
人证核身服务 IVS
IoT物联网
设备接入 IoTDA
IoT物联网
全球SIM联接 GSL
设备发放 IoTDP
IoT开发者服务
IoT边缘 IoTEdge
IoT数据分析
路网数字化服务 DRIS
开发与运维
项目管理 ProjectMan
代码托管 CodeHub
流水线 CloudPipeline
代码检查 CodeCheck
编译构建 CloudBuild
部署 CloudDeploy
云测 CloudTest
发布 CloudRelease
移动应用测试 MobileAPPTest
CloudIDE
Classroom
软件开发平台 DevCloud
开源镜像站 Mirrors
视频
媒体处理 MPC
视频点播 VOD
视频直播 Live
实时音视频 SparkRTC
管理与部署
统一身份认证服务 IAM
云监控服务 CES
应用运维管理 AOM
应用性能管理 APM
云审计服务 CTS
云日志服务 LTS
标签管理服务 TMS
资源管理服务 RMS
应用身份管理服务 OneAccess
专属云
专属计算集群 DCC
专属分布式存储服务 DSS
域名与网站
域名注册服务 Domains
云速建站 CloudSite
企业协同
华为云WeLink
会议
ISDP
解决方案
全栈专属服务
高性能计算 HPC
SAP
游戏云
混合云灾备
快视频
华为工业云平台 IMC
价格
价格原则
成本优化最佳实践
昇腾
昇腾MindX SDK (20.3)
其他
管理控制台
消息中心
产品价格详情
系统权限
我的凭证
客户关联华为云合作伙伴须知
公共问题
宽限期保留期
奖励推广计划
活动
容器
云容器引擎 CCE
云容器实例 CCI
容器镜像服务 SWR
应用编排服务 AOS
容器交付流水线 ContainerOps
应用服务网格 ASM
多云容器平台 MCP
基因容器 GCS
容器洞察引擎 CIE
容器批量计算 BCE
云原生服务中心 OSC
网络
虚拟私有云 VPC
弹性公网IP EIP
弹性负载均衡 ELB
NAT网关 NAT
云专线 DC
虚拟专用网络 VPN
云连接 CC
VPC终端节点 VPCEP
数据库
云数据库 RDS
文档数据库服务 DDS
分布式数据库中间件 DDM
数据复制服务 DRS
数据管理服务 DAS
云数据库 GaussDB(for MySQL)
云数据库 GaussDB NoSQL
云数据库 GaussDB (for openGauss)
数据库和应用迁移 UGO
大数据
MapReduce服务 MRS
应用中间件
应用管理与运维平台 ServiceStage
分布式缓存服务 DCS
分布式消息服务Kafka版
分布式消息服务RabbitMQ版
消息通知服务 SMN
微服务引擎 CSE
云性能测试服务 CPTS
区块链服务 BCS
API网关 APIG
应用魔方 AppCube
分布式消息服务RocketMQ版
多云高可用服务 MAS
可信跨链数据链接服务 TCDAS
企业应用
云桌面 Workspace
云解析服务 DNS
应用与数据集成平台 ROMA Connect
ROMA资产中心 ROMAExchange
ROMA API
鸿源云道
华为乾坤云服务
安全与合规
Web应用防火墙 WAF
漏洞扫描服务 VSS
企业主机安全 HSS
容器安全服务 CGS
数据加密服务 DEW
数据库安全服务 DBSS
态势感知 SA
云堡垒机 CBH
SSL证书管理 SCM
云证书管理服务 CCM
管理检测与响应 MDR
数据安全中心 DSC
威胁检测服务 MTD
DDoS防护 ADS
云防火墙 CFW
应用信任中心 ATC
安全技术与应用
迁移
主机迁移服务 SMS
对象存储迁移服务 OMS
云数据迁移 CDM
智能协作
IdeaHub
企业网络
云管理网络
SD-WAN 云服务
边缘数据中心管理 EDCM
废弃-华为乾坤安全云服务
云通信
语音通话 VoiceCall
消息&短信 MSGSMS
隐私保护通话 PrivateNumber
开发者工具
SDK开发指南
API签名指南
DevStar
HCloud CLI
Terraform
Ansible
云生态
云市场
鲲鹏
昇腾
合作伙伴中心
华为云学院
用户服务
帐号中心
费用中心
成本中心
资源中心
企业管理
工单管理
客户运营能力
国际站常见问题
网站备案
支持计划
专业服务
合作伙伴支持计划
更新时间:2021/06/16 GMT+08:00
分享

基本概念

  • 消息

    消息队列中信息传递的载体,以JSON格式存在,可以发送或消费一条消息,也可以批量发送或消费,其中批量发送只能通过API接口调用完成。

    目前消息负载最大限制为512KB。

  • 消息属性

    每条消息均可以定义消息属性,由属性名及属性值组成,并随消息一起被发送和消费,属于消息的一部分。

    消息属性可以帮助消息的消费者决定如何处理消息,而不必先处理消息正文。

  • 消息队列

    消息队列是在消息的传输过程中保存消息的容器,用于接收消息并以文件的方式存储,一个队列的消息可以同时被多个消息消费者消费,每个用户默认最多可以创建30个队列。

    • 普通队列:包括分区有序和全局有序,分区有序的普通队列具有更高的并发性能,不保证先入先出(FIFO)的严格顺序,全局有序的普通队列保证消息先入先出(FIFO)的严格顺序。
    • 高级队列:支持使用开源kafka客户端进行生产消息和消费消息。支持高吞吐和高可靠两种模式,高吞吐模式的消息副本异步落盘,具有较高的性能,高可靠模式的消息多副本同步落盘,保证消息的可靠性。
    • RabbitMQ队列:采用物理隔离方式部署,支持用户自定义内存规格和自定义特性,您可以根据业务需要定制相应计算能力和存储空间的RabbitMQ实例。
  • 死信消息

    死信消息是指无法被正常消费的消息。

    DMS支持对消息进行异常处理。当消息进行多次重复消费仍然失败后,DMS会将该条消息转存到死信队列中,有效期为72小时,用户可以根据需要对死信消息进行重新消费。

    消费死信消息时,只能消费该消费组产生的死信消息。

    全局有序的普通队列的死信消息依然按照先入先出(FIFO)的顺序存储在死信队列中。

    高级队列不支持死信功能。

  • 消息生产者

    发送消息的一方,也叫消息发送者,发送消息到指定的消息队列中。

  • 消息消费者

    消费消息的一方,也叫消息接收者,通过调用消息服务的消费接口从队列中读取消息,消费确认后消费者将无法再次消费该消息。

  • 消息消费组

    消息消费组用于区分不同类型的消息消费者,一个消息队列最多可以创建三个消费组。

    消息队列中的所有消息可以被不同消费组分别消费一次,一个消费组消费掉的消息,其它消费组仍然可以消费。

    同一个消费组下可以有多个消息消费者并行消费,消费同一个队列里的不同消息。

  • 消息重置

    以时间轴为坐标,在消息持久化存储的时间范围内(普通队列默认72小时),重新设置消费组对指定队列的消费进度,设置完成后消费者将接收设定时间点之后由消息生产者发送到DMS服务端的消息。

  • 消息过滤

    是通过对消息增加标签来区分队列中的消息分类,DMS允许消费者按照标签对消息进行过滤,确保消费者最终只消费到他关心的消息类型。

    发送消息时,无论是否添加消息标签,都可以发送到指定队列中。

    消费消息时,指定过滤标签只能消费到匹配上标签的消息,不指定过滤标签,可以消费队列中所有类型的消息。

  • 延时消息

    延时消息是指消息发送到DMS服务后,并不期望这条消息立即被消费,而是延迟一段时间后才能被消费。

    仅普通队列(包括分区有序和全局有序)可以开启延时消息,高级队列不支持延时消息的功能。

  • 消息重投

    普通队列在使用SDK管理消息时支持消息重投,当消费消息异常时,确认消费设置为“重投”,服务端会将消息标记为已消费,并且转存到重投Topic中,用户可以继续往后消费。重投消息延迟至少30秒后才能再次被消费出来,再次消费确认时,依然可以设置为“成功”、“失败”或“重投”。

  • 广播消息

    普通队列在使用SDK管理消息时支持广播消息,同一个消费组的所有消费者都可以消费相同的消息。

    可以设置是否自动确认,设置为true时,不需要手动提交确认消费。

    在消费消息时,可以设置如下消费模式:

    • 组播:消费成功后,该消费组的其他消费者无法再消费。
    • 广播,从最早一条开始:从队列中第一条消息开始,该消费组的每个消费者都可以消费队列中的所有消息。
    • 广播,从已消费的位置开始:当设置固定Consumer id时,可以从当前的消费位置开始,该消费组的每个消费者都可以消费队列中所有未消费的消息。
    • 广播,从最新一条开始:从队列中最新的一条消息开始,该消费组的每个消费者都可以消费之后生产的消息。
分享:

    相关文档

    相关产品