0

Pessoal como vocês tratam transações entre filas e bancos de dados ?

Estou com um cenário onde devo fazer o débito (Retirar dinheiro da conta) da conta de um cliente e enviar uma mensagem na fila, mas se por algum motivo a mensagem não for enviada (Timeout ou qualquer coisa do gênero) preciso creditar (Colocar dinheiro na conta) o valor novamente na conta do cliente, sei que posso simplesmente fazer o crédito em caso de falha, mas e se a falha no envio para fila na verdade for uma falha de internet ou coisa assim que não disponibilize também a conexão ao banco de dados impossibilitando que eu desfaça o efeito colateral ?

Caso eu já tiver realizado o debito na conta e não puder creditar pois houve uma falha e minha aplicação ficou isolada do mundo o que posso fazer ?

Há alguma forma diferente de resolver, ao invés de adicionar o método de envio para fila no meio da minha transação SQL, para poder fazer um Rollback se houver esse tipo de falha?

Estou utilizando Spring Boot 2, Java 8, RabbitMQ e SQL Server 2017.

4
  • já usou o @Transactional? Commented 8/07/2019 às 15:02
  • No caso de comunicações assíncronas como filas, talvez uma boa estratégia seja utilizar uma arquitetura de event sourcing Commented 8/07/2019 às 16:14
  • O único problema com o @Transactional é que não sei se ele tem esse gerenciamento de transações de dois objetos separados (DB e RabbitMQ). Commented 8/07/2019 às 17:20
  • Event Sourcing é uma ótima arquitetura, mas creio que por sí só não resolva o problema. Commented 8/07/2019 às 17:21

1 Resposta 1

1

O Ricardo Pontual está correto. O uso de @Transactional pode resolver seu problema. Como o assunto é muito extenso e complexo (e não tenho experiência com este uso de transação), recomendo a leitura de dois artigos sobre este assunto:

Agora, como você não quer usar transação e está em um cenário onde sua aplicação ficou isolada do mundo, você acaba ficando sem opções.

e se a falha no envio para fila na verdade for uma falha de internet ou coisa assim que não disponibilize também a conexão ao banco de dados impossibilitando que eu desfaça o efeito colateral ?

Por padrão, o Spring Boot vai ficar tentando enviar a mensagem continuamente até conseguir estabelecer a conexão com o RabbitMQ e conseguir enviar a mensagem. Isto, em teoria, já resolveria para você o seu problema. Só fique atento que acho que existe um limite de tentativas para isto. mas acredito que no Spring Boot este parâmetro esteja configurado para tentar sem limite por padrão. Consulte a documentação para ter certeza. Outro problema aqui é que se durante estas novas tentativas a aplicação for reiniciada, você perderá esta mensagem.

2
  • Obrigado pela resposta assim que possível testarei essas alternativas e responderei. Commented 11/07/2019 às 12:04
  • Decidi seguir com o padrão 1PC e checar em toda mensagem se ela já havia sido processada Commented 15/07/2019 às 17:35

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .