rabbitMQ高級整合應用第四篇 消息監聽適配器

RabbitMQ學習系列第二十二篇 高級整合 第四篇MessageListenerAdapter

MessageListenerAdaoter:即消息監聽適配器。

代碼演示：

在config類中修改：

在SimpleMessageListenerContainer?bean中(上一節課代碼演示)修改如下：

/** 使用適配器模式 **/

MessageListenerAdapter adapter =?new?MessageListenerAdapter(new?MessageDelegate());

messageListenerContainer.setMessageListener(adapter);

在來看看

MessageDelegate類：

運行測試類：

@Test

public void?setRabbitTemplateTest()?throws??Exception{

???//創建消息

???MessageProperties messageProperties =?new?MessageProperties();

?? messageProperties.getHeaders().put("desc","這里可以添加一些描述信息");

?? messageProperties.getHeaders().put("mytype","這里是自定義的");

?? String msessage =?"this spring msg";

?? Message message =?new?Message(msessage.getBytes(),messageProperties);

???//使用模板

???rabbitTemplate.convertAndSend("topic001",?"spring.amqp", message,?new?MessagePostProcessor() {

??????@Override

??????public?Message postProcessMessage(Message message)?throws?AmqpException {

???????? System.out.println("------添加額外的信息---------");

???????? message.getMessageProperties().getHeaders().put("desc","這里可以添加一些描述信息。這是修改后的");

???????? message.getMessageProperties().getHeaders().put("attr","哎呦，這是額外的");

?????????return?message;

????? }

?? });

}

運行效果：

說明我們使用適配器模式成功。

說明：

在MessageDelegate類中

handleMessage方法名稱和參數不能修改。方法體我們可以自定義的。

為什么handlerMessage方法不能修改。我們來看看源碼：

在源碼中，有個DEFAULT_LISTENER_METHOD的靜態變量。其值就是handleMessage了。這下知道為什么不能去掉了吧。

如果想要指定自己寫的名字。其實也是可以的。

在config中listener在setadapter的時候可以指定默認的方法名稱。

如下：

修改MessageDelegate:

運行測試：

我們在控制臺可以看到，調用了我們自定義的方法了。

說明，修改默認調用方法成功。

修改消息內容，不使用OBJ數組。使用字符串。

修改MessageDelegate類如下：

修改config.添加messageConverter:

MyMessageConveter類：

執行測試方法：

在控制臺上正確的打印出來。說明我們修改消息轉換類成功。

本文總結：

下節預告：

我們繼續講解自定義消息轉換器