低版本的springboot(1.5.3)如何集成rocketmq

在低版本的Spring Boot（1.5.3）中集成RocketMQ，可以按照以下步骤进行：

1. 添加Spring Boot和RocketMQ的依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.6.0</version>
</dependency>

1. 配置Spring Boot应用：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Application {
   
    public static void main(String[] args) {
   
        SpringApplication.run(Application.class, args);
    }
}

1. 创建RocketMQ的消息生产者和消费者：

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.common.message.MessageQueue;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import java.util.List;

@Component
public class RocketMQExample {
   

    @Value("${spring.application.name}")
    private String appName;

    public void produce() {
   
        DefaultMQProducer producer = new DefaultMQProducer(appName);
        producer.setNamesrvAddr("localhost:9876");
        producer.start();
        for (int i = 0; i < 10; i++) {
   
            MessageExt msg = new MessageExt("TopicTest", "TagA", "Order_" + i, (long) i * 1000, ("Hello RocketMQ " + i).getBytes());
            producer.send(msg);
        }
        producer.shutdown();
    }

    public void consume() {
   
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("GroupTest");
        consumer.setNamesrvAddr("localhost:9876");
        consumer.setMessageModel(MessageModel.CLUSTERING);
        consumer.subscribe("TopicTest", "TagA");
        consumer.start();
        while (true) {
   
            List<MessageExt> msgs = consumer.pull(new PullRequest("TopicTest", "TagA", 1000));
            for (MessageExt msg : msgs) {
   
                System.out.println("Received message: " + new String(msg.getBody()));
            }
        }
    }
}

以上代码中，我们首先创建了一个消息生产者和消费者，然后分别调用它们的produce和consume方法来发送和接收消息。
需要注意的是，由于Spring Boot 1.5.3版本较老，可能无法支持RocketMQ的最新版本。如果遇到兼容性问题，可以尝试降级RocketMQ的版本，或者使用Spring Boot的更高版本。