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

blocks|key|9fbnc|text|操作场景|type|header-two|depth|inlineStyleRanges|entityRanges|data|ciepc|本文以调用+Java+SDK+为例介绍通过开源+SDK+实现消息收发的操作过程，帮助您更好地理解消息收发的完整过程。|unstyled|e1v8r|涉及腾讯云产品：|2o41u|产品|atomic|offset|length|1shre|说明|style|BOLD|fn5tm|以+Java+客户端为例说明，其他语言客户端请参见+SDK+文档。|fbdpe|前提条件|2kqdh|完成资源创建与准备|aksn|安装1.8或以上版本+JDK|fpf75|安装2.5或以上版本+Maven|3ogon|下载+Demo|f75na|操作步骤|bbuf8|安装+Java+依赖库|header-three|7mntk|在+Java+项目中引入相关依赖，以+Maven+工程为例，在+pom.xml+添加以下依赖：|8gvgq|+++<dependencies>
++++++++<dependency>
++++++++++++<groupId>org.apache.rocketmq</groupId>
++++++++++++<artifactId>rocketmq-client-java</artifactId>
++++++++++++<version>5.0.5</version>
++++++++</dependency>
++++++++<dependency>
++++++++++++<groupId>org.slf4j</groupId>
++++++++++++<artifactId>slf4j-api</artifactId>
++++++++++++<version>1.7.7</version>
++++++++</dependency>
++++</dependencies>|code-block|syntax|javascript|7onh|entityMap|0|PRODUCT|mutability|IMMUTABLE|column|name|products|cardType|free|goodsDesc|体验版+1个月|activityId|goodsId|goodsName|消息队列+RocketMQ|1|LINK|MUTABLE|url|https://cloud.tencent.com/document/product/1493/97807|2|https://cloud.tencent.com/document/product/1493/90086|3|https://www.oracle.com/java/technologies/javase-downloads.html|4|http://maven.apache.org/download.cgi#|5|https://github.com/TencentCloud/rocketmq-demo/tree/main/java/rocketmq-demo/rocketmq5/src/main/java/com/tencent/demo^0|0|0|0|0|2|0|0|0|2|0|Q|6|1|0|0|0|9|2|0|0|E|3|0|0|G|4|0|0|7|5|0|0|0|0|0|1|1COBK2EMNV|BJSALNKX9P^^$0|@$1|2|3|4|5|6|7|27|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|28|8|@]|9|@]|A|$]]|$1|E|3|F|5|D|7|29|8|@]|9|@]|A|$]]|$1|G|3|H|5|I|7|2A|8|@]|9|@$J|2B|K|2C|1|2D]]|A|$]]|$1|L|3|M|5|D|7|2E|8|@$J|2F|K|2G|N|O]]|9|@]|A|$]]|$1|P|3|Q|5|D|7|2H|8|@]|9|@$J|2I|K|2J|1|2K]]|A|$]]|$1|R|3|S|5|6|7|2L|8|@]|9|@]|A|$]]|$1|T|3|U|5|D|7|2M|8|@]|9|@$J|2N|K|2O|1|2P]]|A|$]]|$1|V|3|W|5|D|7|2Q|8|@]|9|@$J|2R|K|2S|1|2T]]|A|$]]|$1|X|3|Y|5|D|7|2U|8|@]|9|@$J|2V|K|2W|1|2X]]|A|$]]|$1|Z|3|10|5|D|7|2Y|8|@]|9|@$J|2Z|K|30|1|31]]|A|$]]|$1|11|3|12|5|6|7|32|8|@]|9|@]|A|$]]|$1|13|3|14|5|15|7|33|8|@]|9|@]|A|$]]|$1|16|3|17|5|D|7|34|8|@]|9|@]|A|$]]|$1|18|3|19|5|1A|7|35|8|@]|9|@]|A|$1B|1C]]|$1|1D|3|-4|5|15|7|36|8|@]|9|@]|A|$]]]|1E|$1F|$5|1G|1H|1I|A|$1J|37|1K|H|1L|@$1M|1N|1O|1P|1Q|38|1R|39|1S|1T]]]]|1U|$5|1V|1H|1W|A|$1X|1Y]]|1Z|$5|1V|1H|1W|A|$1X|20]]|21|$5|1V|1H|1W|A|$1X|22]]|23|$5|1V|1H|1W|A|$1X|24]]|25|$5|1V|1H|1W|A|$1X|26]]]]

