SpringBoot中使用RocketMQ的示例代码

RocketMQ是阿里巴巴开源的一款分布式消息中间件，具有高吞吐量、高可用性、高可靠性等特点。在SpringBoot中使用RocketMQ可以方便地实现消息的发送和接收。本攻略将介绍如何在SpringBoot中使用RocketMQ，并提供两个示例说明。

1. 添加依赖

首先，我们需要在pom.xml文件中添加RocketMQ的依赖：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.2.0</version>
</dependency>

2. 配置RocketMQ

接下来，我们需要在application.properties文件中配置RocketMQ的相关信息：

# RocketMQ配置
rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=my-group
rocketmq.consumer.group=my-group

在上面的配置中，我们指定了RocketMQ的NameServer地址、生产者组和消费者组。

3. 发送消息

下面是一个示例，它演示了如何在SpringBoot中发送消息：

@Service
public class MessageSender {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public void sendMessage(String topic, String message) {
        rocketMQTemplate.convertAndSend(topic, message);
    }
}

在上面的示例中，我们定义了一个MessageSender类，其中包含一个sendMessage方法。在sendMessage方法中，我们使用RocketMQTemplate来发送消息。

4. 接收消息

下面是另一个示例，它演示了如何在SpringBoot中接收消息：

@Component
@RocketMQMessageListener(topic = "my-topic", consumerGroup = "my-group")
public class MessageListener implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在上面的示例中，我们定义了一个MessageListener类，它使用@RocketMQMessageListener注解来指定要监听的主题和消费者组。在onMessage方法中，我们输出接收到的消息。

示例1：发送和接收消息

以下是一个示例，它演示了如何在SpringBoot中发送和接收消息：

@RestController
public class MessageController {
    @Autowired
    private MessageSender messageSender;

    @GetMapping("/send")
    public String sendMessage() {
        messageSender.sendMessage("my-topic", "Hello, RocketMQ!");
        return "Message sent";
    }
}

@Component
@RocketMQMessageListener(topic = "my-topic", consumerGroup = "my-group")
public class MessageListener implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在上面的示例中，我们定义了一个MessageController类和一个MessageListener类。在MessageController类中，我们使用MessageSender来发送消息。在MessageListener类中，我们使用@RocketMQMessageListener注解来指定要监听的主题和消费者组。当我们访问/send接口时，就会发送一条消息。当RocketMQ接收到消息时，就会调用MessageListener的onMessage方法。

示例2：批量发送消息

以下是另一个示例，它演示了如何在SpringBoot中批量发送消息：

@Service
public class BatchMessageSender {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public void sendMessages(String topic, List<String> messages) {
        rocketMQTemplate.send(topic, messages.stream().map(message -> new Message(topic, message.getBytes())).collect(Collectors.toList()));
    }
}

在上面的示例中，我们定义了一个BatchMessageSender类，其中包含一个sendMessages方法。在sendMessages方法中，我们使用RocketMQTemplate来批量发送消息。

总结

在本攻略中，我们介绍了如何在SpringBoot中使用RocketMQ，并提供了两个示例说明。通过这些示例，我们可以了解如何发送和接收消息，以及如何批量发送消息。