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

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

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

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

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

1. @RabbitListener 注解方式

以下是使用 @RabbitListener 注解方式實現(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);
        // 在這里處理接收到的消息
    }
}

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

2. MessageListener 接口方式

以下是使用 MessageListener 接口方式實現(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); // 設置連接工廠
        container.setQueueNames("myQueue"); // 設置監(jiān)聽的隊列名稱
        container.setMessageListener(new MyMessageListener()); // 設置消息監(jiān)聽器
        container.start(); // 啟動監(jiān)聽容器
    }
}

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

3. MessageListenerAdapter 適配器方式

以下是使用 MessageListenerAdapter 適配器方式實現(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); // 設置連接工廠
        container.setQueueNames("myQueue"); // 設置監(jiān)聽的隊列名稱

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

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

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

4. @RabbitHandler 注解方式

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

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ù)類型消息
    }
}

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

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

您可能感興趣的文章: