快捷導(dǎo)航

springboot rocketmq配置生產(chǎn)者和消息者的步驟

更新時(shí)間：2025年03月01日 11:40:26 作者：iteye_10392

本文介紹了如何在Spring Boot中集成RocketMQ,包括添加依賴、配置application.yml、創(chuàng)建生產(chǎn)者和消費(fèi)者,并展示了如何發(fā)送和接收消息,感興趣的朋友一起看看吧

1. 添加依賴

首先，在你的pom.xml文件中添加RocketMQ的依賴項(xiàng)。確保你使用的是與Spring Boot兼容的版本。

<dependencies>
    <!-- 其他依賴 -->
    <!-- RocketMQ Spring Boot Starter -->
    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>rocketmq-spring-boot-starter</artifactId>
        <version>2.2.3</version> <!-- 確認(rèn)這是最新或適合你的版本 -->
    </dependency>
    <!-- 其他依賴 -->
</dependencies>

2. 配置application.yml

在src/main/resources/application.yml中添加RocketMQ的相關(guān)配置。

rocketmq:
  name-server: 127.0.0.1:9876 # RocketMQ NameServer 地址
  producer:
    group: your-producer-group # 生產(chǎn)者的組名
    send-message-timeout: 3000 # 發(fā)送消息超時(shí)時(shí)間，默認(rèn)3秒
  consumer:
    group: your-consumer-group # 消費(fèi)者的組名

3. 創(chuàng)建生產(chǎn)者

你可以創(chuàng)建一個(gè)服務(wù)類來(lái)發(fā)送消息。

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class RocketMQProducer {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
    public void sendMessage(String topic, String message) {
        rocketMQTemplate.convertAndSend(topic, message);
    }
}

4. 創(chuàng)建消費(fèi)者

接下來(lái)，創(chuàng)建一個(gè)監(jiān)聽(tīng)器來(lái)消費(fèi)消息。

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;
@Service
@RocketMQMessageListener(topic = "your-topic", consumerGroup = "your-consumer-group")
public class RocketMQConsumer implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {
        System.out.printf("Receive message: %s %n", message);
        // 處理接收到的消息
    }
}

5. 使用

在需要發(fā)送消息的地方注入RocketMQProducer并調(diào)用其sendMessage方法。
當(dāng)有消息發(fā)布到指定的topic時(shí)，RocketMQConsumer將自動(dòng)接收并處理這些消息。

到此這篇關(guān)于springboot rocketmq配置生產(chǎn)者和消息者的文章就介紹到這了,更多相關(guān)springboot rocketmq生產(chǎn)者和消息者內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: