ENode框架初始化

ENode框架初始化

前言

Conference案例是使用ENode框架来开发的。之前我没有介绍过ENode框架是如何启动的，以及启动时要注意的一些点，估计很多人对ENode框架的初始化这一块感觉很复杂，一头雾水。所以，本文想简单介绍一下在做一个实际项目时，我们该如何初始化ENode。

使用ENode开发的项目的顶层宿主工程一般有两类：1）前台Web项目，它的职责就是发送命令；2）后台ProcessorHost项目，负责处理命令或事件；

这两类项目的初始化方式完全一样，只是Web项目可能需要多初始化Controller的容器管理。下面我们看看使用ENode框架时的主要初始化逻辑：

private static void InitializeECommon()
{
    _ecommonConfiguration = ECommonConfiguration
        .Create()
        .UseAutofac()
        .RegisterCommonComponents()
        .UseLog4Net()
        .UseJsonNet()
        .RegisterUnhandledExceptionHandler();
    _logger = ObjectContainer.Resolve<ILoggerFactory>().Create(typeof(Bootstrap).FullName);
    _logger.Info("ECommon initialized.");
}
private static void InitializeENode()
{
    ConfigSettings.Initialize();

    var assemblies = new[]
    {
        Assembly.Load("Conference.Common"),
        Assembly.Load("Registration.Domain"),
        Assembly.Load("Registration.CommandHandlers"),
        Assembly.Load("Registration.ProcessManagers"),
        Assembly.Load("Registration.ReadModel"),
        Assembly.Load("Registration.ProcessorHost")
    };
    var setting = new ConfigurationSetting
    {
        SqlServerDefaultConnectionString = ConfigSettings.ConferenceENodeConnectionString
    };

    _enodeConfiguration = _ecommonConfiguration
        .CreateENode(setting)
        .RegisterENodeComponents()
        .RegisterBusinessComponents(assemblies)
        .RegisterAllTypeCodes()
        .UseSqlServerLockService()
        .UseSqlServerCommandStore()
        .UseSqlServerEventStore()
        .UseSqlServerSequenceMessagePublishedVersionStore()
        .UseSqlServerMessageHandleRecordStore()
        .UseEQueue()
        .InitializeBusinessAssemblies(assemblies);
    _logger.Info("ENode initialized.");
}

从上面的代码可以看到，ENode框架的初始化是采用FluentAPI的方式，通过使用富有语义的方法来表达当前在做什么配置。

ECommon初始化

配置ENode一般是分为两个阶段，先配置ECommon。ECommon的初始化逻辑比较简单，Create方法创建一个ECommonConfiguration类的实例，然后通过调用UseAutofac方法，告诉框架当前使用的是Autofac容器。 然后RegisterCommonComponents就是把一些默认的组件注入到容器中；然后UseLog4Net和UseJsonNet这两个方法就是告诉框架当前使用的日志组件是Log4Net，JSON序列化组件是JSON.NET。最后，RegisterUnhandledExceptionHandler方法就是告诉框架要捕获未处理的异常，这样框架在发现有未处理的异常时，会尝试记录错误日志。上面的一个配置的两点是，ENode并没有和特定的容器绑定，目前仅实现了Autofac，大家可以根据自己的喜好使用其他的IoC容器，比如Untity, Castle, StructureMap等。

ENode初始化

ECommon初始化完成后，开始初始化ENode框架了。ENode的初始化稍微复杂一点，但因为也是通过富有语义的FluentAPI来实现初始化，所以看起来也比较容易理解。

基本配置

我们先创建ENodeConfiguration的全局实例，然后同样注册ENode的所有默认实现组件以及给定程序集中的所有标记了Component特性的组件到容器。

类型和Code的映射配置

然后接下来就是通过RegisterAllTypeCodes方法告诉框架所有可能涉及到序列化的类的Code。为什么要做这个配置？因为假如一个Command要发送到消息队列，在Command发送时，会用JSON序列化；在Command消费者消费时会用JSON反序列化。如果我们不设计这种Code机制，那序列化的JSON字符串里需要包含类型的名称。而我们的类名可能会调整的。所以为了更好的灵活性，我为ENode框架所有可能需要序列化的地方，都通过这种Code的思想，把类型转换为Code；反序列化时，根据Code找到对应的类型，然后进行反序列化；该方法的内部实现大概如下面这样：

