快捷導(dǎo)航

SpringBoot實(shí)現(xiàn)RabbitMQ監(jiān)聽消息的四種方式

更新時(shí)間：2024年05月21日 09:02:52 作者：阿湯哥

本文主要介紹了SpringBoot實(shí)現(xiàn)RabbitMQ監(jiān)聽消息的四種方式,包括@RabbitListener,MessageListener接口,MessageListenerAdapter適配器,@RabbitHandler這幾種,感興趣的可以了解一下

@RabbitListener 注解方式：通過在方法上標(biāo)記 @RabbitListener 注解來監(jiān)聽指定的隊(duì)列，當(dāng)消息到達(dá)時(shí)，被注解的方法將被調(diào)用。
MessageListener 接口方式：實(shí)現(xiàn) Spring AMQP 提供的 MessageListener 接口，編寫自定義的消息監(jiān)聽器，然后使用 SimpleMessageListenerContainer 設(shè)置消息監(jiān)聽器。
MessageListenerAdapter 適配器方式：通過 MessageListenerAdapter 類，可以將普通的 Java 方法轉(zhuǎn)換為消息監(jiān)聽器，從而簡化消息處理邏輯。
@RabbitHandler 注解方式：結(jié)合 @RabbitListener 和 @RabbitHandler 注解，可以實(shí)現(xiàn)多個(gè)不同類型消息的處理方法，根據(jù)消息內(nèi)容的不同調(diào)用對應(yīng)的處理方法。

這些方式都可以在 Spring Boot 項(xiàng)目中方便地實(shí)現(xiàn) RabbitMQ 的消息監(jiān)聽功能。

1. @RabbitListener 注解方式

以下是使用 @RabbitListener 注解方式實(shí)現(xiàn) RabbitMQ 消息監(jiān)聽的示例代碼：

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

@Component
public class RabbitMQListener {

    @RabbitListener(queues = "myQueue")
    public void handleMessage(String message) {
        System.out.println("Received message: " + message);
        // 在這里處理接收到的消息
    }
}

在這個(gè)示例中，我們創(chuàng)建了一個(gè)名為 RabbitMQListener 的類，并使用 @RabbitListener 注解標(biāo)記 handleMessage 方法，指定監(jiān)聽名為 “myQueue” 的隊(duì)列。當(dāng)消息到達(dá)隊(duì)列時(shí)，handleMessage 方法將被調(diào)用來處理接收到的消息。

2. MessageListener 接口方式

以下是使用 MessageListener 接口方式實(shí)現(xiàn) RabbitMQ 消息監(jiān)聽的示例代碼：

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;

public class MyMessageListener implements MessageListener {

    @Override
    public void onMessage(Message message) {
        System.out.println("Received message: " + new String(message.getBody()));
        // 在這里處理接收到的消息
    }

    public static void main(String[] args) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(connectionFactory); // 設(shè)置連接工廠
        container.setQueueNames("myQueue"); // 設(shè)置監(jiān)聽的隊(duì)列名稱
        container.setMessageListener(new MyMessageListener()); // 設(shè)置消息監(jiān)聽器
        container.start(); // 啟動監(jiān)聽容器
    }
}

在這個(gè)示例中，我們創(chuàng)建了一個(gè)實(shí)現(xiàn)了 MessageListener 接口的 MyMessageListener 類來處理接收到的消息。然后，我們使用 SimpleMessageListenerContainer 設(shè)置連接工廠、隊(duì)列名稱和消息監(jiān)聽器，并啟動監(jiān)聽容器。當(dāng)消息到達(dá)時(shí)，onMessage 方法將被調(diào)用來處理接收到的消息。

3. MessageListenerAdapter 適配器方式

以下是使用 MessageListenerAdapter 適配器方式實(shí)現(xiàn) RabbitMQ 消息監(jiān)聽的示例代碼：

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.amqp.support.converter.SimpleMessageConverter;

public class MyMessageListener {

    public void handleMessage(String message) {
        System.out.println("Received message: " + message);
        // 在這里處理接收到的消息
    }

    public static void main(String[] args) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(connectionFactory); // 設(shè)置連接工廠
        container.setQueueNames("myQueue"); // 設(shè)置監(jiān)聽的隊(duì)列名稱

        MessageListenerAdapter adapter = new MessageListenerAdapter(new MyMessageListener());
        adapter.setDefaultListenerMethod("handleMessage"); // 設(shè)置默認(rèn)處理方法
        MessageConverter converter = new SimpleMessageConverter();
        adapter.setMessageConverter(converter); // 設(shè)置消息轉(zhuǎn)換器

        container.setMessageListener(adapter); // 設(shè)置消息監(jiān)聽適配器
        container.start(); // 啟動監(jiān)聽容器
    }
}

在這個(gè)示例中，我們創(chuàng)建了一個(gè) MyMessageListener 類，并定義了一個(gè)處理消息的方法 handleMessage。然后，我們使用 MessageListenerAdapter 類將 MyMessageListener 類中的方法轉(zhuǎn)換為消息監(jiān)聽器，并設(shè)置默認(rèn)處理方法。最后，將消息監(jiān)聽適配器設(shè)置到 SimpleMessageListenerContainer 中，并啟動監(jiān)聽容器來處理接收到的消息。

4. @RabbitHandler 注解方式

使用 @RabbitHandler 注解方式結(jié)合 @RabbitListener 注解實(shí)現(xiàn)多個(gè)不同類型消息的處理示例代碼如下：

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
@RabbitListener(queues = "myQueue")
public class MyMessageHandler {

    @RabbitHandler
    public void handleStringMessage(String message) {
        System.out.println("Received string message: " + message);
        // 處理字符串類型消息
    }

    @RabbitHandler
    public void handleIntMessage(Integer message) {
        System.out.println("Received integer message: " + message);
        // 處理整數(shù)類型消息
    }
}

在這個(gè)示例中，我們創(chuàng)建了一個(gè)名為 MyMessageHandler 的類，并使用 @RabbitListener 注解標(biāo)記整個(gè)類，指定監(jiān)聽名為 “myQueue” 的隊(duì)列。然后，我們在類中定義了兩個(gè)處理消息的方法，分別使用 @RabbitHandler 注解標(biāo)記，分別處理字符串類型和整數(shù)類型的消息。當(dāng)不同類型的消息到達(dá)隊(duì)列時(shí)，根據(jù)消息類型調(diào)用對應(yīng)的處理方法來處理消息。

到此這篇關(guān)于SpringBoot實(shí)現(xiàn)RabbitMQ監(jiān)聽消息的四種方式的文章就介紹到這了,更多相關(guān)SpringBoot RabbitMQ監(jiān)聽內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: