Microservices relies on interservice communication to share events, state, and data as well as to maintain isolation and decoupling. Many developers implement an asynchronous event-driven publish-subscribe message broker for interservice communication, but doing so is complicated.
Here’s a better way: Redis Streams acts as both a native log data structure and communication channel that can publish an event without requiring an immediate response. It is simple to deploy, supports message persistence, and offers scalability through consumer groups.
How Redis Stream works as a message broker
A microservice domain publishes an event into its own stream; its name reflects the event topic.
Each event is a stream entry. The event timestamp acts as the entry-id.
Other microservices subscribe to specific event streams.
The subscriber acknowledges the event was successfully processed and remembers the last entry-id it processed to easily recover from a failure or disconnect.
Redis Streams inspects the status of unprocessed messages and reassign an event to another subscriber after a specified period of time.
See how Redis Enterprise addresses the challenges of scale, latency, and resiliency in microservice architectures
Asynchronous communication use case where all services in an application do not need to be present to process messages; or some services only need a subset of the information from another service.
You need to reliably store and transmit transient data as an immutable, append-only series of time-stamped events.
One to many communications are required but using message queues are inefficient and requires the location and status of all receiving services.
Messages requiring low latency and persistence, acknowledgement, and can easily handle failure scenarios.
How Redis Enterprise solves your challenges
The microservices problem
The Redis Enterprise solution
It’s hard to keep microservices isolated, yet to also communicate state, events, and data
Redis Streams is a lightweight asynchronous message broker that is both an immutable time-ordered log data structure and event store. Redis is simple to deploy with out-of-the-box partitioning, replication, persistence, and configurable message delivery guarantees.
Scaling and maintaining microservice communications is difficult, especially during traffic spikes
Streams provides efficient write/read operations to improve overall application performance It can capture and process millions of data points per second at sub-millisecond latency It includes advanced consumer group functionality that enables you to split a stream of messages among multiple clients to speed up processing.
Complexity and development cost of using Kafka as message broker
Streams lightweight implementation requires only a key-value pair. That’s far simpler than the administrative overhead of setting up a Kafka topic. Redis Enterprise Operator for Kubernetes enables automated Redis Enterprise cluster deployments. Redis Streams and caching are on one unified multi-tenant data platform. No additional license is required. Learn more
Why use Redis Enterprise as the message broker for interservice communication
Lightweight design and implementation enable faster time to market. You can get started prototyping in minutes.
Increase microservices scalability and responsiveness, even under intense message loads.
99.999% uptime SLA and resiliency (Active-Active geo distribution) help to prevent application downtime.
Applications can easily handle retries, failure scenarios, and the addition of new subscribing services.
Simpler integration with support for a range of platforms and programming languages, as well as for on-premises and managed services in the cloud.
A message broker is software that facilitates the exchange of messages among applications, systems, and services. In a microservices architecture, services can communicate with each other using the message broker, even if they’re built using different technologies or deployed on separate platforms.
What is the difference between synchronous and asynchronous communication patterns?
Synchronous communication means that all participants in a channel, senders and receivers, need to be active at the same time to be able to communicate. A simple example is Service A and Service B doing direct remote procedure calls (RPC), by invoking Service B’s HTTP REST endpoint from Service A, However,if Service B went offline, Service A would not be able to communicate with B, and so A would need to implement an internal failure recovery procedure. Asynchronous means communication can still happen even if not all participants are present at the same time, i.e. Service A does not wait on response from Sender B.
What are some common methods of interservice communication?
In brokerless communication, all participants are connected directly. Brokered communications means that all participants connect to the same service via a message broker, which acts, as the name implies, as a centralized broker to implement the message-routing mechanism. Message brokers can work with both synchronous and asynchronous communications, but is typically associated with asynchronous.
What is an event driven architecture (EDA)?
Event driven architectures use events to trigger and communicate between decoupled services and is common in modern applications built with microservices. An event is a change in state, or an update, like an item being ordered on an e-commerce website causing the inventory management system to decrement the in stock value by one. Event-driven architecture is ideal for real-time applications that need to ingest and process large volumes of data with very low latency or when different subsystems or microservices must perform different types of processing on the same event data. EDA can use a publish/subscribe (pub/sub) model or an event streaming model.
By continuing to use this site, you consent to our updated privacy agreement. You can change your cookie settings at any time but parts of our site will not function correctly without them.
Redis Streams is a lightweight asynchronous message broker that is both an immutable time-ordered log data structure and event store.
