rocketmq异步发送消息-rocketmq异步发送消息文档介绍内容-阿里云

发送消息API

使用发送消息API从生产者发送消息至云消息队列 RocketMQ 版服务端。请求构造请求行 POST/topics/TopicName/messages?ns=INSTANCE_ID HTTP/1.1 参数说明如下。参数是否必选说明 TopicName 是将消息发送至的Topic名称。ns 否实例ID，...

收发定时消息和延时消息

背景信息延时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端...

通过可观测性能力进行故障处理最佳实践

生产异常场景实践方案查看消息发送成功率（rocketmq_send_cost_time_count{invocation_status="success"/invocation_status="success｜failure"}）是否正常，消息发送成功率=消息发送成功次数/消息发送失败次数+成功次数。查询方式，请...

收发定时消息和延时消息

背景信息延时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端...

收发定时消息和延时消息

背景信息延时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端...

生产者负载均衡

生产者发送消息到云消息队列 RocketMQ 版服务端时，云消息队列 RocketMQ 版将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍云消息队列 RocketMQ 版生产者的负载均衡策略。背景信息了解...

消息轨迹

在分布式应用中，云消息队列 RocketMQ 版作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版定义的轨迹参数...

收发定时消息和延时消息

背景信息延时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端...

收发定时消息和延时消息

背景信息延时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端...

收发定时消息和延时消息

背景信息延时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端...

默认配置映射关系

同构消息映射关系当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由基于事件流实现Kafka消息路由基于事件流实现RabbitMQ消息路由基于事件流实现MNS消息路由异构消息映射关系当消息的...

快速入门概述

本文为您介绍如何快速使用云消息队列 RocketMQ 版实现消息收发。使用流程快速使用云消息队列 RocketMQ 版收发消息的流程如下图所示。使用说明权限说明若您的账号为RAM用户，则必须先为该RAM用户进行授权，才能访问云消息队列 ...

示例代码

异步发送消息,发送结果通过callback返回给客户端。producer.sendAsync(msg,new SendCallback(){@Override public void onSuccess(final SendResult sendResult){/消息发送成功。System.out.println("send message success.topic="+...

默认配置映射关系

同构消息映射关系当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由基于事件流实现Kafka消息路由基于事件流实现RabbitMQ消息路由基于事件流实现MNS消息路由异构消息映射关系当消息的...

Spring集成

消息类型 发送消息示例代码订阅消息示例代码普通消息 ProducerClient.java 同步发送：SyncProducerTest.java 异步发送：AsyncProducerTest.java Tag过滤方式订阅：ConsumerClient.java SQL过滤方式订阅：SqlConsumerClient.java 顺序消息...

死信队列

对于消费失败且重试后依然失败的...批量重发在云消息队列 RocketMQ 版控制台按Group ID查询到死信消息后，勾选目标死信消息，然后单击批量重新发送消息，重新发送所有勾选的死信消息。相关文档关于消费重试的相关原理，请参见消息重试。

队列（MessageQueue）

例如，生产者指定某个主题，向主题内发送消息，但实际消息发送到该主题下的某个队列中。云消息队列 RocketMQ 版中通过修改队列数量，以此实现横向的水平扩容和缩容。内部属性读写权限定义：当前队列是否可以读写数据。取值：由服务端...

OnsDLQMessageResendById-重发指定的死信消息

重发指定Message ID的死信消息，使该消息能够被Consumer再次消费。接口说明注意阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则...

快速入门

如果您是首次使用云消息队列 RocketMQ 版，您可以参考快速入门文档，了解如何购买实例并接入云消息队列 RocketMQ 版服务端完成基本的消息收发流程。使用流程快速使用云消息队列 RocketMQ 版收发消息的流程如下图所示。详细操作，请...

消费者分类

云消息队列 RocketMQ 版支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息云消息队列 RocketMQ 版面向不同的业务场景提供了不同...

收发顺序消息

如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达云消息队列 RocketMQ 版服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。具体的示例代码，请以云消息队列 RocketMQ 版代码库为准。全局顺序消息和...

收发顺序消息

如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达云消息队列 RocketMQ 版服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。发送顺序消息的示例代码如下。include"ONSFactory.h"#include...

配额与限制

云消息队列 RocketMQ 版对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用云消息队列 RocketMQ 版时不要超过对应的限制值，避免应用出现异常。参数限制以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...

收发顺序消息

如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达云消息队列 RocketMQ 版服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。发送顺序消息的示例代码如下。import java.util.List;import org.apache....

定时/延时消息

try {/发送消息，需要关注发送结果，并捕获失败等异常。SendReceipt sendReceipt=producer.send(message);System.out.println(sendReceipt.getMessageId());} catch(ClientException e){ e.printStackTrace();}/消费示例一：使用...

发送消息时返回“MQClientException:No route info of...

问题现象使用TCP协议SDK发送消息时，云消息队列 RocketMQ 版服务端返回如下错误：Caused by:com.aliyun.openservices.shade.com.alibaba.rocketmq.client.exception.MQClientException: No route info of this topic可能原因代码中设置的接入...

查询消息轨迹

云消息队列 RocketMQ 版将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...

概述

本文介绍使用社区版TCP协议的Java SDK访问阿里云云消息队列 RocketMQ 版来收发消息的流程。使用说明社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，其他场景推荐您使用阿里云云消息队列 RocketMQ 版提供的商业版SDK进行接...

概述

本文主要介绍如何使用开源社区发布的rocketmq-client-cpp二进制包进行部署和连接阿里云云消息队列 RocketMQ 版的过程。如需源码编译，请您自行前往开源社区下载。使用说明社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，...

收发顺序消息

如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达云消息队列 RocketMQ 版服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。具体的示例代码，请以云消息队列 RocketMQ 版代码库为准。发送顺序消息的...

仪表盘

场景二：线上某些订单状态有异常，需要排查对应的消息链路环节是否正常发送消息。场景三：需要分析消息流量变化趋势、流量分布特点或消息体量，进而进行业务趋势分析规划。场景四：需要查看和分析应用上下游依赖拓扑情况，进行架构升级优化...

接口和参数说明

云消息队列 RocketMQ 版提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从云消息队列 RocketMQ 版获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息云消息队列 RocketMQ 版支持以下两种消息获取方式：Push...

函数计算

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为云消息队列 Kafka 版的消息流出任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已开通函数计算服务，具体...

可观测性体系概述

作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍云消息队列 ...

收发顺序消息

如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达云消息队列 RocketMQ 版服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。发送顺序消息的示例代码如下。import com.aliyun.mq.http.MQClient;import ...

收发顺序消息

如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达云消息队列 RocketMQ 版服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。发送顺序消息的示例代码如下。const { MQClient,MessageProperties }=require...

函数计算

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为云消息队列 Kafka 版的消息流出任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已开通函数计算服务，具体...

消息存储和清理机制

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

版本说明

本文介绍RocketMQ ONS 1.x系列Java SDK的版本信息，包含下载链接、发布时间、更新点等，以便您按需获取适用的Java SDK收发消息。重要 JDK 1.8适用于所有Java ons-client版本，JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为...

确认消息API

使用确认消息API确认消息消费状态。请求构造请求行 DELETE/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID HTTP/1.1 参数说明如下。参数是否必选说明 TopicName 是将消息发送至的Topic名称。ns 否实例ID，针对有命名空间的...

rocketmq异步发送消息

新品推荐