云存储网关利用MQTT服务实现统一管控
业务方设计用于消息收发的Topic时，需要遵循以下原则：上行消息（CSG实例发给管控服务的消息）和下行消息（管控服务发给CSG实例的消息）使用不同的父级Topic。不同优先级或者消息量级差别比较大的消息使用不同的父级Topic。对于上文描述的...
RocketMQ全链路追踪解决方案
取值如下：normal：普通消息 fifo：顺序消息 delay：定时/延时消息 transaction：事务消息 messaging.rocketmq.message.tag string 消息的过滤标签。消费者可通过Tag对消息进行过滤，仅接收指定标签的消息。messaging.rocketmq.message....
直播互动解决方案
您可以将一个直播间与一个MQTT的Topic对应，例如客户端发送消息使用的Topic为roomSend/message，订阅消息使用的Topic为room/message/123456，其中：roomSend为直播间所有客户端发送消息使用的父级Topic，需要在 云消息队列 MQTT 版 控制台...
新零售电子价签解决方案（MQTT）
对于电子价签系统中，改价任务的交互消息建议使用 云消息队列 MQTT 版 提供的P2P消息，P2P消息不需要订阅，发送方直接指定对端接收即可，详细信息，请参见 P2P消息收发模式（MQTT）。收发消息参数设计 由于电子价签场景改价任务一般要求...
环境准备
使用前，请注意以下几点：使用 云消息队列 RocketMQ 版 服务的应用程序需要部署在阿里云ECS上。代码里涉及到的Topic和Group ID，需要到控制台上创建。Message Tag可以完全由应用自定义。创建步骤，请参见快速入门中的 创建资源。Windows....
一机一密概述
当设备与 云消息队列 MQTT 版 建立连接时，需要将设备访问凭证中的信息按照约定的形式设置到Username和Password中，向 云消息队列 MQTT 版 发起认证请求，云消息队列 MQTT 版 认证通过后激活设备，设备与 云消息队列 MQTT 版 间才可传输...
快速使用MQTT.fx模拟SDK收发消息
本文以Windows系统为例，介绍如何使用MQTT.fx模拟SDK接入 云消息队列 MQTT 版 并进行消息收发。前提条件 下载并安装 MQTT.fx。背景信息 云消息队列 MQTT 版 最简单的使用场景即MQTT客户端消息的自发自收。如下图所示，您可以使用MQTT.fx...
广播拉取消息模型
消息服务MNS 支持一对多拉取消息消费模型，以满足一对多订阅、主动拉取的场景。本文介绍如何高效利用该模型实现多消费者并行拉取与处理消息。说明 本文以Java SDK为例介绍广播拉取消息流程，其他语言SDK请参见 新版SDK参考（推荐）。前提...
消息存储和清理机制
消息过期清理机制 开源的Apache RocketMQ中，消息保存时长并不能完整控制消息的实际保存时间，因为消息存储仍然使用本地磁盘，本地磁盘空间不足时，为保证服务稳定性消息仍然会被强制清理，导致消息的实际保存时长小于设置的保存时长。...
是否支持压缩消息？
如需使用压缩消息，您需要在 云消息队列 Kafka 版 的客户端进行设置。在 云消息队列 Kafka 版 客户端进行消息压缩的说明如下：压缩格式：支持Snappy、LZ4、GZIP等压缩格式。其中，GZIP对CPU的消耗较高，因此不建议您选择GZIP，建议您选择...
概述
云消息队列 Kafka 版 快速入门操作流程 操作步骤 具体操作步骤如下：步骤一：获取访问授权 步骤二：购买和部署实例 VPC接入 公网和VPC接入 步骤三：创建资源 步骤四：使用SDK收发消息 默认接入点收发消息 SSL接入点PLAIN机制收发消息 视频...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
查看订阅关系
在 SOFAStack 消息队列控制台，您可实时查看 Group ID 和 Topic 之间的订阅关系。本文介绍如何在消息队列控制台查看订阅关系。从 Topic 视角，查看即个 Topic 被哪些 Group ID 订阅了。从 Group 视角，查看某个 Group ID 订阅了哪些 Topic...
环境准备（v1.x.x）
本文为您介绍使用v1.x.x版本的C++ SDK接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。使用前，请注意以下几点：本文仅针对C++ SDK v1.x.x版本进行说明，若需使用v2.0.0版本的SDK，...
版本说明
本文介绍Java SDK的版本信息，包含使用限制、下载链接、发布时间、更新点等，以便您按需获取适用的Java SDK收发消息。使用限制 JDK 1.8适用于所有Java ons-client版本，JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为避免升级...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
Serverless版实例计费
云消息队列 MQTT 版 的Serverless实例购买成功后，默认为您预留固定规格的资源，若实际使用量超过预留规格，则按照实际使用量弹性计费，可以帮助您提高资源利用率并降低业务成本。重要 Serverless版实例购买后，无论是否使用实例都会开始按...
消息类型
普通消息 定时和延时消息 顺序消息 事务消息 普通消息 普通消息是指消息队列中无特性的消息，区别于有特性的定时/延时消息、顺序消息和事务消息。TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息...
开通服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源，并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
全球消息路由
当 目标类型 为 Exchange 时，该参数生效，取值如下：不设置：使用消息原有的Routing key发送到目标Exchange。设置：使用当前设置的Routing key发送到目标Exchange。test 在 创建启动 页面，确认消息路由的配置信息，单击 创建并启动。在 ...
操作链路概述
创建工作空间 要使用消息队列，您需要确保 SOFAStack 控制台已创建至少一个工作空间。如 SOFAStack 未创建工作空间或您需要创建一个新的工作空间，可参见 添加工作空间。创建好工作空间后，将为您自动创建一个消息队列实例。创建 Topic ...
计费常见问题
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信，云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
消息轨迹
使用限制 使用 云消息队列 RabbitMQ 版 消息轨迹功能时，限制如下：仅当实例支持消息轨迹时，才可以查询该实例中消息收发的轨迹。说明 实例是否支持消息轨迹和可以查询的消息轨迹时间范围，由您在创建实例时选择配置。如果实例未配置消息...
Demo工程
本文介绍 云消息队列 MQTT 版 的Demo工程，包含各种应用场景的使用指导，请参见程序源码的文档注释进行理解。获取多语言Demo 示例代码全集请参见 mqtt-demo。下载完成后解压即可看到本地新增了 mqtt-demo-main 文件夹。其中一级文件夹是...
计费概述
消息收发费用 消息收发为 云消息队列 RocketMQ 版 的基础功能，您只要开通 云消息队列 RocketMQ 版 服务，则默认使用消息收发功能，标准版实例会计算相应费用。具体计费详情，请参见 消息收发定价详情。公网费用 云消息队列 RocketMQ 版 ...
接入点设置说明
背景信息 如需使用 SOFAStack 消息队列来收发消息，则需在使用 TCP 协议下的 SDK 时，将相应参数配置为您实际使用的资源信息。需特别注意的是，以下参数所对应的资源应处于同一地域：GROUP_ID：您在消息队列控制台上创建的 Group ID。TOPIC...
视频专区
本文为您介绍 云消息队列 RocketMQ 版 的操作视频。云消息队列 RocketMQ 版5.x系列 快速使用 云消息队列 RocketMQ 版5.x系列的Java SDK收发消息 云消息队列 RocketMQ 版4.x系列 快速使用云消息队列 RocketMQ 版4.x系列的Java SDK收发消息
死信消息
典型错误使用死信消息场景 处理死信消息时，如果将死信消息多层流转，转储回原Topic，会引起死信消息再次被循环重试，可能会引起雪崩效应。死信策略 什么时候消息会转为死信状态 消息重试达到最大重试次数后还没有被成功消费，消息将不再被...
发送消息（多线程）
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高...
Spring集成
云消息队列 RabbitMQ 版 支持Spring框架的SDK，本文介绍如何集成Spring框架的SDK客户端收发消息。前提条件 您已在 云消息队列 RabbitMQ 版控制台 创建实例、Vhost、Exchange、Queue等相关资源，具体操作，请参见 步骤二：创建资源。安装...
开源版和商业版介绍
SOFABoot 目前对外开放的有...支持 中间件（消息）MsgBroker 不支持 支持 中间件（数据）DTX 支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持同城双活。支持共享版中间件。
使用ACL功能进行访问控制
当需要对不同的用户或用户组授予不同级别的访问权限时，您可以使用 云消息队列 Kafka 版 专业版 或V3系列Serverless 实例的访问控制列表（ACL）功能，为SASL用户赋予对Topic、Group等资源的操作权限，实现细粒度的权限管理。背景信息 企业A...
消息收发常见问题
本文介绍使用 云消息队列 MQTT 版 进行消息收发时的常见问题。为什么会出现一条消息同一时间重试多次？为什么消息会一直重试？消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时，为什么子级Topic后会多了一个“/”?消息发送...
创建资源
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...
创建资源
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...
使用限制
云消息队列 RocketMQ 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免程序出现异常。云消息队列 RocketMQ 版5.x系列 5.x系列使用限制 云消息队列 RocketMQ 版4.x系列 4.x系列使用限制
MQTT快速入门
消息存储实例目前只支持 云消息队列 RocketMQ 版 类型的后端存储实例。目前您在同一个地域（Region）可以创建有限数量的 云消息队列 MQTT 版 实例，且一个 云消息队列 MQTT 版 实例仅可绑定一个相应的 云消息队列 RocketMQ 版 实例。同一...
Demo工程
本文介绍 云消息队列 MQTT 版 的Demo工程，包含各种应用场景的使用指导，请参见程序源码的文档注释进行理解。获取多语言Demo 示例代码全集请参见 mqtt-demo。下载完成后解压即可看到本地新增了 mqtt-demo-main 文件夹。其中一级文件夹是...
重置消费位点
在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID 操作列的 重置消费位点，然后在 重置消费位点 对话框配置以下信息：Topic：选择重置消费位点针对的 Topic。重置类型：清除所有堆积消息，从最新位点开始消费：若选择...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
- 产品推荐
- 这些文档可能帮助您