ViennaNET- နောက်ခံဖိုင်အတွက် စာကြည့်တိုက်များ။ အပိုင်း 2

Raiffeisenbank .NET developer အသိုင်းအဝိုင်းသည် ViennaNET ၏ အကြောင်းအရာများကို အကျဉ်းချုံး သုံးသပ်နေပါသည်။ ဒီကို ဘယ်လိုရောက်လာတာလဲ၊ ပထမပိုင်းကို သင်ဖတ်နိုင်ပါတယ်။.

ဤဆောင်းပါးတွင်၊ ကျွန်ုပ်တို့သည် ကျွန်ုပ်တို့၏ GitHub repository တွင်တွေ့ရှိနိုင်သည့် ဖြန့်ဝေထားသော ငွေပေးငွေယူများ၊ တန်းစီခြင်းများနှင့် ဒေတာဘေ့စ်များဖြင့် လုပ်ဆောင်ရန်အတွက် မစဉ်းစားရသေးသော စာကြည့်တိုက်များကို ဖြတ်သန်းသွားပါမည်။သတင်းရင်းမြစ်တွေက ဒီမှာ), ပြီးတော့ Nuget packages လေးပါ။.

ViennaNET.Sagas

ပရောဂျက်တစ်ခုသည် DDD နှင့် microservice ဗိသုကာသို့ပြောင်းသောအခါ၊ ကွဲပြားသောဝန်ဆောင်မှုများပေါ်တွင် လုပ်ငန်းဆိုင်ရာယုတ္တိကို ဖြန့်ဝေသောအခါ၊ ခွဲဝေပေးငွေယူယန္တရားတစ်ခုကို အကောင်အထည်ဖော်ရန် လိုအပ်ခြင်း၊ နယ်ပယ်များစွာသည် ဒိုမိန်းများစွာကို တစ်ချိန်တည်းတွင် သက်ရောက်မှုရှိတတ်သောကြောင့် ပြဿနာတစ်ခုဖြစ်ပေါ်လာပါသည်။ ဥပမာအားဖြင့်၊ "Microservices Patterns" စာအုပ်တွင် Chris Richardson ဖြစ်သည်။.

ကျွန်ုပ်တို့၏ပရောဂျက်များတွင်၊ ကျွန်ုပ်တို့သည် ရိုးရှင်းသော်လည်း အသုံးဝင်သော ယန္တရားတစ်ခု- ဇာတ်လမ်းတစ်ခု သို့မဟုတ် တီးမှုတ်မှုအခြေခံသည့် ဇာတ်လမ်းတစ်ခုဖြစ်သည်။ ၎င်း၏အနှစ်သာရမှာ အောက်ပါအတိုင်းဖြစ်သည်- မတူညီသောဝန်ဆောင်မှုများတွင် ဆက်တိုက်လုပ်ဆောင်ရန် လိုအပ်သည့် လုပ်ငန်းအခြေအနေတစ်ခုရှိပြီး၊ မည်သည့်အဆင့်တွင်မဆို ပြဿနာများပေါ်ပေါက်ပါက၊ ၎င်းတည်ရှိရာနေရာအားလုံးအတွက် rollback လုပ်ထုံးလုပ်နည်းကို ခေါ်ရန် လိုအပ်ပါသည်။ ပေးထားသည်။ ထို့ကြောင့်၊ အောင်မြင်မှုမခွဲခြားဘဲ ဇာတ်လမ်း၏အဆုံးတွင်၊ ကျွန်ုပ်တို့သည် ဒိုမိန်းအားလုံးတွင် တစ်သမတ်တည်းဒေတာကို လက်ခံရရှိပါသည်။

ကျွန်ုပ်တို့၏ အကောင်အထည်ဖော်မှုကို ၎င်း၏အခြေခံပုံစံဖြင့် ပြုလုပ်ထားဆဲဖြစ်ပြီး အခြားဝန်ဆောင်မှုများနှင့် အပြန်အလှန်တုံ့ပြန်သည့်နည်းလမ်းများကို အသုံးပြုခြင်းနှင့် မသက်ဆိုင်ပါ။ အသုံးပြုရန်မခက်ခဲပါ- T သည် saga အလုပ်လုပ်ရန်အတွက် လိုအပ်သော ကနဦးဒေတာအပြင် အလယ်အလတ်ရလဒ်အချို့ကို သိမ်းဆည်းထားနိုင်သည့် အခြေခံ စိတ္တဇအတန်း SagaBase<T> မှ ဆင်းသက်လာစေသည်။ လုပ်ဆောင်နေစဉ်အတွင်း ဆက်စပ်ဥပမာကို အဆင့်အားလုံးသို့ ဖြတ်သွားပါမည်။ Saga ကိုယ်တိုင်သည် နိုင်ငံမဲ့လူတန်းစားဖြစ်သောကြောင့် လိုအပ်သောမှီခိုမှုများရရှိရန် DI တွင် Singleton အဖြစ်ထားရှိနိုင်ပါသည်။

