{"id":12484,"date":"2018-01-17T09:00:03","date_gmt":"2018-01-17T11:00:03","guid":{"rendered":"https:\/\/king.host\/blog\/?p=12484"},"modified":"2024-06-03T17:09:39","modified_gmt":"2024-06-03T20:09:39","slug":"como-gerenciar-filas-php-com-rabbitmq","status":"publish","type":"post","link":"https:\/\/king.host\/blog\/tecnologia\/como-gerenciar-filas-php-com-rabbitmq\/","title":{"rendered":"Gerenciando filas simples em PHP com RabbitMq"},"content":{"rendered":"

As palavras do momento s\u00e3o escalabilidade e microsservi\u00e7os! Todo mundo quer ser cool e estar por dentro das inova\u00e7\u00f5es. Pensando nisso, venho falar um pouco sobre os message brokers (envio de mensagens entre sistemas), uma das t\u00e9cnicas mais utilizadas para comunica\u00e7\u00e3o ass\u00edncrona,\u00a0utilizando o RabbitMq.<\/span><\/p>\n

\u00c9 legal tamb\u00e9m entender quais problemas essa t\u00e9cnica resolve e quais ele n\u00e3o resolve! Para saber justamente o que \u00e9 prego e o que \u00e9 parafuso.<\/span><\/p>\n

O que \u00e9 uma fila?<\/span><\/h2>\n

Uma fila \u00e9 composta por v\u00e1rias mensagens que ser\u00e3o consumidas por algu\u00e9m.<\/span><\/p>\n

Como podemos ver em vermelho na figura 1 abaixo.<\/span><\/p>\n

\"\"
Fig 1. Fila<\/figcaption><\/figure>\n

Como podemos observar ainda na figura 1, n\u00f3s temos o \u201cP\u201d representando o produtor de mensagens e os consumidores \u201cC\u201d (ou Workers), consumindo as mensagens dessa fila. At\u00e9 a\u00ed\u2026 tudo f\u00e1cil.<\/span><\/p>\n

O que \u00e9 o RabbitMq?<\/span><\/h2>\n

\u00c9 um servi\u00e7o de gerenciamento de filas, com ele voc\u00ea pode criar usu\u00e1rios, filas e uma gama de outras funcionalidades. Vou demonstrar aqui de forma bem simples. Para um primeiro contato apenas.<\/span><\/p>\n

Subindo um servidor Rabbit (utilizando Docker<\/strong>):<\/span><\/p>\n

$ docker run -d --hostname my-rabbit --name some-rabbit -p 8080:15672 -p 5672:5672 rabbitmq:management-alpine<\/code><\/pre>\n
Pronto, ja podemos acessar a aplica\u00e7\u00e3o (user: guest\/ pass: guest):<\/span><\/p>\n
\"\"
Fig 2. Tela Inicial RabbitMq<\/figcaption><\/figure>\n
E j\u00e1 podemos ver o nosso servidor rodando!<\/span><\/p>\n
\"\"<\/p>\n
Criando o primeiro Producer (Produtor de mensagens)<\/span><\/p>\n
Vamos criar um simples script php para interagir com o nosso Rabbit, primeiro crie o arquivo composer.json com o seguinte conte\u00fado:<\/span><\/p>\n
{\n    \"require\": {\n        \"php-amqplib\/php-amqplib\": \">=2.6.1\"\n    }\n}<\/pre>\n
Instale as depend\u00eancias:<\/span><\/p>\n
composer.phar install<\/pre>\n
Vamos criar o arquivo send.php com o seguinte conte\u00fado:<\/span><\/p>\n
<?php\n\nrequire_once __DIR__ . '\/vendor\/autoload.php';\n\nuse PhpAmqpLib\\Connection\\AMQPStreamConnection;\nuse PhpAmqpLib\\Message\\AMQPMessage;\n\n\/**\n * Inicia a conex\u00e3o\n *\/\n$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');\n$channel = $connection->channel();\n\n\/**\n * Declara qual a fila que ser\u00e1 usada\n *\/\n$channel->queue_declare('hello', false, false, false, false);\n\n\/**\n * Cria a nova mensagem\n *\/\n$msg = new AMQPMessage('Ola mundo!');\n\n\/**\n * Envia para a fila\n *\/\n$channel->basic_publish($msg, '', 'hello');\n\n\/**\n * Encerra conex\u00e3o\n *\/\n$channel->close();\n$connection->close();<\/pre>\n
Logo ap\u00f3s criarmos o arquivo receive.php<\/p>\n
<?php\n\nrequire_once __DIR__ . '\/vendor\/autoload.php';\n\nuse PhpAmqpLib\\Connection\\AMQPStreamConnection;\n\n\n\/**\n * Inicia a conex\u00e3o\n *\/\n$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');\n$channel = $connection->channel();\n\n\/**\n * Declara qual a fila que ser\u00e1 usada\n *\/\n$channel->queue_declare('hello', false, false, false, false);\n\necho ' [*] Waiting for messages. To exit press CTRL+C', \"\\n\";\n\n\/**\n * Fun\u00e7\u00e3o que vai receber e tratar efetivamente a mensagem\n *\/\n$callback = function($msg) {\n  echo \" [x] Received \", $msg->body, \"\\n\";\n};\n\n\/**\n * Adiciona esse \"callback\" para a fila \n *\/\n$channel->basic_consume('hello', '', false, true, false, false, $callback);\n\n\/**\n * Mantem a fun\u00e7\u00e3o escutando a fila por tempo indeterminado, at\u00e9 que seja encerrada\n *\/\nwhile(count($channel->callbacks)) {\n    $channel->wait();\n}\n\n$channel->close();\n$connection->close();<\/pre>\n
Rodando esses dois arquivos agora, com o nosso servidor up, podemos ver a seguinte mensagem (clique na imagem para expandir):<\/p>\n
\"\"<\/p>\n

\nPodemos adicionar quantos \u201cworkers\u201d forem necess\u00e1rios! Veja o exemplo abaixo (clique na imagem para expandir):<\/span><\/p>\n
\"\"<\/p>\n
Incr\u00edvel n\u00e3o?<\/span><\/h2>\n
Essa tecnologia nos permite in\u00fameras possibilidades, tendo apenas 1 servidor provendo o servi\u00e7o do Rabbit. Isso significa que v\u00e1rias aplica\u00e7\u00f5es podem utilizar usu\u00e1rios diferentes e criar filas e workers conforme a sua necessidade!<\/span><\/p>\n
Quais os casos em que eu posso utilizar o RabbitMQ?<\/span><\/h2>\n
    \n
  1. Processos independentes: quando eu preciso realizar uma tarefa em paralelo mas n\u00e3o \u00e9 necess\u00e1rio esperar ela terminar para continuar o meu fluxo.<\/span><\/li>\n
  2. Envio de email: Caso comum de quando eu n\u00e3o preciso aguardar uma resposta do meu SMTP. O worker pode se encarregar disso.<\/span><\/li>\n
  3. Registro de logs: Com aplica\u00e7\u00f5es distribu\u00eddas em N servidores, n\u00e3o podemos e nem devemos guardar os logs localmente no servidor. Nesse cen\u00e1rio a aplica\u00e7\u00e3o A1 envia os logs para uma fila no servidor B e o worker no servidor C ir\u00e1 consumir a fila e armazenar\u00e1 corretamente esse log. Mesmo escalando minha aplica\u00e7\u00e3o para A1 A2 A3, todos os logs ser\u00e3o armazenados no local correto.<\/span><\/li>\n<\/ol>\n
    Quando n\u00e3o usar o RabbitMQ?<\/span><\/h2>\n
      \n
    1. Processos baseados em tempo. Ex: Essa rotina deve executar sempre \u00e0s 14h. Para esse problema existem outras formas de resolu\u00e7\u00e3o.<\/span><\/li>\n
    2. Grande volumes de dados: Quando eu falo em grande volume, \u00e9 GRANDE volume\u2026 um servidor m\u00ednimo do rabbit consegue dar conta de pelo menos 20.000 msg\/s. Isso vai depender de qu\u00e3o pesado \u00e9 a atividade do worker. Mas mesmo para aplica\u00e7\u00f5es que geram bastante logs, essa taxa de mensagens \u00e9 suficiente. Voc\u00ea deve pensar em outra solu\u00e7\u00e3o (ex: Kafka) se a sua necessidade excede as 300.000 msg\/s.<\/span><\/li>\n<\/ol>\n
      Conclus\u00e3o<\/span><\/h2>\n
      O servi\u00e7o de mensagens pode ser um grande aliado na constru\u00e7\u00e3o de sistemas simples e independentes, separando responsabilidades e obrigando a cria\u00e7\u00e3o de pap\u00e9is distintos.<\/span><\/p>\n
      O ponto forte do RabbitMQ \u00e9 a simplicidade de utiliza\u00e7\u00e3o, junto com uma interface de gerenciamento. Por outro lado \u00e9 um pouco mais custoso escalar a estrutura.<\/span><\/p>\n
      Eu j\u00e1 utilizo o Rabbit em produ\u00e7\u00e3o h\u00e1 3 anos em diversos projetos e n\u00e3o tive problemas. Aconselho todos a darem uma olhada e brincarem um pouco.<\/span><\/p>\n
      Todos os arquivos est\u00e3o mencionados no texto. Divirtam-se!<\/span><\/p>\n
      Para mais aprendizados: vejam a documenta\u00e7\u00e3o oficial no site do RabbitMQ<\/a>!<\/span><\/p>\n
      Curtiu do material? Acompanhe outros posts meus no blog da KingHost<\/a>.<\/p>\n","protected":false},"excerpt":{"rendered":"
      As palavras do momento s\u00e3o escalabilidade e microsservi\u00e7os! Todo mundo quer ser cool e estar por dentro das inova\u00e7\u00f5es. Pensando nisso, venho falar um pouco sobre os message brokers (envio de mensagens entre sistemas), uma das t\u00e9cnicas mais utilizadas para comunica\u00e7\u00e3o ass\u00edncrona,\u00a0utilizando o RabbitMq. \u00c9 legal tamb\u00e9m entender quais problemas essa t\u00e9cnica resolve e quais […]<\/p>\n","protected":false},"author":292,"featured_media":12514,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1179,8],"tags":[1374],"class_list":["post-12484","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-desenvolvimento","category-tecnologia","tag-php"],"_links":{"self":[{"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/posts\/12484","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/users\/292"}],"replies":[{"embeddable":true,"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/comments?post=12484"}],"version-history":[{"count":22,"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/posts\/12484\/revisions"}],"predecessor-version":[{"id":36417,"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/posts\/12484\/revisions\/36417"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/media\/12514"}],"wp:attachment":[{"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/media?parent=12484"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/categories?post=12484"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/king.host\/blog\/wp-json\/wp\/v2\/tags?post=12484"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}