Este projeto apresenta uma implementação do outbox pattern, servindo de exemplo para o artigo publicado aqui.
Basicamente, temos:
- Um
producer, chamadouser-api, escrito em java (Spring), ele que implementa de fato ooutbox; - Um
consumer, chamadorecomendationsescrito em javascript (Node.js); - Um
message brokerque utiliza o protocoloAMQP(RabbitMQ);
Para iniciar a aplicação você irá precisar do Docker e Docker Compose devidamente instalados, e então, basta clonar o repositório e executar o comando :
docker-compose upPara inciar o fluxo, basta realizar uma requisição POST para http://localhost:8081/api/v1/user com um JSON que segue a seguinte estrutura:
{
"name": "Victor Hugo",
"email": "victor.hugo.origins@gmail.com",
"password": "123123123",
"gender": "MALE"
}Será cadastrado um usuário com estes dados, registrada a solicitação de disparo de notificação e eventualmente, um schedule service irá detectar as mensagens de notificação pendentes e irá publicá-las na queue user_created_q por meio do nosso message broker. A aplicação recomendations irá escutar as mensagens e exibir algumas informações sobre ela por meio do sistema de log.
Para uma explicação mais detalhada do que está acontecendo e o porque disto, recomendo a leitura do artigo originou esse trabalho. Boa leitura!