နမူနာကြော်ငြာ-

public class ExampleSaga : SagaBase<ExampleContext>
{
  public ExampleSaga()
  {
    Step("Step 1")
      .WithAction(c => ...)
      .WithCompensation(c => ...);
	
    AsyncStep("Step 2")
      .WithAction(async c => ...);
  }
}

နမူနာခေါ်ဆိုမှု-

var saga = new ExampleSaga();
var context = new ExampleContext();
await saga.Execute(context);

မတူညီသော အကောင်အထည်ဖော်မှုများ၏ နမူနာအပြည့်အစုံကို ကြည့်ရှုနိုင်ပါသည်။ ဒီမှာ အသင်းတော်၌၎င်း၊ စမ်းသပ်မှုများ.

ViennaNET.Orm.*

Nhibernate မှတဆင့် အမျိုးမျိုးသော ဒေတာဘေ့စ်များနှင့် လုပ်ဆောင်ရန်အတွက် စာကြည့်တိုက်များ အစုံ။ ကျွန်ုပ်တို့သည် Liquibase ကို အသုံးပြု၍ DB-First ချဉ်းကပ်မှုကို အသုံးပြုသည်၊ ထို့ကြောင့် အဆင်သင့်လုပ်ထားသော ဒေတာဘေ့စ်တွင် ဒေတာဖြင့် လုပ်ဆောင်နိုင်သော လုပ်ဆောင်ချက်သာ ရှိပါသည်။

ViennaNET.Orm.Seedwork и ViennaNET.Orm - အခြေခံ အင်တာဖေ့စ်များနှင့် ၎င်းတို့၏ အကောင်အထည်ဖော်မှုများ အသီးသီးပါရှိသော အဓိက စည်းဝေးပွဲများ။ သူတို့ရဲ့ အကြောင်းအရာတွေကို အသေးစိတ် လေ့လာကြည့်ရအောင်။

interface ကို IEntityFactoryService နှင့်၎င်း၏အကောင်အထည်ဖော်မှု EntityFactoryService အလုပ်ယူနစ်၊ သီးခြား entities များနှင့် အလုပ်လုပ်ရန်အတွက် repositories များအပြင် commands ၏ executors နှင့် direct SQL queries များကို ဤနေရာတွင် ဖန်တီးထားသောကြောင့် database နှင့်အလုပ်လုပ်ခြင်းအတွက် အဓိကအစအချက်ဖြစ်သည်။ တခါတရံတွင် Data များကိုသာဖတ်ရှုနိုင်စေရန်၊ ဥပမာအားဖြင့် database တစ်ခုနှင့်အလုပ်လုပ်ရန်အတွက် class တစ်ခု၏စွမ်းရည်များကိုကန့်သတ်ရန်အဆင်ပြေသည်။ ဒီလိုကိစ္စတွေအတွက် IEntityFactoryService ဘိုးဘေး - interface တစ်ခုရှိသည်။ IEntityRepositoryFactoryrepositories ဖန်တီးခြင်းအတွက် နည်းလမ်းတစ်ခုသာ ကြေငြာသည်။

ဒေတာဘေ့စ်ကို တိုက်ရိုက်ဝင်ရောက်ရန်၊ ဝန်ဆောင်မှုပေးသည့် ယန္တရားကို အသုံးပြုသည်။ ကျွန်ုပ်တို့၏အဖွဲ့များတွင်အသုံးပြုသည့် DBMS တစ်ခုစီတွင် ၎င်း၏ကိုယ်ပိုင်အကောင်အထည်ဖော်မှုရှိသည်။ ViennaNET.Orm.MSSQL, ViennaNET.Orm.Oracle, ViennaNET.Orm.SQLite, ViennaNET.Orm.PostgreSql.

