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