另外,我发现一个小问题,不知道是我的理解错误还是本身就是这样,当我在用这里的代码去整合springboot的时候,项目启动和运行都在我的期望之内,不过在项目停止的时候出现了一个错误,而我没有能力去解决...
报错代码:Channel channel = connection.createChannel(false);
报错信息:java.lang.IllegalStateException: The ApplicationContext is closed and the ConnectionFactory can no longer create connections.
我的理解是当我关闭应用的时候,您的connctionFactory关闭了,但是线程还在跑,并尝试去建立rabbitMQ连接,但是由于connctionFactory不再提供connction导致这里连接通道失败,不知道是不是这样产生的。
我的所有的改造后的代码:https://github.com/zhaoqicheng/springboot-rabbitmq-learning
如果大神有时间...能不能帮我参考一下这个问题
rabbitmq可靠发送的自动重试机制//www.greatytc.com/p/4112d78a8753 接这篇 在上文中,主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略,主...
@littlersmall 是的,昨天下午已经研究明白,另外我查阅了资料您使用的@PostConstruct注解来作为消费者运行时机,这个可以完全代替 @RabbitListener(queues = "xxx")和@RabbitHandler注解吗?之前没用过@PostConstruct注解,资料上说@PostConstruct是在这个类被在实例化的时候就会调用,可以完全代替吗?我可以在项目中直接按照您的代码来写吗?
rabbitmq可靠发送的自动重试机制//www.greatytc.com/p/4112d78a8753 接这篇 在上文中,主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略,主...
请问一下,您里面用的注解@PostConstruct配合init方法,和使用rabbitMQ监听的注解@RabbitListener(queues = "xxxx")效果是一样的吗?另外,我在测试您的代码的时候发现,当我不去消费的时候使用您的send方法来发送消息,您的代码里面是不是有这样的机制,当超过一定时间未消费的话,会重新发送消息到通道?如果是的话,这样是否合理?(您写的代码太精简,我真的是有点看不懂。如果在gitlab上面添加一点注释就好了!!!哈哈哈 )。。
请问一下,您里面用的注解@PostConstruct配合init方法,和使用rabbitMQ监听的注解@RabbitListener(queues = "xxxx")效果是一样的吗?另外,我在测试您的代码的时候发现,当我不去消费的时候使用您的send方法来发送消息,您的代码里面是不是有这样的机制,当超过一定时间未消费的话,会重新发送消息到通道?如果是的话,这样是否合理?(您写的代码太精简,我真的是有点看不懂。如果在gitlab上面添加一点注释就好了!!!哈哈哈 )。。
rabbitmq可靠发送的自动重试机制//www.greatytc.com/p/4112d78a8753 接这篇 在上文中,主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略,主...