တစ်ချိန်တည်းမှာပင်၊ ဝန်ဆောင်မှုပေးသူအများအပြားသည် အပလီကေးရှင်းတစ်ခုတွင် တစ်ချိန်တည်းတွင် စာရင်းသွင်းနိုင်ပြီး၊ ဥပမာအားဖြင့်၊ အခြေခံအဆောက်အအုံကို ပြုပြင်မွမ်းမံခြင်းအတွက် ကုန်ကျစရိတ်မရှိဘဲ၊ ဝန်ဆောင်မှုတစ်ခု၏ မူဘောင်အတွင်းမှ တစ်ဆင့်ပြီးတစ်ဆင့် ရွှေ့ပြောင်းခြင်းကို လုပ်ဆောင်နိုင်စေပါသည်။ DBMS တစ်ခုမှ နောက်တစ်ခု။ လိုအပ်သောချိတ်ဆက်မှုကိုရွေးချယ်ခြင်းအတွက်ယန္တရားနှင့်၊ ထို့ကြောင့်၊ သီးခြားentity အတန်းအတွက်ပံ့ပိုးပေးသူ (ဒေတာဘေ့စ်ဇယားများသို့မြေပုံဆွဲခြင်းအတွက်ရေးသားထားသည်) သည် BoundedContext အတန်းတွင်entity ကိုစာရင်းသွင်းခြင်း (ဒိုမိန်းအရာများကိုမှတ်ပုံတင်ရန်နည်းလမ်းတစ်ခုပါရှိသည်) သို့မဟုတ်၎င်း၏ဆက်ခံသူ ApplicationContext (အပလီကေးရှင်းအဖွဲ့အစည်းများ၊ တိုက်ရိုက်တောင်းဆိုမှုများနှင့် အမိန့်များ မှတ်ပုံတင်ခြင်းအတွက် နည်းလမ်းများ ပါ၀င်သည်)၊ ဖွဲ့စည်းမှုပုံစံမှ ချိတ်ဆက်မှုအမှတ်အသားကို အကြောင်းပြချက်တစ်ခုအဖြစ် လက်ခံသည်-

"db": [
  {
    "nick": "mssql_connection",
    "dbServerType": "MSSQL",
    "ConnectionString": "...",
    "useCallContext": true
  },
  {
    "nick": "oracle_connection",
    "dbServerType": "Oracle",
    "ConnectionString": "..."
  }
],

ဥပမာ ApplicationContext-

internal sealed class DbContext : ApplicationContext
{
  public DbContext()
  {
    AddEntity<SomeEntity>("mssql_connection");
    AddEntity<MigratedSomeEntity>("oracle_connection");
    AddEntity<AnotherEntity>("oracle_connection");
  }
}

ချိတ်ဆက်မှု ID ကို မသတ်မှတ်ထားပါက "default" ဟု အမည်ပေးထားသည့် ချိတ်ဆက်မှုကို အသုံးပြုပါမည်။

ဒေတာဘေ့စ်ဇယားများထံ တိုက်ရိုက်မြေပုံဆွဲခြင်းကို စံ NHibernate ကိရိယာများကို အသုံးပြု၍ အကောင်အထည်ဖော်သည်။ ဖော်ပြချက်ကို xml ဖိုင်များမှတစ်ဆင့်လည်းကောင်း၊ အတန်းများမှတစ်ဆင့်လည်းကောင်း သင်အသုံးပြုနိုင်ပါသည်။ Unit tests တွင် stub repositories ကို အဆင်ပြေပြေ ရေးသားနိုင်စေရန်အတွက် Library တစ်ခု ရှိပါသည်။ ViennaNET.TestUtils.Orm.

ViennaNET.Orm.* အသုံးပြုခြင်း၏ နမူနာအပြည့်အစုံကို တွေ့နိုင်ပါသည်။ ဒီမှာ.

ViennaNET.စာတိုပေးပို့ခြင်း။*

တန်းစီခြင်းများဖြင့် လုပ်ဆောင်နိုင်သော စာကြည့်တိုက်များ။

