Este tutorial assume que o RabbitMQ está instalado e em execução no localhost
na porta padrão (5672).
Caso você utilize um host, porta ou credenciais diferentes, as configurações de conexão precisariam ser ajustadas.
- Na raíz do projeto, criar um virtual environment python com o comando:
python3 -m venv venv
- Ative o ambiente virtual com o comando:
source venv/bin/activate
- Instale as dependências necessárias com o comando:
pip install -r requirements.txt
- Nesta seção, escrevemos dois pequenos programas em Python; um produtor (producer) que envia uma única mensagem e um consumidor (consumer) que recebe as mensagens e as imprime. É um "Hello World" de mensagens.
- Em um terminal, inicie o consumidor executando
python HelloWorld/receiving.py
- Em um segundo terminal, envie uma mensagem com o comando
python HelloWorld/sending.py
- Nesta seção, criamos uma fila de trabalho (work queue) que é usada para distribuir time-consuming tasks entre vários workers.
- Em um terminal, inicie o consumidor executando
python WorkQueues/worker.py
- Em um segundo terminal, envie uma mensagem com o comando
python WorkQueues/new_task.py
- Nesta seção, vamos entregar uma mensagem a vários consumidores. Esse padrão é conhecido como "publish / subscribe".
- Em um terminal, inicie o consumidor executando
python PublishSubscribe/receive_log.py
- Em um segundo terminal, envie uma mensagem com o comando
python PublishSubscribe/emit_log.py
- Nesta seção, vamos tornar possível assinar apenas um subconjunto das mensagens.
- Em um terminal, inicie o consumidor executando
python Routing/receive_log_direct.py info warning error
- Em um segundo terminal, envie uma mensagem com o comando
python Routing/emit_log_direct.py
- Nesta seção, iremos melhorar nosso sistema de assinatura.
- Em um terminal, inicie o consumidor executando
python Topics/receive_topic_log.py "#"
- Em um segundo terminal, envie uma mensagem com o comando
python Topics/emit_topic_log.py
- Nesta seção, vamos usar RabbitMQ para construir um sistema RPC: um cliente e um servidor RPC escalonável.
- Em um terminal, inicie o server executando
python RPC/rpc_server.py
- Em um segundo terminal, envie uma mensagem com o comando
python RPC/rpc_client.py