java实现阿里云rocketMQ消息的发送与消费(http协议sdk)

一、准备工作

登录阿里云官网，先申请rocketMQ，再申请Topic、Group ID，然后就是参考阿里云的JAVA SDK进行编程实现。

环境要求：
安装JDK 1.6或以上版本
安装Maven
安装Java SDK

参照 阿里云 官方文档，来一步一步操作。
文档提供的SDK有TCP和Http协议，这里使用HTTP协议来实现rocketMQ消息的发送与消费。

二、代码实现

调用HTTP协议的SDK收发普通消息

1.添加依赖

创建Springboot项目，添加 SDK依赖：

 <dependency>
     <groupId>org.springframework.bootgroupId>
     <artifactId>spring-boot-starter-webartifactId>
 dependency>
 
 <dependency>
     <groupId>com.aliyun.mqgroupId>
     <artifactId>mq-http-sdkartifactId>
     <version>1.0.2version>
 dependency>

1
2
3
4
5
6
7
8
9
10
11

注意：aliyun mq sdk的版本信息，请参见版本说明

2.创建一个常量类存放公共参数

package com.example.rocketdemo.config;

/**
 * @author qzz
 */
public class MqConfigParams {
   

    /**
     * 你的topic
     */
    public static final String TOPIC = "你的topic";
    /**
     * 消息标签  *:代表全部
     */
    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";
    /**
     *设置HTTP协议客户端接入点，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看
     */
    public static final String HTTP_ENDPOINT = "http接入点地址";
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

3.调用HTTP协议的SDK 发送普通消息

package com.example.rocketdemo.util;

import com.aliyun.mq.http.MQClient;
import com.aliyun.mq.http.MQProducer;
import com.aliyun.mq.http.model.TopicMessage;
import com.example.rocketdemo.config.MqConfigParams;
import lombok.extern.slf4j.Slf4j;
import java.util.Date;

/**
 * 生产 阿里云 RocketMQ 消息
 * @author qzz
 */
@Slf4j
public class AliyunMessageProducerTest {
   
    public static void main(String[] args) {
   
        MQClient mqClient = new MQClient(
                // 设置HTTP协议客户端接入点，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。
                MqConfigParams.HTTP_ENDPOINT,
                // AccessKey ID，阿里云身份验证，在阿里云RAM控制台创建。
                MqConfigPa
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22