Limit czasu błędu RabbitMQ

Question

Ustawiłem program RabbitMQ w celu przeanalizowania około 20 000 żądań z zewnętrznego interfejsu API, ale po upływie kilku minut utrzymuje on limit czasu. Pozwala poprawnie przeanalizować około 2000 z łącznej liczby 20 000 zapytań.

Plik dziennika mówi:

=INFO REPORT==== 16-Feb-2016::17:02:50 === 
accepting AMQP connection <0.1648.0> (127.0.0.1:33091 -> 127.0.0.1:5672) 

=ERROR REPORT==== 16-Feb-2016::17:03:21 === 
closing AMQP connection <0.1648.0> (127.0.0.1:33091 -> 127.0.0.1:5672): 
{writer,send_failed,{error,timeout}} 

Już zwiększyła wartość pulsu, ale nie mogę zrozumieć, dlaczego to jest limit czasu. Konfiguracja: Ubuntu 14.04, NGINX 1.8.1, RabbitMQ 3.6.0

Byłbym wdzięczny za poświęcony czas i uwagę!

Answer 1

Właśnie rozwiązałem podobny problem w Pythonie. W moim przypadku został rozwiązany przez zmniejszenie liczby preselekcji na konsumenta, tak aby miał mniej wiadomości w kolejce w swoim buforze odbiorczym.

Moja teoria mówi, że bufor odbiorczy na kliencie jest pełny, a następnie RMQ próbuje napisać inny komunikat do gniazda konsumenta i nie może to być spowodowane pełnym gniazdem konsumenta. RMQ blokuje na tym gnieździe, a ostatecznie limity czasu i po prostu zamyka połączenie z konsumentem. Posiadanie mniejszej kolejki do wstępnego pobierania oznacza, że ​​bufor odbiorczy gniazda nie jest zapełniany, a RMQ jest w stanie zapisać wszystkie wiadomości księgowe, które próbowały wykonać, a więc nie kończy czasu na zapisach, ani nie zamyka połączenia.

To tylko jedna z teorii, ale wydaje się, że trzymam ją w testach.

Answer 2

Dodaj więcej do odpowiedzi @ tul.

subChannel.basicQos(10); 

Zmniejszanie liczby preselekcji konsumenta eliminuje wyjątek dotyczący limitu czasu.
Domyślna liczba preselekcji jest nieograniczona.