草庐IT

AbpVnext 事件总线

灵犀小蜗牛 2023-03-28 原文

AbpVnext 本地事件总线

补充知识

发布订阅

概念

应用场景

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

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

对于要更新的实体

//领域层的实体
public class Book : FullAuditedEntity<Guid>, IHasExtraProperties, IMultiTenant
{
   public string Name{get;set;}

   public string Author {get;set;}

   public long Price {get;set}
   
   public string Title {get;set;}

   public string Classify{get;set;}

   //条形码
   public string BarCode {get;set;}
   // 出版商
   public string Issue{get;set;}
   // 页数
   public string PageTotal{get;set;}
  
   public string BuyerId{get;set;}

   public DateTime? ModifyTime{get;set}
}

//这个实体是必须有的
public class BookRecordEto{

    public string Name{get;set;}

    public string Author {get;set;}

    public long Price {get;set}

    public DateTime? ModifyTime{get;set}
}

//发布事件
public class BookService: ITransientDependency
{
    //Abp使用了字典来保存对实例的引用
    public IAbpLazyServiceProvider LazyServiceProvider { get; set; }

    //按需注入
    protected ILocalEventBus  LocalEventBus => LazyServiceProvider.LazyGetRequiredService<ILocalEventBus >(); 

    //仓储--对应Book的数据库表
    protected IBookRepository BookRepository => LazyGetRequiredService<IBookRepository>();

