Architektury sterowane zdarzeniami

Event-Driven Architecture (EDA) is a design pattern where components communicate by emitting and reacting to events. Instead of directly calling functions, parts of your system publish events when something interesting happens.

This approach helps create systems that are:

• Decoupled: Components don't need to know about each other.
• Scalable: Easily add more consumers without changing producers.
• Resilient: Failures in one part are less likely to bring down the whole system.

An event is a record of something that happened. It's usually a small, immutable message containing data about the event, but not the command to perform an action.

Think of it like a newspaper headline: "User Signed Up" or "Order Placed".

Key characteristics:

• Fact: It describes something that has occurred.
• Immutable: Once published, an event doesn't change.
• Informative: Contains relevant data (e.g., user ID, timestamp).

In an EDA, there are two main roles:

• Producers: These are components that create and publish events. When a user signs up, the "User Service" might produce a "User Signed Up" event.
• Consumers: These are components that subscribe to and react to events. A "Welcome Email Service" might consume "User Signed Up" events to send a welcome email.

The producer doesn't care who consumes the event, and consumers don't care who produced it. This enables powerful decoupling!

How do producers and consumers find each other? That's where a message broker comes in. A broker acts as an intermediary, receiving events from producers and delivering them to interested consumers.

It provides:

• Decoupling: Producers and consumers don't directly communicate.
• Durability: Events can be stored until consumers are ready.
• Routing: Directs events to the correct consumers based on rules.

Common examples include RabbitMQ, Apache Kafka, and AWS SQS.

Clojure, with its focus on immutability and concurrency, is well-suited for event-driven systems. We often use dedicated client libraries to interact with message brokers.

For RabbitMQ, a popular choice in Clojure is langohr. It provides a straightforward API to connect, publish, and consume messages.

Let's look at how to set up a basic connection and publish an event using langohr (conceptually, as full setup is complex for a tiny snippet).

To publish an event, we connect to the message broker and send our event data to a specific exchange. An exchange is like a post office that routes messages.

Here's a simplified example of publishing a "user.signed-up" event to a topic exchange named "events":

Consumers connect to the broker and declare a queue. They then bind this queue to an exchange with a routing key to receive specific types of events. When an event arrives, a handler function processes it.

This example shows a consumer listening for "user.signed-up" events:

Beyond simple decoupling, EDA offers significant advantages for complex systems:

• Scalability: Easily add more consumers to process events in parallel, or scale producers independently.
• Resilience: If a consumer fails, the message broker holds events until it recovers, preventing data loss.
• Auditability: Events can be logged, providing a clear audit trail of system activities.
• Real-time Processing: React to changes instantly across different services.

It's a foundational pattern for microservices and distributed systems.

A powerful related concept is Event Sourcing. Instead of storing the current state of an application, you store all changes as a sequence of immutable events.

The application state can then be reconstructed by replaying these events. This provides a complete historical record and simplifies complex state management in some scenarios.

While related, EDA focuses on communication between services, whereas Event Sourcing focuses on how a single service manages its own state.

Consider a system where a user places an order. Which of the following statements best describes an event-driven approach?

Great job! You've explored the fundamentals of Event-Driven Architectures.

• We learned that events are immutable facts about things that happened.
• Producers publish events, and consumers react to them.
• A message broker facilitates this communication, ensuring decoupling and resilience.
• Clojure libraries like langohr make it easy to integrate with brokers like RabbitMQ.

EDA is a crucial pattern for building scalable, resilient, and decoupled backend systems. Keep practicing with messaging systems to solidify your understanding!