重新创建队列并重新连接到rabbitMQ

涉及的组件：Spring Config-server，Spring AMQP（RabbitMQ），Spring Config-client

目标：使用推送通知来通知config-client刷新配置。

• RabbitMQ实例：从docker hub，我拉出Rabbitmq：3-management图像并运行。

• 配置客户端AMQP版本pom.xml：

  <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-bus-amqp</artifactId>
      <version>1.3.1.RELEASE</version>
  </dependency>
  

• 配置服务器pom.xml：

  <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-config-monitor</artifactId>
      <version>1.3.1.RELEASE</version>
  </dependency>
  
  <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
      <version>1.2.1.RELEASE</version>
  </dependency>
  

容错方案： -降低RabbitMQ服务/集群/实例。-所有配置客户端失去连接。由于队列是作为自动删除创建的，因此将被删除。-恢复RabbitMQ服务。

• 期望：所有配置客户端应重新连接成功。

• 现实：这不起作用。请查看以下错误。

2018-03-27 09：07：12.850 WARN 21251 --- [AO2Q06fYCALSA-6] osarlistener.BlockingQueueConsumer：无法声明队列：springCloudBus.anonymous.FGZPCPqzTAO2Q06fYCALSA 2018-03-27 09：07：12.851错误21251 --- [[ AO2Q06fYCALSA-6] osarlSimpleMessageListenerContainer：消费者在启动时收到致命异常

org.springframework.amqp.rabbit.listener.QueuesNotAvailableException：无法为侦听器准备队列。要么队列不存在，要么经纪人不允许我们使用它。在org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start（BlockingQueueConsumer.java:548）在org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer $ AsyncMessageProcessingConsumer.run（SimpleMessageListenerContainer.java:1335）在java.base / java .lang.Thread.run（Thread.java:844）由以下原因导致：org.springframework.amqp.rabbit.listener.BlockingQueueConsumer $ DeclarationException：无法声明队列：[springCloudBus.anonymous.FGZPCPqzTAO2Q06fYCALSA]在org.springframework上。位于org.springframework.amqp.rabbit.listener.BlockingQueueConsumer的amqp.rabbit.listener.BlockingQueueConsumer.attemptPassiveDeclarations（BlockingQueueConsumer.java:621）。

引起原因：com.rabbitmq.client.ShutdownSignalException：通道错误；协议方法：#method（回复代码= 404，回复文本= NOT_FOUND-虚拟主机'/'中没有队列'springCloudBus.anonymous.FGZPCPqzTAO2Q06fYCALSA'，类别ID = 50，方法ID = 10）

[省略公共帧]原因：com.rabbitmq.client.ShutdownSignalException：通道错误；协议方法：com.rabbitmq上的#method（回复代码= 404，回复文本= NOT_FOUND-虚拟主机'/'中没有队列'springCloudBus.anonymous.FGZPCPqzTAO2Q06fYCALSA'，vhost'/'，class-id = 50，method-id = 10）。 client.impl.ChannelN.asyncShutdown（ChannelN.java:505）

[省略共同的框架]

2018-03-27 09：07：12.852错误21251 --- [AO2Q06fYCALSA-6] osarlSimpleMessageListenerContainer：停止中止消费者的容器2018-03-27 09：07：12.853 INFO 21251 --- [AO2Q06fYCALSA-6] osarlSimpleMessageListenerContainer：等待供工人完成。2018-03-27 09：07：12.853信息21251-[AO2Q06fYCALSA-6] osarlSimpleMessageListenerContainer：成功地等待工作人员完成。

• 我的理解是，使用现有代理的配置客户端的错误描述，侦听器尝试重新连接，但队列丢失。默认情况下进行3次重试。这是预期的，因为我们正在处理Rabbit MQ服务关闭并在没有持久数据的情况下重新启动的情况。问题是重新连接失败。我从许多文章中知道，提到我们必须使用admin才能重新声明队列。为此，我们创建了一个XML配置文件，该文件创建了声明admin和其他内容的属性bean。

问什么？-如果默认情况下所有这些都得到照顾，那将是理想的选择吗？**另外，我仍然没有有效的解决方案。需要帮忙”