快捷導(dǎo)航

偵聽(tīng)消息隊(duì)列的Message Listener類(lèi)示例詳解

更新時(shí)間：2023年12月09日 10:48:33 作者：Rcfee

Spring AMQP 是基于 Spring 框架的AMQP消息解決方案,提供模板化的發(fā)送和接收消息的抽象層,提供基于消息驅(qū)動(dòng)的 POJO的消息監(jiān)聽(tīng)等,簡(jiǎn)化了我們對(duì)于RabbitMQ相關(guān)程序的開(kāi)發(fā),本文給大家介紹偵聽(tīng)消息隊(duì)列的Message Listener類(lèi),感興趣的朋友一起看看吧

Spring AMQP 是基于 Spring 框架的AMQP消息解決方案，提供模板化的發(fā)送和接收消息的抽象層，提供基于消息驅(qū)動(dòng)的 POJO的消息監(jiān)聽(tīng)等，簡(jiǎn)化了我們對(duì)于RabbitMQ相關(guān)程序的開(kāi)發(fā)。

Spring AMQP包含一些模塊，如：spring-amqp, spring-rabbit and spring-erlang等，每個(gè)模塊分別由獨(dú)立的一些Jar包組成。

AbstractAdaptableMessageListener用于在spring容器接收到消息后用于處理消息的抽象基類(lèi)，如果需要使用自己定義的pojoL類(lèi)來(lái)實(shí)現(xiàn)處理消息時(shí)，必須要繼承該類(lèi)，并實(shí)現(xiàn)onMessage()方法，如下：

public class MessageReceive extends AbstractAdaptableMessageListener {
    private static final Logger LOGGER = LoggerFactory.getLogger(MessageReceive.class);
    @Override
    public void onMessage(Message message, Channel channel) throws Exception {
        LOGGER.info("receive message:{}", new String(message.getBody(), "UTF-8"));
    }
}

實(shí)現(xiàn)了MessageListener, ChannelAwareMessageListener接口

MessageListener

@FunctionalInterface
public interface MessageListener {
	void onMessage(Message message);
}

@FunctionalInterface注解表示該接口是一個(gè)功能類(lèi)接口

ChannelAwareMessageListener

@FunctionalInterface
public interface ChannelAwareMessageListener {
	/**
	 * Callback for processing a received Rabbit message.
	 * <p>Implementors are supposed to process the given Message,
	 * typically sending reply messages through the given Session.
	 * @param message the received AMQP message (never <code>null</code>)
	 * @param channel the underlying Rabbit Channel (never <code>null</code>)
	 * @throws Exception Any.
	 */
	void onMessage(Message message, Channel channel) throws Exception;
}

在AbstractAdaptableMessageListener中實(shí)現(xiàn)了MessageListener類(lèi)的onMessage(Message message)方法，其實(shí)際實(shí)現(xiàn)的還是ChannelAwareMessageListener類(lèi)中的onMessage方法，channel設(shè)置為null

@Override
	public void onMessage(Message message) {
		try {
			onMessage(message, null);
		}
		catch (Exception e) {
			throw new ListenerExecutionFailedException("Listener threw exception", e, message);
		}
	}

自定義消息處理的POJO類(lèi)繼承AbstractAdaptableMessageListener類(lèi)后，重寫(xiě)onMessage方法，當(dāng)spring容器接收消息后，會(huì)自動(dòng)交由onMessage進(jìn)行處理。

到此這篇關(guān)于偵聽(tīng)消息隊(duì)列的Message Listener類(lèi)的文章就介紹到這了,更多相關(guān)偵聽(tīng)消息隊(duì)列Message Listener類(lèi)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: