वियनानेट: बैकएंड के लिए पुस्तकालयों का एक सेट। भाग 2

Raiffeisenbank .NET डेवलपर समुदाय वियनानेट की सामग्री की संक्षिप्त समीक्षा करना जारी रखता है। हम इस तक कैसे और क्यों आये, आप पहला भाग पढ़ सकते हैं.

इस लेख में, हम वितरित लेनदेन, कतारों और डेटाबेस के साथ काम करने के लिए अभी तक मानी जाने वाली लाइब्रेरी के बारे में जानेंगे, जो हमारे GitHub रिपॉजिटरी में पाया जा सकता है (स्रोत यहाँ हैं), और नगेट पैकेज यहाँ.

वियनानेट.सागास

जब कोई प्रोजेक्ट डीडीडी और माइक्रोसर्विस आर्किटेक्चर पर स्विच करता है, तो जब व्यावसायिक तर्क विभिन्न सेवाओं में वितरित किया जाता है, तो वितरित लेनदेन तंत्र को लागू करने की आवश्यकता से संबंधित एक समस्या उत्पन्न होती है, क्योंकि कई परिदृश्य अक्सर एक साथ कई डोमेन को प्रभावित करते हैं। आप ऐसे तंत्रों से अधिक विस्तार से परिचित हो सकते हैं, उदाहरण के लिए, क्रिस रिचर्डसन की पुस्तक "माइक्रोसर्विसेज पैटर्न्स" में.

हमारी परियोजनाओं में, हमने एक सरल लेकिन उपयोगी तंत्र लागू किया है: एक गाथा, या बल्कि एक ऑर्केस्ट्रेशन-आधारित गाथा। इसका सार इस प्रकार है: एक निश्चित व्यावसायिक परिदृश्य है जिसमें विभिन्न सेवाओं में क्रमिक रूप से संचालन करना आवश्यक है, और यदि किसी भी चरण में कोई समस्या उत्पन्न होती है, तो पिछले सभी चरणों के लिए रोलबैक प्रक्रिया को कॉल करना आवश्यक है, जहां यह है प्रदान किया। इस प्रकार, गाथा के अंत में, सफलता की परवाह किए बिना, हमें सभी डोमेन में लगातार डेटा प्राप्त होता है।

हमारा कार्यान्वयन अभी भी अपने मूल रूप में किया गया है और अन्य सेवाओं के साथ बातचीत के किसी भी तरीके के उपयोग से बंधा नहीं है। इसका उपयोग करना मुश्किल नहीं है: बस आधार अमूर्त वर्ग SagaBase<T> का वंशज बनाएं, जहां T आपका संदर्भ वर्ग है जिसमें आप गाथा के काम करने के लिए आवश्यक प्रारंभिक डेटा, साथ ही कुछ मध्यवर्ती परिणाम संग्रहीत कर सकते हैं। निष्पादन के दौरान संदर्भ उदाहरण को सभी चरणों में पारित किया जाएगा। सागा स्वयं एक स्टेटलेस वर्ग है, इसलिए आवश्यक निर्भरता प्राप्त करने के लिए उदाहरण को डीआई में सिंगलटन के रूप में रखा जा सकता है।

उदाहरण विज्ञापन:

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.Seedwork и ViennaNET.Orm - मुख्य असेंबली जिनमें क्रमशः बुनियादी इंटरफेस और उनके कार्यान्वयन शामिल हैं। आइए उनकी सामग्री को अधिक विस्तार से देखें।

अंतराफलक IEntityFactoryService और इसका कार्यान्वयन EntityFactoryService डेटाबेस के साथ काम करने के लिए मुख्य प्रारंभिक बिंदु हैं, क्योंकि कार्य की इकाई, विशिष्ट संस्थाओं के साथ काम करने के लिए रिपॉजिटरी, साथ ही कमांड के निष्पादक और प्रत्यक्ष एसक्यूएल क्वेरी यहां बनाई गई हैं। कभी-कभी डेटाबेस के साथ काम करने के लिए किसी वर्ग की क्षमताओं को सीमित करना सुविधाजनक होता है, उदाहरण के लिए, केवल डेटा पढ़ने की क्षमता प्रदान करना। ऐसे मामलों के लिए IEntityFactoryService एक पूर्वज है - इंटरफ़ेस IEntityRepositoryFactory, जो केवल रिपॉजिटरी बनाने की एक विधि घोषित करता है।

