快捷導(dǎo)航

springboot接入mq的方法示例

更新時(shí)間：2023年09月21日 09:45:23 作者：葉秋i

本文主要介紹了springboot接入mq的方法示例,主要實(shí)現(xiàn)配置以及實(shí)現(xiàn)一個(gè)簡單的發(fā)送、接收消息的例子,具有一定的參考價(jià)值,感興趣的可以了解一下

下面以 RabbitMQ 為例，介紹如何在 Spring Boot 中接入 MQ。

1、添加依賴：在 pom.xml 文件中添加 RabbitMQ 的相關(guān)依賴?？梢愿鶕?jù)需要選擇合適的版本，例如：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2、配置 RabbitMQ 連接信息：在 application.properties（或 application.yml）中配置 RabbitMQ 的連接信息，例如：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3、創(chuàng)建消息發(fā)送者：創(chuàng)建一個(gè)類來發(fā)送消息，例如 MessageSender。

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
public class MessageSender {
? ? private final AmqpTemplate amqpTemplate;
? ? @Autowired
? ? public MessageSender(AmqpTemplate amqpTemplate) {
? ? ? ? this.amqpTemplate = amqpTemplate;
? ? }
? ? public void sendMessage(String exchange, String routingKey, Object message) {
? ? ? ? amqpTemplate.convertAndSend(exchange, routingKey, message);
? ? }
}

在 MessageSender 類中，通過自動(dòng)注入 AmqpTemplate 對(duì)象，使用 convertAndSend() 方法發(fā)送消息到指定的交換機(jī)和路由鍵。

4、創(chuàng)建消息接收者：創(chuàng)建一個(gè)類來接收消息，例如 MessageReceiver。

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
public class MessageReceiver {
? ? @RabbitListener(queues = "myQueue")
? ? public void receiveMessage(String message) {
? ? ? ? // 處理接收到的消息
? ? ? ? System.out.println("Received message: " + message);
? ? }
}

在 MessageReceiver 類中，使用 @RabbitListener 注解指定需要監(jiān)聽的隊(duì)列，然后定義一個(gè)方法來處理接收到的消息。

5、配置交換機(jī)和隊(duì)列：如果需要自定義交換機(jī)和隊(duì)列，可以創(chuàng)建一個(gè)配置類來進(jìn)行配置，例如：

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitMQConfig {
? ? @Bean
? ? public Queue myQueue() {
? ? ? ? return new Queue("myQueue");
? ? }
? ? @Bean
? ? public FanoutExchange fanoutExchange() {
? ? ? ? return new FanoutExchange("myExchange");
? ? }
? ? @Bean
? ? public Binding binding(Queue myQueue, FanoutExchange fanoutExchange) {
? ? ? ? return BindingBuilder.bind(myQueue).to(fanoutExchange);
? ? }
}

可以在配置類中使用 @Bean 注解來創(chuàng)建隊(duì)列、交換機(jī)和綁定規(guī)則。

6、使用消息發(fā)送者發(fā)送消息：在需要發(fā)送消息的地方，通過依賴注入 MessageSender，然后調(diào)用 sendMessage() 方法發(fā)送消息，例如：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class MyController {
? ? private final MessageSender messageSender;
? ? @Autowired
? ? public MyController(MessageSender messageSender) {
? ? ? ? this.messageSender = messageSender;
? ? }
? ? @GetMapping("/send-message")
? ? public void sendMessage() {
? ? ? ? String exchange = "myExchange";
? ? ? ? String routingKey = "";
? ? ? ? Object message = "Hello, RabbitMQ!";
? ? ? ? messageSender.sendMessage(exchange, routingKey, message);
? ? }
}

我們通過依賴注入 MessageSender 對(duì)象，在需要發(fā)送消息的方法中調(diào)用 sendMessage() 方法發(fā)送消息。

我們可以在 Spring Boot 中接入 RabbitMQ，并使用消息發(fā)送者發(fā)送消息，消息接收者監(jiān)聽隊(duì)列并處理接收到的消息。同時(shí)，還可以根據(jù)需要進(jìn)行交換機(jī)和隊(duì)列的配置。

到此這篇關(guān)于springboot接入mq的方法示例的文章就介紹到這了,更多相關(guān)springboot接入mq內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: