व्हिएन्नानेट: बॅकएंडसाठी लायब्ररींचा संच. भाग 2

Raiffeisenbank .NET विकसक समुदायाने ViennaNET च्या सामग्रीचे थोडक्यात पुनरावलोकन करणे सुरू ठेवले आहे. आम्ही हे कसे आणि का आलो याबद्दल, तुम्ही पहिला भाग वाचू शकता.

या लेखात, आम्ही वितरित व्यवहार, रांगा आणि डेटाबेससह कार्य करण्यासाठी अद्याप विचारात घेतलेल्या लायब्ररींमधून जाऊ, जे आमच्या GitHub रेपॉजिटरीमध्ये आढळू शकतात (स्रोत येथे आहेत), आणि येथे Nuget पॅकेजेस.

व्हिएन्नानेट.सागास

जेव्हा एखादा प्रकल्प DDD आणि मायक्रोसर्व्हिस आर्किटेक्चरवर स्विच करतो, तेव्हा जेव्हा व्यवसाय तर्कशास्त्र वेगवेगळ्या सेवांमध्ये वितरीत केले जाते, तेव्हा वितरित व्यवहार यंत्रणा कार्यान्वित करण्याच्या गरजेशी संबंधित समस्या उद्भवते, कारण बर्‍याच परिस्थिती एकाच वेळी अनेक डोमेनवर परिणाम करतात. आपण अशा यंत्रणांशी अधिक तपशीलवार परिचित होऊ शकता, उदाहरणार्थ, "मायक्रोसर्व्हिसेस पॅटर्न" या पुस्तकात, ख्रिस रिचर्डसन.

आमच्या प्रकल्पांमध्ये, आम्ही एक साधी पण उपयुक्त यंत्रणा कार्यान्वित केली आहे: गाथा, किंवा त्याऐवजी ऑर्केस्ट्रेशन-आधारित गाथा. त्याचे सार खालीलप्रमाणे आहे: एक विशिष्ट व्यवसाय परिस्थिती आहे ज्यामध्ये वेगवेगळ्या सेवांमध्ये अनुक्रमे ऑपरेशन्स करणे आवश्यक आहे आणि कोणत्याही टप्प्यावर कोणतीही समस्या उद्भवल्यास, मागील सर्व चरणांसाठी रोलबॅक प्रक्रिया कॉल करणे आवश्यक आहे, जिथे ते आहे. प्रदान केले. अशा प्रकारे, गाथेच्या शेवटी, यशाची पर्वा न करता, आम्हाला सर्व डोमेनमध्ये सातत्यपूर्ण डेटा प्राप्त होतो.

आमची अंमलबजावणी अद्याप त्याच्या मूळ स्वरूपात केली गेली आहे आणि इतर सेवांसह परस्परसंवादाच्या कोणत्याही पद्धती वापरण्याशी संबंधित नाही. हे वापरणे कठीण नाही: फक्त बेस अॅबस्ट्रॅक्ट क्लास SagaBase<T> चे वंशज बनवा, जिथे T हा तुमचा संदर्भ वर्ग आहे ज्यामध्ये तुम्ही गाथा कार्य करण्यासाठी आवश्यक प्रारंभिक डेटा तसेच काही इंटरमीडिएट परिणाम संचयित करू शकता. अंमलबजावणी दरम्यान संदर्भ उदाहरण सर्व चरणांमधून जाईल. सागा हा स्वतः एक स्टेटलेस क्लास आहे, त्यामुळे आवश्यक अवलंबित्व मिळविण्यासाठी उदाहरण DI मध्ये सिंगलटन म्हणून ठेवले जाऊ शकते.

उदाहरण जाहिरात:

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-प्रथम दृष्टीकोन वापरतो, त्यामुळे केवळ तयार डेटाबेसमध्ये डेटासह कार्य करण्याची कार्यक्षमता आहे.

ViennaNET.Orm.Seedwork и ViennaNET.Orm - अनुक्रमे मूलभूत इंटरफेस आणि त्यांची अंमलबजावणी असलेली मुख्य असेंब्ली. चला त्यांची सामग्री अधिक तपशीलवार पाहू या.

संवाद IEntityFactoryService आणि त्याची अंमलबजावणी EntityFactoryService डेटाबेससह कार्य करण्यासाठी मुख्य प्रारंभ बिंदू आहेत, कारण कार्य युनिट, विशिष्ट घटकांसह कार्य करण्यासाठी भांडार, तसेच कमांडचे एक्झिक्युटर आणि थेट SQL क्वेरी येथे तयार केल्या आहेत. कधीकधी डेटाबेससह कार्य करण्यासाठी वर्गाची क्षमता मर्यादित करणे सोयीचे असते, उदाहरणार्थ, केवळ डेटा वाचण्याची क्षमता प्रदान करणे. अशा प्रकरणांसाठी IEntityFactoryService एक पूर्वज आहे - इंटरफेस IEntityRepositoryFactory, जे फक्त रेपॉजिटरीज तयार करण्याची पद्धत घोषित करते.

डेटाबेसमध्ये थेट प्रवेश करण्यासाठी, प्रदाता यंत्रणा वापरली जाते. आम्ही आमच्या संघांमध्ये वापरत असलेल्या प्रत्येक DBMS ची स्वतःची अंमलबजावणी आहे: ViennaNET.Orm.MSSQL, ViennaNET.Orm.Oracle, ViennaNET.Orm.SQLite, ViennaNET.Orm.PostgreSql.

