MOSN 总览
日志格式如下：•日志打印时间•fromApp（即 currentApp）•toApp•服务名•方法名•本段时间内调用次数•本段时间内的调用总耗时•结果（Y/N）•全链路压测标志（T/F）•目标 Zone mosnmsgsub MOSN 消息订阅 次 框架配置日志。文件采集...
服务指标
插件类型为：SPM 日志格式如下：•日志打印时间•fromApp（即 currentApp）•toApp•服务名•方法名•本段时间内调用次数•本段时间内的调用总耗时•结果（Y/N）•全链路压测标志（T/F）•目标 Zone mosnmsgsub MOSN 消息订阅 次 框架配置...
Serverless实例计费说明
阶梯单价 Serverless实例的消息收发单价在不同地域有所差异，具体价格如下：公共云地域单价 标准版实例消息收发单价 地域 计费阶梯 月度消息收发累计次数（亿次）普通消息发送（元/百万次）普通消息订阅（元/百万次）高级消息发送（元/百万...
参数说明
参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey AccessKey ID，阿里云身份验证标识。...更多信息 收发普通消息 收发顺序消息 收发定时消息 收发事务消息 订阅消息
参数说明
消息订阅参数 参数名 参数说明 ConsumerId 您在 云消息队列 RocketMQ 版 控制台 上创建的Group ID，更多信息，请参见 基本概念。MessageModel 设置Consumer实例的消费模式，取值说明如下：CLUSTERING（默认值）：表示集群消费。...
主题模型基本概念
订阅（Subscription）订阅关系，只有和主题建立订阅关系后，消息订阅者才可以接收发布者发布到该主题的消息。消息过滤标签（FilterTag）订阅中消息过滤的标签，标签一致的消息才会被推送。推送地址（Endpoint）消息接收端，订阅者用于接收...
普通消息
TCP SDK收发普通消息的示例代码 Java 发送普通消息（三种方式）发送消息（多线程）订阅消息 C或C++ 收发普通消息 订阅消息.NET 收发普通消息 订阅消息 HTTP SDK收发普通消息的示例代码 云消息队列 RocketMQ 版 支持RESTful风格的HTTP协议...
查看应用性能详情
消息订阅 页签显示了指标趋势和数据源明细，包括所选应用调用的消息订阅的消息主题（Topic）、请求次数等信息。参数说明可参考下表。参数名 说明 单位 Topic 所选应用调用的消息订阅的消息主题（Topic）。请求次数 所选应用调用消息订阅的...
接口和参数说明
消息订阅接口 消息订阅参数 参数名 参数说明 GROUP_ID 您在消息队列控制台上创建的 Group ID，详情参见 基础术语。MESSAGE_MODEL 设置 Consumer 的消费模式，取值说明如下：CLUSTERING（默认值）：表示集群消费。BROADCASTING：表示广播...
开发部署扩展程序：自建服务方式
因此，开发并使用扩展程序前，需先开启消息订阅，获取消息订阅的EventBridge信息、订阅事件的消息体格式，用于后续扩展程序的代码开发。开启消息订阅，详情请参见 开启消息订阅。订阅事件的消息体格式，详情请参见 附录：消息格式。步骤二...
SecretExceptionPhoneReport
前提条件 您已在号码隐私保护控制台开启异常号码状态推送消息订阅开关。更多详情，请参见 配置回执消息接收模式。参数说明 参数名 参数类型 示例 描述 secretNo String 1304984*隐私号码。partnerKey String FC1381111*归属合作伙伴号池Key...
MQ监控
ARMS应用监控的MQ监控可展示消息队列Apache ...在 订阅端统计 页签展示消息订阅的统计数据，包括消息请求数、响应时间和错误数。在 调用链查询 页签提供关于消息发布和订阅的接口快照，您可以通过TraceId链接查看完整调用链以及诊断问题原因。
MQ监控
MQ监控可展示消息队列RocketMQ版的Topic发布和...在 订阅端统计 页签展示消息订阅的统计数据，包括消息请求数、响应时间和错误数。在 调用链查询 页签提供关于消息发布和订阅的调用链，您可以通过TraceId链接查看完整调用链以及诊断问题原因。
中间件监控指标
消息监控 指标名称 说明 单位 数据源 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 ...
配置变更
修改或删除消息订阅 在 消息订阅配置 下，单击 修改/删除，在配置窗口中，选择变更类型为 修改 或 删除。勾选需要变更的订阅关系，选定的消息订阅会出现在变更列表中，单击 修改 进行配置调整，或单击 删除，然后单击 保存 完成修改或删除...
参数说明
消息订阅 表 2.消息订阅参数 参数 说明 firstTopic 您在 云消息队列 MQTT 版 控制台创建的父级Topic。更多信息，请参见 基本概念。重要 如果使用了未创建或未授权的Topic，会导致客户端鉴权失败，云消息队列 MQTT 版 服务端断开客户端的...
接口和参数说明
messageListener 消息订阅回调，在回调中处理订阅的消息。设备上下线事件接口 接口名称：subscribeStatus 类名称：com.alibaba.mqtt.server.ServerConsumer 表 3.设备上下线事件接口参数 参数 说明 mqttGroupId 您在 云消息队列 MQTT 版 ...
开启消息订阅
DataWorks的OpenEvent通过EventBridge为您提供事件消息订阅与发送服务。在EventBridge中创建自定义总线后，您需要在DataWorks中配置消息事件分发通道，以便在EventBridge中创建规则并完成事件的发布。本文为您介绍如何开启消息订阅服务与...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从...更多信息 消息收发示例代码的更多信息，请参见以下文档：发送普通消息（三种方式）收发顺序消息 收发定时消息 收发延时消息 收发事务消息 订阅消息
应用没有订阅服务，但是框架重启后显示有消费服务信息...
可能Spring Cloud Alibaba版本过低，在低版本中Spring Cloud框架重启后，默认会开启记录所有消费服务的功能。解决方法如下。方法一：增加启动参数，关闭获取-Dspring.cloud.nacos.discovery.watch.enabled=false。方法二：升级Spring Cloud...
基于MQTT Topic通信
取消消息订阅 重要 Python Link SDK的1.0.0至1.2.11版本中，设备与物联网平台连接断开后，继续调用以下接口取消消息订阅会抛出异常，需要您做好异常处理。在1.2.12版本后，该API执行失败后，会返回非零错误值，不再抛出异常。通过调用 ...
消息发布与订阅
消息订阅者也只能得到订阅之后的消息，频道（channel）中此前的消息将无从获得。此外，消息发布者（即publish客户端）无需独占与服务器端的连接，您可以在发布消息的同时，使用同一个客户端连接进行其他操作（例如List操作等）。但是，消息...
设备模拟器
具体功能如下：功能项 说明 上行指令调试 设备上报消息到物联网平台，包含：自定义Topic的消息上报和消息订阅 属性上报 事件上报 下行指令调试 物联网平台下发指令到设备，包含：自定义Topic的消息下发 属性调试（含获取、设置）服务调用 ...
开放平台概览
开放事件（OpenEvent）DataWorks开放平台的开放事件功能为您提供消息订阅服务，通过订阅DataWorks事件状态，应用系统对接DataWorks，实时获取相关内容的状态变化，帮助您及时响应，满足您的个性化决策需求。关于开放事件功能，具体请参见 ...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的SDK使用.NET语言进行消息订阅。说明 请确保同一个Group ID下所有Consumer实例的订阅关系保持一致。更多信息，请参见 订阅关系一致。云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同...
参数说明
消息订阅参数 参数名 参数说明 consumerGroup Consumer组名，多个Consumer如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一组，即您在阿里云RocketMQ控制台上创建的Group ID，详情请参见 基本概念。...
API概览
消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。UpdateConsumerGroup 更新消费者分组 更新消费者分组的基础信息和消费重试策略。DeleteConsumerGroup 删除消费者分组 删除指定的消费者分组。ListConsumerGroups 查询消费者...
消息队列 RocketMQ 客户端流控设计
限流方式有两种：针对消息订阅者的并发流控 针对消息订阅者的消费延时流控 针对消息订阅者的消费延时流控的基本原理是，每次消费时在客户端增加一个延时来控制消费速度，此时理论上消费并发最快速度为：MaxRate=1/ConsumInterval*...
基础版/铂金版实例计费
则该场景下，消息订阅关系数为10×2=20个。计费单价 实例类型 订阅关系数上限（个）价格（元/月）基础版实例 1千 50 1万 500 5万 2500 10万 5000 20万 10000 50万 25000 100万 50000 铂金版实例 10万 7000 50万 33000 100万 67000 200万 ...
设备数据订阅
完成身份认证和对接进行设备的消息订阅。Demo示例 a.配置参数/System.getenv("iot.hosting.appKey")方法可以从环境变量中获取appkey和appsecret String appKey=System.getenv("iot.hosting.appKey");String appSecret=System.getenv("iot....
环境准备（v2.x.x）
本文介绍使用C++ SDK v2.x.x及以上版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。...cd bin 更多信息 收发普通消息 收发顺序消息 收发定时消息 收发事务消息 订阅消息
操作链路概述
具体操作步骤如下：创建资源 创建工作空间 创建 Topic 创建 Group ID 获取 AK（AccessKey ID）和 SK（AccessKey Secret）获取接入配置 发送消息 订阅消息 创建资源 注意事项 在使用 SOFAStack 消息队列时，请注意以下网络访问限制：Topic ...
什么是云消息队列 MQTT 版
消费者：也称为消息订阅者，负责从Topic接收并消费消息。消息：生产者向Topic发送并最终传送给消费者的数据。规则：云消息队列 MQTT 版 与其他阿里云产品实现数据互通的资源。消息收发模型 云消息队列 MQTT 版 主要包含以下两种消息收发...
什么是服务端订阅
说明 如果您有多个服务器消费同一个产品的订阅消息，消息会随机转发至某个服务器。服务端订阅与规则引擎数据流转的使用场景和能力对比，请参见 数据流转方案对比。使用AMQP服务端订阅消息 AMQP（Advanced Message Queuing Protocol）即高级...
概述
消费者：也称为消息订阅者，负责从 Topic 接收并消费消息。消息：生产者向 Topic 发送并最终传送给消费者的数据和（可选）属性的组合。消息属性：生产者可以为消息定义的属性，包含 Message Key 和 Tag。Group：一类生产者或消费者，这类...
OpenEvent概述
应用优势 DataWorks的OpenEvent具备以下优势：节省运维成本：通过开启DataWorks开放平台的消息订阅功能，您可以很方便的订阅事件消息。提升开发效能：通过在DataWorks界面上创建相关配置，您无需再进行发送消息相关配置，仅需做好相关SDK...
认证与连接
注册自定义消息回调的接口 aiot_device_register_topic_filter，该接口有两个功能：（可选）向云平台发起消息订阅。向SDK注册接收到消息的回调。订阅消息，设置该消息回调函数*/char sub_topic[128]={ 0 };snprintf(sub_topic,sizeof(sub_...
消息收发功能
支持消息发送、消息订阅以及接收终端SDK上下线事件消息。终端和终端消息收发 该场景下消息的发送端和消费端都分布在移动终端环境，通过MQTT协议连接到 云消息队列 MQTT 版。发送端和消费端的终端设备均通过开源的终端SDK接入 云消息队列 ...
示例代码
本文为您介绍RocketMQ 5.x...示例代码函数说明 消息类型 发送消息示例代码 订阅消息示例代码（SimpleConsumer）普通消息 ProducerNormalMessageExample.cs SimpleConsumerExample.cs 顺序消息 ProducerFifoMessageExample.cs 定时/延时消息 ...
示例代码
消息类型 发送消息示例代码 订阅消息示例代码（SimpleConsumer）普通消息 同步发送：ExampleProducerNormalMessage.go 异步发送：AsyncExampleProducerNormalMessage.go ExampleSimpleConsumer.go 顺序消息 ExampleProducerWithFifoMessage...
- 产品推荐
- 这些文档可能帮助您