spring boot 集成rocketMq + 基本使用
在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
- 发送消息:创建一个Service来发送消息。
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class MqService {
@Autowired
private RocketMQTemplate rocketMQTemplate;
public void sendMessage(String topic, String tag, String message) {
rocketMQTemplate.send(topic, tag, message);
}
}
- 接收消息:创建一个Consumer来接收消息。
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
@Component
@RocketMQMessageListener(topic = "your-topic", consumerGroup = "your-consumer_group")
public class Consumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
// 处理接收到的消息
System.out.println("Received message: " + message);
}
}
确保你的RocketMQ服务器正在运行,并且你的topic
和consumerGroup
与RocketMQ服务器配置匹配。以上代码提供了发送和接收消息的基本框架。
评论已关闭