概述

SOFAStack 消息队列(SOFAStack MQ,简称 SOFAMQ)是基于 Apache RocketMQ 构建的分布式消息中间件,并与金融分布式架构 SOFAStack 深度集成,为分布式应用系统提供异步解耦和削峰填谷的能力,支持事务消息、顺序消息、定时消息等多种消息...

产品优势

消息队列 基于 Apache RocketMQ 构建的金融级分布式消息中间件,为分布式应用系统提供异步解耦和削峰填谷的能力,支持多种消息类型与消费模式,并具备高可靠、高吞吐、低延时等金融级特性。任务调度 提供分布式任务调度框架,实现任务的...

功能特性

基于多协议,支持对流媒体、数据库、Redis、消息中间件、微服务等组件及应用进行压测。支持对阿里云RDS、PolarDB、Redis、MSE、EDAS等产品进行压测或容量评估。压测流量控制 支持并发(虚拟用户并发)和RPS(Requests per Second,即吞吐量...

依赖服务

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 数据源之间的数据实时同步,扩展消息处理能力。...

开源RabbitMQ迁移上云概述

本文介绍将开源RabbitMQ集群迁移到 云消息队列 RabbitMQ 版 实例的原理和流程。迁移原理 对于消息队列来说,如果要实现集群迁移,只需消费完旧集群的消息即可。由于Producer和Consumer都是集群化的,您可以通过一台一台操作的方式实现上层...

附录一:运维服务产品清单

性能测试 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]向消息...

加密解密与签名验签的原理

加密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,更多信息,...

AMQP服务端订阅

AMQP服务端订阅设备消息的工作原理,请参见 配置AMQP服务端订阅。使用与限制 设备视频流状态变化通知 消息包含:RTMP设备流接收状态变更通知:RTMP设备向物联网智能视频服务的云端推流的状态通知。仅通过RTMP协议接入物联网平台的IPC设备...

SDK概述

本文介绍 云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK(Software Development Kit)即软件开发工具包,包含示例Demo、库文件、编译工具链以及编译脚本等,不需要开发者进行任何其他的配置,直接可以在SDK对应目录环境下,进行...

鉴权概述

本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类,以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时,服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景,...

分账规则及最佳实践

分账原理:云消息队列 RocketMQ 版 的分账基于标签管理实现。您需要给实例绑定相关标签,然后在查看费用账单时,可通过绑定的实例标签筛选出不同维度的明细账单。分账最佳实践 应用场景 某公司使用一个阿里云账号,该账号下拥有很多 云消息...

分账规则及最佳实践

分账原理:云消息队列 RocketMQ 版 的分账基于标签管理实现。您需要给实例绑定相关标签,然后在查看费用账单时,可通过绑定的实例标签筛选出不同维度的明细账单。分账最佳实践 应用场景 某公司使用一个阿里云账号,该账号下拥有很多 云消息...

鉴权概述

本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类,以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时,服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景,...

MNS回调事件通知

其他语言可以通过调用接口来获取消息内容,首先掌握 调用方式 后,调用 消费消息 接口获取消息内容,调用 删除消息 接口删除消息。相关文档 有关HTTP回调与MNS回调的对比,请参见 HTTP回调与MNS回调对比。使用过程中遇到问题时,请参见 ...

更换PHP版本

Linux操作系统云虚拟主机提供更换PHP版本的功能,您可以根据网站程序对PHP版本的要求,选择合适的PHP版本。使用限制 Linux操作系统云虚拟主机支持PHP 8.0及以下版本,但是根据产品类型不同,云虚拟主机支持的PHP版本也有所不同,具体说明...
共有112条 < 1 2 3 4 ... 112 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
消息服务 云消息队列 Kafka 版 Serverless 应用引擎 云数据库 RDS 云消息队列 RocketMQ 版 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用