背景及环境准备

前置步骤

blocks|key|4a3ei|text|public+class+NormalMessageSyncProducer+{
++++private+static+final+Logger+log+=+LoggerFactory.getLogger(NormalMessageSyncProducer.class);

++++private+NormalMessageSyncProducer()+{
++++}

++++public+static+void+main(String[]+args)+throws+ClientException,+IOException+{
++++++++final+ClientServiceProvider+provider+=+ClientServiceProvider.loadService();

++++++++//+添加配置的ak和sk
++++++++String+accessKey+=+"yourAccessKey";+//ak
++++++++String+secretKey+=+"yourSecretKey";+//sk
++++++++SessionCredentialsProvider+sessionCredentialsProvider+=
++++++++++++new+StaticSessionCredentialsProvider(accessKey,+secretKey);

++++++++//+填写腾讯云提供的接入地址
++++++++String+endpoints+=+"rmq-xxx.rocketmq.xxxtencenttdmq.com:8081";
++++++++ClientConfiguration+clientConfiguration+=+ClientConfiguration.newBuilder()
++++++++++++.setEndpoints(endpoints)
++++++++++++.enableSsl(false)
++++++++++++.setCredentialProvider(sessionCredentialsProvider)
++++++++++++.build();
++++++++String+topic+=+"yourNormalTopic";
++++++++//+通常在一个客户端内无需创建过多的生产者。
++++++++final+Producer+producer+=+provider.newProducerBuilder()
++++++++++++.setClientConfiguration(clientConfiguration)
++++++++++++//+设置主题名，此处的设置非必须，但是推荐设置，以便生产者可以在正式发送消息前，预先抓取消息路由。
++++++++++++.setTopics(topic)
++++++++++++//+如生产者未初始化可能会报+M+{@link+ClientException}+的错误。
++++++++++++.build();
++++++++//+此处定义消息主体。
++++++++byte[]+body+=+"This+is+a+normal+message+for+Apache+RocketMQ".getBytes(StandardCharsets.UTF_8);
++++++++String+tag+=+"yourMessageTagA";
++++++++final+Message+message+=+provider.newMessageBuilder()
++++++++++++//+Set+topic+for+the+current+message.
++++++++++++.setTopic(topic)
++++++++++++//+在+topic+下进行的消息二级分类，区别同一个主题内不同的消息。
++++++++++++.setTag(tag)
++++++++++++//+消息键，除消息+ID+外可以区别不同消息的其他途径。
++++++++++++.setKeys("yourMessageKey-1c151062f96e")
++++++++++++.setBody(body)
++++++++++++.build();
++++++++try+{
++++++++++++final+SendReceipt+sendReceipt+=+producer.send(message);
++++++++++++log.info("Send+message+successfully,+messageId={}",+sendReceipt.getMessageId());
++++++++}+catch+(Throwable+t)+{
++++++++++++log.error("Failed+to+send+message",+t);
++++++++}
++++++++//+发送完成后，如无别的需要可以关闭生产者客户端。
++++++++producer.close();
++++}
}|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|js|bg59d|unstyled|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|G|8|@]|9|@]|A|$B|C]]|$1|D|3|-4|5|E|7|H|8|@]|9|@]|A|$]]]|F|$]]

实现生产消息的应用

生产消息

