**
получая ошибку соединения rabbitmq следующим образом.
**
2019-07-11 13: 14: 51.147.AMQP Соединение 127.0.0.1:5672> ОШИБКА - TID [] UID [] MID [] CID [] - отключение канала: ошибка подключения;Метод протокола: #method (код ответа = 541, текст ответа = INTERNAL_ERROR, идентификатор класса = 0, идентификатор метода = 0) 2019-07-11 13: 14: 51.831.bulkNotificationContainer-100> WARN - TID []UID [] MID [] CID [] - исключение, вызванное потребителем, обработка может быть перезапущена, если фабрика соединений поддерживает это com.rabbitmq.client.ShutdownSignalException: ошибка соединения;Метод протокола: #method (код ответа = 541, текст ответа = INTERNAL_ERROR, идентификатор класса = 0, идентификатор метода = 0) в 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.handleConnectionClose (AMQConnection.java:671) ~ [amqp-client-3.6.5.jar! /: na] в com.rabbitmq.client.impl.AMQConnection.processControlCommand (AMQConnection.java: 625) ~ [amqp-client-3.6.5.jar! /: na] в com.rabbitmq.client.impl.AMQConnection $ 1.processAsync (AMQConnection.java:102) ~ [amqp-client-3.6.5.jar! /: na] в com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand (AMQChannel.java:143) ~ [amqp-client-3.6.5.jar! /: na] в com.rabbitmq.client.impl.AMQChannel.handleFrame (AMQChannel.java:90) ~ [amqp-client-3.6.5.jar! /: Na] в com.rabbitmq.client.impl.AMQConnection $ MainLoop.run (AMQConnection.java:549) ~ [amqp-client-3.6.5.jar! /: na] на java.lang.Thread.run (Thread.java:745) [na: 1.8.0_73]
Мой сервис весенней загрузки, использующий rabbitmq для асинхронной отправки push-уведомлений.Так что push payload опубликовать / получить через rabbitmq, а затем отправить на FCM.Однако эта связь работает в течение последнего года без каких-либо проблем.Но сегодня утром сервер rabbitmq перезапускается следующим образом:
- остановка rabbitmq
- компонент процесса kill (связанный erlang)
- запуск rabbitmq
после этого мы успешно перезапускаем службу весенней загрузки, и health-api показывает состояние кролика.
, но при попытке отправить push.
конфигурация свойств приложения имеет ошибку.
spring.rabbitmq.host = 127.0.0.1 spring.rabbitmq.port = 5672 spring.rabbitmq.username = rabbitadmin spring.rabbitmq.password = admin
customконфигурация
rabbitmq.listeners.retry-policy = UNIFORM_RANDOM_DELAY rabbitmq.listeners.max-interval = 15000 rabbitmq.listener.push-router.concurrent-consumer = 2 rabbitmq.listener.push-router.max-concurrent-consumer = 10
rabbitmq.binding.push-notification.queue.name = pushqueue rabbitmq.binding.push-notification.exchange.name = pushexchange rabbitmq.binding.push -tification.binding.routing-ключ = pushroute-привязка
Я хочу публиковать / получать данные на канал rabbitmq.