rabbitMQ高级整合应用第三篇 SimpleMessageListenerContainer
原创rabbitMQ高级整合应用第三篇 SimpleMessageListenerContainer
原创
rabbitMQ精讲系列第二十一篇 高级整合应用第三篇 SimpleMessageListenerContainer
今天主要内容：
SimpleMessageListenerContainer对象
SimpleMessageListenerContainer：简单消息监听容器。
这个类非常的强大，我们可以对它进行很多的设置，对应消费者的配置项，这个类都可以满足的。
监听队列(多个队列)、自动启动、自动声明功能
设置事务特性、事务管理器、事务属性、事务容量（并发）、是否开启事务、回滚消息等
设置消费者数量、最大最小数量、批量消费
设置消息确认和自动确认模式、是否重回队列、异常捕获handler函数
主要：SimpleMessageListenerContainer可以进行动态设置。比如在运行中的应用可以动态的修改其消费者数量的大小、接收消息的模式等
很多基于RabbitMq的自制定化后端管理台在进行动态设置的是，也是根据这个特性去实现的
思考：SimpleMessageListenerContainer为什么可以动态感知配置变化？
代码示例：
在rabbitMQConfig类中添加SimpleMessageListenerContainer的bean.在simpleMessageListenerContainer可以设置很多东西。如下图：
设置签收模式
@Beanpublic 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
原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。
原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。