{"id":1602,"date":"2022-07-04T13:14:22","date_gmt":"2022-07-04T07:44:22","guid":{"rendered":"https:\/\/ontoborn.com\/blog\/?p=1602"},"modified":"2022-07-12T23:50:06","modified_gmt":"2022-07-12T18:20:06","slug":"distributed-transaction-management-in-microservices-part-2-saga-pattern","status":"publish","type":"post","link":"https:\/\/ontoborn.com\/blog\/distributed-transaction-management-in-microservices-part-2-saga-pattern\/","title":{"rendered":"Distributed Transaction Management in Microservices \u2014 Part 2 \u2014 Saga Pattern"},"content":{"rendered":"\n<p>In this article, we are going to see about the <strong>Saga pattern which is an asynchronous pattern<\/strong> that performs a sequence of transactions in each microservice and publishes messages or events to proceed to the next step. If any step fails in between, compensating steps will be executed by the Saga pattern to reverse the transaction<\/p>\n\n\n\n<figure class=\"wp-block-image size-full\"><a href=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-26.png\"><img loading=\"lazy\" decoding=\"async\" width=\"975\" height=\"292\" src=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-26.png\" alt=\"\" class=\"wp-image-1603\" srcset=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-26.png 975w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-26-300x90.png 300w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-26-768x230.png 768w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-26-583x175.png 583w\" sizes=\"(max-width: 975px) 100vw, 975px\" \/><\/a><\/figure>\n\n\n\n<p>We can see from the above diagram that the Saga patterns perform a sequence of local transactions in each service. Each service updates its database and then publishes a message or event which will trigger the next local transaction.<\/p>\n\n\n\n<figure class=\"wp-block-image size-full\"><a href=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-27.png\"><img loading=\"lazy\" decoding=\"async\" width=\"975\" height=\"500\" src=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-27.png\" alt=\"\" class=\"wp-image-1604\" srcset=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-27.png 975w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-27-300x154.png 300w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-27-768x394.png 768w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-27-583x300.png 583w\" sizes=\"(max-width: 975px) 100vw, 975px\" \/><\/a><\/figure>\n\n\n\n<p>So we have to write the logic to commit the transaction and also have a mechanism to reverse the flow when something goes wrong anywhere in the transaction. All the transactions and compensating transactions will happen through the listeners that listen to an event or a message from the queue<\/p>\n\n\n\n<p>The <strong>compensating transaction must be idempotent<\/strong> and should be able to retry if the previous try fails<\/p>\n\n\n\n<p>The saga pattern can be implemented using 2 ways namely<\/p>\n\n\n\n<ul><li>Choreography-Based Saga Pattern<\/li><li>Orchestration-Based Saga Pattern<\/li><\/ul>\n\n\n\n<h1 class=\"wp-block-heading\"><a><\/a><strong>Choreography-Based Saga Pattern<\/strong><\/h1>\n\n\n\n<p>In the Choreography pattern, there is <strong>no centralized point of control<\/strong> and the services will listen to a message broker to read the message and emit events\/messages back to the queue for other services to listen and consume<\/p>\n\n\n\n<figure class=\"wp-block-image size-full\"><a href=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-28.png\"><img loading=\"lazy\" decoding=\"async\" width=\"975\" height=\"417\" src=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-28.png\" alt=\"\" class=\"wp-image-1605\" srcset=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-28.png 975w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-28-300x128.png 300w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-28-768x328.png 768w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-28-583x249.png 583w\" sizes=\"(max-width: 975px) 100vw, 975px\" \/><\/a><\/figure>\n\n\n\n<p>The following steps are executed in the Choreography pattern<\/p>\n\n\n\n<ol type=\"1\"><li>Order Service gets the request from a user to create an order and hence the order is created in <strong>PENDING<\/strong> state<\/li><li>After creating the order in Pending state, it emits an event in the Order Events Channel or Queue<\/li><li>The Customer Service listens to the event and attempts to reserve the credit<\/li><li>Then it emits the event to Order Service<\/li><li>The Order Service now approves the Order or Rejects it based on the outcome of the event received from the Customer Service<\/li><\/ol>\n\n\n\n<h2 class=\"wp-block-heading\"><a><\/a><strong>Advantages of Choreography Pattern<\/strong><\/h2>\n\n\n\n<ul><li>The Choreography pattern is easy to implement<\/li><li>This is good for use cases with few services participating in the transaction<\/li><li>There is no Single point of failure as the transaction is distributed across services<\/li><\/ul>\n\n\n\n<h2 class=\"wp-block-heading\"><a><\/a><strong>Drawbacks of Choreography Pattern<\/strong><\/h2>\n\n\n\n<ul><li>When more services are added to the transaction, then Choreography patterns will get complicated<\/li><li>Eg: If Order service needs to event to Customer service and Customer Service emits an event to Payment service and so on, then the workflow gets bigger and will be difficult to track and debug<\/li><li>There might be scenarios where two services might be waiting for each other\u2019s events and end up in a deadlock state<\/li><\/ul>\n\n\n\n<h1 class=\"wp-block-heading\"><a><\/a><strong>Orchestrator-Based Saga Pattern<\/strong><\/h1>\n\n\n\n<p>In the Orchestration-based saga pattern, there is a <strong>centralized component<\/strong> that controls the transaction and this component is called the <strong>Orchestrator<\/strong>. It issues commands to the services and decides to commit or abort the transaction based on the outcome received from the saga participants. If any of the microservices fail, the orchestrator will invoke the compensating transactions. The Orchestrator can exist inside the microservice that triggers the flow of transactions or the orchestrator can exist as a separate component outside the service<\/p>\n\n\n\n<ol type=\"1\"><li><strong>Orchestrator as a stand-alone component<\/strong><\/li><\/ol>\n\n\n\n<p>As we see in the diagram below, the Orchestrator is a stand-alone service that interacts with other services that are involved in the transaction. Every service receives the command from the orchestrator and emits the event response back to the orchestrator.<\/p>\n\n\n\n<figure class=\"wp-block-image size-full\"><a href=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-29.png\"><img loading=\"lazy\" decoding=\"async\" width=\"975\" height=\"415\" src=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-29.png\" alt=\"\" class=\"wp-image-1606\" srcset=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-29.png 975w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-29-300x128.png 300w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-29-768x327.png 768w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-29-583x248.png 583w\" sizes=\"(max-width: 975px) 100vw, 975px\" \/><\/a><\/figure>\n\n\n\n<p><strong>2. Orchestrator as a component inside Order Service<\/strong><\/p>\n\n\n\n<p>As we see in the below diagram, the <strong>Create Order Saga <\/strong>is the Orchestrator component that resides inside the Order Service<\/p>\n\n\n\n<figure class=\"wp-block-image size-full\"><a href=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-30.png\"><img loading=\"lazy\" decoding=\"async\" width=\"975\" height=\"404\" src=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-30.png\" alt=\"\" class=\"wp-image-1607\" srcset=\"https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-30.png 975w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-30-300x124.png 300w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-30-768x318.png 768w, https:\/\/ontoborn.com\/blog\/wp-content\/uploads\/2022\/07\/image-30-583x242.png 583w\" sizes=\"(max-width: 975px) 100vw, 975px\" \/><\/a><\/figure>\n\n\n\n<p>The following steps are executed in the orchestrator pattern<\/p>\n\n\n\n<ol type=\"1\"><li>When the user places the order, the endpoint in Order controller is invoked, which then calls the Order Service<\/li><li>The order service creates the <strong>Create Order Saga Orchestrator, <\/strong>which is nothing but an orchestrator (object) that tells the microservices what local transactions to execute<\/li><li>The saga orchestrator creates the Order in <strong>PENDING<\/strong> state<\/li><li>It will then send the Reserve Credit command to the Customer Service<\/li><li>The Customer Service attempts to reserve the credit and sends the outcome back to the Saga orchestrator<\/li><li>The saga orchestrator approves or rejects the order based on the outcome<\/li><\/ol>\n\n\n\n<h2 class=\"wp-block-heading\"><a><\/a><strong>Advantages of Orchestrator Pattern<\/strong><\/h2>\n\n\n\n<ul><li>Unlike the Choreography pattern, the Orchestrator pattern can be used for complex workflows and any new services can be added as part of the transaction and can be managed<\/li><li>Having an orchestrator as a transaction coordinator helps to control the transaction and the flow of activities<\/li><li>No possibility of cyclic dependencies<\/li><li>Saga participants i.e microservices are independent and do not know about other services and hence separation of business logic<\/li><\/ul>\n\n\n\n<h2 class=\"wp-block-heading\"><a><\/a><strong>Drawbacks of Orchestrator Pattern<\/strong><\/h2>\n\n\n\n<ul><li>There is a design complexity when compared to the Choreography pattern as we have the additional implementation of a coordination logic.<\/li><li>There is a single point of failure here because the orchestrator manages the complete workflow.<\/li><\/ul>\n\n\n\n<p>In this article, we saw what is an asynchronous pattern for transaction management in microservices and also explored the Saga pattern and its two variants namely Choreography based and Orchestrator based. We went in-depth about the 2 patterns and then discussed their benefits and drawbacks. Based on the use case, one of the patterns has been chosen for your application.<\/p>\n\n\n\n<p>Saga pattern enables an application to maintain data consistency across multiple services by using local transactions instead of distributed transactions. But this programming model is a bit complicated and takes more time as we have to write the compensating transactions logic across all the services Overall, the <strong>asynchronous<\/strong> Saga patterns are much better and more efficient for microservices when compared to <strong>synchronous<\/strong> patterns like <strong>Two-Phase Commit (2 PC) and Three-Phase Commit (3 PC)<\/strong>. But it has its own drawbacks and handling distributed transactions across multiple microservices is always problematic in terms of ACID compliance hence the <strong>distributed transactions should be avoided if possible<\/strong>.<\/p>\n\n\n\n<p><em><strong><mark style=\"background-color:rgba(0, 0, 0, 0)\" class=\"has-inline-color has-sitetext-color\">I work as a freelance Architect at Ontoborn, who are experts in putting together a team needed for building your product. This article was originally published on <a href=\"https:\/\/medium.com\/@dineshchandgr\" target=\"_blank\" rel=\"noreferrer noopener\" title=\"my personal blog\">my personal blog<\/a>.<\/mark><\/strong><\/em><\/p>\n","protected":false},"excerpt":{"rendered":"<p>In this article, we are going to see about the Saga pattern which is an asynchronous pattern that performs a sequence of transactions in each microservice and publishes messages or events to proceed to the &hellip;<\/p>\n","protected":false},"author":11,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"om_disable_all_campaigns":false,"_mi_skip_tracking":false,"footnotes":""},"categories":[73],"tags":[],"_links":{"self":[{"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/posts\/1602"}],"collection":[{"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/users\/11"}],"replies":[{"embeddable":true,"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/comments?post=1602"}],"version-history":[{"count":5,"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/posts\/1602\/revisions"}],"predecessor-version":[{"id":1655,"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/posts\/1602\/revisions\/1655"}],"wp:attachment":[{"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/media?parent=1602"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/categories?post=1602"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/ontoborn.com\/blog\/wp-json\/wp\/v2\/tags?post=1602"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}