tencent cloud

发送与接收普通消息
下载PDF
最后更新时间：2025-07-15 18:32:07
发送与接收普通消息
最后更新时间： 2025-07-15 18:32:07
下载PDF

操作场景

本文以调用 Spring Boot Starter SDK 为例介绍通过开源 SDK 实现消息收发的操作过程，帮助您更好地理解消息收发的完整过程。

前提条件

完成资源创建与准备
安装1.8或以上版本 JDK
安装2.5或以上版本 Maven
下载 Demo或者前往GitHub 项目

操作步骤

步骤1：添加依赖

在 pom.xml 中添加依赖，建议 2.3.3 最新版本，可以同时支持 Spring Boot 2 和 Spring Boot 3。
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.3.3</version>
     <exclusions>    
             <exclusion>        
                 <groupId>org.apache.rocketmq</groupId>        
                 <artifactId>rocketmq-client</artifactId>    
             </exclusion>    
             <exclusion>        
                 <groupId>org.apache.rocketmq</groupId>        
                 <artifactId>rocketmq-acl</artifactId>    
              </exclusion>
      </exclusions>
</dependency>
 <dependency>    
            <groupId>org.apache.rocketmq</groupId>    
            <artifactId>rocketmq-client</artifactId>    
            <version>4.9.7</version>
        </dependency>
        <dependency>    
            <groupId>org.apache.rocketmq</groupId>    
            <artifactId>rocketmq-acl</artifactId>    
            <version>4.9.7</version>
 </dependency>

步骤2：准备配置

在配置文件中添加配置信息。
server:
  port: 8082

#rocketmq配置信息
rocketmq:
  # tdmq-rocketmq服务接入地址
  name-server: rocketmq-xxx.rocketmq.ap-bj.public.tencenttdmq.com:9876
  # 生产者配置
  producer:
    # 生产者组名
    group: group111
    # 角色密钥
    access-key: eyJrZXlJZC....
    # 已授权的角色名称
    secret-key: admin
  # 消费者公共配置
  consumer:
    # 角色密钥
    access-key: eyJrZXlJZC....
    # 已授权的角色名称
    secret-key: admin

  # 自定义配置，根据业务进行配置
  namespace: rocketmq-xxx|namespace1
  producer1:
    topic: testdev1
  consumer1:
    group: group111
    topic: testdev1
    subExpression: TAG1
  consumer2:
    group: group222
    topic: testdev1
    subExpression: TAG2
参数
说明
name-server
集群接入地址，在控制台集群基本信息页面的接入信息模块获取。

group
生产者的名称，用户自行定义，可以使用对应的 Topic 名字。
secret-key
角色名称，在控制台的角色管理页面 SecretKey 列复制。
access-key
角色密钥，在控制台的角色管理页面 AccessKey 列复制。

namespace
命名空间的名称，在控制台命名空间页面复制。如果您使用的是5.x集群或者 4.x 通用集群，此处填写集群 ID 即可。
topic
Topic 的名称，在控制台 Topic 管理页面复制。
subExpression
用来设置消息的 TAG。

步骤3：发送消息

1. 在需要发送消息的类中注入 RcoketMQTemplate 。
@Value("${rocketmq.namespace}%${rocketmq.producer1.topic}")
      private String topic;  // topic名称 (需要使用topic全称，所以在这里对topic名称进行拼接)
      
      @Autowired
      private RocketMQTemplate rocketMQTemplate;
2. 发送消息，消息体可以是自定义对象，也可以是 Message 对象（org.springframework.messaging包中）。
SendResult sendResult = rocketMQTemplate.syncSend(destination, message);
/*------------------------------------------------------------------------*/
rocketMQTemplate.syncSend(destination, MessageBuilder.withPayload(message).build())
3. 完整示例如下。
/**
* Description: 消息生产者
*/
@Service
public class SendMessage {
// 需要使用topic全称，所以进行topic名称的拼接，也可以自己设置  格式：namespace全称%topic名称
 @Value("${rocketmq.namespace}%${rocketmq.producer1.topic}")
 private String topic;
     @Autowired
 private RocketMQTemplate rocketMQTemplate;
         /**
    * 同步发送
    *
    * @param message 消息内容
    * @param tags    订阅tags
    */
 public void syncSend(String message, String tags) {
         // springboot不支持使用header传递tags，根据要求，需要在topic后进行拼接 formats: `topicName:tags`，不拼接标识无tag
         String destination = StringUtils.isBlank(tags) ? topic : topic + ":" + tags;
         SendResult sendResult = rocketMQTemplate.syncSend(destination,
                         MessageBuilder.withPayload(message)
                                         .setHeader(MessageConst.PROPERTY_KEYS, "yourKey")   // 指定业务key
                                         .build());
         System.out.printf("syncSend1 to topic %s sendResult=%s %n", topic, sendResult);
 }
}
说明：
该示例为同步发送。异步发送，单向发送等请参见 Demo 或者前往 GitHub 项目。

步骤4：消费消息

@Service
   @RocketMQMessageListener(
           consumerGroup = "${rocketmq.namespace}%${rocketmq.consumer1.group}",  // 消费组，格式：namespace全称%group名称
           // 需要使用topic全称，所以进行topic名称的拼接，也可以自己设置  格式：namespace全称%topic名称
           topic = "${rocketmq.namespace}%${rocketmq.consumer1.topic}",
           selectorExpression = "${rocketmq.consumer1.subExpression}" // 订阅表达式, 不配置表示订阅所有消息
   )
   public class MessageConsumer implements RocketMQListener<String> {

       @Override
       public void onMessage(String message) {
           System.out.println("Tag1Consumer receive message：" + message);
       }
   }
可根据业务需求配置多个消费者。消费者其他配置可根据具体业务需求进行配置。
说明：
完整示例参见 下载 Demo 或者前往 GitHub 项目。

步骤5：查看消费详情

发送完成消息后会得到一个消息 ID （messageID），您可以在控制台的消息查询 > 综合查询页面查询刚刚发送的消息，以及该消息的详情和轨迹等信息。


本页内容是否解决了您的问题？
您也可以 联系销售 或 提交工单 以寻求帮助。
是
否

文档反馈