依赖服务
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）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
云消息队列 RocketMQ 版
重要 鉴于 云消息队列 RocketMQ 版 4.x标准版当前最高可达每秒5千条消息的限速机制，使用该版作为实时计算Flink版对接的消息中间件，可能会导致Flink作业运行不稳定。因此，在选择消息中间件时，如果您正在或计划通过标准版RocketMQ与Flink...
产品功能发布记录
2020.02.27 相关文档 Hyperledger Fabric【云服务集成】消息队列 如果您希望区块链上的各种事件能自动发布到消息中间件，您可以将区块链事件和MQ做映射配置。当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以...
使用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对消息中间件的封装模块...
内置时空数据引擎Ganos
IoT时空解决方案：支持通过Kafka、Flink等流式引擎和消息中间件接入时空流式数据建模为移动对象数据库、激光点云数据库或时序点数据库。Ganos将逐步沉淀基础时空云计算能力到云计算基础平台，赋能ISV厂商，推动时空云计算作为数字化转型的...
基于RocketMQ指标的容器水平伸缩
RocketMQ作为一种高性能、高可靠、高扩展性的分布式消息中间件，已经被广泛应用于企业级应用中。但在使用RocketMQ时，消息堆积是常见的问题，特别是在高负载情况下，消息堆积很容易导致系统负载过高，甚至服务崩溃。为了解决这个问题，您...
消息过滤
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
EMQX数据接入
背景信息 EMQX Cloud是EMQ公司推出的一款面向物联网领域的MQTT消息中间件产品。EMQX Cloud提供了一站式运维代管、独有隔离环境的MQTT消息服务。在万物互联的时代，EMQX Cloud可以帮助您快速构建面向物联网领域的行业应用，轻松实现物联网...
通过Elasticsearch和rsbeat实时分析Redis slowlog
Redis：是一个开源的、基于内存的数据结构存储器，可以用作数据库、缓存和消息中间件，详情请参见 Redis官方说明。云数据库Redis版（ApsaraDB for Redis）是兼容开源Redis协议标准、提供内存加硬盘的混合存储方式的数据库服务，基于高可靠...
Kafka数据迁移MaxCompute最佳实践
背景信息 Kafka是一款分布式发布与订阅的消息中间件，具有高性能、高吞量的特点被广泛使用，每秒能处理上百万的消息。Kafka适用于流式数据处理，主要应用于用户行为跟踪、日志收集等场景。一个典型的Kafka集群包含若干个生产者（Producer）...
Kafka数据迁移MaxCompute最佳实践
背景信息 Kafka是一款分布式发布与订阅的消息中间件，具有高性能、高吞量的特点被广泛使用，每秒能处理上百万的消息。Kafka适用于流式数据处理，主要应用于用户行为跟踪、日志收集等场景。一个典型的Kafka集群包含若干个生产者（Producer）...
基本概念
数据模板：用于对非结构化数据的解释，当创建数据同步任务时，且源端数据类型为消息中间件时，通过数据模板对其进行解释。Oracle CDC：实时数据同步模式，对源表进行INSERT、UPDATE或DELETE等操作的同时可以提取数据，变化的数据被保存在...
同步 OceanBase 数据库的数据至 RocketMQ
背景信息 消息队列 RocketMQ 是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。数据传输的数据同步功能可以帮助您实现 OceanBase 数据库的物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。...
阿里云电子政务云产品全家福
阿里云电子政务云平台提供弹性计算类、网络、数据库、存储、大数据、中间件、IoT等品类丰富的产品及高标准的安全合规服务，用以支撑多种政务类业务场景，例如：城市大脑，合规应用平台等。截至文档发布时间，阿里云电子政务云共计上线95款...
查询分析RocketMQ客户端日志
Elastic Stack全栈套件具有“0部署，轻运维”的特性，省去了在分布式环境下逐个节点安装与配置Beats采集器的繁琐工作，同时解决了分布式消息中间件日志分散、采集困难的问题。支持在控制台快速添加和移除Beats实例，能够适应RocketMQ的弹性...
附录一：运维服务产品清单
性能测试 pts 云计算基础 互联网中间件 消息服务 mns 云计算基础 互联网中间件 全局事务服务 txc 云计算基础 互联网中间件 应用配置管理 acms 云计算基础 互联网中间件 消息队列Kafka alikafka 云计算基础 互联网中间件 应用高可用服务 ...
变量
但是存在以下限制：单次请求至多投递100条数据 单条投递数据大小需在10KB以下 每秒最多请求200次 Nats 消息推送方式 针对数据量大，数据更新频率高的应用场景，工业组态还提供了Nats 消息中间件方式进行实时消息同步。Nats是一个开源的，云...
部署异步推理服务
如果您不需要输出队列，例如将推理结果直接输出到OSS或者您自己的消息中间件中，则可以在同步的HTTP推理接口中返回空，此时输出队列会被忽略。创建一个高可用的队列子服务，用于接收客户端发送的请求。推理子服务的实例根据自己所能承受的...
附录：SOFAStack 产品目录
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，为分布式应用提供异步解耦和削峰填谷的能力，支持多种消息类型，提供高可靠、高吞吐量、高可用、事务一致性的异步通讯能力。产品架构 产品优势 开箱即用 多种...
本地SSD型
详情请参见 案例说明 磁盘类KV型数据库，例如RocksDB、ClickHouse OLTP、高性能关系型数据库进行WAL优化等 NoSQL数据库，例如Cassandra、MongoDB、HBase Elasticsearch等搜索场景 其他频繁将数据写入磁盘的I/O密集型应用，例如消息中间件、...
数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
通用软件漏洞收集及奖励计划第四期
重要 2024年04月26日更新：因本次提交的漏洞数量超出预期，所以调整活动结束时间为2024年04月30日，2024年04月30日后提交的漏洞将不予收录。此调整不影响2024年04月30日前提交的漏洞。通用软件漏洞情报收集及奖励标准 为了更好地保障云上...
功能发布记录
2023-06-30 1.3.1 OSP 页面自动启用 新部署服务时，自动开通共享中间件工作空间。控制台页面展示优化 消息查询分页列表支持显示总数。新建 Topic 时，新建数据支持按照创建时间插入。监控管理页面，查看 Topic 信息支持分页查询。控制台 ...
实例规格族
实例是能够为您的业务提供计算服务的最小单位，不同的实例规格可以提供的计算能力不同。本文为您介绍在售的所有ECS实例规格族，包括每种实例规格族的特点、在售规格和适用场景。根据业务场景和使用场景，ECS实例可以分为多种实例规格族。...
查看订阅关系
在 SOFAStack 消息队列控制台，您可实时查看 Group ID 和 Topic 之间的订阅关系。本文介绍如何在消息队列控制台查看订阅关系。从 Topic 视角，查看即个 Topic 被哪些 Group ID 订阅了。从 Group 视角，查看某个 Group ID 订阅了哪些 Topic...
事件通知概述
通过设置事件通知，您还可以为事件配置消息处理中间件，实现事件驱动的自动化运维，取代SDK轮询的方式。事件名称 设置事件通知后，在您收到的通知信息中，name 为事件通知名称参数，其取值格式为<资源类型>:<事件类型>:<系统事件状态>。...
线上业务压测的核心要素
另一种就是压测流量单独打标（如单独定义的Header），然后业务处理过程中识别这个标并传递下去，包括异步消息和中间件，最终落到数据库的影子表或者影子库中。此外，生产环境的压测尽量在业务低峰期进行从而避免影响生产的业务，无论上述哪...
开源版和商业版介绍
SOFABoot 目前对外开放的有...支持 中间件（消息）MsgBroker 不支持 支持 中间件（数据）DTX 支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持同城双活。支持共享版中间件。
操作链路概述
本文将引导您快速体验 SOFAStack 消息队列，从创建资源、配置接入点到使用 SDK 收发消息。具体操作步骤如下：创建资源 创建工作空间 创建 Topic 创建 Group ID 获取 AK（AccessKey ID）和 SK（AccessKey Secret）获取接入配置 发送消息 ...
提供服务
支持的框架 接口调用可自动发现和监控以下Web框架和RPC框架中提供的接口：Tomcat 7+Jetty 8+Resin 3.0+Undertow 1.3+WebLogic 11.0+SpringBoot 1.3.0+HSF 2.0+Dubbo 2.5+消息队列可自动发现和监控以下消息队列中间件：MetaQ Kafaka Notify ...
重置消费位点
在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID 操作列的 重置消费位点，然后在 重置消费位点 对话框配置以下信息：Topic：选择重置消费位点针对的 Topic。重置类型：清除所有堆积消息，从最新位点开始消费：若选择...
Demo 工程
Demo 工程包含普通消息、顺序消息、事务消息和定时、延时消息的配置以及测试代码。前提条件 安装 IDE。您可以使用 IntelliJ IDEA 或者 Eclipse，本文以 IntelliJ IDEA 为例。在 https://www.jetbrains.com/idea/ 下载 IntelliJ IDEA ...
消息查询
在左侧导航栏，选择 中间件>消息队列>消息查询。在 消息查询 页面，您可单击以下任一页签，然后按页面提示输入相应信息。按 Message ID 查询：Message ID 是由服务端生成的 32 位字符串，用于标识一条消息。按 Message ID 查询，即根据 ...
消息路由
在左侧导航栏，选择 中间件>消息队列>消息路由。单击 创建路由任务，然后在 创建路由任务 对话框配置任务信息：源 Topic：输入需要同步的消息所属 Topic 名称。目标单元：选择消息将被同步到的 Topic 所属单元。目标 Topic：输入消息将被...
死信队列
当一条消息初次消费失败，消息队列会自动进行消息重试。达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息。此时，消息队列不会立刻将消息丢弃，而是将其发送到该消费者对应的特殊队列中。在消息队列中，...
查看消费者状态
在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID 进入详情页。单击 消费者状态，即可查看到消费者群组所有相关的状态信息。在线状态：只要该 Group ID 下有一个消费者实例在线，就显示在线。若该 Group ID 下所有消费者...
系统事件
通过设置事件通知，您还可以为事件配置消息处理中间件，实现事件驱动的自动化运维，取代SDK轮询的方式。系统运维管理 OOS（CloudOps Orchestration Service）（OOS）已经支持事件通知，包括模板执行状态通知和任务执行状态通知。系统事件的...
查询消息轨迹
消息轨迹是指一条消息从生产者发送到消息队列服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。本文介绍如何快速查询消息轨迹。前提条件 您的消息已从生产者发送。操作步骤 登录 SOFAStack...
接入点设置说明
在左侧导航栏，选择 中间件>消息队列>概览。在页面底部的 接入配置 找到 内网接入点 及 实例 ID。将该 TCP 协议内网接入点 配置到客户端 SDK 代码的 ENDPOINT 参数。将该 实例 ID 配置到客户端 SDK 代码的 INSTANCE_ID 参数。
- 产品推荐
- 这些文档可能帮助您