云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档，帮助您了解 云消息队列 RocketMQ 版 的发布动态。2024-04-24 实例系列 功能名称 功能描述 变更类型 相关文档 5.x系列实例 Serverless公网...
云消息队列 RocketMQ 版 提供多种语言的SDK用于收发不同类型的消息，本文以Java SDK为例，说明如何调用SDK连接 云消息队列 RocketMQ 版 服务端，完成普通消息的收发流程。前提条件 步骤二：创建资源 安装IDEA 您可以使用IntelliJ IDEA或者...
Java版本为java 8。创建流程 创建步骤 云消息队列 Kafka 版 支持创建消息流入任务将其他资源服务通过Kafka Connect投递到Kafka，也可以创建消息流出任务将Kafka资源通过Kafka Connect投递到其他资源服务。本文以创建消息流入（Source）任务...
云消息队列 RabbitMQ 版是阿里云消息队列（MQ）团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维，帮助您快速上云。
本文提供使用TCP协议下的Java SDK收发事务消息的示例代码。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，...
云消息队列 MQTT 版广泛应用移动互联网以及物联网领域，覆盖互动直播、车联网、金融支付、智能餐饮、即时聊天、移动App等多种应用场景。
云消息队列 Kafka 版（ApsaraMQ for Kafka）秉持开放的原则拥抱开源，全面融合Kafka开源生态，做到无缝迁移，打造更安全、更可靠、更易运维的Kafka企业级消息服务。
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
云消息队列 RocketMQ 版（原名开放消息服务，简称ONS）是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。
针对初次接触 云消息队列 RocketMQ 版 的工程师，本文以TCP协议下的Java SDK为例，提供操作示例帮助您从零开始搭建 云消息队列 RocketMQ 版 测试工程。Demo工程包含普通消息、顺序消息、事务消息、定时和延时消息的测试代码，以及相关...
云消息队列 RocketMQ 版 于2021年10月18日发布新版本Java SDK和C++ SDK客户端，本次发布对客户端大版本进行了升级。本文介绍发布的SDK版本信息、支持升级的地域以及主要的功能差异。SDK版本信息 本次发布的SDK客户端版本信息如下：协议 ...
} } 自定义消息最大重试次数和重试间隔 说明 自定义 云消息队列 RocketMQ 版 的客户端日志配置，请升级TCP Java SDK到1.2.2或以上版本。更多信息，请参见 版本说明。云消息队列 RocketMQ 版 允许Consumer实例启动的时候设置最大重试次数和...
本文介绍RocketMQ 5.x系列Java SDK的版本信息，以便您获取合适的Java SDK收发消息。说明 RocketMQ 5.x系列Java SDK支持JDK 1.8或以上版本。推荐版本 云消息队列 RocketMQ 版 支持使用Apache RocketMQ开源SDK访问。同时支持以下历史版本：...
本文以Java SDK为例介绍如何在公网环境下使用SDK接入 云消息队列 Kafka 版 的SSL接入点并使用PLAIN机制收发消息。前提条件 步骤三：创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在 pom.xml 中添加以下依赖。...
本文以Java SDK为例，说明如何将开源SDK客户端接入 云消息队列 RabbitMQ 版 服务端，并完成消息收发。前提条件 创建资源 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA Ultimate为例。安装JDK 安装Maven 安装Java依赖...
示例代码 消息类型 发送消息示例代码 订阅消息示例代码 PushConsumer SimpleConsumer 普通消息 同步发送：ProducerNormalMessageExample.java 异步发送：AsyncProducerExample.java PushConsumerExample.java 同步订阅：...
云消息队列 MQTT 版 支持使用多种语言的SDK接入服务端实现消息收发，本文以Java为例介绍不同场景下的消息收发流程。操作流程 使用SDK收发消息流程如下图所示。具体操作步骤如下：开通服务并授权 开通消息队列服务，并授予RAM用户操作 云...
当您想要将A地域的 云消息队列 Kafka 版 上的业务无损迁移至B地域，或者创建实例后想复制已有实例元数据（Topic、Group）配置时，您可以使用 云消息队列 Kafka 版 提供的迁移工具将某个 云消息队列 Kafka 版 实例的Topic、Group迁移至另...
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
本文提供使用TCP协议下的Java SDK收发定时消息的示例代码。背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...
本文以单直播间、一名老师、两名学生的场景为例，说明如何使用 云消息队列 MQTT 版 实现直播互动消息、禁言、成员上下线通知以及系统消息通知，其中，老师和学生的客户端以HTML网页为例，后端应用以Java为例。背景信息 在直播互动的场景下...
本文介绍如何获取和使用...语言 下载地址 说明文档 Java Alibaba Cloud AMQP SDK for Java 开始使用 Go Alibaba Cloud AMQP SDK for Go 开始使用 Python Alibaba Cloud AMQP SDK for Python 开始使用 PHP Alibaba Cloud AMQP for PHP 开始使用
本文为您介绍如何将开源MQTT客户端从其他开源MQTT服务端迁移至阿里云的 云消息队列 MQTT 版 服务端上。背景信息 云消息队列 MQTT 版 拥有多协议、多语言平台的开发能力，并支持设备级权限控制以及SSL/TLS传输加密，您可以不变更开源客户端...
本文汇总了使用 云消息队列 Kafka 版 实例时的常见问题。计费问题 为什么购买了按量付费实例后不使用也要收费？为什么按流量峰值收费？按流量峰值收费的依据是什么？为什么额外增加分区要收费？我使用的Connector组件如何计费？客户端报错 ...
报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）失败 说明 该报错仅出现在 云消息队列 Kafka 版 的公网实例中。确保servers配置正确。通过 telnet 命令排除网络问题。如果网络...
本文介绍如何配置服务端订阅，将产品下的设备状态变化消息推送到消息服务（MNS）队列中；服务器通过监听MNS队列接收设备状态变化消息。前提条件 开通阿里云产品：物联网平台。消息服务。准备开发环境，本示例使用Java开发环境如下：操作...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...
在2019年01月23日，云消息队列 RocketMQ 版 优化了资源隔离、资源申请、协议支持以及权限管理。本文提供相关更新说明，帮助您更顺畅地使用 云消息队列 RocketMQ 版。说明 为兼容新老资源配置，建议您将ons-client客户端升级到最新版本。...
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
云消息队列 RocketMQ 版 提供的分布式事务消息适用于所有对数据最终一致性有强需求的场景。本文介绍 云消息队列 RocketMQ 版 事务消息的概念、优势、典型场景、交互流程、使用规则以及示例代码。概念介绍 事务消息：云消息队列 RocketMQ 版...
云消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作：下载1.2.7或以上版本的Java SDK。更多信息，请参见...
rocketmq.enable.message.trace 设置为 true canal.mq.accessChannel 设置为 cloud 序列化方式设置 Canal向 云消息队列 RocketMQ 版 写入的数据是Canal指定的序列化格式，具体代码示例，请参见 CanalRocketMQClientExample.java。...
消息收发为 云消息队列 MQTT 版 最基本的功能，云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
云消息队列 RabbitMQ 版 SDK（RAM角色跨账号授权场景）如果您是RAM STS角色授权的使用场景，需要通过 云消息队列 RabbitMQ 版 SDK收发消息，该SDK只比开源SDK多一个加签依赖。云消息队列 RabbitMQ 版 支持的多语言或框架SDK如 云消息队列 ...
rocketmq.enable.message.trace 设置为 true canal.mq.accessChannel 设置为 cloud 序列化方式设置 Canal向 云消息队列 RocketMQ 版 写入的数据是Canal指定的序列化格式，具体代码示例，请参见 CanalRocketMQClientExample.java。...
背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载均衡策略可分为：负载均衡策略（客户端Java v2.x.x.Final和C++ v3.x.x）负载均衡策略（客户端Java v1.x.x.Final和C++ v1.x.x/v2.x.x）...
如需追踪和识别消息，您可以在 云消息队列 RabbitMQ 版 的Producer客户端设置Message ID属性，为每条消息设置唯一标识符。本文介绍Message ID的相关概念和设置方法。什么是Message ID Message ID（消息标识符）是消息的可选属性，类型为...
本文列举 云消息队列 RocketMQ 版 所支持的所有功能与特性。概览 云消息队列 RocketMQ 版 在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布...