检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
else { fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 204 操作成功。 错误码 请参见错误码。 父主题： Topic管理
同步发送是指消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息的通讯方式。 参考如下示例代码，或者通过Producer.java获取更多示例代码。 import org.apache.rocketmq.client.producer.DefaultMQProducer;
error: %s", err.Error()) } } 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 192.168.0.1:8100：表示实例连接地址和端口。 test：表示Topic名称。 订阅普通消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
收发普通消息 本章节介绍普通消息的收发方法和示例代码。普通消息发送方式分为同步发送和异步发送。 同步发送：消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息。 异步发送：消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息。
producer.shutdown() if __name__ == '__main__': send_message_sync() 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 topic：表示Topic名称。 gid：表示生产者组名称，请根据业务实际情况输入生产者组名称。
nil { fmt.Printf("shutdown producer error: %s", err.Error()) } } 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 192.168.0.1:8100：表示实例连接地址和端口。 AccessKey：表示用户名。创建用户的步骤，请参见创建用户。
GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送定时消息 发送定时消息的示例代码如下（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 package main import ( "context" "fmt"
即开即用：简单几步即可在云上构建自己专属的消息服务，RocketMQ实例创建完成后，使用实例提供的访问地址即可快速接入。兼容开源RocketMQ，业务代码无需改造，即可上云。 全托管服务：分布式消息服务RocketMQ版提供自动部署与完备的运维系统和售后服务，提供包括监控告警在内的多种运维手
应用示例 批量创建Topic
全局顺序消息和分区顺序消息的区别仅为队列数量不同，代码没有区别。 收发顺序消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 发送顺序消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
Topic_Fresh Tag = Province_A Tag = Province_B 以生产发往Province A的普通货物订单消息为例，代码示例如下： Message msg = new Message("Topic_Common", "Province_A" /* Tag */
”。 使用gRPC协议连接RocketMQ实例时，消费者是否顺序消费消息，取决于消费组中是否开启顺序消费，并非在消费代码中设置，顺序消费消息的代码与普通消费的代码相同。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 go version
}} 上述代码中，相同orderId的消息需要保证顺序，不同orderId的消息不需要保证顺序，所以在分区选择算法中以“orderId/队列个数的余数”作为消息发送的队列。 订阅顺序消息 参考如下示例代码，或者通过Consumer.java获取更多示例代码。 import java
error: %s", err.Error()) } } 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 192.168.0.1:8100：表示实例连接地址和端口。 test：表示Topic名称。 上述代码中，相同orderId的消息需要保证顺序，不同orderId的
<version>5.0.5</version> </dependency> 发送顺序消息 参考如下示例代码，或者通过ProducerFifoMessageExample.java获取更多示例代码。 import org.apache.rocketmq.client.apis.ClientConfiguration;
9.8</version> </dependency> 下载依赖JAR包。 发送事务消息 参考如下示例代码，或者通过TransactionProducer.java获取更多示例代码。 import org.apache.rocketmq.client.exception.MQClientException;
else { fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询成功 错误码 请参见错误码。 父主题： Topic管理
需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前，需要确保Topic的消息类型为“事务”。 发送事务消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 import time from rocketmq.client import
<version>5.0.5</version> </dependency> 发送事务消息 参考如下示例代码，或者通过ProducerTransactionMessageExample.java获取更多示例代码。 import org.apache.rocketmq.client.apis.ClientConfiguration;
else { fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询消费组成功。 错误码 请参见错误码。 父主题： 消费组管理
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