public static ENodeConfiguration RegisterAllTypeCodes(this ENodeConfiguration enodeConfiguration)
{
    var provider = ObjectContainer.Resolve<ITypeCodeProvider>() as DefaultTypeCodeProvider;

    //aggregates
    provider.RegisterType<Order>(120);
    provider.RegisterType<OrderSeatAssignments>(121);

    //commands
    provider.RegisterType<MakeSeatReservation>(207);
    provider.RegisterType<CommitSeatReservation>(208);
    provider.RegisterType<CancelSeatReservation>(209);

持久化相关实现类的配置

由于真实的项目，我们肯定需要做各种持久化，比如事件的持久化，事件处理记录的持久化等。所以通过上面代码中的各种UseSql打头的方法，就可以配置各种场景的持久化实现。然后这些Sql的实现类所使用的数据库连接，上面的例子都是使用默认的数据库连接，见上面SqlServerDefaultConnectionString属性的赋值。如果你只是想运行一下基于内存的模型，那这些UseSql的方法是不需要调用的。比如像ENode框架里自带的一些例子的配置都很简单，以NoteSample为例：

static void InitializeENodeFramework()
{
    var assemblies = new[]
    {
        Assembly.Load("NoteSample.Domain"),
        Assembly.Load("NoteSample.Commands"),
        Assembly.Load("NoteSample.CommandHandlers"),
        Assembly.GetExecutingAssembly()
    };
    _configuration = Configuration
        .Create()
        .UseAutofac()
        .RegisterCommonComponents()
        .UseLog4Net()
        .UseJsonNet()
        .RegisterUnhandledExceptionHandler()
        .CreateENode()
        .RegisterENodeComponents()
        .RegisterBusinessComponents(assemblies)
        .RegisterAllTypeCodes()
        .UseEQueue()
        .InitializeBusinessAssemblies(assemblies)
        .StartEQueue();

    Console.WriteLine(string.Empty);

    _logger = ObjectContainer.Resolve<ILoggerFactory>().Create(typeof(Program).Name);
    _logger.Info("ENode started...");
}

EQueue相关配置

因为ENode需要使用EQueue这个分布式消息队列来实现命令或事件的发布和订阅。所以，我们也需要配置EQueue。通过调用UseEQueue实现，该方法的内部实现需要根据当前服务器所需要使用的功能而定。

类似于像下面这样：

public static ENodeConfiguration UseEQueue(this ENodeConfiguration enodeConfiguration)
{
    var configuration = enodeConfiguration.GetCommonConfiguration();

    configuration.RegisterEQueueComponents();

    var producerEndpoint = new IPEndPoint(SocketUtils.GetLocalIPV4(), ConfigSettings.BrokerProducerPort);
    var consumerEndpoint = new IPEndPoint(SocketUtils.GetLocalIPV4(), ConfigSettings.BrokerConsumerPort);
    var producerSetting = new ProducerSetting { BrokerProducerIPEndPoint = producerEndpoint };
    var consumerSetting = new ConsumerSetting { BrokerConsumerIPEndPoint = consumerEndpoint };

    _applicationMessagePublisher = new ApplicationMessagePublisher("PaymentsApplicationMessagePublisher", producerSetting);
    _domainEventPublisher = new DomainEventPublisher("PaymentsDomainEventPublisher", producerSetting);

    configuration.SetDefault<IMessagePublisher<IApplicationMessage>, ApplicationMessagePublisher>(_applicationMessagePublisher);
    configuration.SetDefault<IMessagePublisher<DomainEventStreamMessage>, DomainEventPublisher>(_domainEventPublisher);

    _commandConsumer = new CommandConsumer(
        "PaymentCommandConsumer",
        "PaymentCommandConsumerGroup",
        consumerSetting)
    .Subscribe(Topics.PaymentCommandTopic);

    _eventConsumer = new DomainEventConsumer(
        "PaymentEventConsumer",
        "PaymentEventConsumerGroup",
        consumerSetting)
    .Subscribe(Topics.PaymentDomainEventTopic);

    return enodeConfiguration;
}

使用ENode框架开发的应用，可能会用到如下的角色：

  1. 发送命令，使用CommandService；
  2. 发送领域事件，使用DomainEventPublisher；
  3. 发送应用层消息，使用ApplicationMessagePublisher；
  4. 发送异常，使用PublishableExceptionPublisher；
  5. 消费命令，使用CommandConsumer；
  6. 消费领域事件，DomainEventConsumer；
  7. 消费应用层消息，使用ApplicationMessageConsumer；
  8. 消费异常，使用PublishableExceptionConsumer；

从上面的8个角色中，我们可以知道，主要分为两类：1）消息生产者；2）消息消费者；前面4个是消息生产者；后面4个属于消息消费者；然后生产者内部就是封装了EQueue的Producer；消费者内部就是封装了EQueue的Consumer；是不是很对称，呵呵。

然后一般一个Web工程，它只需要发送命令即可，所以一般只需要初始化CommandService即可；而一般一个ProcessorHost工程，因为可能要处理命令、事件、应用层消息，以及异常消息。且因为可能有Saga流程的存在，所以它们可能需要配置所有上面8个角色。具体需要配置哪些角色，还是要看具体的应用而定。

当我们实例化好了需要的角色后，我们就可以启动或者关闭它们了。代码类似如下：

public static ENodeConfiguration StartEQueue(this ENodeConfiguration enodeConfiguration)
{
    _applicationMessageConsumer.Start();
    _eventConsumer.Start();
    _commandConsumer.Start();
    _domainEventPublisher.Start();
    _commandService.Start();

    return enodeConfiguration;
}
public static ENodeConfiguration ShutdownEQueue(this ENodeConfiguration enodeConfiguration)
{
    _commandService.Shutdown();
    _domainEventPublisher.Shutdown();
    _commandConsumer.Shutdown();
    _eventConsumer.Shutdown();
    _applicationMessageConsumer.Shutdown();
    return enodeConfiguration;
}

关于Controller所依赖的服务如何注入

上面介绍了ENode框架的主要配置如何使用，但还有一种场景没有介绍。就是ASP.NET MVC Web项目，Controller往往也是需要让容器来管理实例的。那这个如何配置呢？其实也很简单。我们只需要在ENode框架配置完成后，在通过如下的代码就可以实现Controller的生命周期的管理了。

private void RegisterControllers()
{
    var webAssembly = Assembly.GetExecutingAssembly();
    var container = (ObjectContainer.Current as AutofacObjectContainer).Container;
    var builder = new ContainerBuilder();
    builder.RegisterControllers(webAssembly);
    builder.Update(container);
    DependencyResolver.SetResolver(new AutofacDependencyResolver(container));
}

上面的代码中，关注点是：AutofacDependencyResolver这个类，这个类是Autofac.Integration.Mvc这个组件提供的。这个组件是Autofac和MVC集成的一个组件。通过它，我们可以方便的实现对Controller的依赖注入。

结束语

好了，基本介绍了一下ENode框架的配置部分如何使用。是不是很复杂？呵呵，其实只要我写的这些例子你看多了，也是很简单的，大家做项目时参考我的案例中的写法即可。

分类: DDD 案例分析

时间： 2024-10-24 01:21:27

ENode框架初始化的相关文章

ENode框架Conference案例分析系列之 - ENode框架初始化

前言 Conference案例是使用ENode框架来开发的.之前我没有介绍过ENode框架是如何启动的,以及启动时要注意的一些点,估计很多人对ENode框架的初始化这一块感觉很复杂,一头雾水.所以,本文想简单介绍一下在做一个实际项目时,我们该如何初始化ENode. 使用ENode开发的项目的顶层宿主工程一般有两类:1)前台Web项目,它的职责就是发送命令:2)后台ProcessorHost项目,负责处理命令或事件: 这两类项目的初始化方式完全一样,只是Web项目可能需要多初始化Controlle

