在线教育的视频直播
利用MQTT消息中间件实现手机端接收和发送消息，同时在服务端实现消息转发时对消息进行内容审核和消息存储。方案架构 通过视频直播+消息服务+表格存储+内容安全，快速实现在线教育的视频直播。解决问题 解决视频直播中手机端的推拉流问题。...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
顺序消息
顺序消息、定时消息、事务消息是不同的消息类型，三者是互斥关系，不能叠加在一起使用。顺序消息支持哪些地域（Region）？支持消息队列所有部署的地域。顺序消息的使用范围是什么？关于顺序消息的使用范围，包括适用场景和使用限制等，请...
工程架构
推荐服务把获取到的N个冷启动物品与常规推荐结果列表混合后，返回给APP展现 APP实时把展现、点击等行为日志上传到日志服务器 Flink任务从消息中间件（kafka、datahub等）读取日志服务器上收集到的实时行为日志 Flink任务解析日志，并根据...
CreateBatch-创建批处理任务
Notification object 否 消息通知对象，支持多种消息中间件，消息格式详情请见异步通知消息格式，请选择其中一种方式接收消息，使用方式如下所示：在与智能媒体管理相同的地域下开通并接入事件总线 EventBridge 服务，及时获取任务信息通知...
CreateTrigger-创建触发器
Notification object 否 消息通知对象，支持多种消息中间件，消息格式详情请见异步通知消息格式，请选择其中一种方式接收消息，使用方式如下所示：在与智能媒体管理相同的地域下开通并接入事件总线 EventBridge 服务，及时获取任务信息通知...
什么是消息演练
消息演练概述 目前市面上有RocketMQ、Kafka、RabbitMQ等流行的消息中间件服务，消息演练功能将这些常见的中间件进行了统一抽离，为消息服务安排分配了精选后的演练最佳实践。您无需分析每种消息服务需要什么演练场景，仅需选择演练方案即可...
什么是云消息队列 RocketMQ 版？
削峰填谷提高稳定性 传统消息中间件仅满足业务的异步化需求，而 云消息队列 RocketMQ 版 诞生于在线互联网和交易业务场景，除了满足异步能力，还将削峰填谷作为消息的基础能力。通过削峰填谷不仅能够提高系统稳定性，还能大幅降低业务成本...
产品优势
消息队列 基于 Apache RocketMQ 构建的金融级分布式消息中间件，为分布式应用系统提供异步解耦和削峰填谷的能力，支持多种消息类型与消费模式，并具备高可靠、高吞吐、低延时等金融级特性。任务调度 提供分布式任务调度框架，实现任务的...
消息队列MQ的审计事件
消息队列MQ（AMQP）已与操作审计服务集成，您可以在操作审计中查询用户操作消息队列MQ产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计记录了...
使用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 消息中间件调用可...
消费托管MQ接口
确认消息 消费托管MQ消息成功后，进行确认，方法名称：ackMQMessage。函数原型 AckMQMessageResponse ackMQMessage(final AckMQMessageRequest request)请求参数 参数 必选 说明 streamId 是 队列ID，即数据导出服务中的任务ID。...
关键类介绍
消息 内部消息全部使用 SofaRequest 和 SofaResponse 进行传递。如果您需要转换为其它协议，请在真正调用和收到请求的时候，转换为实际要传输的对象。可以对 SofaRequest 和 SofaResponse 进行写入操作的模块如下：Invoker Filter ...
同步 OceanBase 数据库的数据至 RocketMQ
背景信息 消息队列 RocketMQ 是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。数据传输的数据同步功能可以帮助您实现 OceanBase 数据库的物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。...
变量
但是存在以下限制：单次请求至多投递100条数据 单条投递数据大小需在10KB以下 每秒最多请求200次 Nats 消息推送方式 针对数据量大，数据更新频率高的应用场景，工业组态还提供了Nats 消息中间件方式进行实时消息同步。Nats是一个开源的，云...
MSHA产品和开源产品对比
✅ 消息层MQ 路由 发布打标（路由ID）✅ ❌ 消息层MQ 路由 消费过滤（依据路由ID计算消费单元）✅ ❌ 消息层MQ Failover 切流时重置位点，消息不丢 ✅ ❌ 数据层MySQL 路由 数据保护，防止多点写脏数据 ✅ ✅ 数据层MySQL Failover 路由ID...
接入点设置说明
背景信息 如需使用 SOFAStack 消息队列来收发消息，则需在使用 TCP 协议下的 SDK 时，将相应参数配置为您实际使用的资源信息。需特别注意的是，以下参数所对应的资源应处于同一地域：GROUP_ID：您在消息队列控制台上创建的 Group ID。TOPIC...
报警管理
如果您选择的 Group ID 在消费对应的 Topic 时产生了消息堆积，并且堆积超过了报警阈值，消息队列 MQ 就会给报警接收人发送短信通知。消费延迟阈值：消费延迟的值是指该 Group ID 最近一次消费该 Topic 消息的时间和该 Topic 最近一次投递...
金融云产品列表
MQ 部署 部署 部署 部署 消息服务 MNS 部署 部署 部署 无 数据传输 部署 部署 部署 部署 资源编排ROS 部署 部署 部署 部署 弹性伸缩 部署 部署 部署 部署 日志服务 SLS 部署 部署 部署 部署 API网关 部署 部署 部署 无 云数据库 OceanBase ...
数据指标说明
规则引擎消息流转MQ云产品次数 规则引擎消息流转OTS云产品次数 规则引擎消息流转RDS云产品次数 规则引擎消息流转REPUBLISH云产品次数 规则引擎消息流转TSDB云产品次数 规则引擎消息流转DATAHUB云产品次数 规则引擎消息流转FC云产品次数 ...
通过读写分离提升数据吞吐性能
本教程主要介绍如何使用中间件MySQL-proxy实现读写分离。前提条件 使用本教程进行操作前，请确保您已经注册了阿里云账号。如还未注册，请先完成 账号注册。背景信息 应用层中直接使用代码实现，在进入Service之前，使用AOP来做出判断，是...
附录：SOFAStack 产品目录
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，为分布式应用提供异步解耦和削峰填谷的能力，支持多种消息类型，提供高可靠、高吞吐量、高可用、事务一致性的异步通讯能力。产品架构 产品优势 开箱即用 多种...
支持的资源类型
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...
支持的云产品列表
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...
消息重试
顺序消息的重试 对于顺序消息，当消费者消费消息失败后，消息队列会自动不断地进行消息重试（每次间隔时间为 1 秒），这时，应用会出现消息消费被阻塞的情况。因此，建议您使用顺序消息时，务必保证应用能够及时监控并处理消费失败的情况，...
概述
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息类型，并具备高可靠、...
启用 TLS 通信加密
本文介绍使用 TLS 消息加密的操作指导。重要 NameServer、Broker、Client 的认证证书 CA 要保持一致。配置 NameServer 准备工作。确认 NameServer 是否安装 OpenSSL。推荐安装，可使用 openssl version 命令查看。生成证书。以 OpenSSL ...
消息（Message）
系统默认的消息最大限制如下：普通和顺序消息：4 MB 事务和定时或延时消息：64 KB 使用建议 单条消息不建议传输超大负载 作为一款消息中间件产品，云消息队列 RocketMQ 版 一般传输的是都是业务事件数据。单个原子消息事件的数据大小需要...
消息过滤
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
故障止损恢复
故障初因定位 集成企业内部可利用的所有稳定性相关数据（变更事件，数据库、MQ等中间件异常事件），以及集成各业务自建的定位工具能力，并在故障及风险预警的应急过程中进行可疑原因定位，帮助促进故障及风险预警初因定位的时长缩短。...
领域模型概述
消息传输模型介绍 主流的消息中间件的传输模型主要为点对点模型和发布订阅模型。点对点模型 点对点模型也叫队列模型，具有如下特点：消费匿名：消息上下游沟通的唯一的身份就是队列，下游消费者从队列获取消息无法声明独立身份。一对一通信...
QueryMqSofamqMessageByKey
Key String 是 messageKey1 需查询的消息的 Message Key Topic String 是 test-mq_topic 需查询的消息的 Topic 返回数据 名称 类型 示例值 描述 Data Array 查询结果 Body String SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 消息体 BodyCrc ...
GetMqSofamqMessageById
10911 存储该消息的服务器实例 BornTimestamp Long 1570761026630 生成时间戳 InstanceId String MQ_INST_111111111111_DOxxxxxx 实例 ID Body String SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 消息体 MsgId String 1E0578FE110F18B4AAC235C0...
步骤一：架构规划
使用的中间件 中间件 配置信息 备注 消息队列 TopicGroupID 创建 topic、groupid 和路由规则。数据访问代理 1 个实例，3 个库，每个库 10 库 10 表 创建实例，添加数据节点，创建数据库、数据表，并连接数据访问代理。分布式事务 无 无 微...
智能对话分析服务关联角色介绍
应用场景 智能对话分析的多种消息、事件需要通过消息队列Rocket MQ来推送给您，通过服务关联角色功能获取您消息队列Rocket MQ服务的发送消息的权限。AliyunServiceRoleForSCA介绍 角色名称：AliyunServiceRoleForSCA 角色权限策略：...
智能对话分析服务关联角色介绍
应用场景 智能对话分析的多种消息、事件需要通过消息队列Rocket MQ来推送给您，通过服务关联角色功能获取您消息队列Rocket MQ服务的发送消息的权限。AliyunServiceRoleForSCA介绍 角色名称：AliyunServiceRoleForSCA 角色权限策略：...
QueryMqSofamqMessageByTopic
Topic String 是 test-mq_topic 需查询的消息的 Topic 名称 返回数据 名称 类型 示例值 描述 Data Struct 分页查询Message Content Array 消息的详细信息 Body String SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 消息体 BodyCrc Long 914112295...
背景信息
OLAP场景中，为避免复杂SQL运行时间过长，程序一直阻塞等待而影响业务运行...DLA支持将消息写入阿里云 消息队列（Message Queue，简称MQ）、消息服务（Message Service，简称MNS，原MQS）或者 钉钉机器人，帮助您快速、异步感知任务执行状态。
- 产品推荐
- 这些文档可能帮助您