rabbitMQ高級(jí)整合應(yīng)用第四篇 消息監(jiān)聽(tīng)適配器

RabbitMQ學(xué)習(xí)系列第二十二篇 高級(jí)整合 第四篇MessageListenerAdapter

MessageListenerAdaoter:即消息監(jiān)聽(tīng)適配器。

代碼演示：

在config類中修改：

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

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

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

messageListenerContainer.setMessageListener(adapter);

在來(lái)看看

MessageDelegate類：

運(yùn)行測(cè)試類：

@Test

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

???//創(chuàng)建消息

???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;

????? }

?? });

}

運(yùn)行效果：

說(shuō)明我們使用適配器模式成功。

說(shuō)明：

在MessageDelegate類中

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

為什么handlerMessage方法不能修改。我們來(lái)看看源碼：

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

如果想要指定自己寫(xiě)的名字。其實(shí)也是可以的。

在config中l(wèi)istener在setadapter的時(shí)候可以指定默認(rèn)的方法名稱。

如下：

修改MessageDelegate:

運(yùn)行測(cè)試：

我們?cè)诳刂婆_(tái)可以看到，調(diào)用了我們自定義的方法了。

說(shuō)明，修改默認(rèn)調(diào)用方法成功。

修改消息內(nèi)容，不使用OBJ數(shù)組。使用字符串。

修改MessageDelegate類如下：

修改config.添加messageConverter:

MyMessageConveter類：

執(zhí)行測(cè)試方法：

在控制臺(tái)上正確的打印出來(lái)。說(shuō)明我們修改消息轉(zhuǎn)換類成功。

本文總結(jié)：

下節(jié)預(yù)告：

我們繼續(xù)講解自定義消息轉(zhuǎn)換器