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

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

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

ViennaNET.Sagas

जब परियोजना 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-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 अर्कोमा। आवश्यक जडान चयन गर्ने संयन्त्र र त्यसकारण, विशेष इकाई वर्गको लागि प्रदायक (जसको लागि डाटाबेस तालिकाहरूमा म्यापिङ लेखिएको छ) 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.* प्रयोग गर्ने पूर्ण उदाहरणहरू फेला पार्न सकिन्छ यहाँ.

ViennaNET.Messaging।*

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

लामहरूसँग काम गर्न, विभिन्न 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