Проблемы с шаблоном RPC

Я читал о шаблоне RPC из официальной документации, но примеры очень простые. Клиент отправляет сообщение со свойствами reply_to и корреляция_id, сервер получает сообщение из очереди и повторно отправляет его клиенту, привязав тот же корреляционный_ид.

Мои вопросы:

1) Что делать, если сервер выключен, как клиент получит ответ

2) Как установить тайм-аут для RPC на стороне клиента

3) Если сервер сломался и выдал исключение, мы должны отправить это исключение клиенту

Буду благодарен за любой ответ.


java rabbitmq rpc
person Almas Abdrazak    schedule 08.07.2017    source источник

Ответы (1)


arrow_upward
1
arrow_downward

  1. #P1# <блочная цитата> #P2#

  2. Вы можете установить TTL для сообщения или всей очереди: https://www.rabbitmq.com/ttl.html< /а>

  3. Это зависит. Если запрос является идемпотентным, можно не подтверждать сообщение — его обработает другой рабочий процесс. Но это может стать ядовитой пилюлей: такие запросы заполнят вашу RPC-очередь и вызовут DoS. Таким образом, вы можете обрабатывать это вручную, например, с заголовком retry_count (в случае сбоя работник повторно ставит в очередь сообщение с уменьшенным счетчиком)

person Alexander    schedule 26.02.2018