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
, chamadorecomendations
escrito em javascript (Node.js); - Um
message broker
que 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 up
Para 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!