တန်းစီခြင်းများဖြင့်လုပ်ဆောင်ရန်၊ တန်းစီမန်နေဂျာကိုအသုံးပြုသည်ဖြစ်စေ၊ တန်းစီမန်နေဂျာကိုအသုံးပြုသည်ဖြစ်စေ စာကြည့်တိုက်နှင့်လုပ်ဆောင်ရာတွင် အများဆုံးဖြစ်နိုင်ချေရှိသော ပေါင်းစပ်ချဉ်းကပ်နည်းကို DBMS အမျိုးမျိုးဖြင့် တူညီသောချဉ်းကပ်နည်းကို ရွေးချယ်ခဲ့သည်။ စာကြည့်တိုက် ViennaNET.Messaging ဤစည်းလုံးညီညွတ်မှုအတွက် အတိအကျ တာဝန်ရှိပါသည်။ ViennaNET.Messaging.MQSeriesQueue, ViennaNET.Messaging.RabbitMQQueue и ViennaNET.Messaging.KafkaQueue IBM MQ၊ RabbitMQ နှင့် Kafka အတွက် adapter အကောင်အထည်ဖော်မှုများ အသီးသီး ပါဝင်ပါသည်။

တန်းစီခြင်းများဖြင့် လုပ်ဆောင်သည့်အခါ၊ မက်ဆေ့ချ်လက်ခံခြင်းနှင့် ပေးပို့ခြင်း လုပ်ငန်းစဉ် နှစ်ခုရှိသည်။

လက်ခံစဉ်းစားပါ။ ဤနေရာတွင် ရွေးချယ်စရာ 2 ခု ရှိသည်- စဉ်ဆက်မပြတ် နားထောင်ခြင်းအတွက် နှင့် မက်ဆေ့ချ်တစ်ခုတည်း လက်ခံခြင်းအတွက်။ တန်းစီခြင်းကို အဆက်မပြတ်နားထောင်ရန်၊ အမွေဆက်ခံသည့် ပရိုဆက်ဆာအတန်းကို ဦးစွာဖော်ပြရပါမည်။ IMessageProcessorဝင်လာသော မက်ဆေ့ဂျ်ကို စီမံဆောင်ရွက်ပေးရန် တာဝန်ရှိသည်။ ထို့နောက်၊ ၎င်းအား သတ်မှတ်ထားသော တန်းစီတစ်ခုသို့ "လင့်ခ်ချိတ်" ရမည်၊ ၎င်းကို မှတ်ပုံတင်ခြင်းဖြင့် လုပ်ဆောင်သည်။ IQueueReactorFactory စီစဉ်သတ်မှတ်မှုမှ တန်းစီအမှတ်အသားကို ညွှန်ပြသည်-

"messaging": {
    "ApplicationName": "MyApplication"
},
"rabbitmq": {
    "queues": [
      {
        "id": "myQueue",
        "queuename": "lalala",
        ...
      }
    ]
},

စတင်နားထောင်ခြင်း ဥပမာ-

_queueReactorFactory.Register<MyMessageProcessor>("myQueue");
var queueReactor = queueReactorFactory.CreateQueueReactor("myQueue");
queueReactor.StartProcessing();

ထို့နောက်၊ ဝန်ဆောင်မှုစတင်သည်နှင့် စတင်နားထောင်ရန် နည်းလမ်းကို ခေါ်သောအခါ၊ သတ်မှတ်ထားသော တန်းစီမှ မက်ဆေ့ချ်များအားလုံး သက်ဆိုင်ရာ ပရိုဆက်ဆာထံသို့ ရောက်သွားပါမည်။

စက်ရုံသုံးအင်တာဖေ့စ်တွင် မက်ဆေ့ချ်တစ်ခုတည်းကို လက်ခံရယူရန် IMessagingComponentFactory နည်းလမ်းတစ်ခုရှိပါတယ်။ CreateMessageReceiver၎င်းထံသို့ သတ်မှတ်ထားသော တန်းစီမှ မက်ဆေ့ချ်ကို စောင့်ဆိုင်းနေသည့် လက်ခံသူအား ဖန်တီးပေးမည်-

using (var receiver = _messagingComponentFactory.CreateMessageReceiver<TestMessage>("myQueue"))
{
    var message = receiver.Receive();
}

မက်ဆေ့ပို့ရန် အတူတူသုံးဖို့လိုတယ်။ IMessagingComponentFactory မက်ဆေ့ချ်ပို့သူ ဖန်တီးပါ။

using (var sender = _messagingComponentFactory.CreateMessageSender<MyMessage>("myQueue"))
{
    sender.SendMessage(new MyMessage { Value = ...});
}

