快捷導(dǎo)航

Spring Boot整合消息隊列RabbitMQ的實現(xiàn)示例

更新時間：2025年03月02日 14:38:40 作者：珠峰日記

本文主要介紹了Spring Boot整合消息隊列RabbitMQ的實現(xiàn)示例,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

RabbitMQ 簡介與安裝

1. RabbitMQ 簡介

RabbitMQ 是一個開源的消息代理和隊列服務(wù)器，基于 AMQP（高級消息隊列協(xié)議）實現(xiàn)。它具有以下特點：

可靠性：支持持久化、傳輸確認(rèn)、發(fā)布確認(rèn)等機(jī)制，確保消息不丟失。
靈活性：支持多種消息模型，如點對點、發(fā)布 - 訂閱等。
分布式：可以通過集群和鏡像隊列來實現(xiàn)高可用性和擴(kuò)展性。
多語言支持：支持多種編程語言，如 Java、Python、C# 等。

2. RabbitMQ 安裝

以下以在 Linux（Ubuntu）系統(tǒng)上安裝 RabbitMQ 為例：

步驟 1：安裝 ErlangRabbitMQ 是用 Erlang 語言編寫的，因此需要先安裝 Erlang。

# 添加 Erlang 倉庫
wget https://packages.erlang-solutions.com/erlang-solutions_2.0_all.deb
sudo dpkg -i erlang-solutions_2.0_all.deb
sudo apt-get update

# 安裝 Erlang
sudo apt-get install esl-erlang

步驟 2：安裝 RabbitMQ

# 添加 RabbitMQ 倉庫
echo "deb https://dl.bintray.com/rabbitmq/debian $(lsb_release -sc) main" | sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list
wget -O- https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc | sudo apt-key add -
wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -
sudo apt-get update

# 安裝 RabbitMQ
sudo apt-get install rabbitmq-server

步驟 3：啟動 RabbitMQ 服務(wù)

sudo systemctl start rabbitmq-server

步驟 4：設(shè)置開機(jī)自啟

sudo systemctl enable rabbitmq-server

步驟 5：啟用管理界面

sudo rabbitmq-plugins enable rabbitmq_management

訪問 http://localhost:15672，使用默認(rèn)用戶名 guest 和密碼 guest 登錄管理界面。

Spring Boot 集成 RabbitMQ

1. 創(chuàng)建 Spring Boot 項目

可以使用 Spring Initializr（https://start.spring.io/）創(chuàng)建一個新的 Spring Boot 項目，添加以下依賴：

Spring Web
Spring AMQP

2. 配置 RabbitMQ

在 application.properties 或 application.yml 中配置 RabbitMQ 連接信息：

application.properties

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

application.yml

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

3. 定義消息隊列和交換機(jī)

創(chuàng)建一個配置類來定義隊列、交換機(jī)和綁定關(guān)系：

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

    public static final String QUEUE_NAME = "myQueue";
    public static final String EXCHANGE_NAME = "myExchange";
    public static final String ROUTING_KEY = "myRoutingKey";

    @Bean
    public Queue queue() {
        return new Queue(QUEUE_NAME, true);
    }

    @Bean
    public DirectExchange exchange() {
        return new DirectExchange(EXCHANGE_NAME);
    }

    @Bean
    public Binding binding(Queue queue, DirectExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
    }
}

4. 發(fā)送消息

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

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class MessageSender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, RabbitMQConfig.ROUTING_KEY, message);
    }
}

5. 接收消息

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

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class MessageReceiver {

    @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME)
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

6. 測試消息發(fā)送和接收

創(chuàng)建一個控制器來測試消息發(fā)送：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MessageController {

    @Autowired
    private MessageSender messageSender;

    @GetMapping("/send")
    public String sendMessage(@RequestParam String message) {
        messageSender.sendMessage(message);
        return "Message sent: " + message;
    }
}

啟動 Spring Boot 應(yīng)用程序，訪問 http://localhost:8080/send?message=Hello,RabbitMQ，在控制臺可以看到消息接收的輸出。

通過以上步驟，就完成了 Spring Boot 與 RabbitMQ 的集成，實現(xiàn)了消息的發(fā)送和接收。

到此這篇關(guān)于Spring Boot整合消息隊列RabbitMQ的實現(xiàn)示例的文章就介紹到這了,更多相關(guān)Spring Boot 消息隊列RabbitMQ內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: