eventsourcing go

Sourcing de eventos + CQRS usando Go Tutorial

Fondo

Imagina que estás trabajando para una gran editorial de noticias llamada Fairflax Media , inspirada en la flor de lino (no confundir con Fairfax Media, por supuesto).

Se le ha encomendado la tarea de dividir el enorme sistema monolítico en microservicios y trasladar todo a Kuberentes. Prefiere el diseño basado en dominios y cree que cada base de datos solo debería ser propiedad de una única aplicación. Pero a medida que pasa el tiempo, notas que muchos servicios necesitan datos comunes. Debe asegurarse de que los datos sean coherentes en todos los servicios y que el rendimiento de la consulta sea razonable.

Objetivos del proyecto

• Cree un tutorial paso a paso para microservicios asincrónicos (obstinados) utilizando Golang.
• Cada paso del tutorial debe estar en una rama de git separada.
• La rama master contiene el estado inicial: servicios estrechamente acoplados.
• La rama event-sourcing debe contener la implementación Event Sourcing + CQRS, que contiene servicios asincrónicos, que son independientes y fáciles de probar.
• Presente problemas reales y resuélvalos usando Event Sourcing + CQRS en Golang (con algunas dependencias)
• Utilice un enfoque minimalista e intente utilizar menos piezas móviles. (Por ejemplo, los servicios se mantienen intencionalmente básicos y no incluyen registros, seguimiento, métricas, indicadores de funciones, limitación de velocidad, contenedores acoplables, autenticación, autorización, gráficos de timón K8, composición acoplable, etc.).
• En la rama inicial, la base de datos se simula intencionalmente.
• Demostrar el uso de almacenes de datos en memoria (por ejemplo, BoltDB y Bleve).
• Sea más detallado y realista que el ejemplo habitual de Hellow World , pero siga siendo minimalista.
• Demostrar el uso de canales para el corredor de eventos básico.

No metas

• Intenta ser todo para todos.
• Demuestre cómo utilizar Kafka/Kafka Streams.
• Demuestre cómo utilizar DistributedLog.
• Garantice la entrega exactamente una vez.
• Muestre cómo guardar/restaurar instantáneas y utilizar sistemas de publicación/sub con períodos de retención limitados (por ejemplo, AWS Kinesis y Google Cloud Pub/Sub).
• Implemente una versión sin servidor, por ejemplo, utilizando AWS Lambda o similar.
• Utilice el abastecimiento de eventos con un libro de contabilidad/cadena de bloques de eventos descentralizado.

Público objetivo

Este proyecto está destinado a cualquiera que esté dispuesto a cambiar a una arquitectura de microservicio asíncrona utilizando Golang.

Requisitos previos

• Vaya a 1.9 o posterior

• $GOPATH está configurado

• dep para gestionar dependencias

  En Mac OSX usando brew ...

   $ brew install dep
  $ brew upgrade dep
  

  En otras plataformas puedes usar el script install.sh:

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

• Agregue y asegúrese de que la RUTA contenga $GOPATH/bin

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

Instalación rápida

 $ 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

Clonar el repositorio

Cualquiera:

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

O:

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

Luego instale las dependencias:

 $ dep ensure

¡Pruébalo!

Ejecute en cuatro ventanas de terminal diferentes:

 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

Navegue a las aplicaciones en su navegador:

• Interfaz de usuario GraphiQL: http://localhost:4001/
• Canal RSS de últimas noticias: http://localhost:4002/feed
• Canal RSS de últimas noticias empresariales: http://localhost:4002/feed/business
• Últimas noticias políticas RSS - http://localhost:4002/feed/politics
• (Ingenuo e inútil) Mapa del sitio: http://localhost:4003/sitemap

Tareas opcionales

Reconstruir el código generado

1. Instalar el compilador protobuf

2. Instale el complemento de protocolo Go

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

3. Reconstruir el código Go generado

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

   O ejecute el comando protoc (con el complemento grpc)

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