为了在Spring Boot中集成RocketMQ，你需要做以下几步：
- 添加依赖：在
pom.xml中添加RocketMQ的Spring Boot Starter依赖。
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.1</version>
</dependency>- 配置RocketMQ：在
application.properties或application.yml中配置RocketMQ的基本属性。
# application.properties
spring.rocketmq.name-server=127.0.0.1:9876
spring.rocketmq.producer.group=my-group- 发送消息：使用
@RocketMQMessageSender注解自动创建的消息发送器发送消息。
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class ProducerController {
@Autowired
private RocketMQTemplate rocketMQTemplate;
@GetMapping("/sendMessage")
public String sendMessage() {
rocketMQTemplate.convertAndSend("topic:tag", "Hello, RocketMQ!");
return "Message sent.";
}
}- 消费消息：使用
@RocketMQMessageListener注解创建消息监听器来消费消息。
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
@Component
@RocketMQMessageListener(topic = "topic:tag", consumerGroup = "my-consumer_group")
public class ConsumerListener implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println("Received message: " + message);
}
}确保你的RocketMQ服务器正在运行并且name-server地址配置正确。上述代码提供了发送和接收消息的基本框架。根据具体需求，你可能需要进一步配置，如消费者的并发消费等级、选择性或广播消息模式等。