名词解释
应用镜像」应用镜像是由开发者开发业务代码组成，其中不包含依赖的中间件等内容，最终应用可以由n个应用镜像+中间件镜像+阿里云服务组成。镜像管理」应用代码打包成docker镜像托管至阿里云IoT镜像仓库。在这个仓库中用户可以实时管理并可将...
消息队列
如果您希望区块链上的各种事件能自动发布到消息中间件，您可以将区块链事件和MQ做映射配置。当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 ...
重置消费位点
目前不支持指定 Message ID、Message Key 和 Tag 来重置消息的消费位点。操作步骤 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID 操作列的 重置消费位点，然后在 重置消费位点 对话框配置以下...
Demo 工程
Demo 工程包含普通消息、顺序消息、事务消息和定时、延时消息的配置以及测试代码。前提条件 安装 IDE。您可以使用 IntelliJ IDEA 或者 Eclipse，本文以 IntelliJ IDEA 为例。在 https://www.jetbrains.com/idea/ 下载 IntelliJ IDEA ...
开通消息服务MNS并授权
使用 消息服务MNS 前，您需在产品页开通该服务。如果您的账号为RAM用户，必须让阿里云账号为RAM用户进行授权，才能通过控制台或API访问相应的 消息服务MNS 资源，并使用资源通过SDK收发消息。本文介绍如何开通 消息服务MNS 和授权RAM用户。...
收发延时消息
本文提供使用 TCP 协议下的 Java SDK 收发延时消息的示例代码供您参考。前提条件 您已完成以下操作：下载 Java SDK。准备环境。（可选）日志配置。背景信息 延时消息用于指定消息发送到消息队列的服务端后，延时一段时间才被投递到客户端...
消息路由
在左侧导航栏，选择 中间件>消息队列>消息路由。单击 创建路由任务，然后在 创建路由任务 对话框配置任务信息：源 Topic：输入需要同步的消息所属 Topic 名称。目标单元：选择消息将被同步到的 Topic 所属单元。目标 Topic：输入消息将被...
概述
同时 SOFABoot 也提供了 SOFA 中间件的轻量级集成方案，仅需少量配置即可在 SOFABoot 中使用金融科技中间件。金融科技中间件也可通过相应的 starter 模块单独配置集成到 Spring Boot 工程中。SOFABoot 基于 Spring Boot 开发，使用标准 ...
准备环境
在运行收发消息的 Java 代码前，您需按照本文提供的步骤来准备环境。操作步骤 通过 Maven 方式引入依赖。Java SDK 的最新版本号，可参见 SDK 版本说明。groupId>...
收发事务消息
本文提供使用 TCP 协议下的 Java SDK 收发事务消息的示例代码供您参考。消息队列提供类似 X/Open XA 的分布式事务功能，通过消息队列事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，阅读 Demo 工程来...
步骤一：架构规划
使用的中间件 中间件 配置信息 备注 消息队列 TopicGroupID 创建 topic、groupid 和路由规则。数据访问代理 1 个实例，3 个库，每个库 10 库 10 表 创建实例，添加数据节点，创建数据库、数据表，并连接数据访问代理。分布式事务 无 无 微...
通过企业监控大盘监控线下IDC的中间件
步骤一：为线下IDC的中间件安装Exporter 本文以中间件Redis部署在Linux操作系统上为例，为您介绍Exporter的安装方法。以root用户登录中间件所在主机。执行以下命令，下载Exporter安装包。wget ...
查看订阅关系
在 SOFAStack 消息队列控制台，您可实时查看 Group ID 和 Topic 之间的订阅关系。本文介绍如何在消息队列控制台查看订阅关系。从 Topic 视角，查看即个 Topic 被哪些 Group ID 订阅了。从 Group 视角，查看某个 Group ID 订阅了哪些 Topic...
消息重试
顺序消息的重试 对于顺序消息，当消费者消费消息失败后，消息队列会自动不断地进行消息重试（每次间隔时间为 1 秒），这时，应用会出现消息消费被阻塞的情况。因此，建议您使用顺序消息时，务必保证应用能够及时监控并处理消费失败的情况，...
收发定时消息
本文将引导您如何使用 TCP 协议下的 Java SDK 进行定时消息的收发。前置条件 需要确保您已完成以下操作：下载 Java SDK。准备环境。（可选）日志配置。背景信息 通过定时消息，在消息发送后，可以在当前时间点之后的某一个时间点，再投递到...
消息轨迹
查询时间区间是否正确，为了提高查询速度，需要您输入消息的发送时间范围。如果查询不到，请尝试扩大时间范围重试。如果确认上述情况无误，但仍然无法查询到结果，请 提交工单 获得技术支持，并附带上日志文件，日志文件位于/home/{user}/...
应用场景
本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...
查看监控数据
点击左侧的 资源监控>服务器明细 菜单，可以看到当前应用在服务器中的相关指标监控数据，如 CPU 使用率、内存使用率、磁盘使用率等。应用日志 在应用监控详情页中，点击左侧的 应用日志>日志查询 菜单，可以查看当前应用的运行日志。支持按...
基础术语
本文主要对 SOFAStack 消息队列涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用消息队列。中文 英文 释义 消息主题 Topic 消息主题，一级消息类型，通过 Topic 对消息进行分类。详情请参见 Topic 与 Tag。消息 ...
报警管理
消费延迟阈值：消费延迟的值是指该 Group ID 最近一次消费该 Topic 消息的时间和该 Topic 最近一次投递消息的时间之间的差值。可设置的消费延迟阈值的最小值是 1 分钟。报警时间：时间精确到分钟，最大范围为 00:00～23:59。您只会在设置的...
消息幂等
消费者收到消息时可以根据消息的 Key，即订单号来实现消息幂等：consumer.subscribe("ons_test","*",new GenericMessageListener(){@Override public Class<OrderPojo>payloadClass(){ return OrderPojo.class;}@Override public Action ...
应用身份识别
根据您选择的中间件类型，控制台会显示可选的中间件版本供您选择。JDK版本 选择JDK（Java语言软件开发工具包）版本。数据库类型 选择数据库类型，请根据数据库的实际情况选择。可选项：Oracle MySQL SQLServer PostgreSQL DB2 登录URL关键...
资产指纹调查
中间件 定期采集服务器的中间件信息。中间件是指可独立运行的系统组件，例如MySQL（数据库）、Docker（容器组件）等。具体采集以下内容：服务器信息：中间件所在的服务器信息，包括服务器名称和IP地址。中间件：中间件的名称。类型：中间件...
创建和管理 Group ID
创建完 Topic 后，您需要为消息的消费者（或生产者）创建客户端 ID，即 Group ID 作为标识。Group ID 和 Topic 的关系是 N：N，即一个消费者可以订阅多个 Topic，同一个 Topic 也可以被多个消费者订阅；一个生产者可以向多个 Topic 发送...
消息负载均衡策略
消息队列的消息负载策略针对发布方和订阅方有所差异。对订阅方而言，消息负载策略在一定程度上影响消息堆积。发布方消息负载均衡策略 消息队列针对发布方采取的是轮询制，即 Producer 的消息以轮询的方式发送至 Queue，如下图所示。图中...
EMQX数据接入
背景信息 EMQX Cloud是EMQ公司推出的一款面向物联网领域的MQTT消息中间件产品。EMQX Cloud提供了一站式运维代管、独有隔离环境的MQTT消息服务。在万物互联的时代，EMQX Cloud可以帮助您快速构建面向物联网领域的行业应用，轻松实现物联网...
集群消费和广播消费
消费者，即消息的订阅方订阅关注的 Topic，以获取并消费消息。由于消费者应用一般是分布式系统，以集群方式部署，因此消息队列约定以下概念：集群：使用相同 Group ID 的消费者属于同一个集群。同一个集群下的消费者消费逻辑必须完全一致...
消息堆积
常见的消息堆积相关问题如下：如何处理消息堆积？除了异步解耦功能，消息队列还有挡住前端数据洪峰的重要功能，以此保证后端系统的稳定性。这要求消息队列具有一定的消息堆积能力。消息队列能支持 10 亿级别的消息堆积，不会因为消息堆积...
版本说明
0.6（2020-01-10）发布 SOFAStack 消息队列，是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成。支持多种消息类型：普通消息、定时消息、分区顺序消息、事务消息。详见 消息类型。提供专业、可靠、...
收发顺序消息
本文提供使用 TCP 协议下的 Java SDK 收发顺序消息的示例代码供您参考。前提条件 您已完成以下操作：通过 Maven 方式引入依赖。Java SDK 的最新版本号，可参见 SDK 版本说明。dependency><groupId>...
消费重试
以下场景建议使用消息重试 业务处理失败，且失败原因跟当前的消息内容相关，比如该消息对应的事务状态还未获取到，预期一段时间后可执行成功。消费失败的原因不会导致连续性，即当前消息消费失败是一个小概率事件，不是常态化的失败，后面...
产品架构
集群级别的高可用，是消息队列跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为是成功了。说明 文中所提及的消息队列的服务端或者服务器包含 Name ...
使用异常
收到消息后，如果直接进入业务逻辑，一旦代码遗漏某个逻辑分支，就会导致消息信息没有被留在业务日志里，造成没有收到消息的假象。建议您收到消息后，立即打印消息信息留存 messageId、timestamp、reconsumeTime 等。消费端部署了多个消费...
名词解释
应用运行所依赖中间件及中间件相关配置，可以是第三方的中间件（mysql、redis、MongoDB等）也可以是阿里云服务（RDS、Redis、OTS等）的相关软件初始化内容。应用依赖的IoT提供的接口服务列表。应用依赖的数据模型列表。应用依赖的服务模型...
基于RocketMQ指标的容器水平伸缩
RocketMQ作为一种高性能、高可靠、高扩展性的分布式消息中间件，已经被广泛应用于企业级应用中。但在使用RocketMQ时，消息堆积是常见的问题，特别是在高负载情况下，消息堆积很容易导致系统负载过高，甚至服务崩溃。为了解决这个问题，您...
应用内存不足
本文介绍在使用消息队列时出现应用内存不足时的一些常见问题及解决方法。现象 在应用部署的机器上查看内存已消耗完。在/{user.home}/logs/sofamq.log 能搜索到 OutOfMemory 关键字。在消息队列控制台查看目标 Group ID 的消费者状态，堆积...
DBS
目前支持DBS开放的中间件节点有：MySQL、SQL Server。打开入口 在运维界面中，打开DBS开启的入口，如下所示。访问入口 单击 打开DBS入口 后，会显示一个访问地址和端口，您可以登录DBS服务，使用这里的地址和端口，以及该节点配置时，指定...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
将 Spring Boot 工程迁移至 SOFABoot 工程
在阅读本文中的 注意事项 后，您可以遵循 迁移步骤 将现有的 Spring Boot 工程改为使用 SOFABoot 框架的工程。注意事项 SOFABoot 框架基于 Spring Boot 2.1.0.RELEASE 版本构建，您在迁移过程中可能会发生 Spring Boot 版本的变更。如果在...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
- 产品推荐
- 这些文档可能帮助您