Akka.NET CQRS与分片及内存复制架构源码下载

【实例简介】
Akka.CQRS是一个面向Akka.NET的参考架构，旨在展示如何使用Akka.NET技术和原则来实现命令查询责任分离(CQRS)、Akka.Cluster集群、Akka.Cluster.Sharding分片、Akka.Persistence持久化以及Akka.Persistence.Query读侧查询等功能。本架构通过示例代码，展示了如何构建一个高可扩展、容错、弹性的Akka.NET actor网络，以及如何利用Docker简化开发者的部署和配置工作。本文还详细介绍了如何在交易服务和定价服务领域中应用这些技术，包括如何处理不可达节点和故障转移等问题。最后，本文提供了如何使用Docker和docker-compose来运行Akka.CQRS的指南，以及如何测试其一致性和故障转移能力。
【实例截图】
【核心代码】
文件清单
└── InMemoryCQRSReplication-39d745811e02cc491c1e30cf35142b2d667067e5
    ├── Akka.CQRS.sln
    ├── appsettings.json
    ├── build.cmd
    ├── build.fsx
    ├── build.ps1
    ├── build.sh
    ├── build-system
    │   ├── azure-pipeline.template.yaml
    │   ├── linux-pr-validation.yaml
    │   ├── README.md
    │   ├── windows-pr-validation.yaml
    │   └── windows-release.yaml
    ├── docker-compose.yaml
    ├── docs
    │   ├── api
    │   │   └── index.md
    │   ├── articles
    │   │   ├── index.md
    │   │   └── toc.yml
    │   ├── docfx.json
    │   ├── images
    │   │   ├── akka-cqrs-architectural-overview.png
    │   │   ├── akka-cqrs-inmemory-replication.png
    │   │   ├── docker-for-windows-networking.png
    │   │   └── icon.png
    │   ├── index.md
    │   ├── toc.yml
    │   └── web.config
    ├── global.json
    ├── LICENSE
    ├── README.md
    ├── RELEASE_NOTES.md
    ├── serve-docs.cmd
    ├── serve-docs.ps1
    └── src
        ├── Akka.CQRS
        │   ├── Akka.CQRS.csproj
        │   ├── AvailableTickerSymbols.cs
        │   ├── Commands
        │   │   ├── GetOrderBookSnapshot.cs
        │   │   └── GetRecentMatches.cs
        │   ├── Entities
        │   │   ├── Order.cs
        │   │   └── OrderExtensions.cs
        │   ├── EntityIdHelper.cs
        │   ├── Events
        │   │   ├── Ask.cs
        │   │   ├── Bid.cs
        │   │   ├── Fill.cs
        │   │   └── Match.cs
        │   ├── ITimestamper.cs
        │   ├── ITradeEvent.cs
        │   ├── ITradeOrderGenerator.cs
        │   ├── IWithOrderId.cs
        │   ├── IWithStockId.cs
        │   ├── OrderbookSnapshot.cs
        │   ├── PriceRange.cs
        │   ├── PriceRangeExtensions.cs
        │   └── Util
        │       ├── CurrentUtcTimestamper.cs
        │       └── GuidTradeOrderIdGenerator.cs
        ├── Akka.CQRS.Infrastructure
        │   ├── Akka.CQRS.Infrastructure.csproj
        │   ├── Ops
        │   │   ├── ops.conf
        │   │   └── OpsConfig.cs
        │   ├── SqlDbHoconHelper.cs
        │   ├── StockEventTagger.cs
        │   └── StockShardMsgRouter.cs
        ├── Akka.CQRS.Infrastructure.Tests
        │   ├── Akka.CQRS.Infrastructure.Tests.csproj
        │   └── ConfigSpecs.cs
        ├── Akka.CQRS.Matching
        │   ├── Akka.CQRS.Matching.csproj
        │   └── MatchingEngine.cs
        ├── Akka.CQRS.Matching.Tests
        │   ├── Akka.CQRS.Matching.Tests.csproj
        │   └── MatchingEngineSpecs.cs
        ├── Akka.CQRS.Pricing
        │   ├── Akka.CQRS.Pricing.csproj
        │   ├── Commands
        │   │   ├── FetchPriceAndVolume.cs
        │   │   ├── GetPriceHistory.cs
        │   │   ├── Ping.cs
        │   │   └── PriceAndVolumeSnapshot.cs
        │   ├── Events
        │   │   ├── IPriceUpdate.cs
        │   │   ├── IVolumeUpdate.cs
        │   │   ├── PriceChanged.cs
        │   │   └── VolumeChanged.cs
        │   ├── MatchAggregatorSnapshot.cs
        │   ├── PriceTopicHelpers.cs
        │   └── Views
        │       ├── EMWA.cs
        │       ├── MatchAggregate.cs
        │       └── PriceHistory.cs
        ├── Akka.CQRS.Pricing.Actors
        │   ├── Akka.CQRS.Pricing.Actors.csproj
        │   ├── MatchAggregator.cs
        │   ├── PriceInitiatorActor.cs
        │   ├── PriceViewActor.cs
        │   ├── PriceViewMaster.cs
        │   └── UnexpectedEndOfStream.cs
        ├── Akka.CQRS.Pricing.Cli
        │   ├── Akka.CQRS.Pricing.Cli.csproj
        │   ├── PriceCmdHandler.cs
        │   ├── PriceCmdRouter.cs
        │   ├── PriceTrackingActor.cs
        │   └── PricingCmd.cs
        ├── Akka.CQRS.Pricing.Service
        │   ├── Akka.CQRS.Pricing.Service.csproj
        │   ├── app.conf
        │   ├── Dockerfile
        │   └── Program.cs
        ├── Akka.CQRS.Subscriptions
        │   ├── Akka.CQRS.Subscriptions.csproj
        │   ├── DistributedPubSub
        │   │   ├── DistributedPubSubTopicFormatter.cs
        │   │   ├── DistributedPubSubTradeEventPublisher.cs
        │   │   └── DistributedPubSubTradeEventSubscriptionManager.cs
        │   ├── InMem
        │   │   └── InMemoryTradeEventPublisher.cs
        │   ├── ITradeEventPublisher.cs
        │   ├── ITradeEventSubscriptionManager.cs
        │   ├── NoOp
        │   │   └── NoOpTradeEventSubscriptionManager.cs
        │   ├── TradeEventHelpers.cs
        │   ├── TradeEventType.cs
        │   ├── TradeSubscribeAck.cs
        │   ├── TradeSubscribe.cs
        │   ├── TradeSubscribeNack.cs
        │   ├── TradeUnsubscribeAck.cs
        │   ├── TradeUnsubscribe.cs
        │   └── TradeUnsubscribeNack.cs
        ├── Akka.CQRS.Subscriptions.Tests
        │   ├── Akka.CQRS.Subscriptions.Tests.csproj
        │   ├── DistributedPubSub
        │   │   ├── DistributedPubSubEnd2EndSpecs.cs
        │   │   └── DistributedPubSubFormatterSpecs.cs
        │   └── TradeEventExtensionsSpecs.cs
        ├── Akka.CQRS.Tests
        │   ├── Akka.CQRS.Tests.csproj
        │   └── OrderSpecs.cs
        ├── Akka.CQRS.TradePlacers.Service
        │   ├── Akka.CQRS.TradePlacers.Service.csproj
        │   ├── app.conf
        │   ├── Dockerfile
        │   └── Program.cs
        ├── Akka.CQRS.TradeProcessor.Actors
        │   ├── Akka.CQRS.TradeProcessor.Actors.csproj
        │   ├── AskerActor.cs
        │   ├── BidderActor.cs
        │   └── OrderBookActor.cs
        ├── Akka.CQRS.TradeProcessor.Service
        │   ├── Akka.CQRS.TradeProcessor.Service.csproj
        │   ├── app.conf
        │   ├── Dockerfile
        │   └── Program.cs
        ├── Directory.Build.props
        └── Directory.Packages.props

34 directories, 127 files