RabbitMq застревает после отправки определенного количества клиенту через Tcp Socket
У нас есть служба Windows, где мы публикуемся в rabbitmq, подписываемся на сообщение, а затем отправляем сообщение клиенту через сокет.
Проблема, с которой мы сталкиваемся, заключается в том, что rabbitmq застревает после удаления определенного количества сообщений.
PS: у нас есть журналы, написанные для каждого сообщения, подписанного из очереди, и каждого сообщения, отправленного на сервер сокетов. Наша система является клиентской системой, а система на стороне клиента действует как сервер.
Вот что я сделал до сих пор:
- Опубликовано 13000 записей на RabbitMq. Все 13000 было подписано и успешно отправлено клиенту
- Опубликовано 13110 записей в RabbitMq. Через 3 минуты было обработано 13109 сообщений, и последнее было записано в журнал сервера. Но все равно все 13110 было обработано и успешно отправлено заказчику
- Опубликовано 14000 записей. 13109 подписан и успешно отправлен на сервер. После этого продолжайте отправлять живые сообщения, и в журнал сервера больше не будет записываться никаких сообщений, а RabbitMq застрял с одним непрочитанным сообщением.
Я не уверен, имеет ли смысл число 13109, но в соответствии с проведенными мною тестами я могу воспроизводить его каждый раз, когда запускаю наши системы.
Пожалуйста, дайте мне знать, если у кого-нибудь есть какие-либо материалы.
Спасибо!