डेटाबेस तक सीधे पहुंचने के लिए प्रदाता तंत्र का उपयोग किया जाता है। हमारी टीमों में उपयोग किए जाने वाले प्रत्येक DBMS का अपना कार्यान्वयन होता है: ViennaNET.Orm.MSSQL, ViennaNET.Orm.Oracle, ViennaNET.Orm.SQLite, ViennaNET.Orm.PostgreSql.

एक ही समय में, कई प्रदाताओं को एक ही समय में एक एप्लिकेशन में पंजीकृत किया जा सकता है, जो उदाहरण के लिए, एक सेवा के ढांचे के भीतर, बुनियादी ढांचे को संशोधित करने की किसी भी लागत के बिना, चरण-दर-चरण माइग्रेशन करने की अनुमति देता है। एक DBMS से दूसरे DBMS. आवश्यक कनेक्शन का चयन करने के लिए तंत्र और, इसलिए, एक विशिष्ट इकाई वर्ग के लिए प्रदाता (जिसके लिए डेटाबेस तालिकाओं में मैपिंग लिखी गई है) को BoundedContext वर्ग (डोमेन इकाइयों को पंजीकृत करने के लिए एक विधि शामिल है) या उसके उत्तराधिकारी में इकाई को पंजीकृत करने के माध्यम से कार्यान्वित किया जाता है। एप्लिकेशन कॉन्टेक्स्ट (एप्लिकेशन इकाइयों, प्रत्यक्ष अनुरोधों और आदेशों को पंजीकृत करने के तरीके शामिल हैं), जहां कॉन्फ़िगरेशन से कनेक्शन पहचानकर्ता को एक तर्क के रूप में स्वीकार किया जाता है:

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

उदाहरण एप्लिकेशन कॉन्टेक्स्ट:

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

यदि कनेक्शन आईडी निर्दिष्ट नहीं है, तो "डिफ़ॉल्ट" नामक कनेक्शन का उपयोग किया जाएगा।

डेटाबेस तालिकाओं में संस्थाओं की सीधी मैपिंग मानक NHibernet टूल का उपयोग करके कार्यान्वित की जाती है। आप विवरण का उपयोग xml फ़ाइलों और कक्षाओं दोनों के माध्यम से कर सकते हैं। यूनिट परीक्षणों में स्टब रिपॉजिटरी के सुविधाजनक लेखन के लिए, एक पुस्तकालय है ViennaNET.TestUtils.Orm.

वियनानेट.ऑर्म.* का उपयोग करने के पूर्ण उदाहरण पाए जा सकते हैं यहां.

वियनानेट.मैसेजिंग.*

कतारों के साथ काम करने के लिए पुस्तकालयों का एक सेट।

कतारों के साथ काम करने के लिए, विभिन्न डीबीएमएस के समान ही दृष्टिकोण चुना गया था, अर्थात्, लाइब्रेरी के साथ काम करने के संदर्भ में अधिकतम संभव एकीकृत दृष्टिकोण, कतार प्रबंधक का उपयोग किए बिना। पुस्तकालय 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, जो आपको सेवा में प्रवेश करने वाले अनुरोध से डेटा संग्रहीत करने की अनुमति देता है। इस मामले में, अनुरोध कैसे किया गया, कतार के माध्यम से या HTTP के माध्यम से, कोई फर्क नहीं पड़ता। फिर, आउटगोइंग अनुरोध या संदेश भेजने से पहले, संदर्भ से डेटा लिया जाता है और हेडर में रखा जाता है। इस प्रकार, अगली सेवा सहायक डेटा प्राप्त करती है और इसे उसी तरह प्रबंधित करती है।

आपके ध्यान के लिए धन्यवाद, हम आपकी टिप्पणियों और अनुरोधों की प्रतीक्षा कर रहे हैं!

स्रोत: www.habr.com