阿里云官方文档地址： [https://help.aliyun.com/product/29530.html?spm=a2c4g.11186623.6.540.18dc4fedo9nsoQ](https://help.aliyun.com/product/29530.html?spm=a2c4g.11186623.6.540.18dc4fedo9nsoQ) Demo地址： [https://github.com/AliwareMQ/mq-demo](https://github.com/AliwareMQ/mq-demo) 1.**下载好Demo后，导入 java-tcp-demo项目** **在 IntelliJ IDEA 界面，选择 Open，选择 java-tcp-demo文件夹。**  **若出现打开方式，选择open as project，直到导入完成。 Demo 工程需要加载依赖的 JAR 包，因此导入过程需要等待 2-3 分钟。** 2.**创建资源** 需要先到控制台创建所需资源，包括消息队列 RocketMQ 的实例、Topic、Group ID (GID)，以及鉴权需要的 AccessKey（AK）。 更多详细信息与操作指导： [https://help.aliyun.com/document\_detail/34411.html?spm=a2c4g.11186623.2.17.6bdac931bF6gLn](https://help.aliyun.com/document_detail/34411.html?spm=a2c4g.11186623.2.17.6bdac931bF6gLn) 3.**完善配置MqConfig文件，** 按以下说明配置 MqConfig 类。 lpublic static final String TOPIC = “刚才创建的 Topic”; lpublic static final String GROUP\_ID = “刚才创建的 Group ID”; lpublic static final String ACCESS\_KEY = “您的阿里云账号的 AccessKeyId”; lpublic static final String SECRET\_KEY = “您的阿里云账号的 AccessKeySecret”; lpublic static final String NAMESRV\_ADDR = “您的消息队列 RocketMQ 实例的 TCP 接入点，可在控制台的实例管理的获取接入点信息区域获取 TCP 协议接入点“; 4.**选择要测试的消息类型进行测试**； 运行 SimleMQProducer类发送消息。(发送普通消息) 登录消息队列 RocketMQ 控制台，在左侧导航栏选择消息查询 > 按 Topic 查询，选择 Topic 名称进行查询。可以看见消息已经发送至 Topic。 运行 SimpleMQConsumer 类接收消息。可以看到消息被接收打印的日志。因为有初始化，所以需等待几秒，在生产环境中不会经常初始化。