blocks|key|el7q8|text|腾讯云消息队列+TDMQ+RocketMQ+版+5.x+系列支持两种消费模式，分别为+Push+Consumer+和+Simple+Consumer，以下代码示例以+Push+Consumer+为例。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|etba|public+class+NormalPushConsumer+{
++++private+static+final+Logger+log+=+LoggerFactory.getLogger(NormalPushConsumer.class);

++++private+NormalPushConsumer()+{
++++}

++++public+static+void+main(String[]+args)+throws+ClientException,+IOException,+InterruptedException+{
++++++++final+ClientServiceProvider+provider+=+ClientServiceProvider.loadService();

++++++++//+添加配置的+ak+和+sk
++++++++String+accessKey+=+"yourAccessKey";+//ak
++++++++String+secretKey+=+"yourSecretKey";+//sk
++++++++SessionCredentialsProvider+sessionCredentialsProvider+=
++++++++++++new+StaticSessionCredentialsProvider(accessKey,+secretKey);

++++++++//+填写腾讯云提供的接入地址
++++++++String+endpoints+=+"rmq-xxx.rocketmq.xxxtencenttdmq.com:8081";
++++++++ClientConfiguration+clientConfiguration+=+ClientConfiguration.newBuilder()
++++++++++++.setEndpoints(endpoints)
++++++++++++.enableSsl(false)
++++++++++++.setCredentialProvider(sessionCredentialsProvider)
++++++++++++.build();
++++++++String+tag+=+"*";
++++++++FilterExpression+filterExpression+=+new+FilterExpression(tag,+FilterExpressionType.TAG);
++++++++String+consumerGroup+=+"yourConsumerGroup";
++++++++String+topic+=+"yourTopic";
++++++++//+通常在一个客户端内无需创建过多的消费者。
++++++++PushConsumer+pushConsumer+=+provider.newPushConsumerBuilder()
++++++++++++.setClientConfiguration(clientConfiguration)
++++++++++++//+设置消费者组名称。
++++++++++++.setConsumerGroup(consumerGroup)
++++++++++++//+设置消费者订阅名称
++++++++++++.setSubscriptionExpressions(Collections.singletonMap(topic,+filterExpression))
++++++++++++.setMessageListener(messageView+->+{
++++++++++++++++//+处理消息并返回消息消费结果。
++++++++++++++++log.info("Consume+message={}",+messageView);
++++++++++++++++return+ConsumeResult.SUCCESS;
++++++++++++})
++++++++++++.build();
++++++++//+生产环境无需阻塞主线程。
++++++++Thread.sleep(Long.MAX_VALUE);
++++++++//+消费完成后，如无别的需要可以关闭消费者客户端。
++++++++pushConsumer.close();
++++}
}|code-block|syntax|js|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|H|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|I|8|@]|9|@]|A|$E|F]]]|G|$]]

实现消费消息的应用

消费消息

entityMap|0|type|LINK|mutability|MUTABLE|data|url|https://cloud.tencent.com/document/product/1493/90088|1|IMAGE|IMMUTABLE|placeHolderUrl|error|dpi|imageUrl|https://developer.qcloudimg.com/operation/attachment/900005/20240408-7bb5f1d4.png|blocks|key|89iq1|text|发送完成消息后会得到一个消息+ID+（messageID），开发者可以在+“消息查询”+页面查询刚刚发送的消息，如下图所示；并且可以查看特定消息的详情和轨迹等信息，详情见+消息查询+章节。|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|820j3|990nv|image.png|atomic|a4b4^0|0|2E|4|0|0|0|0|9|1|0^^$0|$1|$2|3|4|5|6|$7|8]]|9|$2|A|4|B|6|$C|-3|D|-3|E|X|F|G]]]|H|@$I|J|K|L|2|M|N|Y|O|@]|P|@$Q|Z|R|10|I|11]]|6|$]]|$I|S|K|-4|2|M|N|12|O|@]|P|@]|6|$]]|$I|T|K|U|2|V|N|13|O|@]|P|@$Q|14|R|15|I|16]]|6|$]]|$I|W|K|-4|2|M|N|17|O|@]|P|@]|6|$]]]]

查看消息详情

查看信息

使用 5.0 SDK 收发普通消息

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

使用 5.0 SDK 收发普通消息

操作场景

前提条件

操作步骤

安装 Java 依赖库

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