Como funciona request/reply (RPC) no RabbitMQ?

Question

Accepted Answer

**Request/reply (RPC)** sobre RabbitMQ permite comunicação síncrona de requisição-resposta usando mensagens — um cliente envia uma requisição e recebe uma resposta através de uma fila de resposta, usando um **ID de correlação** para associar respostas às requisições. É um padrão útil para chamadas entre serviços.

## Como RPC funciona no RabbitMQ

```text
RPC pattern over messaging:
  1. CLIENT sends a REQUEST message, including:
     → a REPLY-TO queue (where the response should go)
     → a CORRELATION ID (unique ID to match the response to this request)
  2. SERVER (consumer) processes the request and sends a RESPONSE to the reply-to queue,
     including the same CORRELATION ID
  3. CLIENT receives the response from its reply queue, matches it by CORRELATION ID →
     pairs the response with the original request
→ request-response over async messaging
```

## Por que IDs de correlação importam

```text
→ a client may have MANY outstanding requests on one reply queue → responses arrive mixed
→ the CORRELATION ID matches each response to its request (which response is for which call)
→ without it, the client couldn't tell which response answers which request
```

## Considerações

```text
✓ TIMEOUTS → the client must handle no-response (the server may be down/slow) → don't wait
  forever
✓ Reply queue → a per-client (often exclusive) reply queue, or a direct-reply-to feature
✓ RPC over messaging adds latency vs direct calls → consider if async is acceptable
⚠️ couples client and server timing (synchronous-style) → sometimes async messaging is
  better than RPC
```

## Por que isso importa

Compreender como request/reply (RPC) funciona no RabbitMQ é valioso porque é um **padrão de mensagens útil para comunicação entre serviços**, então é conhecimento relevante para essa necessidade.

RPC sobre RabbitMQ permite comunicação de requisição-resposta em estilo síncrono usando mensagens, útil quando serviços precisam de respostas.

Compreender **como funciona** — um cliente enviando uma requisição com uma **fila de resposta** (onde a resposta vai) e um **ID de correlação** (para associar a resposta), o servidor processando e enviando uma resposta para a fila de resposta com o mesmo ID de correlação, e o cliente recebendo e associando a resposta pelo ID de correlação — esclarece o mecanismo para requisição-resposta sobre mensagens assíncronas.

Compreender **por que IDs de correlação importam** é o insight-chave: como um cliente pode ter muitas requisições pendentes em uma fila de resposta (com respostas chegando misturadas), o **ID de correlação associa cada resposta à sua requisição** (informando ao cliente qual resposta responde qual chamada) — sem ele, o cliente não poderia associar respostas com requisições, tornando IDs de correlação essenciais ao padrão RPC.

Compreender as **considerações** — lidar com **timeouts** (o cliente deve lidar com falta de resposta já que o servidor pode estar indisponível ou lento, não aguardando para sempre), configuração de fila de resposta (filas exclusivas por cliente ou direct-reply-to), a latência que RPC adiciona versus chamadas diretas, e a ressalva de que RPC acopla o timing do cliente e servidor (então às vezes mensagens assíncronas são melhores que comunicação síncrona em estilo RPC) — reflete uso reflexivo do padrão.

Compreender RPC sobre RabbitMQ fornece uma maneira de fazer comunicação requisição-resposta através de mensagens (com os benefícios de desacoplamento e confiabilidade das mensagens), útil para certos cenários entre serviços, enquanto reconhece quando mensagens assíncronas podem ser preferíveis.

Como request/reply (RPC) sobre RabbitMQ é um padrão útil para comunicação requisição-resposta entre serviços (usando filas de resposta e IDs de correlação) e compreender como funciona e suas considerações é relevante para essa necessidade, compreender como RPC funciona no RabbitMQ é conhecimento RabbitMQ valioso e praticamente relevante — um padrão útil para comunicação requisição-resposta sobre mensagens (com IDs de correlação associando respostas às requisições), relevante para chamadas entre serviços, e refletindo compreensão de quando mensagens em estilo RPC encaixam versus mensagens puramente assíncronas.