A custom implementation of the SAGA pattern using event driven architecture, created within a single nodejs process.
In this scenario the event bus is a Event Emitter into a nodejs process, in more complex project the bus will be sqs or sns in AWS. This project are only node.js modules and a scaffolding for more realistics scenarios will be necesary to add an api rest interface.
The Fail feature or the saga is only present in some events, in a real situation all the request should have it.
In this diagram I show how a transaction is done through different messages. For each operation two types of SUCCESS and FAIL messages are issued, in the case of FAIL status updates are applied to maintain consistency.
For this example, I will use for mock the Order, Notification and Payment service the web mocky.io to make fake but real request.
Events name with description.
- ORDER_CREATED: Initial event of the payment flow.
- ORDER_CREATED_SUCCESS: Sucess order creation event.
- ORDER_CREATED_FAIL: Order creaation error.
- PAYMENT_FAIL: Error in process payment.
- PAYMENT_SUCCESS: Payment succeffull.
- FLOW_END: Send email with the bill and finish the flow.
npm install
node app.js- https://microservices.io/patterns/data/saga.html
- https://itnext.io/effectively-communicate-between-microservices-de7252ba2f3c
- https://developers.redhat.com/blog/2018/10/01/patterns-for-distributed-transactions-within-a-microservices-architecture/
- https://blog.couchbase.com/saga-pattern-implement-business-transactions-using-microservices-part/
- https://medium.com/@ijayakantha/microservices-the-saga-pattern-for-distributed-transactions-c489d0ac0247
- https://itnext.io/microservices-architecture-an-implementation-of-saga-pattern-dbbe5d881c78
- https://dzone.com/articles/distributed-sagas-for-microservices