springboot 和 rabbitmq 实现同步和异步队列
2018-02-01 14:26
661 查看
异步队列配置代码
@Component @RabbitListener(bindings = {@QueueBinding(value = @Queue(value = "async"), exchange = @Exchange(value = "async.exchange"))}) public class AsyncConsumer { public void execute(Message message) { } }
异步发送消息发送代码
amqpTemplate.convertAndSend('async.exchange','','内容');
同步队列配置代码
@Component @RabbitListener(queues = "sync") public class SyncConsumer { @Override public Boolean execute(Message message) { return true; } }
同步发送消息发送代码
Object content = amqpTemplate.convertSendAndReceive('async.exchange','','内容');
以上就是同步和异步的配置方式和发送消息方式
同步发送消息时有超时时间如果超过配置时间则视为失败,这个配置可以在
RabbitTemplate 的 setReplyTimeout 配置超时时间 配置为-1时是无视超时间,默认超时时间为5秒。
相关文章推荐
- SpringBoot整合RabbitMQ实现微服务间的异步消息沟通
- SpringBoot 集成 rabbitmq 简单实现通过队列进行,订单系统与库存系统,物流系统之间的信息交互
- [置顶] 【Excel_To_DB】SpringBoot+EasyPoi+Redis消息队列实现Excel批量异步导入数据库(一)
- Spring Boot与RabbitMQ结合实现延迟队列的示例
- [置顶] 【Excel_To_DB】SpringBoot+EasyPoi+Redis消息队列实现Excel批量异步导入数据库(三)
- springboot+springAOP实现数据库读写分离及数据库同步(MySQL)
- Spring Boot使用@Async实现异步调用
- Spring Boot中使用@Async实现异步调用
- rabbitmq结合spring实现消息队列优先级
- Spring Boot与RabbitMQ延迟队列使用示例
- Spring Boot + RabbitMQ 实现消息队列场景
- Spring Boot中使用@Async实现异步调用
- springboot~rabbitmq的队列初始化和绑定
- spring boot-使用redis的Keyspace Notifications实现定时任务队列
- Springboot+Quartz实现定时小demo(线程实现异步)
- Spring Boot中使用@Async实现异步调用
- SpringBoot非官方教程 | 第十四篇:在springboot中用redis实现消息队列
- Spring boot 下使用RabbitMQ报错:链接拒绝和不能创建队列
- springboot实现rabbitmq
- SpringBoot中如何监听两个不同源的RabbitMQ消息队列