search

forezp / blog-comments

3 stars 0 forks source link

Spring Boot教程第15篇：Rabbitmq - 方志朋的博客 #81

Open forezp opened 5 years ago

forezp commented 5 years ago

https://www.fangzhipeng.com/springboot/2017/05/15/sb15-rabbitmq.html

这篇文章带你了解怎么整合RabbitMQ服务器，并且通过它怎么去发送和接收消息。我将构建一个springboot工程，通过RabbitTemplate去通过MessageListenerAdapter去订阅一个POJO类型的消息。

ruanwenjun commented 5 years ago

hi,您好，对于>其中，它有CountDownLatch这样的一个类，它是用于告诉发送者消息已经收到了，你不需要在应用程序中具体实现它，只需要latch.countDown()就行了 这句话我不太理解

drinkagain commented 5 years ago

你好，springboot 与 rabbitmq 整合，配置文件里有个配置是spring.rabbitmq.listener.simple.retry.enable = true， 我配置过之后为什么retry不生效呢？或者是在什么情况下@RabbitListener 才会触发retry呢？ 比如支付宝接口回调，如果没有收到success答复，则过几分钟后再次回调。如果用rabbitmq 该如何才能实现没有unack 的消息过几分钟后再次回调呢？谢谢你

drinkagain commented 5 years ago

springboot 2.0 在配置retry时有个stateless 如果设置为true 在linster抛出业务异常时就能重发，如果设置为false则不行

yangjunguang commented 5 years ago

AMQP.Queue(String, boolean) is undefined

yangjunguang commented 5 years ago

import包引入错了，应该引入： import org.springframework.amqp.core.Queue;