ENode框架Conference案例分析系列之 - 架构设计

Conference架构概述 先贴一下Conference案例的在线地址,UI因为完全拿了微软的实现,所以都是英文的,以后我有空再改为中文的. Conference后台会议管理:http://www.enode.me/conference Conference前台预定座位:http://www.enode.me/registration ENode论坛开源案例:http://www.enode.me/post ENode开源项目地址:https://github.com/tangxuehua/e

ENode框架Conference案例分析系列之 - 复杂情况的读库更新设计

问题背景 Conference案例,是一个关于在线创建会议(类似QCon这种全球开发者大会).在线管理会议位置信息.在线预订某个会议的位置的,这样一个系统.具体可以看微软的这个项目的主页:http://cqrsjourney.github.io. 然后我们设计了一个Conference聚合根,对应领域中的会议这个领域概念.Conference聚合根下面,有一些位置信息SeatType.一个会议聚合根下面可以添加不同类型的位置,每种类型的位置可以指定数量以及价格.所以,Conference是聚合根

ENode框架Conference案例分析系列之 - 订单处理减库存的设计

前言 前面的文章,我介绍了Conference案例的业务.上下文划分.领域模型.架构,以及代码整体流程.接下来想针对案例中一些重要的场景,分别做进一步的分析.本文想先介绍一下Conference案例的核心业务场景 - 订单处理减库存的设计. 下单以及订单处理流程描述 下单过程 预订者浏览某个已发布的会议: 进入会议的详情页面,该页面显示了所有可预订的座位分类信息: 预订者选择好要预订的座位分类,录入每个分类的预定数量: 预订者点击提交按钮,提交下单请求到Server端: Server端订单处理过