त्याच वेळी, एकाच वेळी अनेक प्रदाते एका अनुप्रयोगात नोंदणीकृत केले जाऊ शकतात, जे, उदाहरणार्थ, एका सेवेच्या चौकटीत, पायाभूत सुविधांमध्ये सुधारणा करण्यासाठी कोणत्याही खर्चाशिवाय, येथून चरण-दर-चरण स्थलांतर करण्यास परवानगी देतात. एक डीबीएमएस ते दुसरे. आवश्यक कनेक्शन निवडण्याची यंत्रणा आणि म्हणून, विशिष्ट घटक वर्गासाठी प्रदाता (ज्यासाठी डेटाबेस टेबलवर मॅपिंग लिहिलेले आहे) BoundedContext वर्गात अस्तित्वाची नोंदणी करून (डोमेन घटकांची नोंदणी करण्याची पद्धत समाविष्ट आहे) किंवा त्याच्या उत्तराधिकारीद्वारे कार्यान्वित केली जाते. 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");
  }
}

कनेक्शन आयडी निर्दिष्ट न केल्यास, "डीफॉल्ट" नावाचे कनेक्शन वापरले जाईल.

डेटाबेस टेबलवर घटकांचे थेट मॅपिंग मानक NHibernate साधनांचा वापर करून लागू केले जाते. तुम्ही एक्सएमएल फाइल्स आणि वर्गांद्वारे वर्णन वापरू शकता. युनिट चाचण्यांमध्ये स्टब रिपॉझिटरीजच्या सोयीस्कर लेखनासाठी, एक लायब्ररी आहे ViennaNET.TestUtils.Orm.

ViennaNET.Orm.* वापरण्याची संपूर्ण उदाहरणे आढळू शकतात येथे.

ViennaNET.मेसेजिंग.*

रांगेत काम करण्यासाठी लायब्ररीचा संच.

रांगांसह कार्य करण्यासाठी, विविध DBMS प्रमाणेच दृष्टिकोन निवडला गेला, म्हणजे, लायब्ररीसह कार्य करण्याच्या दृष्टीने जास्तीत जास्त संभाव्य युनिफाइड दृष्टीकोन, रांग व्यवस्थापक वापरला असला तरीही. लायब्ररी ViennaNET.Messaging या एकीकरणासाठी तंतोतंत जबाबदार आहे, आणि ViennaNET.Messaging.MQSeriesQueue, ViennaNET.Messaging.RabbitMQQueue и ViennaNET.Messaging.KafkaQueue IBM MQ, RabbitMQ आणि Kafka साठी अनुक्रमे अडॅप्टर अंमलबजावणी समाविष्टीत आहे.

रांगांसह काम करताना, दोन प्रक्रिया असतात: संदेश प्राप्त करणे आणि पाठवणे.

प्राप्त करण्याचा विचार करा. येथे 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 आपल्याला केवळ मजकूरच नाही तर बाइट संदेश देखील पाठविण्याची परवानगी देते आणि ViennaNET.Messaging.RabbitMQQueue रूटिंग आणि ऑन-द-फ्लाय रांगेला समर्थन देते. RabbitMQ साठी आमचे अॅडॉप्टर रॅपर देखील RPC चे काही स्वरूप लागू करते: आम्ही एक संदेश पाठवतो आणि एका विशेष तात्पुरत्या रांगेतून प्रतिसादाची प्रतीक्षा करतो, जी केवळ एका प्रतिसाद संदेशासाठी तयार केली जाते.

येथे मूलभूत कनेक्शन बारकावे असलेल्या रांगा वापरण्याचे उदाहरण.

ViennaNET.CallContext

आम्‍ही रांगांचा वापर केवळ वेगवेगळ्या सिस्‍टममध्‍ये एकत्रीकरणासाठीच करत नाही तर त्याच अॅप्लिकेशनच्‍या मायक्रोसर्व्हिसेसमध्‍ये संवाद साधण्‍यासाठी देखील करतो, उदाहरणार्थ, गाथामध्‍ये. यामुळे संदेशासह सहाय्यक डेटा जसे की वापरकर्ता लॉगिन, एंड-टू-एंड लॉगिंगसाठी विनंती अभिज्ञापक, स्त्रोत IP पत्ता आणि अधिकृतता डेटा पाठविण्याची गरज निर्माण झाली. हा डेटा फॉरवर्ड करण्यासाठी, आम्ही एक लायब्ररी विकसित केली आहे ViennaNET.CallContext, जे तुम्हाला सेवेमध्ये प्रवेश करणार्‍या विनंतीवरून डेटा संचयित करण्याची परवानगी देते. या प्रकरणात, विनंती कशी केली गेली, रांगेद्वारे किंवा Http द्वारे, काही फरक पडत नाही. त्यानंतर, आउटगोइंग विनंती किंवा संदेश पाठवण्यापूर्वी, संदर्भातून डेटा घेतला जातो आणि शीर्षलेखांमध्ये ठेवला जातो. अशा प्रकारे, पुढील सेवेला सहाय्यक डेटा प्राप्त होतो आणि त्याच प्रकारे ते व्यवस्थापित केले जाते.

तुमचे लक्ष दिल्याबद्दल धन्यवाद, आम्ही तुमच्या टिप्पण्या आणि पुल विनंत्याची वाट पाहत आहोत!

स्त्रोत: www.habr.com