rabbitMQ高级整合应用第三篇 SimpleMessageListenerContainer

简介 rabbitMQ精讲系列第二十一篇高级整合应用第三篇 SimpleMessageListenerContainer今天主要内容:SimpleMessageListenerContainer对象SimpleMessageListenerContainer:简单消息监听容器。这个类非常的强大,我们可以对它进行很多的设置,对应消费者的配置项,这个类都可以满足的。监听队列(多个队列)、自动启动、

🔔🔔好消息!好消息!🔔🔔

 如果您需要注册ChatGPT,想要升级ChatGPT4。凯哥可以代注册ChatGPT账号代升级ChatGPT4

有需要的朋友👉:微信号 kaigejava2022


rabbitMQ精讲系列第二十一篇 高级整合应用第三篇 SimpleMessageListenerContainer

今天主要内容:

SimpleMessageListenerContainer对象

SimpleMessageListenerContainer:简单消息监听容器。

这个类非常的强大,我们可以对它进行很多的设置,对应消费者的配置项,这个类都可以满足的。

监听队列(多个队列)、自动启动、自动声明功能

设置事务特性、事务管理器、事务属性、事务容量(并发)、是否开启事务、回滚消息等

设置消费者数量、最大最小数量、批量消费

设置消息确认和自动确认模式、是否重回队列、异常捕获handler函数

主要:SimpleMessageListenerContainer可以进行动态设置。比如在运行中的应用可以动态的修改其消费者数量的大小、接收消息的模式等

很多基于RabbitMq的自制定化后端管理台在进行动态设置的是,也是根据这个特性去实现的

思考:SimpleMessageListenerContainer为什么可以动态感知配置变化?

代码示例:

在rabbitMQConfig类中添加SimpleMessageListenerContainer的bean.在simpleMessageListenerContainer可以设置很多东西。如下图:

设置签收模式

@Bean

public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory){

SimpleMessageListenerContainer messageListenerContainer = new SimpleMessageListenerContainer(connectionFactory);

//添加队列监听

messageListenerContainer.setQueues(queue001, queue002, queue003, queue_image, queue_pdf);

//设置监听数据

messageListenerContainer.setConcurrentConsumers(1);

messageListenerContainer.setMaxConcurrentConsumers(5);

//设置是否重回队列

messageListenerContainer.setDefaultRequeueRejected(false);

//设置签收模式 为自动签收

messageListenerContainer.setAcknowledgeMode(AcknowledgeMode.AUTO);

//设置客户端tage

messageListenerContainer.setConsumerTagStrategy(new ConsumerTagStrategy {

@Override

public String createConsumerTag(String queue) {

return queue+"_"+ UUID.randomUUID.toString;

}

});

//消息

messageListenerContainer.setMessageListener(new ChannelAwareMessageListener {

@Override

public void onMessage(Message message, Channel channel) throws Exception {

String msg = new String (message.getBody,"UTF-8");

System.out.println(">>消息为:"+msg);

}

});

return messageListenerContainer;

}

启动代码,我们从页面管控台查看:

点进去查看:

我们可以看到,我们自定义的consumer tag已经生效了

进行发送消息测试。

在测试类中,运行发送消息的代码:

运行之后,我们在控制台可以看到,打印出三条数据。也就是我们在RabbitMqConfig类中设置的。如下图:

说明监听消息成功。

经过以上两个测试,我们的simpleMessageListenerContainer设置成功了。

相关代码以更新到git上了。

下节预告:MessageListenerAdapter


TopTop