မက်ဆေ့ချ်ကို စီစဥ်ပြီး ခွဲခြားသတ်မှတ်ခြင်းအတွက် အဆင်သင့်လုပ်ထားသည့် ရွေးချယ်စရာသုံးခုရှိသည်- စာသား၊ XML နှင့် JSON မျှသာဖြစ်သော်လည်း လိုအပ်ပါက၊ သင်သည် သင်၏ကိုယ်ပိုင်အင်တာဖေ့စ်အကောင်အထည်ဖော်မှုများကို အလွယ်တကူပြုလုပ်နိုင်သည်။ IMessageSerializer и IMessageDeserializer.

တန်းစီမန်နေဂျာတစ်ခုစီ၏ ထူးခြားသောစွမ်းရည်များကို ထိန်းသိမ်းထားရန် ကျွန်ုပ်တို့ကြိုးစားခဲ့ပြီး၊ ဥပမာ၊ ViennaNET.Messaging.MQSeriesQueue စာသားသာမက byte မက်ဆေ့ခ်ျများကိုပါ ပေးပို့နိုင်စေပါသည်။ ViennaNET.Messaging.RabbitMQQueue လမ်းကြောင်းလမ်းကြောင်းနှင့် ပျံသန်းမှု တန်းစီခြင်းကို ပံ့ပိုးပေးသည်။ RabbitMQ အတွက် ကျွန်ုပ်တို့၏ adapter wrapper သည် RPC ၏ ပုံသဏ္ဍာန်အချို့ကိုလည်း လုပ်ဆောင်သည်- ကျွန်ုပ်တို့သည် မက်ဆေ့ချ်ပို့ပြီး တုံ့ပြန်မှုမက်ဆေ့ချ်တစ်ခုအတွက်သာ ဖန်တီးထားသည့် အထူး ယာယီတန်းစီမှ တုံ့ပြန်မှုကို စောင့်မျှော်နေပါသည်။

ဒီမှာ အခြေခံချိတ်ဆက်မှု ကွဲပြားမှုများနှင့်အတူ တန်းစီခြင်းကို အသုံးပြုခြင်း ဥပမာ.

ViennaNET.CallContext

ကျွန်ုပ်တို့သည် မတူညီသောစနစ်များကြား ပေါင်းစည်းရန်အတွက်သာမက တူညီသောအပလီကေးရှင်းတစ်ခု၏ microservices များအကြား ဆက်သွယ်မှုအတွက်လည်း တန်းစီခြင်းကို အသုံးပြုပါသည်။ ၎င်းသည် အသုံးပြုသူ၏ဝင်ရောက်မှုကဲ့သို့သော အရန်ဒေတာ၊ အဆုံးမှအဆုံးမှတ်တမ်းရယူခြင်းအတွက် တောင်းဆိုချက်အထောက်အထား၊ ရင်းမြစ် IP လိပ်စာနှင့် ခွင့်ပြုချက်ဒေတာတို့ကို မက်ဆေ့ဂျ်နှင့်အတူ ပေးပို့ရန် လိုအပ်လာသည်။ ဤဒေတာကို ထပ်ဆင့်ပေးပို့ခြင်းအား အကောင်အထည်ဖော်ရန်၊ ကျွန်ုပ်တို့သည် စာကြည့်တိုက်တစ်ခုကို တီထွင်ခဲ့သည်။ ViennaNET.CallContextဝန်ဆောင်မှုထဲသို့ ဝင်ရောက်သည့် တောင်းဆိုချက်မှ ဒေတာကို သိမ်းဆည်းနိုင်စေမည့်၊ ဤကိစ္စတွင်၊ တန်းစီခြင်း သို့မဟုတ် Http မှတစ်ဆင့် တောင်းဆိုမှုကို မည်သို့ပြုလုပ်ခဲ့သည်မှာ အရေးမကြီးပါ။ ထို့နောက် အထွက်တောင်းဆိုမှု သို့မဟုတ် မက်ဆေ့ချ်ကို မပို့မီ၊ အကြောင်းအရာမှ အချက်အလက်များကို ထုတ်ယူပြီး ခေါင်းစီးများတွင် ထည့်သွင်းပါ။ ထို့ကြောင့် နောက်ဝန်ဆောင်မှုသည် အရန်ဒေတာကို လက်ခံရရှိပြီး ထိုနည်းအတိုင်း စီမံခန့်ခွဲသည်။

သင့်အာရုံစိုက်မှုအတွက် ကျေးဇူးတင်ပါသည်၊ သင့်မှတ်ချက်များနှင့် တောင်းဆိုချက်များကို ဆွဲထုတ်ရန် ကျွန်ုပ်တို့ မျှော်လင့်ပါသည်။

source: www.habr.com