eventsourcing go

Event Sourcing + CQRS mit Go Tutorial

Hintergrund

Stellen Sie sich vor, Sie arbeiten für einen großen Nachrichtenverlag namens Fairflax Media , inspiriert von Flachsblüten (natürlich nicht zu verwechseln mit Fairfax Media).

Sie wurden damit beauftragt, das riesige Monolithsystem in Microservices aufzuteilen und alles nach Kuberentes zu verlagern. Sie bevorzugen domänengesteuertes Design und glauben, dass jede Datenbank immer nur einer einzigen Anwendung gehören sollte. Doch mit der Zeit merkt man, dass viele Dienste gemeinsame Daten benötigen. Sie müssen sicherstellen, dass die Daten über alle Dienste hinweg konsistent sind und die Abfrageleistung angemessen ist.

Projektziele

• Erstellen Sie eine Schritt-für-Schritt-Anleitung für (meinungsbasierte) asynchrone Microservices mit Golang.
• Jeder Schritt des Tutorials sollte sich in einem separaten Git-Zweig befinden.
• Der master enthält den Ausgangszustand – eng gekoppelte Dienste.
• Der event-sourcing Zweig sollte die Event Sourcing + CQRS-Implementierung enthalten, die asynchrone Dienste enthält, die unabhängig und einfach zu testen sind.
• Präsentieren Sie aktuelle Probleme und lösen Sie sie mithilfe von Event Sourcing + CQRS in Golang (mit einigen Abhängigkeiten).
• Gehen Sie minimalistisch vor und versuchen Sie, weniger bewegliche Teile zu verwenden. (Zum Beispiel sind die Dienste absichtlich einfach gehalten und umfassen keine ordnungsgemäße Protokollierung, Ablaufverfolgung, Metriken, Feature-Flags, Ratenbegrenzung, Docker-Container, Authentifizierung, Autorisierung, K8s-Helmdiagramme, Docker-Compose usw.).
• Im ersten Zweig wird DB absichtlich nachgebildet.
• Demonstrieren Sie die Verwendung von In-Memory-Datenspeichern (z. B. BoltDB und Bleve).
• Seien Sie detaillierter und realistischer als das reguläre Hellow World- Beispiel, bleiben Sie aber minimalistisch.
• Demonstrieren Sie die Verwendung von Kanälen für den Basis-Event-Broker.

Nicht-Ziele

• Versuchen Sie, alles für alle zu sein.
• Demonstrieren Sie die Verwendung von Kafka/Kafka Streams.
• Demonstrieren Sie die Verwendung von DistributedLog.
• Garantieren Sie eine exakt einmalige Lieferung.
• Zeigen Sie, wie Sie Snapshots speichern/wiederherstellen und Pub/Sub-Systeme mit begrenzten Aufbewahrungsfristen verwenden (z. B. AWS Kinesis und Google Cloud Pub/Sub).
• Implementieren Sie eine serverlose Version, beispielsweise mit AWS Lambda oder ähnlichem.
• Nutzen Sie Event-Sourcing mit einem dezentralen Event-Ledger/einer dezentralen Blockchain.

Zielgruppe

Dieses Projekt richtet sich an alle, die bereit sind, mit Golang auf eine asynchrone Microservice-Architektur umzusteigen.

Voraussetzungen

• Gehen Sie auf 1.9 oder höher

• $GOPATH ist gesetzt

• dep zum Verwalten von Abhängigkeiten

  Unter Mac OSX mit brew ...

   $ brew install dep
  $ brew upgrade dep
  

  Auf anderen Plattformen können Sie das Skript install.sh verwenden:

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

• Stellen Sie sicher, dass der PATH $GOPATH/bin enthält

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

Schnelle Installation

 $ 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

Klonen Sie das Repository

Entweder:

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

Oder:

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

Installieren Sie dann die Abhängigkeiten:

 $ dep ensure

Probieren Sie es aus!

Führen Sie es in vier verschiedenen Terminalfenstern aus:

 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

Navigieren Sie zu den Apps in Ihrem Browser:

• GraphiQL-Benutzeroberfläche – http://localhost:4001/
• Neueste Nachrichten RSS-Feed – http://localhost:4002/feed
• Neuester RSS-Feed für Wirtschaftsnachrichten – http://localhost:4002/feed/business
• Aktuelle politische Nachrichten RSS-Feed – http://localhost:4002/feed/politics
• (Naiv und nutzlos) Sitemap – http://localhost:4003/sitemap

Optionale Aufgaben

Erstellen Sie den generierten Code neu

1. Installieren Sie den Protobuf-Compiler

2. Installieren Sie das Protoc Go-Plugin

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

3. Erstellen Sie den generierten Go-Code neu

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

   Oder führen Sie den Befehl protoc aus (mit dem grpc-Plugin).

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