当前位置：首页 > news >正文

终极指南：如何用KurrentDB与ASP.NET Core构建企业级事件驱动应用

news 2026/4/11 1:30:48

终极指南：如何用KurrentDB与ASP.NET Core构建企业级事件驱动应用

【免费下载链接】EventStoreThe stream database optimised for event sourcing项目地址: https://gitcode.com/gh_mirrors/ev/EventStore

KurrentDB是一款专为事件溯源优化的流数据库，能够帮助开发者构建高性能、可扩展的事件驱动应用。本指南将详细介绍如何将KurrentDB与ASP.NET Core框架结合，快速搭建企业级事件驱动系统，从环境搭建到实际应用开发，让你轻松掌握事件驱动架构的核心技术。

快速了解KurrentDB与事件驱动架构

事件驱动架构（EDA）通过事件的产生、传播和处理来驱动系统行为，非常适合构建松耦合、高弹性的现代应用。KurrentDB作为流数据库，提供了持久化存储事件流、实时事件处理和高效事件查询的能力，是实现事件驱动架构的理想选择。

KurrentDB管理界面展示了服务器状态、集群信息和资源使用情况，帮助开发者实时监控系统运行状态

KurrentDB的核心优势包括：

专为事件溯源优化的存储引擎
支持高吞吐量的事件写入和查询
内置投影（Projections）功能，可实时处理事件流
原生支持集群部署，确保高可用性
与.NET生态系统无缝集成

搭建KurrentDB开发环境

安装KurrentDB

KurrentDB提供多种安装方式，包括Docker容器、Linux包管理器和Windows Chocolatey。对于开发环境，推荐使用Docker方式快速部署：

# 拉取KurrentDB镜像 docker pull docker.kurrent.io/kurrent-latest/kurrentdb:latest # 启动单节点KurrentDB（开发环境） docker run --name kurrentdb-node -it -p 2113:2113 \ docker.kurrent.io/kurrent-latest/kurrentdb:latest --insecure --run-projections=All \ --enable-atom-pub-over-http

启动后，可通过访问 http://localhost:2113 打开KurrentDB管理界面，默认管理员账号为admin，密码为changeit。

创建ASP.NET Core项目

使用.NET CLI创建一个新的ASP.NET Core Web API项目：

dotnet new webapi -n EventDrivenApp cd EventDrivenApp

KurrentDB与ASP.NET Core集成

安装KurrentDB客户端

KurrentDB提供了官方.NET客户端库，可通过NuGet安装：

dotnet add package KurrentDB.Client

配置连接字符串

在appsettings.json中添加KurrentDB连接配置：

{ "KurrentDB": { "ConnectionString": "kurrentdb://localhost:2113?tls=false" } }

创建事件模型

定义应用所需的事件模型，例如订单创建事件：

public record OrderCreatedEvent( Guid OrderId, string CustomerId, decimal Amount, DateTime CreatedAt );

实现事件存储服务

创建一个事件存储服务，封装KurrentDB的操作：

public class EventStoreService { private readonly EventStoreClient _client; public EventStoreService(IConfiguration configuration) { var connectionString = configuration.GetConnectionString("KurrentDB"); _client = new EventStoreClient(EventStoreClientSettings.Create(connectionString)); } public async Task AppendEventAsync<T>(string streamName, T @event) { var eventData = new EventData( Uuid.NewUuid(), typeof(T).Name, JsonSerializer.SerializeToUtf8Bytes(@event) ); await _client.AppendToStreamAsync( streamName, StreamState.Any, new[] { eventData } ); } // 其他事件操作方法... }

构建事件驱动API

创建事件发布端点

在ASP.NET Core控制器中实现事件发布API：

[ApiController] [Route("api/orders")] public class OrdersController : ControllerBase { private readonly EventStoreService _eventStore; public OrdersController(EventStoreService eventStore) { _eventStore = eventStore; } [HttpPost] public async Task<IActionResult> CreateOrder(CreateOrderCommand command) { var orderId = Guid.NewGuid(); var @event = new OrderCreatedEvent( orderId, command.CustomerId, command.Amount, DateTime.UtcNow ); await _eventStore.AppendEventAsync($"orders-{orderId}", @event); return CreatedAtAction(nameof(GetOrder), new { id = orderId }, orderId); } // 其他API端点... }

实现事件订阅

使用KurrentDB的订阅功能实时处理事件：

public class OrderEventSubscriber : IHostedService { private readonly EventStoreClient _client; private readonly ILogger<OrderEventSubscriber> _logger; private IDisposable _subscription; public OrderEventSubscriber(EventStoreClient client, ILogger<OrderEventSubscriber> logger) { _client = client; _logger = logger; } public Task StartAsync(CancellationToken cancellationToken) { _subscription = _client.SubscribeToAllAsync( FromAll.Start, async (subscription, @event, cancellationToken) => { if (@event.Event.EventType == nameof(OrderCreatedEvent)) { var orderEvent = JsonSerializer.Deserialize<OrderCreatedEvent>( @event.Event.Data.Span); _logger.LogInformation( "Order {OrderId} created for customer {CustomerId}", orderEvent.OrderId, orderEvent.CustomerId); // 处理订单创建事件... } }); return Task.CompletedTask; } // 其他实现... }

使用KurrentDB投影处理事件流

KurrentDB的投影功能允许你实时处理事件流并生成派生数据。通过管理界面可以轻松创建和管理投影。

KurrentDB投影创建界面，可使用JavaScript编写事件处理逻辑

以下是一个简单的投影示例，用于计算订单总数：

fromAll() .when({ $init: function() { return { count: 0 }; }, OrderCreatedEvent: function(s, e) { s.count++; } })

探索KurrentDB流浏览器

KurrentDB提供了直观的流浏览器界面，可帮助开发者查看和管理事件流。

KurrentDB流浏览器展示了系统中的事件流列表，可用于查看和分析事件数据

通过流浏览器，你可以：

查看所有事件流
检查特定流的事件历史
添加新事件到流中
管理流的访问控制列表

部署与扩展

生产环境配置

在生产环境中，建议部署KurrentDB集群以确保高可用性。可使用Docker Compose快速部署三节点集群：

# docker-compose.yaml version: '3.8' services: node1: image: docker.kurrent.io/kurrent-latest/kurrentdb:latest environment: - EVENTSTORE_CLUSTER_SIZE=3 - EVENTSTORE_NODE_IP=node1 - EVENTSTORE_GOSSIP_SEED=node1:2113,node2:2113,node3:2113 ports: - "2111:2113" volumes: - node1-data:/var/lib/eventstore # node2和node3配置... volumes: node1-data: # 其他节点卷...