eventsourcing go

Источник событий + CQRS с использованием Go Tutorial

Фон

Представьте, что вы работаете в крупном новостном издательстве Fairflax Media , вдохновленном цветком льна (конечно, не путать с Fairfax Media).

Вам поставили задачу разбить огромную монолитную систему на микросервисы и перенести все в Kuberentes. Вы предпочитаете проектирование, ориентированное на предметную область, и считаете, что каждая база данных должна принадлежать только одному приложению. Но со временем вы замечаете, что многим сервисам нужны общие данные. Вам необходимо убедиться, что данные согласованы во всех службах и производительность запросов приемлема.

Цели проекта

• Создайте пошаговое руководство по (самоуверенным) асинхронным микросервисам с использованием Golang.
• Каждый шаг руководства должен быть в отдельной ветке git.
• Ветка master содержит исходное состояние — тесно связанные сервисы.
• Ветка event-sourcing должна содержать реализацию Event Sourcing + CQRS, содержащую асинхронные сервисы, которые независимы и легко тестируются.
• Представляйте актуальные проблемы и решайте их, используя Event Sourcing + CQRS в Golang (с несколькими зависимостями).
• Используйте минималистичный подход и старайтесь использовать меньше движущихся частей. (Например, службы намеренно остаются базовыми и не включают в себя надлежащее ведение журналов, трассировку, метрики, флаги функций, ограничение скорости, контейнеры докеров, аутентификацию, авторизацию, контрольные диаграммы K8s, создание докеров и т. д.).
• В исходной ветке БД макетирована намеренно.
• Продемонстрируйте использование хранилищ данных в памяти (например, BoltDB и Bleve).
• Будьте более подробными и реалистичными, чем обычный пример «Hello World» , но оставайтесь минималистичным.
• Продемонстрируйте использование каналов для базового брокера событий.

Нецели

• Старайтесь быть всем для всех.
• Продемонстрируйте, как использовать Kafka/Kafka Streams.
• Продемонстрируйте, как использовать DistributedLog.
• Гарантия одноразовой доставки.
• Покажите, как сохранять/восстанавливать снимки и использовать системы публикации/подписки с ограниченными сроками хранения (например, AWS Kinesis и Google Cloud Pub/Sub).
• Внедрите бессерверную версию, например, используя AWS Lambda или аналогичный.
• Используйте источник событий с децентрализованным реестром событий/блокчейном.

Целевая аудитория

Этот проект предназначен для всех, кто хочет перейти на асинхронную микросервисную архитектуру с использованием Golang.

Предварительные условия

• Перейти 1.9 или новее

• $GOPATH установлен

• dep для управления зависимостями

  В Mac OSX с помощью brew ...

   $ brew install dep
  $ brew upgrade dep
  

  На других платформах вы можете использовать скрипт install.sh:

   $ curl https://raw.githubusercontent.com/golang/dep/master/install.sh | sh
  

• Добавьте, что PATH содержит $GOPATH/bin.

   $ go help gopath
  $ export PATH=$PATH:$GOPATH/bin
  

Быстрая установка

 $ go get -u github.com/pavelnikolov/eventsourcing-go/demo-articles
$ go get -u github.com/pavelnikolov/eventsourcing-go/demo-graph
$ go get -u github.com/pavelnikolov/eventsourcing-go/demo-sitemap
$ go get -u github.com/pavelnikolov/eventsourcing-go/demo-rss

Клонировать репозиторий

Или:

 $ go get -u github.com/pavelnikolov/eventsourcing-go/...

Или:

 $ mkdir -p $GOPATH/github.com/pavelnikolov
$ cd $GOPATH/github.com/pavelnikolov
$ git clone github.com/pavelnikolov/eventsourcing-go

Затем установите зависимости:

 $ dep ensure

Попробуйте!

Запустите в четырех разных окнах терминала:

 go install ./cmd/demo-articles && demo-articles
go install ./cmd/demo-graph && demo-graph
go install ./cmd/demo-rss && demo-rss
go install ./cmd/demo-sitemap && demo-sitemap

Перейдите к приложениям в браузере:

• Пользовательский интерфейс GraphiQL — http://localhost:4001/
• RSS-канал последних новостей - http://localhost:4002/feed
• RSS-канал последних деловых новостей — http://localhost:4002/feed/business
• Последние политические новости RSS-канал – http://localhost:4002/feed/politics
• (Наивно и бесполезно) Карта сайта - http://localhost:4003/sitemap

Дополнительные задачи

Пересобрать сгенерированный код

1. Установите компилятор protobuf

2. Установите плагин protoc Go.

    $ go get -u github.com/golang/protobuf/protoc-gen-go
   

3. Перестройте сгенерированный код Go.

    $ go generate github.com/pavelnikolov/eventsourcing-go/...
   

   Или запустите команду protoc (с плагином grpc)

    $ protoc -I publishing/ publishing/publishing.proto --go_out=plugins=grpc:publishing