Autofac, Rebus, AutoMapper

Autofac

• 객체의 생성과 수명 관리 및 의존성 주입을 자동으로 처리

• 컨트롤러, 서비스, 저장소 등에 필요한 의존 객체를 생성자나 속성, 메서드를 통해 주입

Autofac - Module

• ControllerModule : Controller

• DbContextModule : DB connect

• DbJobModule : Scheduling

• ServiceModule : Service

Module - *.Module.cs

• builder : Autofac에서 컨테이너 빌더(Container Builder)의 인스턴스, 의존성 등록 및 구성 작업을 담당

• RegisterType<ProcessBOMController>() : ProcessBOMController 클래스를 등록한다는 의미

• .PropertiesAutowired() : 속성 주입(Property Injection)을 활성화

캡슐화된 구성

.Module.Config.json

{
	"modules" : [{
		"type" : "MyNamespace.(...)Modulem, MyAssembly",
		"Properties" : {
			...
		}
	}]
}

builder.Host.ConfigureContainer<ContainerBuilder>(
    b =>
    {
        var configBuilder = new ConfigurationBuilder().AddJsonFile("autofac.json", true, true);
        var config = configBuilder.Build();
        b.RegisterModule(new ExtendConfigurationModule(config));

        var path = Path.Combine(Path.GetDirectoryName(Assembly.GetEntryAssembly()!.Location)!, "Configurations");
        if (!Directory.Exists(path))
        {
            Directory.CreateDirectory(path);
        }

        Directory.GetFiles(path).Where(f => new FileInfo(f).Extension.EndsWith("json")).ToList().ForEach(f =>
        {
            var subConfigBuilder = new ConfigurationBuilder().AddJsonFile(f, true, true);
            var subConfig = subConfigBuilder.Build();
            b.RegisterModule(new ExtendConfigurationModule(subConfig));

            builder.Configuration.AddJsonFile(f, true, true);

        });

        b.RegisterSource<ContravariantRegistrationSource>();
        b.RegisterType<BusinessObjectDocumentBuilder>().As<IBusinessObjectDocumentBuilder>().SingleInstance();
    }
);

Rebus

builder.RegisterRebus((configurer, context) =>
{
    var queueName = "mes-queue";
    var subscriberStore = new InMemorySubscriberStore(); // 구독정보를 메모리에 저장하는 클래스
    var inMemNetwork = new InMemNetwork(true); // 메모리 내에서만 메시지를 송수신 할 수 있도록 도와주는 가짜 네트워크

    configurer
        .Logging(l => l.ColoredConsole()) // color console log 출력
        .Transport(x => x.UseInMemoryTransport(new InMemNetwork(true), queueName, false)) // message broker connect 
        .Subscriptions(s => s.StoreInMemory(new InMemorySubscriberStore())) // Pub/Sub 구독자 정보 저장소 지정
        .Options(x =>
        {
            x.SetMaxParallelism(1);
        });

    return configurer;
});

// 모든 의존성 등록을 끝내고 빌드를 완료한 직후에 동작
builder.RegisterBuildCallback(c =>
{
    var bus = c.Resolve<IBus>();
    var assembly = typeof(ProcessCustomerPartyMaster).Assembly;

    foreach (var type in assembly.GetTypes())
    {
        if (type.IsAssignableTo(typeof(BusinessObjectDocumentBase)) && !type.IsAbstract)
        {
            bus.Subscribe(type).GetAwaiter().GetResult(); // 메시지 구독
        }
    }
});

builder.Register(c =>
{
    var context = c.Resolve<IComponentContext>();
    var config = context.Resolve<MapperConfiguration>();
    return config.CreateMapper(context.Resolve);
}).As<IMapper>().InstancePerLifetimeScope();

builder.RegisterType<MappingService>().As<IMappingService>().InstancePerLifetimeScope();
builder.RegisterType<ServiceBusClient>().As<IServiceBusClient>().InstancePerLifetimeScope();

Quartz

quartz.config

quartz.scheduler.instanceName = MyScheduler
quartz.jobStore.type = Quartz.Simpl.RAMJobStore, Quartz
quartz.threadPool.maxConcurrency = 3

• quartz.scheduler.instanceName : 스케줄러 이름

• quartz.jobStore.type : 작업 및 트리거의 세부 정보 등 Quartz의 모든 데이터는 메모리에 보관

• quartz.threadPool.maxConcurrency : 최대 3개의 작업을 동시에 실행 가능(기본은 10개)

Service Broker Setting

execsys.sp_cdc_enable_db 
	go

exec sys.sp_cdc_enable_table @source_schema = 'Purchase', @source_name = 'PurchaseOrder', @role_name = 'cdcrole', @supports_net_changes = 1
	go

• 프로그래밍 기능 - 함수 - 테이블 반환 함수
• cdc.fn_cdc_get_all_changes_Purchase_PurchaseOrder
• cdc.fn_cdc_get_net_changes_Purchase_PurchaseOrder

프로시저(dbo.CreateDocument, dbo.SendDocument) 생성

Automapper

1. MapperConfiguration
1. MapperConfiguration 객체를 생성하여 매핑 설정을 정의

2. CreateMap<A, B>
1. A 클래스에서 B 클래스로의 매핑을 정의

3. ForMember
1. 매핑 규칙을 세부적으로 정의
2. destination ⇒ destination.AId : A클래스의 AId속성에 대해 매핑을 설정
3. options ⇒ options.MapFrom(Source ⇒ source.b_id) : B 클래스의 b_id 속성을 A 클래스의 AId 속성으로 매핑

4. MapFrom
1. 매핑 소스 속성을 지정