在线教育的视频直播
利用MQTT消息中间件实现手机端接收和发送消息，同时在服务端实现消息转发时对消息进行内容审核和消息存储。方案架构 通过视频直播+消息服务+表格存储+内容安全，快速实现在线教育的视频直播。解决问题 解决视频直播中手机端的推拉流问题。...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
sample-txc-edas 样例
该样例综合了 GTS、EDAS 及 MQ 的使用，通过 Console 和 Web 两种方式充分展现了用户的使用场景，是 EDAS 上部署 GTS 的进阶样例，帮助您更全面的理解 GTS 的使用场景。前提条件 在使用 sample-txc-edas 样例工程，请先完成以下工作：开通...
报警管理
如果您选择的 Group ID 在消费对应的 Topic 时产生了消息堆积，并且堆积超过了报警阈值，消息队列 MQ 就会给报警接收人发送短信通知。消费延迟阈值：消费延迟的值是指该 Group ID 最近一次消费该 Topic 消息的时间和该 Topic 最近一次投递...
工程架构
推荐服务把获取到的N个冷启动物品与常规推荐结果列表混合后，返回给APP展现 APP实时把展现、点击等行为日志上传到日志服务器 Flink任务从消息中间件（kafka、datahub等）读取日志服务器上收集到的实时行为日志 Flink任务解析日志，并根据...
什么是消息演练
消息演练概述 目前市面上有RocketMQ、Kafka、RabbitMQ等流行的消息中间件服务，消息演练功能将这些常见的中间件进行了统一抽离，为消息服务安排分配了精选后的演练最佳实践。您无需分析每种消息服务需要什么演练场景，仅需选择演练方案即可...
什么是云消息队列 RocketMQ 版？
削峰填谷提高稳定性 传统消息中间件仅满足业务的异步化需求，而 云消息队列 RocketMQ 版 诞生于在线互联网和交易业务场景，除了满足异步能力，还将削峰填谷作为消息的基础能力。通过削峰填谷不仅能够提高系统稳定性，还能大幅降低业务成本...
CreateBatch-创建批处理任务
Notification object 否 消息通知对象，支持多种消息中间件，消息格式详情请见异步通知消息格式，请选择其中一种方式接收消息，使用方式如下所示：在与智能媒体管理相同的地域下开通并接入事件总线 EventBridge 服务，及时获取任务信息通知...
CreateTrigger-创建触发器
Notification object 否 消息通知对象，支持多种消息中间件，消息格式详情请见异步通知消息格式，请选择其中一种方式接收消息，使用方式如下所示：在与智能媒体管理相同的地域下开通并接入事件总线 EventBridge 服务，及时获取任务信息通知...
MQ配置
前提条件 使用MQ订阅云价签产品消息，您需要先开通 RocketMQ产品 并创建实例。开通权限 云价签需要获取用户发送MQ消息的权限，需在 RAM控制台 创建一个新角色，角色名为：CloudEslNotificationRole，并在选择信任的阿里云账号一栏，填入...
金融云产品列表
MQ 部署 部署 部署 部署 消息服务 MNS 部署 部署 部署 无 数据传输 部署 部署 部署 部署 资源编排ROS 部署 部署 部署 部署 弹性伸缩 部署 部署 部署 部署 日志服务 SLS 部署 部署 部署 部署 API网关 部署 部署 部署 无 云数据库 OceanBase ...
支持的资源类型
Ons 消息队列 MQ Instance/Group Group组 Instance/Topic 主题 Instance 实例 OOS 运维编排 PatchBaseline 补丁基线 SecretParameter 加密参数 OSS 对象存储 Bucket 存储空间 PolarDB 云原生关系型数据库 PolarDB ParameterGroup 参数模板 ...
AddPipeline-添加管道
mts-queue-1 MqTag string 消息队列 mq 标签。mts-test Topic string 主题名称。mts-topic-1 Role string 角色。AliyunMTSDefaultRole Name string 管道名称。视频DNA Id string 管道 ID。ed450ea0bfbd41e29f80a401fb4d*QuotaAllocate long...
产品优势
消息队列 基于 Apache RocketMQ 构建的金融级分布式消息中间件，为分布式应用系统提供异步解耦和削峰填谷的能力，支持多种消息类型与消费模式，并具备高可靠、高吞吐、低延时等金融级特性。任务调度 提供分布式任务调度框架，实现任务的...
顺序消息
顺序消息、定时消息、事务消息是不同的消息类型，三者是互斥关系，不能叠加在一起使用。顺序消息支持哪些地域（Region）？支持消息队列所有部署的地域。顺序消息的使用范围是什么？关于顺序消息的使用范围，包括适用场景和使用限制等，请...
支持的云产品列表
Ons 消息队列MQ v20190214 2019年7月 OSS 对象存储 2019年7月 polardb Polardb v20170801 2019年7月 Push 移动推送 v20160801 2019年7月 RAM 访问控制 v20150501 2019年6月 RDS 云数据库 v20140815 2019年6月 SAS 云安全中心（态势感知）v...
数据指标说明
规则引擎消息流转MQ云产品次数 规则引擎消息流转OTS云产品次数 规则引擎消息流转RDS云产品次数 规则引擎消息流转REPUBLISH云产品次数 规则引擎消息流转TSDB云产品次数 规则引擎消息流转DATAHUB云产品次数 规则引擎消息流转FC云产品次数 ...
使用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对消息中间件的封装模块...
依赖服务
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 消息中间件调用可...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。mq-http-cpp-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-01-23 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式，暂不支持...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。mq-http-nodejs-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-01-23 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式，暂不支持...
同步 OceanBase 数据库的数据至 RocketMQ
背景信息 消息队列 RocketMQ 是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。数据传输的数据同步功能可以帮助您实现 OceanBase 数据库的物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。mq-http-csharp-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-01-23 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式，暂不支持...
关键类介绍
消息 内部消息全部使用 SofaRequest 和 SofaResponse 进行传递。如果您需要转换为其它协议，请在真正调用和收到请求的时候，转换为实际要传输的对象。可以对 SofaRequest 和 SofaResponse 进行写入操作的模块如下：Invoker Filter ...
变量
但是存在以下限制：单次请求至多投递100条数据 单条投递数据大小需在10KB以下 每秒最多请求200次 Nats 消息推送方式 针对数据量大，数据更新频率高的应用场景，工业组态还提供了Nats 消息中间件方式进行实时消息同步。Nats是一个开源的，云...
接入点设置说明
背景信息 如需使用 SOFAStack 消息队列来收发消息，则需在使用 TCP 协议下的 SDK 时，将相应参数配置为您实际使用的资源信息。需特别注意的是，以下参数所对应的资源应处于同一地域：GROUP_ID：您在消息队列控制台上创建的 Group ID。TOPIC...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。mq-http-java-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-01-23 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式，暂不支持...
消费托管MQ接口
消费托管MQ接口主要用于获取托管MQ中的消息以及消息成功后进行确认的功能。获取消息 获取托管MQ中的消息，方法名称：consumeMQMessage。函数原型 ConsumeMQMessageResponse consumeMQMessage(final ConsumeMQMessageRequest request)请求...
附录：SOFAStack 产品目录
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，为分布式应用提供异步解耦和削峰填谷的能力，支持多种消息类型，提供高可靠、高吞吐量、高可用、事务一致性的异步通讯能力。产品架构 产品优势 开箱即用 多种...
通过读写分离提升数据吞吐性能
本教程主要介绍如何使用中间件MySQL-proxy实现读写分离。前提条件 使用本教程进行操作前，请确保您已经注册了阿里云账号。如还未注册，请先完成 账号注册。背景信息 应用层中直接使用代码实现，在进入Service之前，使用AOP来做出判断，是...
智能对话分析服务关联角色介绍
应用场景 智能对话分析的多种消息、事件需要通过消息队列Rocket MQ来推送给您，通过服务关联角色功能获取您消息队列Rocket MQ服务的发送消息的权限。AliyunServiceRoleForSCA介绍 角色名称：AliyunServiceRoleForSCA 角色权限策略：...
智能对话分析服务关联角色介绍
应用场景 智能对话分析的多种消息、事件需要通过消息队列Rocket MQ来推送给您，通过服务关联角色功能获取您消息队列Rocket MQ服务的发送消息的权限。AliyunServiceRoleForSCA介绍 角色名称：AliyunServiceRoleForSCA 角色权限策略：...
消息重试
顺序消息的重试 对于顺序消息，当消费者消费消息失败后，消息队列会自动不断地进行消息重试（每次间隔时间为 1 秒），这时，应用会出现消息消费被阻塞的情况。因此，建议您使用顺序消息时，务必保证应用能够及时监控并处理消费失败的情况，...
概述
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息类型，并具备高可靠、...
启用 TLS 通信加密
本文介绍使用 TLS 消息加密的操作指导。重要 NameServer、Broker、Client 的认证证书 CA 要保持一致。配置 NameServer 准备工作。确认 NameServer 是否安装 OpenSSL。推荐安装，可使用 openssl version 命令查看。生成证书。以 OpenSSL ...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。mq-http-go-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-06-10 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式，暂不支持广播...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。支持Python 3。mq-http-python-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-01-23 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费...
消息（Message）
系统默认的消息最大限制如下：普通和顺序消息：4 MB 事务和定时或延时消息：64 KB 使用建议 单条消息不建议传输超大负载 作为一款消息中间件产品，云消息队列 RocketMQ 版 一般传输的是都是业务事件数据。单个原子消息事件的数据大小需要...
授权信息
操作（Action）下表是 消息队列 MQ（Ons）定义的操作，这些操作可以在RAM权限策略语句的 Action 元素中使用，用来授予执行该操作的权限。下面对表中的具体项提供说明：操作：是指具体的权限点。API：是指操作对应的API接口。访问级别：是指...
版本说明
支持使用Message ID查询消息轨迹。支持消息属性。mq-http-php-sdk-1.0.1.zip 1.0.0 发布时间 发布内容 下载 2019-01-23 新特性 首次发布。暂不支持高级特性消息，包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式，暂不支持...
- 产品推荐
- 这些文档可能帮助您