Что такое Event Sourcing

• Append-only log: events immutable, порядок matters
• Event store: EventStore DB, Kafka, Postgres tables
• Snapshots: для performance — периодический dump state
• Projections: read models, built from event stream
• Upcasters: преобразуют old event versions в new

// Events append
EventStore.append('order-123', [
  OrderCreated { customerId, items }
  OrderConfirmed { timestamp }
  OrderShipped { trackingNumber }
])
// Rebuild state by replaying events
state = fold(events, initialState, applyEvent)

• CQRS
• Saga
• Webhook

Event Sourcing — это архитектурный паттерн, который сохраняет состояние системы в виде последовательности событий, а не текущего состояния. Это позволяет эффективно отслеживать изменения, восстанавливать состояние системы и обеспечивать высокую степень аудита. Вместо обновления записи в базе данных, каждое изменение сохраняется как отдельное событие, что обеспечивает полную историю изменений и возможность отката к предыдущим состояниям.

Использование Event Sourcing имеет несколько ключевых преимуществ:

• Полная история изменений: Каждое событие сохраняется, что позволяет отслеживать, как и почему система изменилась.
• Отладка и тестирование: Благодаря возможности воспроизводить состояние системы в любой момент времени, тестирование становится проще и эффективнее.
• Производительность: Event Sourcing может снизить нагрузку на базу данных, так как события могут быть записаны в более легковесные хранилища.
• Масштабируемость: Системы, основанные на событиях, легче масштабировать, так как они могут обрабатывать события асинхронно.

Эти преимущества делают Event Sourcing особенно привлекательным для систем с высоким уровнем изменений и требований к аудиту.

Рассмотрим практический пример реализации Event Sourcing на языке программирования Java с использованием Spring Framework. Предположим, у нас есть приложение для управления заказами, и мы хотим реализовать Event Sourcing для обработки изменений статуса заказа.

import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

@Component
public class OrderEventHandler {

    @EventListener
    public void handleOrderCreated(OrderCreatedEvent event) {
        // Логика обработки события создания заказа
    }

    @EventListener
    public void handleOrderUpdated(OrderUpdatedEvent event) {
        // Логика обработки события обновления заказа
    }
}

В этом примере мы создаем обработчики событий, которые реагируют на события создания и обновления заказа. Эти события могут быть сохранены в хранилище событий, таком как Apache Kafka или Amazon Kinesis, что позволяет асинхронно обрабатывать их и обеспечивать высокую доступность.

Для хранения событий можно использовать следующий пример конфигурации в application.yml:

spring:
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      group-id: order-service
      auto-offset-reset: earliest

С помощью этой конфигурации приложение будет подключаться к Kafka, чтобы получать события и обрабатывать их в порядке их создания.