springboot rocketmq 工具类

对于Spring Boot与RocketMQ的工具类，可以使用阿里云提供的RocketMQ Spring Boot Starter。该工具类提供了一套封装了RocketMQ的Spring Boot自动配置和注解，简化了使用RocketMQ的开发过程。

您可以通过以下步骤来使用RocketMQ Spring Boot Starter：
1. 在您的Spring Boot项目中添加以下依赖：

<dependency>
    <groupId>com.aliyun.openservices</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.2.0</version>
</dependency>

2. 创建一个配置类来配置RocketMQ的参数，例如：

@Configuration
public class RocketMQConfig {
    @Value("${rocketmq.name-server}")
    private String nameServer;
    @Value("${rocketmq.access-key}")
    private String accessKey;
    @Value("${rocketmq.secret-key}")
    private String secretKey;
    
    // Getter and Setter
    
    @Bean
    public RocketMQTemplate rocketMQTemplate() {
        RocketMQTemplate rocketMQTemplate = new RocketMQTemplate();
        rocketMQTemplate.setProducerGroup("your-producer-group");
        rocketMQTemplate.setNameServer(nameServer);
        rocketMQTemplate.setAccessKey(accessKey);
        rocketMQTemplate.setSecretKey(secretKey);
        return rocketMQTemplate;
    }
}

3. 然后，您可以在您的代码中使用@Autowired注解来注入RocketMQTemplate，并使用它来发送和接收消息。例如：

@Autowired
private RocketMQTemplate rocketMQTemplate;

public void sendMessage() {
    rocketMQTemplate.convertAndSend("your-topic", "your-message");
}

@RocketMQMessageListener(topic = "your-topic", consumerGroup = "your-consumer-group")
public class MyRocketMQListener implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {
        // 处理接收到的消息
    }
}

以上就是使用RocketMQ Spring Boot Starter的基本步骤。您可以根据您的需求进一步定制和扩展。