热门标签
热门文章
- 1Unity Bound_unity中的bound
- 2基于ssm的宠物医院管理系统的设计与实现_宠物医院管理软件设计
- 3Android EditText关于imeOptions的设置和响应_android:imeoptions
- 4RTTHREAD 软件包目录（实时更新）_rtthread env 软件包目录
- 5从高考到程序员的成长之路_cui 程序员
- 6LeetCode-48. 旋转图像【数组 数学 矩阵】
- 7图文介绍HTTP/2（特性、解决的问题、实现方法）_http2 实现
- 8我，程序员，32岁失业后干啥都赔钱，月薪2万的好日子一去不返_失业的程序员在干什么
- 9开源 | 30余套STM32单片机、嵌入式Linux、物联网、人工智能项目(开发板+教程+视频)_单片机开源项目
- 10如何阅读“计算机界三大神书”之一 ——SICP
当前位置: article > 正文
Spring RabbitMQ 异步消费_rabbitmq 没有异步消费
作者：盐析白兔 | 2024-04-08 12:28:47
赞
踩
rabbitmq 没有异步消费
Spring RabbitMQ
1。消费端配置异步消费几种方式，最简洁方式为第三种
1）配置文件配置Container-listener指定处理对象但不指定方法，对应对象实现MessageListener接口，覆写onMessage方法
<!--配置监听-->
<rabbit:listener-container connection-factory="connectionFactory">
<rabbit:listener queue-names="myQueue" ref="consumerReceiver"/>
</rabbit:listener-container>
<!-- 编写处理对象-->
public class MessageReceiver implements MessageListener {
public void onMessage(Message message) {
System.out.println(message.getBody());
}
}
2）配置文件配置Container-listener指定处理对象但指定方法，对应对象为普通对象，不需要实现MessageListener接口
<!--配置监听-->
<rabbit:listener-container connection-factory="connectionFactory">
<rabbit:listener queue-names="myQueue" ref="consumerReceiver" method="messageHandler" priority="10"/>
</rabbit:listener-container>
<!-- 编写处理对象-->
@Component
public class MessageReceiver {
public void messageHandler(User user) {
System.out.println(user.getName());
}
}
3）配置开启Rabbit注解，注册
SimpleRabbitListenerContainerFactory并配置参数，消费对象（不需要实现继承任何类）使用注解标记，推荐此方式
<!--配置监听-->
<rabbit:annotation-driven/>
<bean id="rabbitListenerContainerFactory" class="org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory">
<!-- 需要转化时配置，这里配置使用json转对象-->
<property name="messageConverter" ref="messageConverter" />
<property name="connectionFactory" ref="connectionFactory"/>
<property name="concurrentConsumers "value="3"/>
<property name="maxConcurrentConsumers"value="10"/>
</bean>
<!-- json转换器，消息可以自动根据转换器转换格式，不配置时默认为java序列化，可以自行配置 -->
<bean id="messageConverter" class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter" />
<!-- 编写处理对象，注解定义在方法级别，还可以注解定义在对象@RabbitListener和方法@RabbitHandler-->
@Component
public class MyService {
@RabbitListener(bindings = @QueueBinding( value = @Queue(value = "myQueue", durable = "true"), exchange = @Exchange(value = "auto.exch", ignoreDeclarationExceptions = "true"), key = "orderRoutingKey") )
public void processOrder(User user) { ... }
}
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/盐析白兔/article/detail/385478
推荐阅读
相关标签
