0

**

得到rabbitmq连接错误如下。

**

2019-07-11 13:14:51.147.AMQP 连接 127.0.0.1:5672> 错误 - TID[] UID[] MID[] CID[] - 通道关闭:连接错误;协议方法:#method(reply-code=541, reply-text=INTERNAL_ERROR, class-id=0, method-id=0) 2019-07-11 13:14:51.831.bulkNotificationContainer-100> WARN - TID[] UID[] MID[] CID[] - 消费者引发异常,如果连接工厂支持,处理可以重新启动 com.rabbitmq.client.ShutdownSignalException: 连接错误;协议方法:#method(reply-code=541, reply-text=INTERNAL_ERROR, class-id=0, method-id=0) at com.rabbitmq.client.impl.AMQConnection.startShutdown(AMQConnection.java:742) ~ [amqp-client-3.6.5.jar!/:na] 在 com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:732) ~[amqp-client-3.6.5.jar!/:na]在 com.rabbitmq.client.impl.AMQConnection。

我的 spring-boot 服务使用 rabbitmq 异步发送推送通知。因此,通过 rabbitmq 推送有效负载发布/接收,然后在 FCM 上发送。但是,此连接在过去一年中正常工作,没有任何问题。但是今天早上rabbitmq服务器重启如下

  1. rabbitmq 停止
  2. 杀死进程bean(相关的erlang)
  3. rabbitmq 启动

之后我们成功重启spring-boot服务,health-api显示rabbit-up状态。

但尝试发送推送时出错。

应用程序属性配置。

spring.rabbitmq.host=127.0.0.1 spring.rabbitmq.port=5672 spring.rabbitmq.username=rabbitadmin spring.rabbitmq.password=admin

自定义配置

rabbitmq.listeners.retry-policy = UNIFORM_RANDOM_DELAY rabbitmq.listeners.max-interval=15000 rabbitmq.listener.push-router.concurrent-consumers=2 rabbitmq.listener.push-router.max-concurrent-consumers=10

rabbitmq.binding.push-notification.queue.name=pushqueue rabbitmq.binding.push-notification.exchange.name=pushexchange rabbitmq.binding.push-notification.binding.routing-key=pushroute-binding

我想将数据发布/接收到rabbitmq 频道。

4

1 回答 1

0

重新安装rabbitmq的软件包后,此问题得到解决。还是不知道为什么会这样。。

于 2019-07-11T07:27:43.973 回答