快捷導(dǎo)航

SpringBoot項(xiàng)目嵌入RocketMQ的實(shí)現(xiàn)示例

更新時(shí)間：2024年05月24日 11:10:21 作者：李三不四

本文主要介紹了SpringBoot項(xiàng)目嵌入RocketMQ的實(shí)現(xiàn)示例,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

在Spring Boot中嵌入RocketMQ可以通過添加相應(yīng)的依賴來完成。

首先需要在pom.xml文件中引入spring-boot-starter-amqp依賴：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>rocketmq-spring-boot-starter</artifactId>
        <version>2.1.0</version>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
</dependencies>

然后，在application.properties或者application.yml配置文件中設(shè)置RocketMQ連接信息：

# RocketMQ服務(wù)器地址
rocketmq.name-server=127.0.0.1:9876
# 生產(chǎn)者分組
rocketmq.producer.group=my-group

最后，創(chuàng)建消息發(fā)送者（Producer）和消息接收者（Consumer）類，并使用@Autowired注解將其自動(dòng)裝載到Spring容器中。示例如下：

創(chuàng)建消息發(fā)送者類：

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("/send")
    public String send(String message) {
        rocketMQTemplate.convertAndSend("test-topic", message);
        return "Message: '" + message + "' sent.";
    }

}

創(chuàng)建消息接收者類：

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

@Service
@RocketMQMessageListener(topic = "test-topic", consumerGroup = "my-consumer_test-topic")
public class ConsumerService implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        System.out.printf("------- StringConsumer received: %s \n", message);
    }
}

當(dāng)調(diào)用/send接口時(shí)，會(huì)向"myQueue"隊(duì)列發(fā)送消息；

而MessageReceiver則會(huì)監(jiān)聽該隊(duì)列，并處理接收到的消息。

查看控制臺(tái)的輸出來驗(yàn)證消息消費(fèi)者是否可以正常接收消息

到此這篇關(guān)于SpringBoot項(xiàng)目嵌入RocketMQ的實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)SpringBoot嵌入RocketMQ內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: