鉴权概述
鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时，服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景，UserName和Password参数具备不同的含义。MQTT客户端开发应该根据实际场景选择合适的鉴权...
鉴权概述
鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时，服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景，UserName和Password参数具备不同的含义。MQTT客户端开发应该根据实际场景选择合适的鉴权...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
开通消息服务MNS并授权
使用 消息服务MNS 前，您需在产品页开通该服务。如果您的账号为RAM用户，必须让阿里云账号为RAM用户进行授权，才能通过控制台或API访问相应的 消息服务MNS 资源，并使用资源通过SDK收发消息。本文介绍如何开通 消息服务MNS 和授权RAM用户。...
操作链路概述
创建工作空间 要使用消息队列，您需要确保 SOFAStack 控制台已创建至少一个工作空间。如 SOFAStack 未创建工作空间或您需要创建一个新的工作空间，可参见 添加工作空间。创建好工作空间后，将为您自动创建一个消息队列实例。创建 Topic ...
MNS回调事件通知
如何使用PHP代码消费消息，请参见 队列使用手册。其他语言可以通过调用接口来获取消息内容，首先掌握 调用方式 后，调用 消费消息 接口获取消息内容，调用 删除消息 接口删除消息。相关文档 有关HTTP回调与MNS回调的对比，请参见 HTTP回调...
准备环境
在使用PHP SDK收发消息前，您需按照本文提供的内容来准备环境。环境要求 安装PHP 5.5.0或以上版本，更多信息，请参见 安装PHP。重要 对于PHP版本小于7.2.5的运行环境，需要将Composer依赖降低到2.2.x或以下版本。安装Composer，更多信息，...
Notification
名称 类型 描述 示例值 object 消息通知对象，支持多种消息中间件，消息格式详情请见 异步通知消息格式，请选择其中一种方式接收消息，使用方式如下所示：在与智能媒体管理相同的地域下开通并接入 事件总线 EventBridge 服务，及时获取任务...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
应用场景
通用分布式事务管理 提供通用的分布式事务管理能力，支持微服务框架（Spring Cloud、Dubbo 和 HSF）、数据库（DRDS、RDS、MySQL、Oracle等）、消息中间件（MQ）的组合使用，灵活方便。多业务场景：通过混合事务，GTS可以应用到金融、电信、...
什么是云消息队列 RocketMQ 版？
削峰填谷提高稳定性 传统消息中间件仅满足业务的异步化需求，而 云消息队列 RocketMQ 版 诞生于在线互联网和交易业务场景，除了满足异步能力，还将削峰填谷作为消息的基础能力。通过削峰填谷不仅能够提高系统稳定性，还能大幅降低业务成本...
CreateBatch-创建批处理任务
Notification object 否 消息通知对象，支持多种消息中间件，消息格式详情请见异步通知消息格式，请选择其中一种方式接收消息，使用方式如下所示：在与智能媒体管理相同的地域下开通并接入事件总线 EventBridge 服务，及时获取任务信息通知...
CreateTrigger-创建触发器
Notification object 否 消息通知对象，支持多种消息中间件，消息格式详情请见异步通知消息格式，请选择其中一种方式接收消息，使用方式如下所示：在与智能媒体管理相同的地域下开通并接入事件总线 EventBridge 服务，及时获取任务信息通知...
消息服务MNS中使用PHP编写HttpEndpoint接口时接收不到...
问题描述 消息服务MNS中使用PHP编写HttpEndpoint接口时接收不到消息体。问题原因 可能是因为PHP程序中使用了$_POST[]方法获取HttpBody。POST[]方法只能接收如下Content-Type类型提交的数据，即表单POST过来的数据。application/x-...
云消息队列 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对消息中间件的封装模块...
Topic 与 Tag
建议您从以下几个方面进行判断：消息类型是否一致：如普通消息、事务消息、定时或延时消息、顺序消息，不同的消息类型使用不同的 Topic。创建 Topic 时需要指定消息类型，无法通过 Tag 进行区分。业务是否相关联：没有直接关联的消息，如...
什么是全局事务服务GTS
可以与RDS、MySQL、PostgreSQL等数据源，Spring Cloud、Dubbo、HSF及其他RPC框架，MQ消息队列等中间件产品配合使用，轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务及各种组合。为什么需要全局事务服务 一个完整的业务往往...
同步 OceanBase 数据库的数据至 RocketMQ
背景信息 消息队列 RocketMQ 是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。数据传输的数据同步功能可以帮助您实现 OceanBase 数据库的物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。...
SDK参考
SDK列表 升级版SDK列表 安装说明 详细使用说明 Java Java SDK 开始使用 TypeScript TypeScript SDK 开始使用 Go Go SDK 开始使用 PHP PHP SDK 开始使用 Python Python SDK 开始使用 C#C#SDK 开始使用 C++ C++ SDK-Swift Swift SDK-您可以...
接入点设置说明
背景信息 如需使用 SOFAStack 消息队列来收发消息，则需在使用 TCP 协议下的 SDK 时，将相应参数配置为您实际使用的资源信息。需特别注意的是，以下参数所对应的资源应处于同一地域：GROUP_ID：您在消息队列控制台上创建的 Group ID。TOPIC...
服务部署概述
部署原理 使用 EAS 进行模型部署时，支持 镜像部署 和 Processor部署 两类部署方式，对比介绍如下。镜像部署（推荐）使用镜像方式部署时，EAS 通过拉取 容器镜像服务ACR 中的环境镜像、挂载存储云产品（OSS 对象存储OSS、文件存储NAS），来...
附录：SOFAStack 产品目录
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，为分布式应用提供异步解耦和削峰填谷的能力，支持多种消息类型，提供高可靠、高吞吐量、高可用、事务一致性的异步通讯能力。产品架构 产品优势 开箱即用 多种...
消息存储和清理机制
消息存储机制 原理机制 云消息队列 RocketMQ 版 使用存储时长作为消息存储的依据，即每个节点对外承诺消息的存储时长。在存储时长范围内的消息都会被保留，无论消息是否被消费；超过时长限制的消息则会被清理掉。消息存储机制主要定义以下...
迁移上云操作
本文为您介绍如何使用 云消息队列 RocketMQ 版 的迁移工具将开源自建的Apache RocketMQ迁移至阿里云 云消息队列 RocketMQ 版。前提条件 创建消息队列RocketMQ版5.0系列实例 创建服务关联角色 角色名称：AliyunServiceRoleForRMQMigration ...
概述
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息类型，并具备高可靠、...
快速入门
本文将向您描述如何使用 SOFABoot 框架创建一个Web 工程，实现本地运行或部署到云端运行，以及如何引入中间件服务。主要步骤如下：创建 Web 工程 将 Web 工程导入 IDE 实现本地编译和运行 实现云端运行 引入中间件服务 说明 Core 工程 与 ...
PHP SDK
为了更好地使用阿里云服务，建议尽快完成实名认证，否则...步骤 3 开始一个新的 PHP 项目 您可以开始使用 PHP SDK。使用任何文本编辑器或者 PHP IDE，运行如下示例代码即可与机器翻译服务端交互并得到相应输出。示例代码详见 SDK示例（PHP）
应用部署时的默认启动命令参数
部署应用时，EDAS会默认添加启动命令参数，用于优化应用性能，保证应用可以使用中间件和应用管理相关功能。配置项 配置值 解析 类别 alicloud.deployment.mode EDAS_MANAGED 添加该配置后，会自动将中间件组件的服务端地址替换为EDAS提供的...
镜像启动加速（ACR个人版）
本文介绍使用ACR个人版实现镜像启动加速的使用原理等。使用原理 对于运行环境为Custom Container且使用阿里云容器镜像服务ACR个人版的函数，函数计算 默认为其开启镜像启动加速功能。每次创建或更新该类函数时，函数计算 会扮演服务RAM角色...
应用场景
本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...
镜像启动加速（ACR企业版）
本文介绍使用ACR企业版实现镜像启动加速的使用原理和配置方法等。使用优势（相比ACR个人版）除了拥有ACR个人版的所有镜像加速功能外，ACR企业版镜像还具备以下优势：单独的网络访问，可配置独立的VPC安全规则管理仓库实例的网络访问。更多...
应用内存不足
本文介绍在使用消息队列时出现应用内存不足时的一些常见问题及解决方法。现象 在应用部署的机器上查看内存已消耗完。在/{user.home}/logs/sofamq.log 能搜索到 OutOfMemory 关键字。在消息队列控制台查看目标 Group ID 的消费者状态，堆积...
领域模型概述
消息传输模型介绍 主流的消息中间件的传输模型主要为点对点模型和发布订阅模型。点对点模型 点对点模型也叫队列模型，具有如下特点：消费匿名：消息上下游沟通的唯一的身份就是队列，下游消费者从队列获取消息无法声明独立身份。一对一通信...
应用场景
混合分布式事务 有些系统在使用数据库保证系统内数据一致的同时，也会使用消息队列作为和其他系统间的消息传递，完成不同系统间的数据一致。例如会员注册服务和邮件发送服务，当用户注册会员成功，需要给用户发送一封邮件，告诉用户注册...
基础术语
本文主要对 SOFAStack 消息队列涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用消息队列。中文 英文 释义 消息主题 Topic 消息主题，一级消息类型，通过 Topic 对消息进行分类。详情请参见 Topic 与 Tag。消息 ...
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
主题别名
使用场景 下图以温度传感器为示例，介绍主题别名的原理及使用流程。示例中消息A和消息B的Payload是一样的，消息A有主题和别名，消息B主题为空用别名替换。主题/sys/product_name/device_001/farmland_1234/sensors/temperature 长度超过60...
- 产品推荐
- 这些文档可能帮助您