Microservice Architecture Best Practices - Messaging Queues


In this article, we discuss why queues are needed, and how they form the cornerstone of asynchronous communication in microservices architectures.

What you will learn

  • What is a Queue?
  • What is asynchronous communication or asynchronous messaging?
  • What are the advantages of using Queues in microservices architectures?

Best Practices with Cloud and Microservices

This is the fourth article in a series of six articles on best practices with cloud and microservices:

Why Asynchronous Messaging?

Why is asynchronous messaging important?

Consider the simple example of an ordering service:

image info

A customer places an order through the OrderService. Let’s say following steps are involved:

  • It needs to send a request to the StockService
  • Send communication to the user through the EmailService and SMSService
  • Call the PackageService to start delivery

Option 1 : Single Component for all processing

One way to design this application would be to have a single component that accomplishes all this functionality. For example, write a Java class which accepts the order, and does the entire processing itself.

Option 2 : Introducing Asynchronous Messaging using Queues

The other option is to have a queue in-between the receiving OrderService component, and the rest of the components. When the OrderService receives an order, it places the request on the Queue. The rest of the components are independent services, listening on the Queue.

As soon as an order is placed on the queue:

  • The StockService processes the order and updates the database
  • The EmailService sends out an email to the customer
  • The SMSService sends out an SMS to the user
  • The PackageService does the required package processing on the item

Single Component v Queue

If your business goal is to support a few hundreds or thousands of users, then a simple architecture would be a good choice. The first architecture might be all you need.

However, when we talk of a large scale e-commerce web application such as Amazon.com, that receives millions of orders in a short time, you need a lot of flexibility. That’s when you go for the second approach, of bringing a queue in.

Advantages of Using A Messaging Queue

Let’s look at the advantages of using asynchronous communication based on a messaging queue.

A Queue Improves Reliability

Let’s say the SMSService is down for a short time.

In Option 1, since the OrderService directly invokes the SMSService on receiving an order, an SMS cannot be sent out. That might mean canceling the order, as all steps are part of a single transaction. Failure of one of the components would lead to cancellation of the customer request, with a need for him to re-initiate the order - at a later point in time.

However in the second approach, called asynchronous communication, the order request is placed on the queue. When the SMSService comes back up, it will find the order event and process it. It can then send out the SMS messages for all its pending requests.

A Queue Provides Scalability

Suppose on a given day, there is a need to send out 100,000 SMS messages. An option with having asynchronous communication is that you can increase the number of instances of the SMSService. This flexibility in number of instances of the components, improves system scalability.

A Queue Improves Testability

Each of the components/services are loosely tied, and have independent requirements. It is thus much easier to test each one of them, preferably in isolation.

A Queue Improves Maintainability

A queue also improves system maintainability, as the application is divided into smaller services.

A Queue Improves Flexibility

Not only increase instances of existing services, a queue makes the system flexible to add more services in future. All that you need to do is add a new service listen to events on the queue and consuming them. The new service could be plugged in, with a minimum of down time.

An extremely popular message queue framework is RabbitMQ.

Different frameworks use different communication protocols, but the concept underlying all of them is the same. At the core, a queue separates the component that generates the event, from the services that consume the event.

In general, if you need a system that addresses a very large user base, whose users submit a large number of requests to be processed, go for queue-based systems.

Do check out our video on this:

image info

Summary

In this article, we looked at the fact that there are two types of architectures - synchronous and asynchronous. Synchronous systems have the disadvantage that one component being down, causes loss of service to the entire system. Asynchronous systems solve this problem by introducing an intermediary queue to hold events. An architecture based on asynchronous communication using a queue improves testability, scalability, maintainability and flexibility.

Related Posts

Spring Boot Tutorials for Beginners

At in28Minutes, we are creating a number of tutorials with videos, articles & courses on Spring Boot for Beginners and Experienced Developers. This resources will help you learn and gain expertise at Spring Boot.

Asynchronous communication with queues and microservices - A perfect combination?

In this article, we throw some light on what asynchronous messaging is all about and discuss why you should consider it for your microservices architectures.

Microservice Best Practice - Build an Archetype

In this article, we focus on learning why creating proper archetypes is important for successful microservices architecture.

Microservice Best Practice - Why do you build a Vertical Slice?

In this article, we look at what is a vertical slice, and why we build it. We also discuss the best practices involved in building vertical slices.

Microservices Architectures - Event Driven Approach

In this article, we talk about event driven approach, in the context of microservices architectures. We also discuss what are the advantages of using an event driven approach.

The 12 Factor App - Best Practices In Cloud Native Applications and Microservices

In order that an application be deployed in the cloud and enjoy features such as auto scaling, it first needs to be cloud native. In this article, we have a close look at the best practices for cloud native applications, popularly known as The 12 Factor App.

Microservices Architectures - What is Fault Tolerance?

In this article, we discuss an important property of microservices, called fault tolerance

Microservices Architectures - Introduction to Auto Scaling

In this article, we focus our attention on the Dynamic Scaling or Auto Scaling. Why do we need applications that can auto scale?

Microservices Architectures - Importance of Centralized Logging

In this article, we explore the concept of centralized logging, in the context of microservices.

Microservices Architectures - Introduction to API Gateway

In this article, we look at what an API Gateway is, in the context of microservices.