🐇 Routing

README.md

@@ -149,7 +149,8 @@ flowchart LR
   X -- Binding --> Q2
 ```
 
-Chamamos de `binding` o relacionamento entre exchange (troca) e uma queue (fila).
+Chamamos de `binding` (traduzido: Vinculação) o relacionamento entre exchange (troca) e uma queue (fila).
+"Pode ser lido como: A queue está interessada em mensagens dessa exchange."
 ```typescript
   channel.bindQueue(queue_name, 'logs', '')
 ```
@@ -170,6 +171,66 @@ Utilize esses comandos para teste:
   # -> [x] Sent: <mensagem>
 ```
 
+De forma simples: Criamos um sistema de registro simples que trasmite mensagens de registros (logs) para receptores.
+
+## ([#3](https://github.com/lucasgianine/message-queuing/pull/3)) Routing
+Trabalharemos com roteamento junto ao que foi aprendido no item anterior, redirecionaremos mensagens de erros críticas para o arquivo de log (economizando espaço no disco).
+Ainda trabalharemos em cima das bindings, e dessa vez, passaremos parâmetros de chave de binding para que possamos fazer uma <i>exchange</i> direta para diversas queues
+
+Anteriormente enviávamos mensagens para todos os <i>consumers</i> sem nenhuma filtragem, isso se dava ao fato de usarmos a troca `fanout`, dessa vez usaremos a troca `direct` que enviará mensagens para queues específicas, e todas as outras mensagens sem um binding key serão descartadas.
+
+```typescript
+// logs/emit_logs.js
+const exchange = 'direct_logs'
+channel.assertExchange(exchange, 'direct', {
+  durable: false
+})
+channel.publish(exchange, severity, Buffer.from(message))
+```
+
+```typescript
+// logs/receive_logs.js
+args.forEach((severity) => {
+  channel.bindQueue(q.queue, exchange, severity)
+})
+```
+
+Aplicaremos esse tipo de troca no nosso sistema de logs, trocaremos `fanout` por `direct` e forneceremos uma `routing key` na hora de publicar para selecionar a gravidade que o receptor irá receber.
+`severity` é o tipo de `routing key` que passaremos, nesse caso vamos assumir que ela seja `info`, `warning` ou `error`.
+
+```mermaid
+flowchart LR
+  P["Producer"]
+  X{"direct"}
+  Q1["Queue 1"]
+  Q2["Queue 2"]
+  C1["Consumer 1"]
+  C2["Consumer 2"]
+
+  P --> X -- error --> Q1 --> C1
+  X -- info --> Q2 --> C2
+  X -- warning --> Q2
+  X -- error --> Q2
+```
+
+Utilize esses comandos para teste:
+```bash
+  # shell 1
+  npm run receive_logs <rountingKey>
+
+  # -> Será criado um arquivo .log na pasta src/logs
+  # -> No arquivo aparecerá a <rountingKey> e a <mensagem> escrita no próximo shell
+```
+
+Especificar `rountingKey` significa aplicar dentro da pasta `.log` somente as mensagens para aquela rota específica.
+
+```bash
+  # shell 2
+  npm run emit_logs <rountingKey> <mensagem>
+
+  # -> [x] Sent '<rountingKey>': <mensagem>
+```
+
 ## Referência
 - [RabbitMQ](https://www.rabbitmq.com/)
 - [Documentação do RabbitMQ](https://www.rabbitmq.com/tutorials)

src/logs/emit_logs.js

@@ -6,21 +6,18 @@ amqp.connect('amqp://localhost', (err, conn) => {
   conn.createChannel((err, channel) => {
     if (err) throw err
 
-    const exchange = 'logs'
-    const message = process.argv.slice(2).join(' ') ?? 'Hello World!'
+    const exchange = 'direct_logs'
+    const args = process.argv.slice(2)
+    const message = args.slice(1).join(' ') || 'Hello World!'
+    const severety = (args.length > 0) ? args[0] : 'info'
 
-    channel.assertExchange(exchange, 'fanout', {
+    channel.assertExchange(exchange, 'direct', {
       durable: false
     })
 
-    /*
-      A string vazia como segundo parâmetro significa que não queremos
-      enviar a mensagem para nenhuma fila específica.
-      Queremos apenas publicá-la em nossa troca de 'logs'.
-    */
-    channel.publish(exchange, '', Buffer.from(message))
+    channel.publish(exchange, severety, Buffer.from(message))
 
-    console.log(` [x] Sent: ${message}`)
+    console.log(` [x] Sent to ${severety}: ${message}`)
   })
 
   setTimeout(() => {

src/logs/receive_logs.js

@@ -1,14 +1,21 @@
 const amqp = require('amqplib/callback_api')
 
+const args = process.argv.slice(2)
+
+if (args.length === 0) {
+  console.log('Usage: receive_logs.js [info] [warning] [error]')
+  process.exit(1)
+}
+
 amqp.connect('amqp://localhost', (err, conn) => {
   if (err) throw err
 
   conn.createChannel((err, channel) => {
     if (err) throw err
 
-    const exchange = 'logs'
+    const exchange = 'direct_logs'
 
-    channel.assertExchange(exchange, 'fanout', {
+    channel.assertExchange(exchange, 'direct', {
       durable: false
     })
 
@@ -17,10 +24,12 @@ amqp.connect('amqp://localhost', (err, conn) => {
     }, (err, q) => {
       if (err) throw err
 
-      channel.bindQueue(q.queue, exchange, '')
+      args.forEach((severity) => {
+        channel.bindQueue(q.queue, exchange, severity)
+      })
 
       channel.consume(q.queue, (message) => {
-        if (message.content) console.log(` [x] ${message.content.toString()}`)
+        if (message.content) console.log(` [x] ${message.fields.routingKey}: ${message.content.toString()}`)
       }, { noAck: true })
     })
   })