org.springframework.amqp.rabbit.connection.CachingConnectionFactory
을 사용하여 RabbitMQ에 연결합니다. 그러나 네트워크 문제로 인해 내 응용 프로그램이 토끼 서버에 자동으로 다시 연결되지 않음 (네트워크 문제로 인해)spring amqp와 다시 연결
CachingConnectionFactory
자동으로 다시 연결되도록 구성되어 있습니까?
org.springframework.amqp.rabbit.connection.CachingConnectionFactory
을 사용하여 RabbitMQ에 연결합니다. 그러나 네트워크 문제로 인해 내 응용 프로그램이 토끼 서버에 자동으로 다시 연결되지 않음 (네트워크 문제로 인해)spring amqp와 다시 연결
CachingConnectionFactory
자동으로 다시 연결되도록 구성되어 있습니까?
해당 개체에 setRequestedHeartBeat()
(requested-heartbeat
)을 사용합니다. RabbitMQ Manual에 따르면
는, 패킷 손실은 중단 TCP 연결이 운영 체제를 탐지 할 시간이 걸릴 의미 할 수 있습니다. AMQP는 하트 비트 기능을 제공하여 응용 프로그램 계층이 중단 된 연결 (및 완전히 응답하지 않는 피어)을 즉시 알 수 있도록합니다. 또한 하트 비트는 "유휴"TCP 연결을 종료시킬 수있는 특정 네트워크 장비를 방어합니다. RabbitMQ 버전 3.0 이상에서는 브로커가 기본적으로 하트 비트를 협상하려고 시도하지만 (클라이언트가 여전히 거부 할 수 있음). 이전 버전을 사용하면 하트 비트를 요청하도록 클라이언트를 구성해야합니다.
오류를 처리하고 다시 연결하려면 Lyra (spring-amqp 대신)을 확인하십시오.