一、准备工作
登录阿里云官网，先申请rocketMQ，再申请Topic、Group ID，然后就是参考阿里云的JAVA SDK进行编程实现。
环境要求：
安装JDK 1.8或以上版本
安装Maven
安装Java SDK
参照 阿里云 官方文档，来一步一步操作。
文档提供的SDK有TCP和Http协议，这里使用TCP协议来实现rocketMQ消息的发送与消费。
二、代码实现
调用TCP协议的SDK收发普通消息
1.添加依赖
创建Springboot项目，添加 SDK依赖：文章来源：https://www.toymoban.com/news/detail-469386.html
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--aliyun mq tcp协议 sdk-->
<dependency>
<groupId>com.aliyun.openservices</groupId>
<artifactId>ons-client</artifactId>
<!--以下版本号请替换为Java SDK的最新版本号-->
<version>2.0.3.Final</version>
</dependency>
注意：aliyun mq sdk的版本信息，请参见版本说明文章来源地址https://www.toymoban.com/news/detail-469386.html
2.创建一个常量类存放公共参数
package com.example.rocketdemotcp.config;
/**
* @author qzz
*/
public class MqConfigParams {
/**
* 你的topic
*/
public static final String TOPIC = "你的topic";
/**
* tag消息标签 *:代表全部
*/
public static final String TAG = "你的tag消息标签";
/**
* 你的Group_Id
*/
public static final String GROUP_ID = "你的Group_Id";
/**
*你的accessKey
*/
public static final String ACCESS_KEY = "你的accessKey";
/**
*你的secretKey
*/
public static final String SECRET_KEY = "你的secretKey";
/**
* 实例ID
*/
public static final String INSTANCE_ID = "你的实例ID";
/**
* 设置TCP协议客户端接入点，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看
*/
public static final String NAMESRV_ADDR = "你的TCP接入点地址";
}
3.调用TCP协议的SDK 发送消息
package com.example.rocketdemotcp.util;
import com.aliyun.openservices.ons.api.到了这里，关于java实现阿里云rocketMQ消息的发送与消费(tcp协议sdk)的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
