Serverless实例计费说明
阶梯单价 Serverless实例的消息收发单价在不同地域有所差异，具体价格如下：公共云地域单价 标准版实例消息收发单价 地域 计费阶梯 月度消息收发累计次数（亿次）普通消息发送（元/百万次）普通消息订阅（元/百万次）高级消息发送（元/百万...
主题模型基本概念
订阅（Subscription）订阅关系，只有和主题建立订阅关系后，消息订阅者才可以接收发布者发布到该主题的消息。消息过滤标签（FilterTag）订阅中消息过滤的标签，标签一致的消息才会被推送。推送地址（Endpoint）消息接收端，订阅者用于接收...
参数说明
参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey AccessKey ID，阿里云身份验证标识。...更多信息 收发普通消息 收发顺序消息 收发定时消息 收发事务消息 订阅消息
参数说明
消息订阅参数 参数名 参数说明 ConsumerId 您在 云消息队列 RocketMQ 版 控制台 上创建的Group ID，更多信息，请参见 基本概念。MessageModel 设置Consumer实例的消费模式，取值说明如下：CLUSTERING（默认值）：表示集群消费。...
普通消息
TCP SDK收发普通消息的示例代码 Java 发送普通消息（三种方式）发送消息（多线程）订阅消息 C或C++ 收发普通消息 订阅消息.NET 收发普通消息 订阅消息 HTTP SDK收发普通消息的示例代码 云消息队列 RocketMQ 版 支持RESTful风格的HTTP协议...
查看应用性能详情
消息订阅 页签显示了指标趋势和数据源明细，包括所选应用调用的消息订阅的消息主题（Topic）、请求次数等信息。参数说明可参考下表。参数名 说明 单位 Topic 所选应用调用的消息订阅的消息主题（Topic）。请求次数 所选应用调用消息订阅的...
接口和参数说明
消息订阅接口 消息订阅参数 参数名 参数说明 GROUP_ID 您在消息队列控制台上创建的 Group ID，详情参见 基础术语。MESSAGE_MODEL 设置 Consumer 的消费模式，取值说明如下：CLUSTERING（默认值）：表示集群消费。BROADCASTING：表示广播...
什么是云消息队列 MQTT 版
消费者：也称为消息订阅者，负责从Topic接收并消费消息。消息：生产者向Topic发送并最终传送给消费者的数据。规则：云消息队列 MQTT 版 与其他阿里云产品实现数据互通的资源。消息收发模型 云消息队列 MQTT 版 主要包含以下两种消息收发...
中间件监控指标
消息监控 指标名称 说明 单位 数据源 Msg Pub Count 消息推送数量 条 ant cloud agent Msg Pub Avg Cost 消息推送平均耗时 ms ant cloud agent Msg Sub Count 消息订阅数量 条 ant cloud agent Msg Sub Avg Cost 消息订阅平均耗时 ms ant ...
开发部署扩展程序：自建服务方式
因此，开发并使用扩展程序前，需先开启消息订阅，获取消息订阅的EventBridge信息、订阅事件的消息体格式，用于后续扩展程序的代码开发。开启消息订阅，详情请参见 开启消息订阅。订阅事件的消息体格式，详情请参见 附录：消息格式。步骤二...
MQ监控
ARMS应用监控的MQ监控可展示消息队列Apache ...在 订阅端统计 页签展示消息订阅的统计数据，包括消息请求数、响应时间和错误数。在 调用链查询 页签提供关于消息发布和订阅的接口快照，您可以通过TraceId链接查看完整调用链以及诊断问题原因。
SecretExceptionPhoneReport
前提条件 您已在号码隐私保护控制台开启异常号码状态推送消息订阅开关。更多详情，请参见 配置回执消息接收模式。参数说明 参数名 参数类型 示例 描述 secretNo String 1304984*隐私号码。partnerKey String FC1381111*归属合作伙伴号池Key...
MQ监控
MQ监控可展示消息队列RocketMQ版的Topic发布和...在 订阅端统计 页签展示消息订阅的统计数据，包括消息请求数、响应时间和错误数。在 调用链查询 页签提供关于消息发布和订阅的调用链，您可以通过TraceId链接查看完整调用链以及诊断问题原因。
参数说明
消息订阅 表 2.消息订阅参数 参数 说明 firstTopic 您在 云消息队列 MQTT 版 控制台创建的父级Topic。更多信息，请参见 基本概念。重要 如果使用了未创建或未授权的Topic，会导致客户端鉴权失败，云消息队列 MQTT 版 服务端断开客户端的...
配置变更
修改或删除消息订阅 在 消息订阅配置 下，单击 修改/删除，在配置窗口中，选择变更类型为 修改 或 删除。勾选需要变更的订阅关系，选定的消息订阅会出现在变更列表中，单击 修改 进行配置调整，或单击 删除，然后单击 保存 完成修改或删除...
接口和参数说明
messageListener 消息订阅回调，在回调中处理订阅的消息。设备上下线事件接口 接口名称：subscribeStatus 类名称：com.alibaba.mqtt.server.ServerConsumer 表 3.设备上下线事件接口参数 参数 说明 mqttGroupId 您在 云消息队列 MQTT 版 ...
应用总览
MOSN 消息订阅-mosnmsgsub MOSN 消息订阅时的监控指标。MOSN 消息发布-mosnmsgpub MOSN 消息发布时的监控指标。MOSN Error-mosnerror MOSN 错误信息监控指标。ob proxy 指标-odpstat ob 代理监控指标。ODP 异常-odperror ODP 异常监控指标...
开启消息订阅
DataWorks的OpenEvent通过EventBridge为您提供事件消息订阅与发送服务。在EventBridge中创建自定义总线后，您需要在DataWorks中配置消息事件分发通道，以便在EventBridge中创建规则并完成事件的发布。本文为您介绍如何开启消息订阅服务与...
应用总览
MOSN 消息订阅-mosnmsgsub MOSN 消息订阅时的监控指标。MOSN 消息发布-mosnmsgpub MOSN 消息发布时的监控指标。MOSN Error-mosnerror MOSN 错误信息监控指标。OB Proxy 指标-odpstat OB（OceanBase）代理监控指标。ODP 异常-odperror ODP...
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从...更多信息 消息收发示例代码的更多信息，请参见以下文档：发送普通消息（三种方式）收发顺序消息 收发定时消息 收发延时消息 收发事务消息 订阅消息
RocketMQ 5.x Serverless实例概述
在使用消息中间件时，为保证业务的稳定性，往往需要按照业务请求的峰值去配置消息中间件集群的资源，包括CPU、内存、存储、网络等多种资源。但在实际生产使用时，消息中间件所用资源大部分时间处于低利用率状态，造成资源浪费与闲置。云...
消息发布与订阅
消息订阅者也只能得到订阅之后的消息，频道（channel）中此前的消息将无从获得。此外，消息发布者（即publish客户端）无需独占与服务器端的连接，您可以在发布消息的同时，使用同一个客户端连接进行其他操作（例如List操作等）。但是，消息...
设备模拟器
具体功能如下：功能项 说明 上行指令调试 设备上报消息到物联网平台，包含：自定义Topic的消息上报和消息订阅 属性上报 事件上报 下行指令调试 物联网平台下发指令到设备，包含：自定义Topic的消息下发 属性调试（含获取、设置）服务调用 ...
操作链路概述
具体操作步骤如下：创建资源 创建工作空间 创建 Topic 创建 Group ID 获取 AK（AccessKey ID）和 SK（AccessKey Secret）获取接入配置 发送消息 订阅消息 创建资源 注意事项 在使用 SOFAStack 消息队列时，请注意以下网络访问限制：Topic ...
基于MQTT Topic通信
取消消息订阅 重要 Python Link SDK的1.0.0至1.2.11版本中，设备与物联网平台连接断开后，继续调用以下接口取消消息订阅会抛出异常，需要您做好异常处理。在1.2.12版本后，该API执行失败后，会返回非零错误值，不再抛出异常。通过调用 ...
概述
消费者：也称为消息订阅者，负责从 Topic 接收并消费消息。消息：生产者向 Topic 发送并最终传送给消费者的数据和（可选）属性的组合。消息属性：生产者可以为消息定义的属性，包含 Message Key 和 Tag。Group：一类生产者或消费者，这类...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的SDK使用.NET语言进行消息订阅。说明 请确保同一个Group ID下所有Consumer实例的订阅关系保持一致。更多信息，请参见 订阅关系一致。云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同...
基础版/铂金版实例计费
则该场景下，消息订阅关系数为10×2=20个。计费单价 实例类型 订阅关系数上限（个）价格（元/月）基础版实例 1千 50 1万 500 5万 2500 10万 5000 20万 10000 50万 25000 100万 50000 铂金版实例 10万 7000 50万 33000 100万 67000 200万 ...
API概览
消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。UpdateConsumerGroup 更新消费者分组 更新消费者分组的基础信息和消费重试策略。DeleteConsumerGroup 删除消费者分组 删除指定的消费者分组。ListConsumerGroups 查询消费者...
准备环境
在运行收发消息的 Java 代码前，您需按照本文提供的步骤来准备环境。操作步骤 通过 Maven 方式引入依赖。Java SDK 的最新版本号，可参见 SDK ...发送普通消息（三种方式）发送消息（多线程）收发顺序消息 收发事务消息 收发延时消息 订阅消息
开放平台概览
开放事件（OpenEvent）DataWorks开放平台的开放事件功能为您提供消息订阅服务，通过订阅DataWorks事件状态，应用系统对接DataWorks，实时获取相关内容的状态变化，帮助您及时响应，满足您的个性化决策需求。关于开放事件功能，具体请参见 ...
参数说明
消息订阅参数 参数名 参数说明 consumerGroup Consumer组名，多个Consumer如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一组，即您在阿里云RocketMQ控制台上创建的Group ID，详情请参见 基本概念。...
设备数据订阅
完成身份认证和对接进行设备的消息订阅。Demo示例 a.配置参数/System.getenv("iot.hosting.appKey")方法可以从环境变量中获取appkey和appsecret String appKey=System.getenv("iot.hosting.appKey");String appSecret=System.getenv("iot....
什么是服务端订阅
说明 如果您有多个服务器消费同一个产品的订阅消息，消息会随机转发至某个服务器。服务端订阅与规则引擎数据流转的使用场景和能力对比，请参见 数据流转方案对比。使用AMQP服务端订阅消息 AMQP（Advanced Message Queuing Protocol）即高级...
中间件产品总览
Spring Boot 自研的开发框架 集成 SOFA 中间件，且中间件可插拔 服务网格 将传统微服务和 Service Mesh 进行融合 对接经典应用服务和容器应用服务 提供丰富的服务治理功能 消息队列 基于 Apache RocketMQ 构建的分布式消息中间件 ...
消息队列 RocketMQ 客户端流控设计
限流方式有两种：针对消息订阅者的并发流控 针对消息订阅者的消费延时流控 针对消息订阅者的消费延时流控的基本原理是，每次消费时在客户端增加一个延时来控制消费速度，此时理论上消费并发最快速度为：MaxRate=1/ConsumInterval*...
消息 Mesh
新 MOSN 完成存量连接迁移后，向所有的消息服务端发送接收消息的控制指令，开始正常的消息订阅。消息 Mesh 流量调度 消息 Mesh 的流量调度，示例如下：流量调度流程说明如下：控制平面会将与流量调度相关的规则下发至 MOSN，规则主要包含该...
环境准备（v2.x.x）
本文介绍使用C++ SDK v2.x.x及以上版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。...cd bin 更多信息 收发普通消息 收发顺序消息 收发定时消息 收发事务消息 订阅消息
- 产品推荐
- 这些文档可能帮助您