linux驱动摸索 --驱动框架初始化（结合韦东山视频教程）

一.驱动框架 初始化:insmod 加载 1.确定主设备号: 分为静态和动态分配,其中LED_GPIO_SIZE 表示支持的次设备号数目,一般默认为1. 相关实现代码如下: [cpp] view plain copy int result; dev_t dev; /*分配主设备号*/ if (scull_major)   /*静态分配一个主设备号*/ { dev = MKDEV(scull_major,0); result = register_chrdev_region(dev,LED_GPI

ENode框架Conference案例转载

ENode框架Conference案例分析系列之 - Quick Start 前言 前一篇文章介绍了Conference案例的架构设计,本篇文章开始介绍Conference案例的代码实现.由于代码比较多,一开始就全部介绍所有细节,估计很多人接受不了,也理解不了.所以,我先进行一次QuickStart的介绍,即选取某个简单典型的场景从前到后过一下每个环节.这样大家就能够快速对代码的重要关键环节有大概的理解.另外,我现在正在做ENode的官网,到时会像axon framework一样,介绍ENode

ENode框架Conference案例分析系列之 - 文章索引

ENode框架Conference案例分析系列之 - 业务简介 ENode框架Conference案例分析系列之 - 上下文划分和领域建模 ENode框架Conference案例分析系列之 - 架构设计 ENode框架Conference案例分析系列之 - Quick Start ENode框架Conference案例分析系列之 - 复杂情况的读库更新设计

ENode框架Conference案例分析系列之 - Quick Start

前言 前一篇文章介绍了Conference案例的架构设计,本篇文章开始介绍Conference案例的代码实现.由于代码比较多,一开始就全部介绍所有细节,估计很多人接受不了,也理解不了.所以,我先进行一次QuickStart的介绍,即选取某个简单典型的场景从前到后过一下每个环节.这样大家就能够快速对代码的重要关键环节有大概的理解.另外,我现在正在做ENode的官网,到时会像axon framework一样,介绍ENode框架本身.使用场景.性能数据.案例,以及论坛社区等功能: 本文打算选择Conf

基于vue项目的组件中导入mui框架初始化滑动等效果时需移除严格模式的问题

基于vue项目的组件中导入mui框架初始化滑动等效果时,控制台报错:Uncaught TypeError: 'caller', 'callee', and 'arguments' properties may not be accessed on strict mode functions or the arguments objects for calls to them 可使用 babel-plugin -transform-remove-strict-mode 移除严格模式 可先进行$ n