基于.NET Core、Kafka和MongoDB的六边形架构DDD+聚合+事件溯源博客引擎源码

【实例简介】
本文介绍了一个基于事件驱动架构的解决方案，该方案采用了领域驱动设计(DDD)和命令查询责任分离(CQRS)。解决方案包含以下应用程序：

1. 生产者Web API接收命令产生域事件。同时接收查询并返回JSON。
2. 消费者控制台应用读取事件流，并将投影到MongoDB数据库。
3. 用于认证和生成JWT的Web API。

环境要求：
- Visual Studio 2017 + Update 3
- .NET CORE SDK 2.0
- Docker

环境设置：
如果您已经有了Kafka和MongoDB的有效连接，可以跳过此步骤，直接运行应用程序。

使用以下命令检查数据层是否准备就绪：

$ docker images
$ docker ps

运行应用程序有两种选项：通过Visual Studio 2017或使用dotnet core命令。

如何运行Bearer认证API：

$ dotnet run

导航至Swagger UI (例如 http://localhost:16024/swagger)，提交以下凭据：

{
  "username": "ivanpaulovich",
  "password": "mysecret"
}

存储Bearer Token，因为您将需要该令牌值来登录生产者API。

如何运行消费者API：

$ dotnet run

请保持控制台应用运行以处理事件。

如何运行生产者API：

$ dotnet run

导航至Swagger UI (例如 http://localhost:14398/swagger)。
【实例截图】
【核心代码】
文件清单
└── event-sourcing-jambo-15ac2de003dead45ca25fc673f08aa7b7168350a
    ├── CODE_OF_CONDUCT.md
    ├── _config.yml
    ├── CONTRIBUTING.md
    ├── LICENSE
    ├── Producer.png
    ├── README.md
    ├── setup
    │   ├── docker-compose.yml
    │   ├── down-kafka-mongodb.sh
    │   └── up-kafka-mongodb.sh
    └── source
        ├── Auth
        │   ├── Jambo.Auth.Application
        │   │   ├── Commands
        │   │   │   └── LoginCommand.cs
        │   │   └── Jambo.Auth.Application.csproj
        │   ├── Jambo.Auth.Infrastructure
        │   │   ├── Jambo.Auth.Infrastructure.csproj
        │   │   └── Properties
        │   │       └── launchSettings.json
        │   ├── Jambo.Auth.sln
        │   └── Jambo.Auth.UI
        │       ├── appsettings.Development.json
        │       ├── appsettings.json
        │       ├── Config.cs
        │       ├── Controllers
        │       │   └── AccountController.cs
        │       ├── Dockerfile
        │       ├── Jambo.Auth.UI.csproj
        │       ├── Program.cs
        │       ├── Properties
        │       │   └── launchSettings.json
        │       └── Startup.cs
        ├── Consumer
        │   ├── Jambo.Consumer.Application
        │   │   ├── DomainEventHandlers
        │   │   │   ├── Blogs
        │   │   │   │   ├── BlogCreatedEventHandler.cs
        │   │   │   │   ├── BlogDisabledEventHandler.cs
        │   │   │   │   ├── BlogEnabledEventHandler.cs
        │   │   │   │   └── BlogUrlUpdatedEventHandler.cs
        │   │   │   └── Posts
        │   │   │       ├── CommentCreatedEventHandler.cs
        │   │   │       ├── PostContentUpdatedEventHandler.cs
        │   │   │       ├── PostCreatedEventHandler.cs
        │   │   │       ├── PostDisabledEventHandler.cs
        │   │   │       ├── PostEnabledEventHandler.cs
        │   │   │       ├── PostHiddenDomainEventHandler.cs
        │   │   │       └── PostPublishedDomainEventHandler.cs
        │   │   └── Jambo.Consumer.Application.csproj
        │   ├── Jambo.Consumer.Infrastructure
        │   │   ├── DataAccess
        │   │   │   ├── MongoContext.cs
        │   │   │   └── Repositories
        │   │   │       ├── Blogs
        │   │   │       │   ├── BlogReadOnlyRepository.cs
        │   │   │       │   └── BlogWriteOnlyRepository.cs
        │   │   │       └── Posts
        │   │   │           ├── PostReadOnlyRepository.cs
        │   │   │           └── PostWriteOnlyRepository.cs
        │   │   ├── Jambo.Consumer.Infrastructure.csproj
        │   │   ├── Modules
        │   │   │   ├── ApplicationModule.cs
        │   │   │   ├── BusModule.cs
        │   │   │   └── MediatRModule.cs
        │   │   └── ServiceBus
        │   │       └── Bus.cs
        │   ├── Jambo.Consumer.sln
        │   └── Jambo.Consumer.UI
        │       ├── appsettings.json
        │       ├── autofac.Development.json
        │       ├── autofac.json
        │       ├── Dockerfile
        │       ├── Jambo.Consumer.UI.csproj
        │       ├── Program.cs
        │       └── Startup.cs
        ├── Producer
        │   ├── Jambo.Producer.Application
        │   │   ├── CommandHandlers
        │   │   │   ├── Blogs
        │   │   │   │   ├── CreateBlogCommandHandler.cs
        │   │   │   │   ├── DisableBlogCommandHandler.cs
        │   │   │   │   ├── EnableBlogCommandHandler.cs
        │   │   │   │   └── UpdateBlogUrlCommandHandler.cs
        │   │   │   └── Posts
        │   │   │       ├── CreateCommentCommandHandler.cs
        │   │   │       ├── CreatePostCommandHandler.cs
        │   │   │       ├── DisablePostCommandHandler.cs
        │   │   │       ├── EnablePostCommandHandler.cs
        │   │   │       ├── HidePostCommandHandler.cs
        │   │   │       ├── PublishPostCommandHandler.cs
        │   │   │       └── UpdateContentCommandHandler.cs
        │   │   ├── Commands
        │   │   │   ├── Blogs
        │   │   │   │   ├── CreateBlogCommand.cs
        │   │   │   │   ├── DisableBlogCommand.cs
        │   │   │   │   ├── EnableBlogCommand.cs
        │   │   │   │   └── UpdateBlogUrlCommand.cs
        │   │   │   ├── CommandBase.cs
        │   │   │   └── Posts
        │   │   │       ├── CreateCommentCommand.cs
        │   │   │       ├── CreatePostCommand.cs
        │   │   │       ├── DisablePostCommand.cs
        │   │   │       ├── EnablePostCommand.cs
        │   │   │       ├── HidePostCommand.cs
        │   │   │       ├── PublishPostCommand.cs
        │   │   │       └── UpdatePostContentCommand.cs
        │   │   ├── Jambo.Producer.Application.csproj
        │   │   └── Queries
        │   │       ├── IBlogQueries.cs
        │   │       └── IPostQueries.cs
        │   ├── Jambo.Producer.Infrastructure
        │   │   ├── DataAccess
        │   │   │   ├── MongoContext.cs
        │   │   │   └── Repositories
        │   │   │       ├── Blogs
        │   │   │       │   └── BlogReadOnlyRepository.cs
        │   │   │       └── Posts
        │   │   │           └── PostReadOnlyRepository.cs
        │   │   ├── Jambo.Producer.Infrastructure.csproj
        │   │   ├── Modules
        │   │   │   ├── ApplicationModule.cs
        │   │   │   ├── BusModule.cs
        │   │   │   ├── MediatRModule.cs
        │   │   │   └── QueriesModule.cs
        │   │   ├── Properties
        │   │   │   └── launchSettings.json
        │   │   ├── Queries
        │   │   │   ├── BlogQueries.cs
        │   │   │   └── PostQueries.cs
        │   │   └── ServiceBus
        │   │       └── Bus.cs
        │   ├── Jambo.Producer.sln
        │   └── Jambo.Producer.UI
        │       ├── appsettings.Development.json
        │       ├── appsettings.json
        │       ├── autofac.Development.json
        │       ├── autofac.json
        │       ├── Controllers
        │       │   ├── BlogsController.cs
        │       │   └── PostsController.cs
        │       ├── Dockerfile
        │       ├── Filters
        │       │   ├── CorrelationFilter.cs
        │       │   ├── DomainExceptionFilter.cs
        │       │   └── ValidateModelAttribute.cs
        │       ├── Jambo.Producer.UI.csproj
        │       ├── Program.cs
        │       ├── Properties
        │       │   └── launchSettings.json
        │       └── Startup.cs
        └── Shared
            ├── Jambo.Domain
            │   ├── Exceptions
            │   │   ├── DomainException.cs
            │   │   ├── JamboException.cs
            │   │   └── TransactionConflictException.cs
            │   ├── Jambo.Domain.csproj
            │   ├── Model
            │   │   ├── AggregateRoot.cs
            │   │   ├── Blogs
            │   │   │   ├── Blog.cs
            │   │   │   ├── Events
            │   │   │   │   ├── BlogCreatedDomainEvent.cs
            │   │   │   │   ├── BlogDisabledDomainEvent.cs
            │   │   │   │   ├── BlogEnabledDomainEvent.cs
            │   │   │   │   └── BlogUrlUpdatedDomainEvent.cs
            │   │   │   ├── IBlogReadOnlyRepository.cs
            │   │   │   ├── IBlogWriteOnlyRepository.cs
            │   │   │   └── Url.cs
            │   │   ├── DomainEvent.cs
            │   │   ├── Entity.cs
            │   │   ├── Header.cs
            │   │   ├── IDomainEvent.cs
            │   │   ├── IEntity.cs
            │   │   └── Posts
            │   │       ├── Comment.cs
            │   │       ├── CommentShouldNotBeEmptyException.cs
            │   │       ├── Content.cs
            │   │       ├── ContentShouldNotBeEmptyException.cs
            │   │       ├── Events
            │   │       │   ├── CommentCreatedDomainEvent.cs
            │   │       │   ├── PostContentUpdatedDomainEvent.cs
            │   │       │   ├── PostCreatedDomainEvent.cs
            │   │       │   ├── PostDisabledDomainEvent.cs
            │   │       │   ├── PostEnabledDomainEvent.cs
            │   │       │   ├── PostHiddenDomainEvent.cs
            │   │       │   └── PostPublishedDomainEvent.cs
            │   │       ├── IPostReadOnlyRepository.cs
            │   │       ├── IPostWriteOnlyRepository.cs
            │   │       ├── Post.cs
            │   │       ├── Title.cs
            │   │       └── TitleShouldNotBeEmptyException.cs
            │   └── ServiceBus
            │       ├── IPublisher.cs
            │       └── ISubscriber.cs
            └── Jambo.Domain.UnitTests
                ├── Jambo.Domain.UnitTests.csproj
                └── ValueObjectsTests.cs

56 directories, 144 files