什么是消息服务MNS
更多信息，请参见：推送到队列 广播拉取消息模型 一对多广播消息 发布到主题中的一条消息可以被多个订阅者订阅。消息服务MNS 会按照多个订阅指定的队列去推送消息。您仅需发布一次，就可以将消息推送到多个接收端，保证了消息发布的原子性...
基于RocketMQ指标的容器水平伸缩
RocketMQ作为一种高性能、高可靠、高扩展性的分布式消息中间件，已经被广泛应用于企业级应用中。但在使用RocketMQ时，消息堆积是常见的问题，特别是在高负载情况下，消息堆积很容易导致系统负载过高，甚至服务崩溃。为了解决这个问题，您...
订阅者最佳实践
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践...消息广播 云消息队列 Kafka 版 没有消息广播的语义，可以通过创建不同的 Group 来模拟实现。订阅关系 同一个 Group 内，各个消费实例订阅的Topic最好保持一致，避免给排查问题带来干扰。
广播拉取消息模型
主题模型提供一对多的广播消息消费模型，采用服务端主动推送（Push）模式。推送模式的好处是即时性能较好，但需要暴露客户端地址来接收服务端的消息推送。有些情况下有的信息，例如企业内网，无法暴露推送地址，希望改用拉取（Pull）的方式...
PubBroadcast
调用该接口向指定产品下在线设备发布广播消息。在线设备可指定为所有在线设备或订阅了指定Topic的在线设备。使用说明 您可通过设置 请求参数 中 TopicFullName 值决定广播消息的对象：指定产品下所有在线设备或订阅了指定Topic的在线设备。...
运行日志
[1624933980.266][LK-0309]sub:/broadcast/a18wP*/test suback,res:0x0000,packet id:1,max qos:1 发送广播消息日志：向指定Topic发送广播：调用物联网平台的 PubBroadcast，向指定Topic，例如/broadcast/a18wP*/test，发送消息内容为 ...
Pub
调用该接口通过自定义Topic向设备发布消息，支持向指定产品下订阅了指定自定义Topic的在线设备发送广播消息。使用说明 发送广播消息时：相关Topic是在设备开发时编码定义的，无需控制台创建。一个Topic默认最多可被1,000个设备订阅。若后续...
直播互动解决方案
云消息队列 MQTT 版 将该消息广播至所有客户端，涉及成员老师、学生A以及学生B。场景四：系统通知消息 此场景使用 云消息队列 MQTT 版 的消息收发功能，系统的更新通知都会发送到直播间的所有成员。此场景下，所有的客户端都需订阅room/...
直播互动消息常见问题
本文主要介绍使用新版直播互动消息中遇到的常见问题。直播互动消息创建群组后，如果没有人加入群组是否会失效？不会失效。创建后会将群组信息存储到后端存储服务，直到用户调用删除该群组。直播互动消息支持创建多少群组数？每个群组最多...
同步 OceanBase 数据库的数据至 RocketMQ
背景信息 消息队列 RocketMQ 是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。数据传输的数据同步功能可以帮助您实现 OceanBase 数据库的物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。...
阿里云电子政务云产品全家福
阿里云电子政务云平台提供弹性计算类、网络、数据库、存储、大数据、中间件、IoT等品类丰富的产品及高标准的安全合规服务，用以支撑多种政务类业务场景，例如：城市大脑，合规应用平台等。截至文档发布时间，阿里云电子政务云共计上线95款...
附录一：运维服务产品清单
性能测试 pts 云计算基础 互联网中间件 消息服务 mns 云计算基础 互联网中间件 全局事务服务 txc 云计算基础 互联网中间件 应用配置管理 acms 云计算基础 互联网中间件 消息队列Kafka alikafka 云计算基础 互联网中间件 应用高可用服务 ...
Link SDK运行相关问题
如果两个设备之间需要通信，有两种方式：基于消息转发的M2M设备间通信 基于Topic消息路由的M2M设备间通信 广播消息Topic如何填写？广播Topic格式：/broadcast/productKey/xxxx。广播是否只能针对在线的设备？广播Topic 默认是QoS=0，且不...
使用自定义Topic通信
Pub 通过自定义Topic向指定设备发布消息，支持向指定产品下订阅了指定自定义Topic的在线设备发送广播消息。BatchPub 通过自定义Topic向指定产品下的多个设备批量发送消息。PubBroadcast 向指定产品所有设备，或向订阅了指定Topic的所有设备...
Exchange
使用场景 Fanout Exchange适用于广播消息的场景。例如，分发系统使用Fanout Exchange来广播各种状态和配置更新。路由示例 Fanout Exchange忽略Routing Key和Binding Key的匹配规则将消息路由到所有绑定的Queue的示例如下：Message Routing ...
通用软件漏洞收集及奖励计划第四期
Admin 阿里巴巴 B Nacos 阿里巴巴 B Apache-ActiveMQ Apache B RabbitMQ VMware B Apache-Kafka Apache B Apache-RocketMQ Apache B Elasticsearch Elastic B Kibana Elastic B Logstash Elastic B Apache-Hadoop Apache B OpenStack 开源...
变量
但是存在以下限制：单次请求至多投递100条数据 单条投递数据大小需在10KB以下 每秒最多请求200次 Nats 消息推送方式 针对数据量大，数据更新频率高的应用场景，工业组态还提供了Nats 消息中间件方式进行实时消息同步。Nats是一个开源的，云...
流程控制
流程控制内的逻辑节点包括 条件判断、定时器、序列执行、多路判断 和 websocket。本文介绍在蓝图编辑器中，配置流程控制类节点的方法。条件判断 条件判断 节点属于If-Else判断条件节点。当满足设定条件时，抛出 满足 事件，不满足设定条件...
消息通信计费
PubBroadcast 发布广播消息。RRpc RRPC调用的消息。DeleteDevice 删除子设备时，触发下发消息到/sys/${productKey}/${deviceName}/thing/delete。DisableThing 禁用子设备时，触发下发消息到/sys/${productKey}/${deviceName}/thing/...
SDK 版本说明
支持全站广播消息。支持消费异步确认。升级 ANTVIP 至 1.5.4，支持跨域连接。支持注解 noop schema url。修复 修复消费端列表变动（发布、重启、扩缩容）后一段时间限流值偏小问题。修复在特定流量和限流情况下限流值偏小问题。修复 Tracer...
数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
使用限制
64 KB 服务端SDK每分钟只可发一条全量广播消息。1条/分钟 设备影子 限制项 描述 限制 JSON层级 设备影子JSON文档的最大层级深度。5 文件大小 设备影子JSON文档的最大限制。16 KB 属性数量 设备影子JSON文档的属性数量限制。128 每秒请求数 ...
API列表
是 Pub 通过自定义Topic向指定设备发布消息，支持向指定产品下订阅了指定自定义Topic的在线设备发送广播消息。是。BatchPub 通过自定义Topic向指定产品下的多个设备批量发送消息。是。PubBroadcast 向指定产品所有设备，或向订阅了指定...
什么是Topic
调用云端API PubBroadcast 向订阅了该Topic的所有设备发送广播消息，实现批量控制设备。物模型通信Topic 属性上报 各物模型功能的Topic。说明 在物联网平台，不可以调用 Pub 接口向物模型通信Topic发送消息。在物联网平台的云端，通过物...
物联网平台通信方式概述
批量控制：调用 PubBroadcast 接口向产品下的全量在线设备发布广播消息，实现批量控制设备。批量控制设备的详细说明，请参见 广播通信。使用物模型远程控制设备。您可以在云端通过发送物模型数据的特有接口，发布设置属性值和调用服务指令...
操作审计日志说明
sync 消息 数据同步 MSS CreateMssSingleSyncData 创建单推 sync 消息 消息推送 MPS PushMpsBroadcast 推送广播消息 消息推送 MPS PushMpsMultiple 群发消息 消息推送 MPS PushMpsTemplate 发送模板消息 消息推送 MPS PushMpsSimple 发送...
通信消息相关问题
PubBroadcast 向指定产品下在线设备发布广播消息。在线设备可指定为所有在线设备或订阅了指定Topic的在线设备。RRpc 向指定设备发送请求消息，并同步返回响应。SetDeviceProperty 设置指定设备的物模型属性值。SetDevicesProperty 设置指定...
Java SDK版本说明
增加一对多广播消息功能。新增JAVA SDK性能测试示例代码。使用帮助 下载sample并解压 aliyun-sdk-mns-samples-1.1.5.zip。用Eclipse导入Maven工程，选中 aliyun-sdk-mns-samples 文件夹。在用户目录中创建.aliyun-mns.properties 文件，并...
公共错误码
诊断 400 BIZ_BROADCASTING_PULL_UNSUPPORT%s.Please check and try again later.PullConsumer或者广播消息订阅不支持消费进度查询。诊断 400 BIZ_BROKER_NOT_FOUND%s.Please check and try again later.服务器节点信息不存在。诊断 400 ...
集群消费和广播消费
本文介绍 SOFAStack 消息队列的集群消费和广播消费的基本概念、适用场景以及注意事项。消息队列是基于发布/订阅模型的消息系统。消费者，即消息的订阅方订阅关注的 Topic，以获取并消费消息。由于消费者应用一般是分布式系统，以集群方式...
消息 Mesh
消息 Mesh 经过蚂蚁消息中间件团队大半年的打磨和沉淀，已经迈出了坚实的一大步：在开源社区迟迟未在消息 Mesh 上取得实质性进展时，蚂蚁团队已经为蚂蚁内部主流消息中间件打通了数据平面。同时，依赖消息的精细化流量调度，预期可以发掘出...
配额与限制
Apache RocketMQ Streaming组件 云消息队列 RocketMQ 版 暂不支持提供托管的Apache RocketMQ Streaming组件服务。您可以基于阿里云环境自行部署，或使用 云消息队列 RocketMQ 版 提供的消息集成功能实现轻量级的数据集成及计算。Apache ...
开源版和商业版介绍
SOFABoot 目前对外开放的有...支持 中间件（消息）MsgBroker 不支持 支持 中间件（数据）DTX 支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持同城双活。支持共享版中间件。
查看订阅关系
在 SOFAStack 消息队列控制台，您可实时查看 Group ID 和 Topic 之间的订阅关系。本文介绍如何在消息队列控制台查看订阅关系。从 Topic 视角，查看即个 Topic 被哪些 Group ID 订阅了。从 Group 视角，查看某个 Group ID 订阅了哪些 Topic...
Demo 工程
Demo 工程包含普通消息、顺序消息、事务消息和定时、延时消息的配置以及测试代码。前提条件 安装 IDE。您可以使用 IntelliJ IDEA 或者 Eclipse，本文以 IntelliJ IDEA 为例。在 https://www.jetbrains.com/idea/ 下载 IntelliJ IDEA ...
操作链路概述
本文将引导您快速体验 SOFAStack 消息队列，从创建资源、配置接入点到使用 SDK 收发消息。具体操作步骤如下：创建资源 创建工作空间 创建 Topic 创建 Group ID 获取 AK（AccessKey ID）和 SK（AccessKey Secret）获取接入配置 发送消息 ...
消息查询
在左侧导航栏，选择 中间件>消息队列>消息查询。在 消息查询 页面，您可单击以下任一页签，然后按页面提示输入相应信息。按 Message ID 查询：Message ID 是由服务端生成的 32 位字符串，用于标识一条消息。按 Message ID 查询，即根据 ...
消息路由
在左侧导航栏，选择 中间件>消息队列>消息路由。单击 创建路由任务，然后在 创建路由任务 对话框配置任务信息：源 Topic：输入需要同步的消息所属 Topic 名称。目标单元：选择消息将被同步到的 Topic 所属单元。目标 Topic：输入消息将被...
死信队列
当一条消息初次消费失败，消息队列会自动进行消息重试。达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息。此时，消息队列不会立刻将消息丢弃，而是将其发送到该消费者对应的特殊队列中。在消息队列中，...
查看消费者状态
如果消息消费异常，您可以在 SOFAStack 消息队列控制台查看消费者状态，进行问题排查。本文介绍如何查看消费者状态。查看 Group ID 消费者状态 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID ...
- 产品推荐
- 这些文档可能帮助您