发布者最佳实践

默认情况下,云消息队列 Kafka 版 为了提升可用性,并不保证单个分区内绝对有序,在升级或者宕机时,会发生少量消息乱序(某个分区挂掉后把消息Failover到其它分区)。如果业务要求分区保证严格有序,请在创建Topic时选择使用Local存储。

MQTT与RocketMQ的消息结构映射

云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的消息负载(Payload)均是您的业务消息的数据序列化结果,云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 不会对业务消息再做进一步的编解码处理。属性字段映射 目前,云消息队列 MQTT 版 ...

Topic与Tag最佳实践

消息队列RocketMQ版 中,Topic与Tag都是业务上用来归类的标识,区分在于Topic是一级分类,而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下:Topic 消息主题,通过...

消息(Message)

消息负载 消息负载 定义:业务消息的实际报文数据。取值:由生产者负责序列化编码,按照二进制字节传输。约束:请参见 参数限制。行为约束 消息大小不得超过其类型所对应的限制,否则消息会发送失败。系统默认的消息最大限制如下:普通和...

什么是消息队列RabbitMQ版?

核心概念 云消息队列 RabbitMQ 版 的核心概念如下:生产者:发送消息的应用。消费者:接收消息的应用。Exchange:将消息路由到Queue的组件。Queue:存储消息的缓冲区。更多 云消息队列 RabbitMQ 版 相关概念,请参见 名词解释。云消息队列 ...

消息查询

