ViennaNET: ब्याकएन्डको लागि पुस्तकालयहरूको सेट। भाग 2

Raiffeisenbank को .NET विकासकर्ता समुदायले ViennaNET को संक्षिप्त सिंहावलोकन जारी राख्छ। हामी कसरी र किन यो निष्कर्षमा पुग्यौं जान्नुहोस्। तपाईंले यसको बारेमा पहिलो भागमा पढ्न सक्नुहुन्छ.

यस लेखमा, हामी वितरित लेनदेन, क्यु, र डाटाबेसहरूसँग काम गर्ने केही पुस्तकालयहरूको बारेमा छलफल गर्नेछौं जुन अहिलेसम्म समेटिएको छैन, र जुन हाम्रो GitHub भण्डारमा फेला पार्न सकिन्छ (स्रोत कोड यहाँ छ।), र नुगेट प्याकेजहरू यहाँ छन्.

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

जब कुनै परियोजना 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);

विभिन्न कार्यान्वयनका पूर्ण उदाहरणहरू हेर्न सकिन्छ यहाँ र सभामा परीक्षणहरू.

भियनानेट.ओर्म.*

Nhibernate मार्फत विभिन्न डाटाबेसहरूसँग काम गर्ने पुस्तकालयहरूको सेट। हामी Liquibase सँग DB-First दृष्टिकोण प्रयोग गर्छौं, त्यसैले यो पुस्तकालयमा अवस्थित डाटाबेसमा डेटासँग काम गर्ने कार्यक्षमता मात्र समावेश छ।

ViennaNET.Orm.Seedwork и ViennaNET.Orm – क्रमशः आधार इन्टरफेसहरू र तिनीहरूको कार्यान्वयनहरू समावेश गर्ने मुख्य एसेम्बलीहरू। तिनीहरूको सामग्रीलाई थप विवरणमा जाँच गरौं।

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

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

एउटै एप्लिकेसनमा धेरै प्रदायकहरू एकैसाथ दर्ता गर्न सकिन्छ, उदाहरणका लागि, कुनै पनि पूर्वाधार परिमार्जन बिना एउटै सेवा भित्र एक DBMS बाट अर्कोमा चरण-दर-चरण माइग्रेसन गर्न अनुमति दिन्छ। आवश्यक जडान चयन गर्ने संयन्त्र र फलस्वरूप, एक विशिष्ट इकाई वर्ग (जसको लागि DB तालिकाहरूमा म्यापिङ लेखिएको छ) को लागि प्रदायकलाई BoundedContext वर्ग (जसमा डोमेन संस्थाहरू दर्ता गर्ने विधि समावेश छ) वा यसको उत्तराधिकारी, ApplicationContext (जसमा अनुप्रयोग संस्थाहरू, प्रत्यक्ष प्रश्नहरू, र आदेशहरू दर्ता गर्ने विधिहरू समावेश छन्) मा संस्था दर्ता गरेर लागू गरिन्छ, जहाँ कन्फिगरेसनबाट जडान पहिचानकर्तालाई तर्कको रूपमा स्वीकार गरिन्छ:

"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");
  }
}

यदि जडान ID निर्दिष्ट गरिएको छैन भने, "पूर्वनिर्धारित" नामको जडान प्रयोग गरिनेछ।

डाटाबेस तालिकाहरूमा संस्थाहरूको वास्तविक म्यापिङ मानक NHibernate उपकरणहरू प्रयोग गरेर कार्यान्वयन गरिन्छ। तपाईं विवरणहरूको लागि XML फाइलहरू र कक्षाहरू दुवै प्रयोग गर्न सक्नुहुन्छ। एकाइ परीक्षणहरूमा स्टब रिपोजिटरीहरू सजिलै लेख्नको लागि पुस्तकालय उपलब्ध छ। ViennaNET.TestUtils.Orm.

ViennaNET.Orm.* प्रयोग गर्ने पूर्ण उदाहरणहरू फेला पार्न सकिन्छ। यहाँ.

भियनानेट। सन्देश।*

लामहरूसँग काम गर्नको लागि पुस्तकालयहरूको सेट।

क्युहरूसँग काम गर्नको लागि, विभिन्न DBMS सँग जस्तै दृष्टिकोण छनोट गरिएको थियो, अर्थात्, पुस्तकालयसँग काम गर्ने सन्दर्भमा सबैभन्दा सम्भावित एकीकृत दृष्टिकोण, प्रयोग गरिएको क्यु प्रबन्धकको पर्वाह नगरी। पुस्तकालय ViennaNET.Messaging यो एकीकरणको लागि ठ्याक्कै जिम्मेवार छ, र ViennaNET.Messaging.MQSeriesQueue, ViennaNET.Messaging.RabbitMQQueue и ViennaNET.Messaging.KafkaQueue क्रमशः IBM MQ, RabbitMQ र Kafka का लागि एडेप्टरहरूको कार्यान्वयन समावेश गर्दछ।

लाइनहरूसँग काम गर्ने दुई प्रक्रियाहरू छन्: सन्देशहरू प्राप्त गर्ने र पठाउने।

प्राप्त गर्ने बारेमा विचार गरौं। यहाँ दुई विकल्पहरू छन्: निरन्तर सुन्नको लागि र एकल सन्देश प्राप्त गर्नको लागि। लगातार क्यु सुन्नको लागि, तपाईंले पहिले प्रोसेसर वर्ग परिभाषित गर्नुपर्छ जुन बाट प्राप्त हुन्छ IMessageProcessor, जुन आगमन सन्देश प्रशोधन गर्न जिम्मेवार हुनेछ। अर्को, यो एक विशिष्ट क्युमा "लिङ्क" हुनुपर्छ, जुन दर्ता गरेर गरिन्छ। IQueueReactorFactory कन्फिगरेसनबाट क्यु ID निर्दिष्ट गर्दै:

"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