概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
产品优势
消息队列 基于 Apache RocketMQ 构建的金融级分布式消息中间件，为分布式应用系统提供异步解耦和削峰填谷的能力，支持多种消息类型与消费模式，并具备高可靠、高吞吐、低延时等金融级特性。任务调度 提供分布式任务调度框架，实现任务的...
提供服务
Server：通用服务端请求类型 消息中间件请求类型：kafka：Kafka消息队列的消费方 Consumer：通用消息消费方类型 定时任务请求类型：SchedulerX：通过SchedulerX执行定时任务 Spring_Scheduled：通过Spring_Scheduled执行定时任务 JDK_Timer...
依赖服务
Thrift RPC协议请求的客户端 sofa_client：Sofa RPC协议请求的客户端 client：通用客户端端请求类型 消息中间件请求类型：kafka_client：Kafka消息队列的生产方 producer：通用消息生产方类型 数据库请求类型：MySQL Oracle PostgreSQL ...
提供服务
Server：通用服务端请求类型 消息中间件请求类型：kafka：Kafka消息队列的消费方 Consumer：通用消息消费方类型 定时任务请求类型：SchedulerX：通过SchedulerX执行定时任务 Spring_Scheduled：通过Spring_Scheduled执行定时任务 JDK_Timer...
依赖服务
Thrift RPC协议请求的客户端 sofa_client：Sofa RPC协议请求的客户端 client：通用客户端端请求类型 消息中间件请求类型：kafka_client：Kafka消息队列的生产方 producer：通用消息生产方类型 数据库请求类型：MySQL Oracle PostgreSQL ...
依赖服务
jdbc Druid Hikari-CP MyBatis MyBatisPlus Jedis Lettuce Redisson MemCached MongoDB Java Driver Spring-MongoDB Elasticsearch Rest Client Elasticsearch Rest High Level Client Clickhouse JDBC Driver influxDB 消息中间件调用可...
集成概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
产品功能发布记录
2020.02.27 相关文档 Hyperledger Fabric【云服务集成】消息队列 如果您希望区块链上的各种事件能自动发布到消息中间件，您可以将区块链事件和MQ做映射配置。当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以...
云消息队列 RocketMQ 版
重要 鉴于 云消息队列 RocketMQ 版 4.x标准版当前最高可达每秒5千条消息的限速机制，使用该版作为实时计算Flink版对接的消息中间件，可能会导致Flink作业运行不稳定。因此，在选择消息中间件时，如果您正在或计划通过标准版RocketMQ与Flink...
使用Spring Cloud框架收发消息
spring.cloud.stream.bindings.MyOutput.destination=${kafka.output.topic.name} spring.cloud.stream.bindings.MyOutput.contentType=text/plain spring.cloud....MyInput.contentType=text/plain#Binder是Spring Cloud对消息中间件的封装模块...
基于RocketMQ指标的容器水平伸缩
RocketMQ作为一种高性能、高可靠、高扩展性的分布式消息中间件，已经被广泛应用于企业级应用中。但在使用RocketMQ时，消息堆积是常见的问题，特别是在高负载情况下，消息堆积很容易导致系统负载过高，甚至服务崩溃。为了解决这个问题，您...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
EMQX数据接入
背景信息 EMQX Cloud是EMQ公司推出的一款面向物联网领域的MQTT消息中间件产品。EMQX Cloud提供了一站式运维代管、独有隔离环境的MQTT消息服务。在万物互联的时代，EMQX Cloud可以帮助您快速构建面向物联网领域的行业应用，轻松实现物联网...
Kafka数据迁移MaxCompute最佳实践
背景信息 Kafka是一款分布式发布与订阅的消息中间件，具有高性能、高吞量的特点被广泛使用，每秒能处理上百万的消息。Kafka适用于流式数据处理，主要应用于用户行为跟踪、日志收集等场景。一个典型的Kafka集群包含若干个生产者（Producer）...
Kafka数据迁移MaxCompute最佳实践
背景信息 Kafka是一款分布式发布与订阅的消息中间件，具有高性能、高吞量的特点被广泛使用，每秒能处理上百万的消息。Kafka适用于流式数据处理，主要应用于用户行为跟踪、日志收集等场景。一个典型的Kafka集群包含若干个生产者（Producer）...
同步 OceanBase 数据库的数据至 RocketMQ
背景信息 消息队列 RocketMQ 是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。数据传输的数据同步功能可以帮助您实现 OceanBase 数据库的物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。...
附录一：运维服务产品清单
性能测试 pts 云计算基础 互联网中间件 消息服务 mns 云计算基础 互联网中间件 全局事务服务 txc 云计算基础 互联网中间件 应用配置管理 acms 云计算基础 互联网中间件 消息队列Kafka alikafka 云计算基础 互联网中间件 应用高可用服务 ...
消息收发功能
云消息队列 MQTT 版 支持多语言的消息收发。本文提供单独使用 云消息队列 MQTT 版 收发消息以及与 云消息队列 RocketMQ 版 结合使用时需使用的代码示例的链接。单独使用 云消息队列 MQTT 版 收发消息 语言 链接 Java ...
附录：SOFAStack 产品目录
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，为分布式应用提供异步解耦和削峰填谷的能力，支持多种消息类型，提供高可靠、高吞吐量、高可用、事务一致性的异步通讯能力。产品架构 产品优势 开箱即用 多种...
消息堆积和延迟问题
通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或在运维过程中及时调整业务逻辑，避免因消息堆积和延迟影响业务运行。背景信息 消息处理流程中，如果客户端的消费...
迁移概述
本文介绍将自建Kafka集群迁移到 云消息队列 Kafka 版 实例的优势、原理、方案架构、迁移工具和操作流程。迁移优势 将自建Kafka集群迁移到 云消息队列 Kafka 版 实例的优势，请参见 产品优势。迁移原理 对于消息队列来说，如果要实现集群...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
获取MQTT客户端在线状态
云消息队列 MQTT 版 提供同步查询和异步上下线事件通知两种方式，来获取MQTT客户端在线状态。本文介绍这两种方式的基本原理、应用场景、具体差异以及实现方式。基本原理 云消息队列 MQTT 版 服务端（下文简称为MQTT服务端）提供以下方式...
获取MQTT客户端在线状态
基本原理 云消息队列 MQTT 版 服务器（下文简称为MQTT服务器）使用异步上下线通知方式获取客户端在线状态。该方式使用消息通知，在客户端上线和下线事件触发时，MQTT服务器会向后端存储消息队列推送一条上下线消息。业务应用一般部署在阿里...
示例代码
向消息服务 MNS 队列投递消息[node.js14]向消息服务 MNS 队列投递消息[python3]向消息服务 MNS 队列投递消息[php7.2]向消息服务 MNS 队列投递消息[go1]向消息服务 MNS 队列投递消息[java11]向消息服务 MNS 主题投递消息[node.js14]向消息...
用户身份识别
功能原理 云消息队列 RocketMQ 版 的访问控制支持智能身份识别和ACL身份识别两种类型，云消息队列 RocketMQ 版 实例需要至少选择其中一种访问控制类型，用于控制客户端接入服务端时的认证方式。具体操作，请参见 设置访问控制类型。智能...
加密解密与签名验签的原理
加密SDK（Encryption SDK）支持加密解密、签名验签，了解其工作原理可以帮助您更好地使用加密SDK。加密解密原理 加密原理 加密SDK使用数字信封对数据进行加密。加密SDK支持通过用户主密钥（CMK）保护数据密钥（DataKey），使用数据密钥加密...
消息存储和清理机制
消息存储机制 原理机制 云消息队列 RocketMQ 版 使用存储时长作为消息存储的依据，即每个节点对外承诺消息的存储时长。在存储时长范围内的消息都会被保留，无论消息是否被消费；超过时长限制的消息则会被清理掉。消息存储机制主要定义以下...
什么是RRPC
物联网平台基于MQTT协议给用户服务端提供了RRPC接口，实现用户服务端下发RRPC消息数据并同步等待设备响应数据。名词解释 名词 说明 RRPC 是Revert-RPC的简称。RPC（Remote Procedure Call）是指采用客户机/服务器模式，您不需要了解底层...
变量
但是存在以下限制：单次请求至多投递100条数据 单条投递数据大小需在10KB以下 每秒最多请求200次 Nats 消息推送方式 针对数据量大，数据更新频率高的应用场景，工业组态还提供了Nats 消息中间件方式进行实时消息同步。Nats是一个开源的，云...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
版本说明
本文介绍HTTP协议下PHP SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的PHP SDK收发消息。1.0.4 发布时间 发布内容 下载 2023-01-11 问题修复 修复当消息体存在不合法字符时无法解析的问题。mq-...
准备环境
在使用PHP SDK收发消息前，您需按照本文提供的内容来准备环境。环境要求 安装PHP 5.5.0或以上版本，更多信息，请参见 安装PHP。重要 对于PHP版本小于7.2.5的运行环境，需要将Composer依赖降低到2.2.x或以下版本。安装Composer，更多信息，...
SDK概述
本文介绍 云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK（Software Development Kit）即软件开发工具包，包含示例Demo、库文件、编译工具链以及编译脚本等，不需要开发者进行任何其他的配置，直接可以在SDK对应目录环境下，进行...
鉴权概述
本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类，以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时，服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景，...
分账规则及最佳实践
分账原理：云消息队列 RocketMQ 版 的分账基于标签管理实现。您需要给实例绑定相关标签，然后在查看费用账单时，可通过绑定的实例标签筛选出不同维度的明细账单。分账最佳实践 应用场景 某公司使用一个阿里云账号，该账号下拥有很多 云消息...
分账规则及最佳实践
分账原理：云消息队列 RocketMQ 版 的分账基于标签管理实现。您需要给实例绑定相关标签，然后在查看费用账单时，可通过绑定的实例标签筛选出不同维度的明细账单。分账最佳实践 应用场景 某公司使用一个阿里云账号，该账号下拥有很多 云消息...
鉴权概述
本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类，以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时，服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景，...
- 产品推荐
- 这些文档可能帮助您