为什么不推荐使用Sarama Go客户端收发消息？
当Sarama Go客户端同时订阅两个以上的Topic时，有可能会导致部分分区无法正常消费消息。当Sarama Go客户端的消费位点重置策略设置为 Oldest(earliest)时，如果客户端宕机或服务端版本升级，由于Sarama Go客户端自行实现OutOfRange机制，有...
注意要点
生产环境大规模消费消息推荐使用 basicConsume，而不是 basicGet。queueDeclare 和 exchangeDeclare 等元数据接口有限流限制，建议在控制台上创建，不建议在发送数据时调用，否则可能触发限流导致连接关闭。更多信息，请参见 使用限制。
版本说明
推荐版本 云消息队列 RocketMQ 版 5.x系列实例完全兼容Apache RocketMQ Go SDK，以下版本经由阿里云工程师进行测试验证，建议您使用以下SDK版本进行消息收发。具体推荐版本：rocketmq-client-golang-5.0.0 历史版本 更多历史版本，请参见 ...
版本说明
推荐版本 云消息队列 RocketMQ 版 5.x版本实例完全兼容Apache RocketMQ C#SDK，以下版本经由阿里云工程师进行测试验证，建议您使用以下SDK版本进行消息收发。具体推荐版本：rocketmq-client-csharp-5.1.0 dotnet add package RocketMQ....
步骤二：创建资源
包年包月或按量付费实例配置参数 参数 取值示例 主系列类型 标准版 子系列类型 集群高可用版本（生产环境推荐）消息收发计算规格 rmq.s2.2xlarge VPC ID vpc-bp1cg09dua6sgh0*该参数为您在前提条件中创建的专有网络的ID。重要 云消息队列 ...
QueryDataMessage-查询用户数据表中的更新消息
用户数据表中的更新消息查询。接口说明 查询用户指定实例，指定数据表中的更新消息。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 当前API...
查询用户数据表中的更新消息统计数据
用户数据表中的更新消息统计数据查询。接口说明 查询用户指定实例，指定数据表中的更新消息的统计数据。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。...
版本说明
推荐版本 云消息队列 RocketMQ 版 支持使用Apache RocketMQ开源SDK访问。同时支持以下历史版本：rocketmq-client 5.x版本 rocketmq-client 4.x版本 rocketmq-client 3.x版本 推荐您使用Apache RocketMQ 5.x版本的SDK获取更高的性能和更全面...
评估规格
使用说明 云消息队列 Kafka 版 提供的规格评估功能将根据您输入的自建Kafka集群的信息，如集群流量情况、磁盘容量和类型、分区数量等，来为您评估并推荐需要的 云消息队列 Kafka 版 实例规格，帮助您提前根据推荐部署 云消息队列 Kafka 版 ...
版本说明
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
环境准备（v2.x.x）
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
版本说明
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面地功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x系列SDK和ONS系列SDK后续仅做...
Spring集成
步骤三：调用SDK收发消息 创建连接 推荐缓存模式：客户端和服务端建立连接时，推荐将缓存模式设置为 CONNECTION 模式。该模式下支持创建多个Connection，程序会缓存一定数量的Connection，每个Connection中缓存一定的Channel。云消息队列 ...
环境准备
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
批量消费
如需提高消息的处理效率，或降低下游资源的API调用频率，您可使用批量...此外，为了获得更好的批量消费效果，强烈推荐您实现消息幂等，保证消息有且仅被处理1次。幂等处理的具体信息，请参见 消费幂等。更多信息 商业版TCP Java SDK订阅消息
环境准备（v1.x.x）
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
收发事务消息
如果要求消息绝对不重复，推荐做法是对消息体body使用crc32或MD5来防止重复消息。TransactionStatus transactionStatus=Unknow;try { boolean isCommit=本地事务执行结果;if(isCommit){/本地事务成功、提交消息。transactionStatus=...
收发事务消息
如果要求消息绝对不重复，推荐做法是对消息体body使用crc32或MD5来防止重复消息。TransactionStatus transactionStatus=TransactionStatus.Unknow;try { boolean isCommit=本地事务执行结果;if(isCommit){/本地事务成功则提交消息。...
通知
消息服务MNS 不再提供Android SDK，如果您的客户端是Android操作系统，推荐您使用微消息队列MQTT。阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车联网...
名词解释
网络类 ServerUrl 云消息队列 MQTT 版 推荐移动终端使用公网接入点，也支持内网接入点。目前 云消息队列 MQTT 版 的接入除了支持标准协议的1883端口，同时还支持加密SSL、WebSocket等方式。接入点URL是在创建实例之后自动分配，请妥善保管...
创建RocketMQ Sink Connector
说明 如果需要全量传递源端的RocketMQ消息的属性，推荐使用示例中的配置。变量：{"userProperties":"$.data.userProperties","msgId":"$.data.systemProperties.UNIQ_KEY"} 模板：{"EB_SYS_EMBED_OBJECT":"${userProperties}","UNIQ_KEY":...
通知
消息服务MNS 不再提供Objective-C iOS SDK，如果您的客户端是iOS操作系统，推荐您使用微消息队列MQTT。阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车...
快速入门概述
VPC访问（推荐）：云消息队列 RocketMQ 版 实例默认提供VPC接入点。生产环境建议使用VPC网络访问 云消息队列 RocketMQ 版 服务。公网访问：使用公网访问，需要手动开启公网访问功能。开启后，实例同时提供VPC接入点和公网接入点。公网访问...
迁移概述
说明 如果元数据文件中包含了自建Kafka集群的流量、磁盘、配置等信息，购买实例时，云消息队列 Kafka 版 会根据元数据文件信息，自动评估并推荐实例规格，您可以根据推荐意见购买实例。迁移自建Kafka集群元数据至已有实例：在 云消息队列 ...
示例代码
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
示例代码
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
概述
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
概述
和社区版SDK相比，商业版的SDK提供了更加丰富的功能特性并具有更高的稳定性保障，推荐您使用商业版SDK访问阿里云 云消息队列 RocketMQ 版。更多信息，请参见 商业版TCP协议SDK。适用场景 使用社区版TCP协议的SDK访问阿里云 云消息队列 ...
常见问题
消费端从服务端拉取不到消息或拉取消息缓慢 为什么不推荐使用Sarama Go客户端收发消息？使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息 实例问题 实例支持哪些开源版本？VPC实例和公网/VPC实例的区别是什么？...
消息查询
推荐查询过程 推荐按照以下流程查询消息。操作步骤 登录 云消息队列 RocketMQ 版 控制台，在左侧导航栏，单击 实例列表。在顶部菜单栏，选择地域，如 华东1（杭州）。在 实例列表 页面，找到目标实例，在其 操作 列，单击 更多，然后在下拉...
配置消息监控告警实现风险预警
根据大量生产环境实践经验，建议您根据以下原则配置如下告警：说明 以下核心监控项仅为基础推荐配置项，云消息队列 RocketMQ 版 提供了全面、丰富的监控指标项，您可以根据业务需求进行更细粒度更全面的告警配置。更多信息，请参见 监控...
配置消息监控告警实现风险预警
根据大量生产环境实践经验，建议您根据以下原则配置如下告警：说明 以下核心监控项仅为基础推荐配置项，云消息队列 RocketMQ 版 提供了全面、丰富的监控指标项，您可以根据业务需求进行更细粒度和更全面的告警配置。更多信息，请参见 监控...
身份管理
推荐的做法是使用RAM身份（即RAM用户和RAM角色）来访问 云消息队列 RocketMQ 版。RAM用户 RAM用户需要由阿里云账号（即主账号）或拥有管理员权限的RAM用户、RAM角色来创建，且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的...
身份管理
推荐的做法是使用RAM身份（即RAM用户和RAM角色）来访问 云消息队列 RocketMQ 版。RAM用户 RAM用户需要由阿里云账号（即主账号）或拥有管理员权限的RAM用户、RAM角色来创建，且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的...
元数据导入
无 evaluate 是否获取当前机器规格、近期存储情况、流量、Kafka集群配置信息，在迁移时根据获取的信息进行评估，推荐您购买规格更合适的 云消息队列 Kafka 版 实例。默认为true，即默认获取以进行规格评估，如果不需要评估，则需设置为...
顺序消息
以Java语言为例，收发顺序消息的示例代码如下：完整的消息收发示例代码请参见 RocketMQ 5.x系列SDK（推荐）。顺序消息发送。MessageBuilder messageBuilder=null;Message message=messageBuilder.setTopic("topic")/设置消息索引键，可根据...
普通消息
以Java语言为例，收发普通消息的示例代码如下：完整的消息收发示例代码请参见 RocketMQ 5.x系列SDK（推荐）。普通消息发送。MessageBuilder messageBuilder=new MessageBuilder();Message message=messageBuilder.setTopic("topic")/设置...
概述
使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，其他场景推荐您使用阿里云 云消息队列 RocketMQ 版 提供的商业版SDK进行接入。和社区版SDK相比，商业版SDK提供了更加丰富的功能特性并具有更高的稳定性保障。更多信息...
SDK参考概述
普通消息 顺序消息 定时和延时消息 事务消息 PushConsumer PullConsumer 批量消费 广播消费 集群消费 消息重试 查询消息轨迹 死信队列 重置消费位点 SDK使用说明 HTTP协议和TCP协议的接入点不可混用。例如，您使用TCP协议的SDK收发消息，您...
概述
使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，其他场景推荐您使用阿里云 云消息队列 RocketMQ 版 提供的商业版SDK进行接入。和社区版SDK相比，商业版SDK提供了更加丰富的功能特性并具有更高的稳定性保障。更多信息...
- 产品推荐
- 这些文档可能帮助您