直播互动解决方案
您可以将一个直播间与一个MQTT的Topic对应，例如客户端发送消息使用的Topic为roomSend/message，订阅消息使用的Topic为room/message/123456，其中：roomSend为直播间所有客户端发送消息使用的父级Topic，需要在 云消息队列 MQTT 版 控制台...
Quick BI使用订阅消息时，只有部分人员能收到工作通知
问题描述 Quick BI使用订阅消息时，只有部分人员能收到工作通知。问题原因 无法收到工作通知的几个用户没有在钉钉里点击过微应用。解决方案 无法收到工作通知的几个用户需要在钉钉里点击微应用。访问过微应用以后就可以收到工作通知。适用...
什么是服务端订阅
服务端可以直接订阅产品下多种类型的消息，例如设备上报...使用消息服务订阅设备消息的具体配置方法，请参见 使用消息服务（MNS）订阅设备消息。说明 消息服务会对创建的队列和接收的消息收取费用。消息服务计费和使用，请参见 消息服务文档。
消息轨迹
计费说明 包年包月和按量付费实例可免费使用消息轨迹功能且默认支持消息轨迹。Serverless实例可选择手动开启或关闭消息轨迹功能，具体操作，请参见 开启/关闭Serverless实例的消息轨迹功能。若开启消息轨迹，则Serverless实例按照实际产生...
普通消息
TCP SDK收发普通消息的示例代码 Java 发送普通消息（三种方式）发送消息（多线程）订阅消息 C或C++ 收发普通消息 订阅消息.NET 收发普通消息 订阅消息 HTTP SDK收发普通消息的示例代码 云消息队列 RocketMQ 版 支持RESTful风格的HTTP协议...
查看消费者状态
如果消息消费出现异常，您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
查看应用性能详情
消息订阅 页签显示了指标趋势和数据源明细，包括所选应用调用的消息订阅的消息主题（Topic）、请求次数等信息。参数说明可参考下表。参数名 说明 单位 Topic 所选应用调用的消息订阅的消息主题（Topic）。请求次数 所选应用调用消息订阅的...
数据订阅操作指导
4.消费订阅数据 新版 根据消费客户端和数据库的类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用SDK示例代码消费PolarDB-X 1.0订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据 5.结束数据订阅 ...
中间件监控指标
消息监控 指标名称 说明 单位 数据源 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 ...
MQ监控
ARMS应用监控的MQ监控可展示消息队列Apache ...在 订阅端统计 页签展示消息订阅的统计数据，包括消息请求数、响应时间和错误数。在 调用链查询 页签提供关于消息发布和订阅的接口快照，您可以通过TraceId链接查看完整调用链以及诊断问题原因。
MQ监控
MQ监控可展示消息队列RocketMQ版的Topic发布和...在 订阅端统计 页签展示消息订阅的统计数据，包括消息请求数、响应时间和错误数。在 调用链查询 页签提供关于消息发布和订阅的调用链，您可以通过TraceId链接查看完整调用链以及诊断问题原因。
概述
消费者：也称为消息订阅者，负责从 Topic 接收并消费消息。消息：生产者向 Topic 发送并最终传送给消费者的数据和（可选）属性的组合。消息属性：生产者可以为消息定义的属性，包含 Message Key 和 Tag。Group：一类生产者或消费者，这类...
最佳实践：订阅实例状态变更消息
开启并配置消息订阅（OpenEvent）开启并配置消息订阅的详细步骤请参见 开启消息订阅，以下为本实践中的核心配置流程与注意事项。在 EvenBridge控制台，跳过事件源等配置，快速创建一个自定义总线。在 EvenBridge控制台 对应的事件总线中，...
AMQP服务端订阅多个消费组如何处理？
在物联网平台控制台配置AMQP服务端订阅时，一个AMQP订阅可关联多个消费组。具体操作，请参见 配置AMQP服务端订阅。相关文档 管理消费组：了解如何创建、使用消费组。服务端订阅使用限制：了解AMQP服务端订阅消费组的使用限制。
OpenEvent概述
应用优势 DataWorks的OpenEvent具备以下优势：节省运维成本：通过开启DataWorks开放平台的消息订阅功能，您可以很方便的订阅事件消息。提升开发效能：通过在DataWorks界面上创建相关配置，您无需再进行发送消息相关配置，仅需做好相关SDK...
产品架构
本文介绍 云消息队列 RocketMQ 版 的系统部署架构，方便您更好地理解...Consumer既可以从Master Broker订阅消息，也可以从Slave Broker订阅消息，订阅规则由Broker配置决定。更多信息 云消息队列 RocketMQ 版 中的概念详情，请参见 基本概念。
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个...
消息过滤
使用SDK订阅主题消息时，可以通过设置消息的标签值来进行消息过滤。完整的示例代码，请参见 步骤五：发布消息。向主题发送消息时设置消息的标签值的示例代码如下：TopicMessage message=new Base64TopicMessage();这里的标签值要和订阅规则...
产品架构
Consumer 既可以从 Master Broker 订阅消息，也可以从 Slave Broker 订阅消息，订阅规则由 Broker 配置决定。SOFAMQ 还包含如下两个未在图中展示的组件，主要功能如下：Console：SOFAMQ 的图形化管理控制台。Router：LDC 场景下，根据配置...
概述
使用限制 使用消息集成功能时的限制项如下表所示。限制项 说明 任务数 单地域总任务数（包括消息流入和消息流出）不超过20个，如果您需要提升创建消息集成的任务数，请 提交工单 申请。任务名称 必须以字母或数字开头，剩余部分可以包含...
概述
使用限制 使用消息集成功能时的限制项如下表所示。限制项 说明 任务数 单地域总任务数（包括消息流入和消息流出）不超过20个，如果您需要提升创建消息集成的任务数，请 提交工单 申请。任务名称 必须以字母或数字开头，剩余部分可以包含...
概述
使用限制 使用消息集成功能时的限制项如下表所示。限制项 说明 任务数 单地域总任务数（包括消息流入和消息流出）不超过20个，如果您需要提升创建消息集成的任务数，请 提交工单 申请。任务名称 必须以字母或数字开头，剩余部分可以包含...
消费重试
以下场景建议使用消息重试 业务处理失败，且失败原因跟当前的消息内容相关，比如该消息对应的事务状态还未获取到，预期一段时间后可执行成功。消费失败的原因不会导致连续性，即当前消息消费失败是一个小概率事件，不是常态化的失败，后面...
订阅关系一致
订阅关系一致指的是同一个消费者 Group ID 下所有消费者实例所订阅的 Topic、Tag 以及对消息的处理逻辑必须完全一致。一旦订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。本文提供订阅关系不一致的示例代码，帮助您顺畅地订阅...
为什么在控制台看不到Group的订阅关系？
问题现象 您已启动某个Group的消费线程，但在 云消息队列 Kafka 版 控制台 的 Topic 详情 页面的 订阅关系 页签，查不到Topic被Group订阅的信息，或者在 Group 详情 页面的 消费状态 页签，查不到该Group订阅的Topic信息。可能原因 客户端...
报警管理
您可通过 SOFAStack 消息队列的报警管理功能来监控某 Group ID 订阅的某 Topic 的消息消费状态并接收报警短信，帮助您实时掌握消息堆积情况，以便及时处理消费异常。前提条件 确保您需监控的 Group ID 已订阅相应 Topic。订阅消息的详细...
消息发布与订阅
因此消息订阅者需要使用单独的服务器连接，或者需要在单独的线程中使用（参见如下示例）。代码示例 消息发布者（即publish client）package message.kvstore.aliyun.com;import redis.clients.jedis.Jedis;public class KVStorePubClient {...
Webhook订阅API变更消息
本文介绍如何获取钉钉机器人Webhook地址，便于开发者通过Webhook地址接受订阅消息。前提条件 已创建用于接收订阅消息的钉钉群。操作步骤 请按照如下步骤在钉钉群中添加自定义钉钉机器人并获取Webhook地址。在PC版钉钉上打开您想要添加报警...
LTS（原BDS）服务介绍
使用指南 日志生命周期管理说明 开启日志订阅后，如果不消费数据，默认日志会保留48小时，超时后订阅关系自动取消，保留的数据自动删除 什么场景会导致“不消费数据”：没有终止任务的前提下直接释放LTS集群；同步任务暂停；使用日志订阅的...
订阅
再次使用订阅功能时，系统默认展示已绑定的 Email 地址。若修改，所有已订阅通知的 Email 地址将同步修改。钉钉通知：配置钉钉机器人信息。支持配置多个钉钉机器人。机器人名称：自定义的名称，便于用户识别。webhook 地址：系统需要此信息...
开通消息服务MNS并授权
使用 消息服务MNS 前，您需在产品页开通该服务。如果您的账号为RAM用户，必须让阿里云账号为RAM用户进行授权，才能通过控制台或API访问相应的 消息服务MNS 资源，并使用资源通过SDK收发消息。本文介绍如何开通 消息服务MNS 和授权RAM用户。...
回调及监听
bytesReceivedPerSecond Number 每秒接收到的字节数（仅订阅使用）。onMediaStreamUpdate：订阅流返回回调。aliWebrtc.on("onMediaStreamUpdate",(data)=>{ console.log(data)})返回值 类型 描述 userId String 订阅用户的ID。mediaStream ...
CREATE SUBSCRIPTION
默认行为是使用订阅名称作为插槽的名称。当 slot_name 设置为 NONE 时，将不会有复制槽与订阅关联。这在需要稍后手动设置复制槽的情况下会使用。这样的订阅必须同时 enabled 并且 create_slot 设置为 false。synchronous_commit(enum)该...
快速入门
本文将向您描述如何使用 SOFABoot 框架创建一个Web 工程，实现本地运行或部署到云端运行，以及如何引入中间件服务。主要步骤如下：创建 Web 工程 将 Web 工程导入 IDE 实现本地编译和运行 实现云端运行 引入中间件服务 说明 Core 工程 与 ...
应用部署时的默认启动命令参数
部署应用时，EDAS会默认添加启动命令参数，用于优化应用性能，保证应用可以使用中间件和应用管理相关功能。配置项 配置值 解析 类别 alicloud.deployment.mode EDAS_MANAGED 添加该配置后，会自动将中间件组件的服务端地址替换为EDAS提供的...
查看客户端连接日志
步骤三（可选）：订阅客户端连接日志 如果您需要重点关注某些客户端的连接状态，您可以使用订阅功能，订阅后，系统会定时向您发送这些客户端的连接日志。在左侧导航栏，选择 智能接入网关App>连接日志。在 连接日志 页面的 审计列表 页签，...
数据转发到消息服务（MNS）
当需要对设备数据进行复杂或精细化处理，且单个产品下所有设备或指定设备的消息量小于1,000 QPS时，可以使用云产品流转功能将物联网平台数据转发到消息服务（MNS）中，服务端再从消息服务主题中订阅消息，实现设备端与服务端之间高性能的...
服务端订阅
服务端可以直接订阅产品下所有类型的消息，配置服务端订阅后，物联网平台会将产品下所有设备的已订阅类型的消息转发至您的服务端。重要 同一组数据请勿同时开通云产品流转和服务端订阅两种订阅模式，避免消息干扰。配置服务端订阅 在左侧...
数据转发到消息服务（MNS）
当需要对设备数据进行复杂或精细化处理，且单个产品下所有设备或指定设备的消息量小于1,000 QPS时，可以使用云产品流转功能将物联网平台数据转发到消息服务（MNS）中，服务端再从消息服务主题中订阅消息，实现设备端与服务端之间高性能的...
消息通知功能说明
激活媒体处理消息通知功能。启用媒体处理消息通知功能步骤 激活媒体处理消息通知功能。媒体处理通过MNS实现转码作业及模板分析作业结束时的消息通知功能，因此激活此功能请先 开通MNS服务。创建MNS通知主题。登录 MNS控制台（选择与媒体...
- 产品推荐
- 这些文档可能帮助您