用SpringBoot快速入门Apache RocketMQ

2024-02-21 04:20:28

Apache RocketMQ 简介

Apache RocketMQ是一个分布式消息队列系统，由阿里巴巴开发并开源。它提供了高吞吐量、低延迟和可靠的消息传输服务，广泛应用于电商、金融、物流等领域。

2. Springboot集成RocketMQ

2.1 依赖引入

首先，我们需要在项目中引入RocketMQ的依赖。我们可以使用Maven或Gradle来引入依赖。

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

2.2 创建生产者

创建一个生产者类，并使用@RocketMQTransactionListener注解标记该类。

@RocketMQTransactionListener(txProducerGroup = "myTxProducerGroup")
public class Producer {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public void send(String message) {
        // 创建消息
        Message msg = new Message("myTopic", "myTag", message.getBytes());

        // 发送消息
        rocketMQTemplate.sendMessageInTransaction("myProducerGroup", msg, null);
    }
}

2.3 创建消费者

创建一个消费者类，并使用@RocketMQMessageListener注解标记该类。

@RocketMQMessageListener(consumerGroup = "myConsumerGroup", topic = "myTopic")
public class Consumer {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @Consume(consumeMode = ConsumeMode.ORDERLY)
    public void listen(MessageExt messageExt) {
        // 接收消息
        String message = new String(messageExt.getBody());

        // 处理消息
        System.out.println("Received message: " + message);
    }
}

2.4 发送和接收消息

在我们的控制器中，我们可以使用生产者和消费者来发送和接收消息。

@Controller
public class MyController {

    @Autowired
    private Producer producer;

    @Autowired
    private Consumer consumer;

    @GetMapping("/send")
    public String send(String message) {
        producer.send(message);
        return "Message sent successfully.";
    }

    @GetMapping("/receive")
    public String receive() {
        consumer.listen(null);
        return "Message received successfully.";
    }
}