Skip to content

Golang Microservices for implementing pub/sub messesing using RabbitMQ.

License

Notifications You must be signed in to change notification settings

alisenola/microservices-rabbitmq

Repository files navigation

CI Go Version

Golang Microservices

The main idea of creating this project is implementing an infrastructure for up and running distributed system with the latest technology and architecture like Vertical Slice Architecture, OpenTelemetry, RabbitMq in Golang, and we will not deal mainly with business.

Open in Gitpod

The Goals of This Project

  • ❇️ Using Vertical Slice Architecture for architecture level.
  • ❇️ Using Rabbitmq for Event Driven Architecture between our microservices with streadway/amqp library.
  • ❇️ Using gRPC for internal communication between our microservices with grpc/grpc-go library.
  • ❇️ Using CQRS implementation with mehdihadeli/Go-MediatR library.
  • ❇️ Using Postgres for database in our microservices with go-gorm/gorm library.
  • ❇️ Using go-playground/validator for validating input data in the REST calls.
  • ❇️ Using OpenTelemetry for distributed tracing top of Jaeger.
  • ❇️ Using OAuth2 for implementation authentication and authorization with go-oauth2/oauth2 library.
  • ❇️ Using Echo framework for RESTFul api.
  • ❇️ Using Swagger with swaggo/swag library for api documentation.
  • ❇️ Using uber-go/fx library for dependency injection.
  • ❇️ Using Viper for configuration management.
  • ❇️ Using logrus as a structured logger.
  • ❇️ Using Unit Testing,Integration Testing and End To End Testing for testing level.
  • ❇️ Using Docker-Compose for our deployment mechanism.
  • 🚧 Using OpenTelemetry for monitoring top of Prometteuse and Grafana
  • 🚧 Using MongoDB for read side with mongo-driver.
  • 🚧 Using Domain Driven Design (DDD) to implement all business processes in microservices.
  • 🚧 Using Inbox Pattern for ensuring message idempotency for receiver and Exactly once Delivery.
  • 🚧 Using Outbox Pattern for ensuring no message is lost and there is at At Least One Delivery.

Plan

🌀This project is a work in progress, new features will be added over time.🌀

I will try to register future goals and additions in the Issues section of this repository.

Technologies - Libraries

The Domain And Bounded Context - Service Boundary

Structure of Project

In this project I used vertical slice architecture and feature folder structure to structure my files.

I used RabbitMQ as my MessageBroker for async communication between microservices using the eventual consistency mechanism.

Microservices are event based which means they can publish and/or subscribe to any events occurring in the setup. By using this approach for communicating between services, each microservice does not need to know about the other services or handle errors occurred in other microservices.

I treat each request as a distinct use case or slice, encapsulating and grouping all concerns from front-end to back. When adding or changing a feature in an application in n-tire architecture, we are typically touching many "layers" in an application. We are changing the user interface, adding fields to models, modifying validation, and so on. Instead of coupling across a layer, we couple vertically along a slice. We minimize coupling between slices, and maximize coupling in a slice.

With this approach, each of our vertical slices can decide for itself how to best fulfill the request. New features only add code, we're not changing shared code and worrying about side effects.

Instead of grouping related action methods in one endpoint, I used the REPR pattern. Each action gets its own small endpoint, and for communication between our endpoint and handlers, I use Go-MediatR for decouple our endpoint to handlers directly, and it gives use some pipeline behavior for logging, caching, validation and... easily.

The use of the mediator pattern in my endpoints creates clean and thin endpoint. By separating action logic into individual handlers we support the Single Responsibility Principle and Don't Repeat Yourself principles, this is because traditional controllers tend to become bloated with large action methods and several injected Services only being used by a few methods.

I used CQRS to decompose my features into small parts that makes our application:

  • Maximize performance, scalability and simplicity.
  • Easy to maintain and add features to. Changes only affect one command or query, avoiding breaking changes or creating side effects.
  • It gives us better separation of concerns and cross-cutting concern (with help of mediatr behavior pipelines), instead of bloated service classes doing many things.

Using the CQRS pattern, we cut each business functionality into vertical slices, for each of these slices we group classes (see technical folders structure) specific to that feature together (command, handlers, infrastructure, repository, controllers, etc). In our CQRS pattern each command/query handler is a separate slice. This is where you can reduce coupling between layers. Each handler can be a separated code unit, even copy/pasted. Thanks to that, we can tune down the specific method to not follow general conventions (e.g. use custom postgresql query or even different storage). In a traditional layered architecture, when we change the core generic mechanism in one layer, it can impact all methods.

Support

If you like my work, feel free to:

  • ⭐ this repository. And we will be happy together :)

Thanks a bunch for supporting me!

Contribution

Thanks to all contributors, you're awesome and this wouldn't be possible without you! The goal is to build a categorized community-driven collection of very well-known resources.

Please follow this contribution guideline to submit a pull request or create the issue.

Project References & Credits

License

This project is made available under the MIT license. See LICENSE for details.

About

Golang Microservices for implementing pub/sub messesing using RabbitMQ.

Topics

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published