本期亮点

本期带来了很多开发者期待的功能。

亮点一：支持通配符、正则表达式事件消息

 // 支持正则表达式匹配 [EventSubscribe("(^1[3456789][0-9]{9}$)|((^[0-9]{3,4}\\-[0-9]{3,8}$)|(^[0-9]{3,8}$)|(^\\([0-9]{3,4}\\)[0-9]{3,8}$)|(^0{0,1}13[0-9]{9}$))")] public async Task RegexHandler(EventHandlerExecutingContext context) {     var eventId = context.Source.EventId;     await Task.CompletedTask; }

测试：

 await _eventPublisher.PublishAsync("13800138000"); await _eventPublisher.PublishAsync("13434563233");

亮点二：支持局部重试策略，全局自定义策略

 // 支持多种异常重试配置 [EventSubscribe("test:error", NumRetries = 3)] [EventSubscribe("test:error", NumRetries = 3, RetryTimeout = 1000)] // 重试间隔时间 [EventSubscribe("test:error", NumRetries = 3, ExceptionTypes = new[] { typeof(ArgumentException) })]    // 特定类型异常才重试 public async Task ExceptionHandler(EventHandlerExecutingContext context) {     var eventId = context.Source.EventId;     await Task.CompletedTask; }

 // 全局自定义策略 public class RetryEventHandlerExecutor : IEventHandlerExecutor {     public async Task ExecuteAsync(EventHandlerExecutingContext context, Func<EventHandlerExecutingContext, Task> handler)     {         // 如果执行失败，每隔 1s 重试，最多三次         await Retry(async () => {             await handler(context);         }, 3, 1000);     } }

亮点三：支持运行时订阅消息或删除消息

 public class TestEventBusController : Controller {     private readonly IEventPublisher _eventPublisher;     private readonly IEventBusFactory _eventBusFactory;     public TestEventBusController(IEventPublisher eventPublisher, IEventBusFactory eventBusFactory)     {         _eventPublisher = eventPublisher;         _eventBusFactory = eventBusFactory;     }      // 运行时动态添加一个订阅器     public async Task AddSubscriber()     {         await _eventBusFactory.AddSubscriber("xxx", async (c) =>         {             Console.WriteLine("我是动态的");             await Task.CompletedTask;         });     }      // 运行时动态删除一个订阅器     public async Task RemoveDynamic(string eventId)     {         await _eventBusFactory.RemoveSubscriber(eventId);     } }

 亮点四：支持多种丰富注册处理程序方式

 // 注册 EventBus 服务 services.AddEventBus(builder => {     // 注册 ToDo 事件订阅者     builder.AddSubscriber<ToDoEventSubscriber>();      // 通过类型注册     builder.AddSubscriber(typeof(ToDoEventSubscriber));      // 批量注册事件订阅者     builder.AddSubscribers(ass1, ass2, ....); });

---

Jaina

源码解析

特性

• 简化组件之间通信
  • 支持事件监视器
  • 支持动作执行器
  • 支持自定义消息存储组件
  • 支持自定义策略执行
  • 支持单消费、多消费消息
  • 支持消息幂等性处理
• 高内聚，低耦合，使代码更简单
• 非常快速，每秒可处理 30000 + 消息
• 很小，仅 10KB
• 无第三方依赖
• 可在 Windows/Linux/MacOS 守护进程部署
• 支持分布式、集群
• 高质量代码和良好单元测试

安装

• Package Manager

 Install-Package Jaina 

• .NET CLI

 dotnet add package Jaina 

快速入门

我们在主页上有不少例子，这是让您入门的第一个：

1. 定义事件订阅者 ToDoEventSubscriber：

 // 实现 IEventSubscriber 接口 public class ToDoEventSubscriber : IEventSubscriber {     private readonly ILogger<ToDoEventSubscriber> _logger;     public ToDoEventSubscriber(ILogger<ToDoEventSubscriber> logger)     {         _logger = logger;     }      [EventSubscribe("ToDo:Create")] // 支持多个     [EventSubscribe(YourEnum.Message)]   // 支持枚举     public async Task CreateToDo(EventHandlerExecutingContext context)     {         var todo = context.Source;         _logger.LogInformation("创建一个 ToDo：{Name}", todo.Payload);         await Task.CompletedTask;     }      // 支持枚举类型     [EventSubscribe(YourEnum.Some)]     public async Task EnumHandler(EventHandlerExecutingContext context)     {         var eventEnum = context.Source.EventId.ParseToEnum(); // 将事件 Id 转换成枚举对象         await Task.CompletedTask;     }      // 支持正则表达式匹配     [EventSubscribe("(^1[3456789][0-9]{9}$)|((^[0-9]{3,4}\\-[0-9]{3,8}$)|(^[0-9]{3,8}$)|(^\\([0-9]{3,4}\\)[0-9]{3,8}$)|(^0{0,1}13[0-9]{9}$))")]     public async Task RegexHandler(EventHandlerExecutingContext context)     {         var eventId = context.Source.EventId;         await Task.CompletedTask;     }      // 支持多种异常重试配置     [EventSubscribe("test:error", NumRetries = 3)]     [EventSubscribe("test:error", NumRetries = 3, RetryTimeout = 1000)] // 重试间隔时间     [EventSubscribe("test:error", NumRetries = 3, ExceptionTypes = new[] { typeof(ArgumentException) })]    // 特定类型异常才重试     public async Task ExceptionHandler(EventHandlerExecutingContext context)     {         var eventId = context.Source.EventId;         await Task.CompletedTask;     } } 

2. 创建控制器 ToDoController，依赖注入 IEventPublisher 服务：

 public class ToDoController : ControllerBase {     // 依赖注入事件发布者 IEventPublisher     private readonly IEventPublisher _eventPublisher;     public ToDoController(IEventPublisher eventPublisher)     {         _eventPublisher = eventPublisher;     }      // 发布 ToDo:Create 消息     public async Task CreateDoTo(string name)     {         await _eventPublisher.PublishAsync(new ChannelEventSource("ToDo:Create", name));         // 简化版本         await _eventPublisher.PublishAsync("ToDo:Create", name);     } } 

3. 在 Startup.cs 注册 EventBus 服务：

 await _eventPublisher.PublishAsync("13800138000"); await _eventPublisher.PublishAsync("13434563233");0

4. 运行项目：

 await _eventPublisher.PublishAsync("13800138000"); await _eventPublisher.PublishAsync("13434563233");1

更多文档

文档

您可以在主页找到 Jaina 文档。

贡献

该存储库的主要目的是继续发展 Jaina 核心，使其更快、更易于使用。Jaina 的开发在 Gitee 上公开进行，我们感谢社区贡献错误修复和改进。

许可证

Jaina 采用 MulanPSL-2.0 开源许可证。

 await _eventPublisher.PublishAsync("13800138000"); await _eventPublisher.PublishAsync("13434563233");2