Windows系统实例的宕机问题排查
定位宕机原因 您可以通过以下方式，定位ECS实例发生宕机的具体原因。方式一：（推荐）通过自助诊断工具定位 登录 ECS管理控制台，左侧导航栏单击 自助问题排查。单击 实例问题排查 页签。选择 实例无法连接或启动异常>实例出现宕机，然后...
消息幂等
消息重复的可能原因如下：发送时消息重复 当一条消息已被成功发送到服务端并完成持久化，此时出现了网络闪断或者客户端宕机，导致服务端对客户端应答失败。如果此时Producer意识到消息发送失败并尝试再次发送消息，Consumer后续会收到两条...
MQTT与RocketMQ的消息结构映射
云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的消息负载（Payload）均是您的业务消息的数据序列化结果，云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 不会对业务消息再做进一步的编解码处理。属性字段映射 目前，云消息队列 MQTT 版 ...
Topic与Tag最佳实践
在 消息队列RocketMQ版 中，Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下：Topic 消息主题，通过...
网络架构介绍
业务网络 用于承载用户业务虚拟机的业务网络。用户在VMware服务产品控制台完成NSX Overlay网段添加后，再登录NSX Manager控制台添加网络分段。业务虚拟机 用户基于业务需求创建的虚拟机，连接虚拟机的网卡至业务网络。T1 MGW VMware NSX T1...
基本概念
Message Key 消息的业务标识，由消息生产者（Producer）设置，唯一标识某个业务逻辑。Tag 消息标签，二级消息类型，用来进一步区分某个Topic下的消息分类。更多信息，请参见 Topic与Tag最佳实践。Producer 消息生产者，也称为消息发布者，...
消息（Message）
消息负载 消息负载 定义：业务消息的实际报文数据。取值：由生产者负责序列化编码，按照二进制字节传输。约束：请参见 参数限制。行为约束 消息大小不得超过其类型所对应的限制，否则消息会发送失败。系统默认的消息最大限制如下：普通和...
什么是消息队列RabbitMQ版？
核心概念 云消息队列 RabbitMQ 版 的核心概念如下：生产者：发送消息的应用。消费者：接收消息的应用。Exchange：将消息路由到Queue的组件。Queue：存储消息的缓冲区。更多 云消息队列 RabbitMQ 版 相关概念，请参见 名词解释。云消息队列 ...
消息查询
对每条消息设置其检索的Key，该Key值代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息。不设置也不会影响消息正常收发。msg.setKey("TestKey"+System....
消费幂等
消息重复的场景如下：发送时消息重复 当一条消息已被成功发送到服务端并完成持久化，此时出现了网络闪断或者客户端宕机，导致服务端对客户端应答失败。如果此时生产者意识到消息发送失败并尝试再次发送消息，消费者后续会收到两条内容相同...
云消息队列 Kafka 版何时删除旧消息？
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
收发定时消息
本文提供使用TCP协议下的C/C++ SDK收发定时消息的示例代码供您参考。定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...
收发普通消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");发送消息，只要不抛出异常，就代表...
创建和管理 Topic
Key：可选，消息的业务标识，由消息生产者设置，唯一标识某个业务逻辑。消息体：必填，需要发送的具体消息内容。单击 确定，即可发送测试消息。消息发送后，您可以直接单击 进入消息查询 查看该消息的发送情况，或复制该消息的 MessageID ...
Topic 与 Tag
在 SOFAStack 消息队列中，Topic 与 Tag 都是业务上用来归类的标识，区分在于 Topic 是一级分类，而 Tag 可以理解为是二级分类。您可通过本文了解如何搭配使用 Topic 和 Tag 来实现消息过滤。背景信息 Topic 和 Tag 的定义如下：Topic：...
收发延时消息
本文提供使用TCP协议下的Java SDK收发延时消息的示例代码供您参考。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备环境。创建资源。代码中涉及的资源信息，例如实例、Topic和Group ID等，需要在控制台上提前创建。更多...
VMware无代理迁移
VMware无代理迁移 通过VMware Agentless无侵入式迁移技术，可将VMware虚拟机的业务迁移到阿里云，提高业务迁移到阿里云的效率，同时消除您对迁移过程业务安全和业务性能的顾虑。本文介绍VMware无代理迁移的产品优势、应用场景、使用限制等...
发送普通消息（三种方式）
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_"+i);try { SendResult sendResult=...
收发事务消息
本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...
收发定时消息
本文提供使用TCP协议下的Java SDK收发定时消息的示例代码。背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...
收发定时消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time，单位：ms。指定一个...
函数计算
利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...
函数计算
利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...
基本概念
但是会出现部分分区发送消息失败的情况，等到宕机机器重新上线后即可恢复正常。更多信息，请参见 存储引擎对比。Connector 云消息队列 Kafka 版 的组件，用于 云消息队列 Kafka 版 和其他阿里云服务之间的数据同步。更多信息，请参见 ...
消息幂等
当一条消息已被成功发送到服务端并完成持久化，此时出现了网络闪断或者客户端宕机，导致服务端对客户端应答失败。如果此时生产者意识到消息发送失败并尝试再次发送消息，消费者后续会收到两条内容相同并且 Message ID 也相同的消息。投递时...
收发事务消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通消息队列RocketMQ版过控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");发送消息，只要不抛出异常，就代表...
步骤五：到控制台验证
Topic 信息：Topic 所在 Zone、Topic 名称、消息的业务标识 key、消息标签 tag。消费者信息：消费者所在 Zone、耗时、投递时间、消费状态。按单元推送动态配置 在转账场景中，您还可以通过微服务按单元推送动态配置。操作步骤如下：登录微...
功能发布列表
功能描述 变更类型 相关文档 5.x系列实例 自建RocketMQ集群迁移上云 提供开源RocketMQ集群迁移上云工具，支持分批次将元数据迁移至阿里云 云消息队列 RocketMQ 版 的实例中，并支持按Topic粒度对客户端读写流量进行切换实现业务消息的迁移...
批量消费
如需提高消息的处理效率，或降低下游资源的API调用频率，您可使用批量消费功能。本文介绍批量消费的定义、优势与场景、使用限制和示例代码等信息。什么是批量消费 定义 批量消费是 云消息队列 RocketMQ 版 通过Push消费者提供的、将消息分...
示例代码
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_"+i);try { SendResult sendResult=...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
调用TCP协议的SDK收发普通消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");异步发送消息，发送结果通过callback返回给客户端。...
开源对比
项目 云消息队列 Kafka 版 Apache Kafka 差异原因 Topic 创建方式 云消息队列 Kafka 版 控制台 云消息队列 Kafka 版 OpenAPI 服务端自动创建（默认不开启）Kafka CLI Kafka Manager 服务端自动创建 云消息队列 Kafka 版 默认通过阿里云控制...
清林云
稳定性难以保障：某节点的宕机会导致整个服务的中断。问题定位困难：长时间流的执行丢失，若出现内存泄漏等问题，将难以定位，流状态管理复杂。高阶企业级需求难满足：自动化流的分布式问题难以解决，定时等任务还需要引入外部组件，多租户...
清林云
稳定性难以保障：某节点的宕机会导致整个服务的中断。问题定位困难：长时间流的执行丢失，若出现内存泄漏等问题，将难以定位，流状态管理复杂。高阶企业级需求难满足：自动化流的分布式问题难以解决，定时等任务还需要引入外部组件，多租户...
自动创建Topic
例如网络抖动、服务端升级、管控平台升级维护、ECS宕机等情况，会大幅度增加创建Topic的耗时，导致创建失败。业务冲突：自动创建Topic，容易触发不同业务名称冲突，如果触发会导致不同业务数据混合，很难发现问题。发现之后，恢复难度过大...
示例代码
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time，单位：ms。指定一个...
自动化创建Topic相关问题
例如网络抖动、服务端升级、管控平台升级维护、ECS宕机等情况，会大幅度增加创建Topic的耗时，业务的超时是固定的，必然因为超时，导致创建失败。业务冲突：自动创建Topic，容易触发不同业务名称冲突，如果触发，不同业务数据混合，很难...
消费重试
系统异常时处理中的消息状态如何恢复：帮助您了解当系统出现异常（宕机故障）等场景时，处理中的消息状态如何恢复，是否会出现状态不一致。消费重试策略 消费重试策略指消费者在消费某条消息失败后，消息重试的间隔时间和最大重试次数。...
自动创建Topic
例如网络抖动、服务端升级、管控平台升级维护、ECS宕机等情况，会大幅度增加创建Topic的耗时，业务的超时是固定的，必然因为超时，导致创建失败。业务冲突：自动创建Topic，容易触发不同业务名称冲突，如果触发会导致不同业务数据混合，很...
- 产品推荐
- 这些文档可能帮助您