    public async Task UpdateData(Guid id)
    {
        var book =  await BookRepository.FindAsync(x=>x.Id = id);
        if (book == null){//不存在实体}
        var updateEntity = await BookRepository.UpdateAsync(book);
        if (updateEntity == null){//更新失败}
        
        //实体数据发生变更，发布事件
        await LocalEventBus.PublishAsync(new BookEto(){
            Name = book.Name;
            Author = book.Author;
            Price = book.Price;
            ModifyTime = DateTime.Now;
        });
    } 
}

//订阅事件
using Volo.Abp.DependencyInjection;
using Volo.Abp.EventBus;
public class EventBusHandler: ApplicationService,
      , ILocalEventHandler<BookRecordEto> 
      , ITransientDependency
{
    // 进行业务数据更新，比如要更新购买这边书读者记录
    public IAbpLazyServiceProvider LazyServiceProvider{get;set;}
 
    protected IBookBoughtRecordRepository BoughtRecordRepository => LazyServiceProvider.LazyGetRequiredService<IBookBoughtRecordRepository>();

    [UnitOfWork]//这个特性以及方法头里面的virtual很重要
    public async virtual Task HandleEventAsync(BookRecordEto eventData)
    {
        //获取购买记录
        var record =  await  BoughtRecordRepository.GetQueryableAsync();

        var recordList = await AsyncExecuter.ToListAsync(record);
        
        if(recordList.Count() != 0){

            var boughtRecord  = ObjectMapper.Map(eventData, new BoughtRecord());
            //插入一条数据
            await BoughtRecordRepository.InsertAsync(boughtRecord);
        }
    }
}

总结

AbpVnext事件publicstringget.NET技术

有关AbpVnext 事件总线的更多相关文章

  1. ruby-on-rails - 事件管理员日期过滤器日期格式自定义 - 2

    是否有简单的方法来更改默认ISO格式(yyyy-mm-dd)的ActiveAdmin日期过滤器显示格式？ 最佳答案 您可以像这样为日期选择器提供额外的选项，而不是覆盖js:=f.input:my_date,as::datepicker,datepicker_options:{dateFormat:"mm/dd/yy"} 关于ruby-on-rails-事件管理员日期过滤器日期格式自定义，我们在StackOverflow上找到一个类似的问题： https://s

  2. ruby-on-rails - 事件记录 : Select max of limit - 2

    我正在尝试将以下SQL查询转换为ActiveRecord，它正在融化我的大脑。deletefromtablewhereid有什么想法吗？我想做的是限制表中的行数。所以，我想删除少于最近10个条目的所有内容。编辑:通过结合以下几个答案找到了解决方案。Temperature.where('id这给我留下了最新的10个条目。 最佳答案 从您的SQL来看，您似乎想要从表中删除前10条记录。我相信到目前为止的大多数答案都会如此。这里有两个额外的选择:基于MurifoX的版本:Table.where(:id=>Table.order(:id).

  3. ruby-on-rails - 事件管理员和自定义方法 - 2

    这是我在ActiveAdmin中的自定义页面ActiveAdmin.register_page"Settings"doaction_itemdolink_to('Importprojects','settings/importprojects')endcontentdopara"Text"endcontrollerdodefimportprojectssystem"rakedataspider:import_projects_ninja"para"OK"endendend我想做的是，当我单击“导入项目”按钮时，我想在Controller中执行rake任务。但是我无法访问该方法。可能是什

  4. ruby-on-rails - 在不重新查询数据库的情况下重新排序 Rails 中的事件记录？ - 2

    例如，假设我有一个名为Products的模型，并且在ProductsController中，我有以下代码用于product_listView以显示已排序的产品。@products=Product.order(params[:order_by])让我们想象一下，在product_listView中，用户可以使用下拉菜单按价格、评级、重量等进行排序。数据库中的产品不会经常更改。我很难理解的是，每次用户选择新的order_by过滤器时，rails是否必须查询，或者rails是否能够以某种方式缓存事件记录以在服务器端重新排序？有没有一种方法可以编写它，以便在用户排序时rails不会重新查询结果

  5. ruby-on-rails - Ruby 长时间运行的进程对队列事件使用react - 2

    我有一个将某些事件写入队列的Rails3应用。现在我想在服务器上创建一个服务，每x秒轮询一次队列，并按计划执行其他任务。除了创建ruby​​脚本并通过cron作业运行它之外，还有其他稳定的替代方案吗？ 最佳答案 尽管启动基于Rails的持久任务是一种选择，但您可能希望查看更有序的系统，例如delayed_job或Starling管理您的工作量。我建议不要在cron中运行某些东西，因为启动整个Rails堆栈的开销可能很大。每隔几秒运行一次它是不切实际的，因为Rails上的启动时间通常为5-15秒，具体取决于您的硬件。不过，每天这样做几

  6. ruby-on-rails - 使用 Rails 事件记录获取二级模型 - 2

    我有一个帖子属于城市的关系，城市又属于一个州，例如:classPost现在我想找到所有帖子及其所属的城市和州。我编写了以下查询来获取带有城市的帖子，但不知道如何在同一查找器中获取带有城市的相应州:@post=Post.find:all,:include=>[:city]感谢任何帮助。谢谢。 最佳答案 Post.all(:include=>{:city=>:state}) 关于ruby-on-rails-使用Rails事件记录获取二级模型，我们在StackOverflow上找到一个类似的问

  7. ruby - 在没有数据库的情况下伪造一个事件记录模型 - 2

    我觉得我错过了什么。我正在编写一个ruby​​gem，它允许与事件记录进行交互，作为其主要功能的附加功能。在为其编写测试用例时，我需要能够指定虚拟事件记录模型来测试此功能。如果我可以获得一个事件记录模型的实例，它不需要与数据库的任何连接，可以有关系，所有这些东西，但不需要我在数据库中设置表，那就太棒了。我对测试还很陌生，在Rails测试之外我也很陌生，但似乎我应该能够相当轻松地完成类似的事情，但我什么也没找到。谁能告诉我我错过了什么？我看过工厂、制造商、固定装置，所有这些似乎都想达到目标。人们如何在您只需要AR对象进行测试的地方测试gem？ 最佳答案

  8. ruby-on-rails - 在事件记录库中添加某些方法的首选方法是什么？ - 2

    我想创建一个模块，为从事件记录库继承的类提供一些通用方法。以下是我们可以实现的两种方式。1)moduleCommentabledefself.extended(base)base.class_evaldoincludeInstanceMethodsextendClassMethodsendendmoduleClassMethodsdeftest_commentable_classmethodputs'testclassmethod'endendmoduleInstanceMethodsdeftest_commentable_instance_methodputs'testinstanc

  9. sql - 如何查询具有 3 个标签的事件？ - 2

    我有以下模型:activity.rbtag.rbtagging.rb标签是事件和标签的连接模型。我想搜索具有2个或更多标签的事件。我如何在Rails中执行此操作？例如:我有tag1=Christmas，tag2=Florida，tag3=John如果存在，我想找到tag1、tag2和tag3存在的Activity。[编辑]我最终做了什么:tags=[tag1,tag2,tag3]activities=[]tags.eachdo|tag|activities如果任何组值的大小等于tags.size，则该事件包含所有标签。 最佳答案 如

  10. ruby-on-rails - 如何 stub 事件记录关系以使用 rspec 测试 where 子句？ - 2

    我有一个看起来像这样的类:classFoo在测试#nasty_bars_present？我想编写一个rspec测试来对bars关联进行stub，但允许where自然执行。像这样的东西:describe"#nasty_bars_present?"docontext"withnastybars"dobefore{foo.stub(:bars).and_return([mock(Bar,bar_type:"Nasty")])}it"shouldreturntrue"doexpect(foo.nasty_bars_present?).tobe_trueendendend上面的测试给出了一个关于

随机推荐