给我个spring boot 集成 rocketmq的示例代码
时间: 2023-07-30 21:07:09 浏览: 205
springboot整合rocketMQ案例代码
当然可以,以下是一个简单的 Spring Boot 集成 RocketMQ 的示例代码:
首先,需要在 pom.xml 文件中添加 RocketMQ 的依赖:
```xml
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.1.1</version>
</dependency>
```
然后,在 application.properties 文件中添加 RocketMQ 的配置项:
```
rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=my-group
rocketmq.consumer.group=my-group
```
接着,定义一个消息发送者和一个消息接收者:
```java
@Service
public class MessageProducer {
@Autowired
private RocketMQTemplate rocketMQTemplate;
public void send(String message) {
rocketMQTemplate.convertAndSend("my-topic", message);
}
}
@Component
@RocketMQMessageListener(topic = "my-topic", consumerGroup = "my-group")
public class MessageConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
最后,在启动类上添加 `@EnableRocketMQ` 注解:
```java
@SpringBootApplication
@EnableRocketMQ
public class RocketMQApplication {
public static void main(String[] args) {
SpringApplication.run(RocketMQApplication.class, args);
}
}
```
以上就是一个简单的 Spring Boot 集成 RocketMQ 的示例代码。需要注意的是,这只是一个最基本的示例,实际应用中还需要考虑更多的细节问题,如消息的序列化、消息的重试、消息的顺序性等等。
阅读全文