对每条消息设置其检索的Key,该Key值代表消息的业务关键属性,请尽可能全局唯一。以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息。不设置也不会影响消息正常收发。msg.setKey("TestKey"+System....

收发定时消息

本文提供使用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等,需要在控制台上提前创建。更多...

发送普通消息(三种方式)

设置代表消息的业务关键属性,请尽可能全局唯一。以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_"+i);try { SendResult sendResult=...

收发定时消息

本文提供使用TCP协议下的Java SDK收发定时消息的示例代码。背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费,适用于对消息生产和消费有时间窗口要求,或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...

收发事务消息

本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...

收发定时消息

设置代表消息的业务关键属性,请尽可能全局唯一。以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time,单位:ms。指定一个...

查询消息轨迹

Topic:Key:消息的业务标识,由消息生产者设置,唯一标识某个业务逻辑。Tag:消息标签,二级消息类型,用来进一步区分某个 Topic 下的消息分类。消费者:耗时:消息推送到客户端之后执行 consumeMessage 方法的耗时。投递时间:客户端执行...

函数计算

利用函数实现业务消息的处理,通过函数计算平台开发、运行业务消息处理逻辑,订单处理,任务执行。利用函数对消息进行快速加工处理,ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...

函数计算

利用函数实现业务消息的处理,通过函数计算平台开发、运行业务消息处理逻辑,订单处理,任务执行。利用函数对消息进行快速加工处理,ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...

步骤五:到控制台验证

Topic 信息:Topic 所在 Zone、Topic 名称、消息的业务标识 key、消息标签 tag。消费者信息:消费者所在 Zone、耗时、投递时间、消费状态。按单元推送动态配置 在转账场景中,您还可以通过微服务按单元推送动态配置。操作步骤如下:登录微...

收发事务消息

设置代表消息的业务关键属性,请尽可能全局唯一。以方便您在无法正常收到消息情况下,可通消息队列RocketMQ版过控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");发送消息,只要不抛出异常,就代表...

示例代码

设置代表消息的业务关键属性,请尽可能全局唯一。以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_"+i);try { SendResult sendResult=...

批量消费

如需提高消息的处理效率,或降低下游资源的API调用频率,您可使用批量消费功能。本文介绍批量消费的定义、优势与场景、使用限制和示例代码等信息。什么是批量消费 定义 批量消费是 云消息队列 RocketMQ 版 通过Push消费者提供的、将消息分...

调用TCP协议的SDK收发普通消息

设置代表消息的业务关键属性,请尽可能全局唯一。以方便您在无法正常收到消息情况下,可通过控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");异步发送消息,发送结果通过callback返回给客户端。...

创建FC Sink Connector

利用函数实现业务消息的处理,通过函数计算平台开发、运行业务消息处理逻辑,订单处理,任务执行。利用函数对消息进行快速加工处理,ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其他下游系统。利用函数连接消息系统和其他阿里云...

功能发布列表

功能描述 变更类型 相关文档 5.x系列实例 自建RocketMQ集群迁移上云 提供开源RocketMQ集群迁移上云工具,支持分批次将元数据迁移至阿里云 云消息队列 RocketMQ 版 的实例中,并支持按Topic粒度对客户端读写流量进行切换实现业务消息的迁移...

示例代码

设置代表消息的业务关键属性,请尽可能全局唯一。以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time,单位:ms。指定一个...

消息存储和清理机制

本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制,包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义,消息按照达到服务器的先后顺序被存储到队列中,理论上每个队列都支持无限...

混合云接入

混合云接入是阿里云为部署在非阿里云的业务流量提供的Web应用防护和管理方案。如果您的业务部署在第三方公共云、私有云、线下IDC机房等,您可以通过混合云接入方式,通过 Web应用防火墙(Web Application Firewall,简称WAF)统一管控和运...

附录:SOFAStack 产品目录

产品架构 产品优势 跨云/跨域互通 支持对混合云和多业务域之间的网络互通,实现 API 的统一管理。弱网优化 针对移动端的特性,优化弱网下的数据传输通信协议,提高网络通信质量和效率。异构集成 支持不同语言和不同技术栈实现的业务系统...

常见问题

在分布式事务服务挂掉的情况下,事务是否能正常回滚?分布式事务的服务端会记录下事务的状态并持久化,即使服务挂掉,在服务重新启动后,事务仍然能够正常回滚。建表时,是否可以使用 SQL 的关键字作为列的名称?不可以,建表时列名不能...

基本概念

Sharding Key 是顺序消息中用来区分不同分区的关键字段,和普通消息的 Message Key 是完全不同的概念。详情请参见 消息类型>顺序消息。分布式事务 distributed transaction,事务的发起者、资源及资源管理器和事务协调者分别位于不同的分布...

文档更新动态(2022年)

维度更名为业务对象,业务过程更名为业务活动,并增加三种子类型:事件、业务流程和业务快照。更新说明 创建并管理业务实体 创建并管理业务活动 创建并管理主题域 2022年07月19日 离线管道功能增强 支持项目中的物理表作为管道任务中的来源...

使用异常

收到消息后,如果直接进入业务逻辑,一旦代码遗漏某个逻辑分支,就会导致消息信息没有被留在业务日志里,造成没有收到消息的假象。建议您收到消息后,立即打印消息信息留存 messageId、timestamp、reconsumeTime 等。消费端部署了多个消费...

基于云备份统一备份云上数据

本文介绍基于 云备份(Cloud Backup)的统一备份云上数据功能。该功能主要为阿里云ECS、NAS、OSS,以及自建机房内的各类数据提供安全、高效的备份服务,主要解决阿里云云上数据和数据中心备份问题。云上统一备份的业务架构如下图所示。适用...

消费重试

消费失败的原因不会导致连续性,即当前消息消费失败是一个小概率事件,不是常态化的失败,后面的消息大概率会消费成功。此时可以对当前消息进行重试,避免进程阻塞。以下场景不建议使用消息重试 消费处理逻辑中使用消费失败来做条件判断的...

消息堆积和延迟问题

通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因,帮助您可以在业务部署前更好的规划资源和配置,或在运维过程中及时调整业务逻辑,避免因消息堆积和延迟影响业务运行。背景信息 消息处理流程中,如果客户端的消费...

什么是云开发平台

统一的团队业务环境:提供统一灵活的团队环境,团队成员随时随地都可以投入开发工作,也让每一个新人都可以立即投入到新业务开发。全云端的开发环境实现所测即所得、测完即上线的快速交付;一致的 Serverless 环境:不需要购买和部署传统...

消息回放

消息回放会按照设备消息数重新消耗企业版实例下的 消息上下行TPS 或 消息转发TPS 资源,但消息回放消耗的资源规格不会超过当前企业版实例下 消息上下行TPS 或 消息转发TPS 可用资源的 50%。创建消息回放任务 登录 物联网平台控制台。在 ...

API 统一网关

API 网关是金融分布式架构 SOFAStack 下的一个 API ...支持多种自定义参数配置模型,包括参数映射、数据模型、外部授权 API 等,满足不同业务场景的统一网关需求。关于 API 网关详细的功能介绍和使用指南,请参见 SOFAStack API 统一网关。

消息重试

注意事项 一条消息无论重试多少次,这些重试消息的Message ID都不会改变。消息重试只针对集群消费模式生效;广播消费模式不提供失败重试特性,即消费失败后,失败消息不再重试,继续消费新的消息。消息重试策略概述 云消息队列 RocketMQ 版...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云数据库 Redis 版 云服务器 ECS 物联网无线连接服务 数字证书管理服务(原SSL证书) 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用