Sparkdo.EventBus.StackExchangeRedis
1.0.3-preview.1
This is a prerelease version of Sparkdo.EventBus.StackExchangeRedis.
dotnet add package Sparkdo.EventBus.StackExchangeRedis --version 1.0.3-preview.1
NuGet\Install-Package Sparkdo.EventBus.StackExchangeRedis -Version 1.0.3-preview.1
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Sparkdo.EventBus.StackExchangeRedis" Version="1.0.3-preview.1" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
<PackageVersion Include="Sparkdo.EventBus.StackExchangeRedis" Version="1.0.3-preview.1" />
<PackageReference Include="Sparkdo.EventBus.StackExchangeRedis" />
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.
paket add Sparkdo.EventBus.StackExchangeRedis --version 1.0.3-preview.1
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: Sparkdo.EventBus.StackExchangeRedis, 1.0.3-preview.1"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
#:package Sparkdo.EventBus.StackExchangeRedis@1.0.3-preview.1
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.
#addin nuget:?package=Sparkdo.EventBus.StackExchangeRedis&version=1.0.3-preview.1&prerelease
#tool nuget:?package=Sparkdo.EventBus.StackExchangeRedis&version=1.0.3-preview.1&prerelease
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
Sparkdo.EventBus.StackExchangeRedis
基于 StackExchange.Redis 的分布式事件总线实现。
功能特性
- 支持通过 Redis 的 Pub/Sub 机制进行事件发布和订阅
- 支持事件的持久化和可靠投递
- 支持多租户环境
- 支持事件 Inbox/Outbox 模式
- 兼容 Sparkdo 框架的分布式事件总线接口
使用方法
1. 安装包
<PackageReference Include="Sparkdo.EventBus.StackExchangeRedis" Version="latest" />
2. 配置
在 appsettings.json 中配置事件总线选项：
{
"Sparkdo": {
"StackExchangeRedis": {
"EventBus": {
"ChannelPrefix": "eventbus",
}
}
}
}
3. 定义事件
[EventName("Order.Created")]
public class OrderCreatedEvent
{
public Guid OrderId { get; set; }
public string CustomerName { get; set; }
public decimal Amount { get; set; }
}
4. 发布事件
public class OrderService
{
private readonly IDistributedEventBus _eventBus;
public OrderService(IDistributedEventBus eventBus)
{
_eventBus = eventBus;
}
public async Task CreateOrderAsync(CreateOrderInput input)
{
// 创建订单逻辑...
// 发布事件
await _eventBus.PublishAsync(new OrderCreatedEvent
{
OrderId = order.Id,
CustomerName = input.CustomerName,
Amount = input.Amount
});
}
}
5. 订阅事件
public class OrderEventHandler : IDistributedEventHandler<OrderCreatedEvent>
{
public async Task HandleEventAsync(OrderCreatedEvent eventData)
{
// 处理订单创建事件
Console.WriteLine($"订单 {eventData.OrderId} 已创建，客户：{eventData.CustomerName}，金额：{eventData.Amount}");
// 执行业务逻辑...
await Task.CompletedTask;
}
}
配置选项
SparkdoStackExchangeRedisEventBusOptions
| 属性 | 类型 | 默认值 | 说明 |
|---|---|---|---|
| ChannelPrefix | string | "eventbus" | Redis 频道前缀 |
实现细节
- 使用 Redis 的 Pub/Sub 机制进行消息传递
- 事件序列化使用 JSON 格式
- 支持事件的可靠投递和重试机制
- 兼容 Sparkdo 框架的分布式事件总线标准接口
注意事项
- Redis Pub/Sub 是内存消息，服务重启时未消费的消息会丢失
- 建议结合 Inbox/Outbox 模式保证消息的可靠性
- 在高并发场景下需要考虑 Redis 的性能和连接数限制
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.
-
net10.0
- JetBrains.Annotations (>= 2025.2.4)
- Microsoft.Extensions.Configuration (>= 10.0.8)
- Microsoft.Extensions.Configuration.CommandLine (>= 10.0.8)
- Microsoft.Extensions.Configuration.EnvironmentVariables (>= 10.0.8)
- Microsoft.Extensions.Configuration.FileExtensions (>= 10.0.8)
- Microsoft.Extensions.Configuration.Json (>= 10.0.8)
- Microsoft.Extensions.Configuration.UserSecrets (>= 10.0.8)
- Microsoft.Extensions.DependencyInjection (>= 10.0.8)
- Microsoft.Extensions.DependencyInjection.Abstractions (>= 10.0.8)
- Microsoft.Extensions.DependencyModel (>= 10.0.8)
- Microsoft.Extensions.FileProviders.Composite (>= 10.0.8)
- Microsoft.Extensions.FileProviders.Embedded (>= 10.0.8)
- Microsoft.Extensions.FileProviders.Physical (>= 10.0.8)
- Microsoft.Extensions.Hosting.Abstractions (>= 10.0.8)
- Microsoft.Extensions.Localization (>= 10.0.8)
- Microsoft.Extensions.Logging (>= 10.0.8)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.8)
- Microsoft.Extensions.Options (>= 10.0.8)
- Microsoft.Extensions.Options.ConfigurationExtensions (>= 10.0.8)
- Microsoft.Extensions.Options.DataAnnotations (>= 10.0.8)
- Nito.AsyncEx.Context (>= 5.1.2)
- Sparkdo.EventBus (>= 1.0.3-preview.1)
- Sparkdo.Json (>= 1.0.3-preview.1)
- Sparkdo.StackExchangeRedis (>= 1.0.3-preview.1)
- StackExchange.Redis (>= 2.13.1)
- System.Linq.Dynamic.Core (>= 1.7.2)
- TimeZoneConverter (>= 7.2.0)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 1.0.3-preview.1 | 30 | 5/17/2026 |
| 1.0.2 | 102 | 4/27/2026 |
| 1.0.2-preview.5 | 58 | 4/15/2026 |
| 1.0.2-preview.4 | 75 | 2/8/2026 |
| 1.0.2-preview.3 | 65 | 2/1/2026 |
| 1.0.2-preview.2 | 65 | 1/31/2026 |
| 1.0.2-preview.1 | 171 | 12/4/2025 |
| 1.0.1 | 215 | 11/27/2025 |
| 1.0.0 | 210 | 11/25/2025 |
| 1.0.0-preview.5 | 133 | 10/24/2025 |