AbpVnext 分布式事件总线

AbpVnext 本地事件总线

补充知识

发布订阅

概念

应用场景

本地事件总线允许服务发布和订阅进程内事件，这意味着如果两个服务>(发布者和订阅者)在同一个进程中运行，那么它是合适的

完整示例
DDD开发规范: 先定义好接口层、后实现层、暴露接口

对于要更新的实体

1. //领域层的实体
2. public class Book : FullAuditedEntity<Guid>, IHasExtraProperties, IMultiTenant
3. {
4.    public string Name{get;set;}
6.    public string Author {get;set;}
8.    public long Price {get;set}
9.    
10.    public string Title {get;set;}
12.    public string Classify{get;set;}
14.    //条形码
15.    public string BarCode {get;set;}
16.    // 出版商
17.    public string Issue{get;set;}
18.    // 页数
19.    public string PageTotal{get;set;}
20.   
21.    public string BuyerId{get;set;}
23.    public DateTime? ModifyTime{get;set}
24. }

复制代码

1. //这个实体是必须有的
2. public class BookRecordEto{
4.     public string Name{get;set;}
6.     public string Author {get;set;}
8.     public long Price {get;set}
10.     public DateTime? ModifyTime{get;set}
11. }

复制代码

1. //发布事件
2. public class BookService: ITransientDependency
3. {
4.     //Abp使用了字典来保存对实例的引用
5.     public IAbpLazyServiceProvider LazyServiceProvider { get; set; }
7.     //按需注入
8.     protected ILocalEventBus  LocalEventBus => LazyServiceProvider.LazyGetRequiredService<ILocalEventBus >();
10.     //仓储--对应Book的数据库表
11.     protected IBookRepository BookRepository => LazyGetRequiredService<IBookRepository>();
13.     public async Task UpdateData(Guid id)
14.     {
15.         var book =  await BookRepository.FindAsync(x=>x.Id = id);
16.         if (book == null){//不存在实体}
17.         var updateEntity = await BookRepository.UpdateAsync(book);
18.         if (updateEntity == null){//更新失败}
19.         
20.         //实体数据发生变更，发布事件
21.         await LocalEventBus.PublishAsync(new BookEto(){
22.             Name = book.Name;
23.             Author = book.Author;
24.             Price = book.Price;
25.             ModifyTime = DateTime.Now;
26.         });
27.     }
28. }

复制代码

1. //订阅事件
2. using Volo.Abp.DependencyInjection;
3. using Volo.Abp.EventBus;
4. public class EventBusHandler: ApplicationService,
5.       , ILocalEventHandler<BookRecordEto>
6.       , ITransientDependency
7. {
8.     // 进行业务数据更新，比如要更新购买这边书读者记录
9.     public IAbpLazyServiceProvider LazyServiceProvider{get;set;}
11.     protected IBookBoughtRecordRepository BoughtRecordRepository => LazyServiceProvider.LazyGetRequiredService<IBookBoughtRecordRepository>();
13.     [UnitOfWork]//这个特性以及方法头里面的virtual很重要
14.     public async virtual Task HandleEventAsync(BookRecordEto eventData)
15.     {
16.         //获取购买记录
17.         var record =  await  BoughtRecordRepository.GetQueryableAsync();
19.         var recordList = await AsyncExecuter.ToListAsync(record);
20.         
21.         if(recordList.Count() != 0){
23.             var boughtRecord  = ObjectMapper.Map(eventData, new BoughtRecord());
24.             //插入一条数据
25.             await BoughtRecordRepository.InsertAsync(boughtRecord);
26.         }
27.     }
28. }

复制代码

总结

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！