ViennaNET: raamatukogude kogum tagaplaanile. 2. osa

Raiffeisenbanki .NET-arendajate kogukond jätkab ViennaNETi sisuloome lühikokkuvõtet. Kuidas ja miks me selle juurde jõudsime, võite lugeda esimeses osas.

Selles artiklis käsitleme veel mitte käsitletud teeke, mis on seotud jaotatud tehingute, järjekordade ja andmebaasidega, mida leiate meie GitHubi repost (allikas asub siin), and Nuget-pakettide kohta siin.

ViennaNET.Sagas

Kui projektis toimub üleminek DDD-le ja mikroteenuste arhitektuurile, siis äriloogika jagamisel erinevatesse teenustesse tekib probleem, mis on seotud jaotatud tehingute mehhanismi rakendamise vajadusega, kuna paljud stsenaariumid hõlmavad sageli mitmeid domeene. Selliste mehhanismidega saab lähemalt tutvuda näiteks raamatust «Microservices Patterns», autor Chris Richardson.

Meie projektides oleme rakendanud lihtsa, kuid kasuliku mehhanismi: saga, täpsemalt orkestreeritud saga. Selle olemus on järgmine: olemas on teatud äristsenaarium, kus on vaja järjestikku teostada toiminguid erinevates teenustes, samas, kui mis tahes sammus tekib probleeme, tuleb kutsuda esile tagasivõtmise protseduur kõikidele varasematele sammudele, kus see on ette nähtud. Seeläbi saame sagade täitmise lõpus, sõltumata eduka lõpuleviimise, järjepidevad andmed kõikides domeenides.

Meie rakendus on seni tehtud põhilisel kujul ja ei sõltu teiste teenustega suhtlemiseks vajalike meetodite kasutamisest. Seda on lihtne rakendada: piisab, kui luua järeltulija põhiklassist SagaBase<T>, kus T on teie konteksti klass, kus saab hoida algandmeid, mis on vajalikud saga toimimiseks, samuti mõned vahepealsed tulemused. Konteksti eksemplar edastatakse kõigile sammustel täitmise ajal. Igal juhul on saga staateless klass, seega võib eksemplar sisestada DI-sse kui Singleton, et saada vajalikke sõltuvusi.

Näide deklaratsioonist:

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

Kutsumise näide:

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

Täielikke näiteid erinevatest rakendustest saate vaadata siit ja kogus, kus testid.

ViennaNET.Orm.*

Raamatukogude komplekt erinevate andmebaasidega töötamiseks läbi Nhibernate. Me kasutame DB-First lähenemist koos Liquibase'i rakendamisega, seega on siin ainult andmete haldamiseks vajalik funktsionaalsus valmis andmebaasis.

ViennaNET.Orm.Seedwork ja ViennaNET.Orm – peamised kogud, mis sisaldavad vastavaid põhiliideseid ja nende rakendusi. Jätkame nende sisu detailsemalt.

Liides IEntityFactoryService ja selle rakendus EntityFactoryService on peamine alguspunkt andmebaasiga töötamiseks, kuna siin luuakse Unit of Work, konkreetsete entiteetidega töötavad repositooriumid, samuti käsu ja otse SQL-päringute täitjad. Mõnikord on mugav piirata klassi võimalusi andmebaasiga töötamiseks, näiteks lubada ainult andmete lugemist. Selliseid juhtumeid on IEntityFactoryService eelkäija – liides IEntityRepositoryFactory, milles on deklareeritud ainult meetod repositooriumide loomiseks.

Andmebaasiga otse suhtlemiseks kasutatakse pakkujate mehhanismi. Iga andmebaasi haldamiseks kasutatavale süsteemile on meie meeskondades oma rakendus: ViennaNET.Orm.MSSQL, ViennaNET.Orm.Oracle, ViennaNET.Orm.SQLite, ViennaNET.Orm.PostgreSql.

Samuti võib ühes rakenduses olla registreeritud mitu pakkujat korraga, mis võimaldab, näiteks, ühe teenuse raames teostada astmelist migratsiooni ühe andmebaasist teise ilma otseste infrastruktuuri parandusteta. Vajadus vajalikku ühendust ja seega pakkujat konkreetse entiteediklassi jaoks (mille jaoks kirjutatakse kaardistamine andmebaasi tabelitega) on rakendatud entiteedi registreerimise kaudu klassis BoundedContext (mis sisaldab meetodit domeenide entiteetide registreerimiseks) või selle järeltulijarakenduses ApplicationContext (mis sisaldab meetodeid rakenduse entiteetide, otsepäringute ja käskude registreerimiseks), kus argumendina võetakse ühenduse identifikaator konfiguratsioonist:

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

Näide ApplicationContextist:

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

Kui ühenduse identifikaatorit ei ole määratud, siis kasutatakse ühendust nimega «default».

Entiteetide otsemapping andmebaasi tabelitele toimub NHibernate'i standardsete vahenditega. Kirjeldust on võimalik kasutada nii XML-failide kui ka klasside kaudu. Repo-zhtestide mugavaks kirjutamiseks on saadaval raamatukogu ViennaNET.TestUtils.Orm.

Täielikud näited ViennaNET.Orm.* kasutamisest leiate siit.

ViennaNET.Messaging.*

Raamatukogude komplekt, mis tegeleb järjekordadega.

Järjekordadega töötamiseks valiti sama lähenemine, mis erinevate andmebaasidega, nimelt maksimaalselt võimalik ühtne lähenemine raamatukoguga töötamisel, sõltumata kasutatavast järjekorra haldurist. Raamatukogu ViennaNET.Messaging vastutab just selle ühtsuse eest, ning ViennaNET.Messaging.MQSeriesQueue, ViennaNET.Messaging.RabbitMQQueue ja ViennaNET.Messaging.KafkaQueue sisaldavad adapterite rakendusi IBM MQ, RabbitMQ ja Kafka jaoks vastavalt.

Järjekordadega töötamisel on kaks protsessi: sõnumi vastuvõtmine ja saatmine.

Uurime sõnumi vastuvõtmist. Siin on kaks võimalust: pidev kuulamine ja üksiku sõnumi vastuvõtt. Pideva kuulamise jaoks tuleb esmalt kirjeldada protsessoriklass, mis on päritud IMessageProcessor, mis vastutab sissetuleva sõnumi töötlemise eest. Edasi tuleb see „siduda” kindla järjekorraga, mis toimub registreerimise kaudu IQueueReactorFactory konfiguratsioonist järjekorra identifikaatori määramisega:

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

Näide kuulamise käivitamisest:

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

Seejärel, teenuse käivitamisel ja meetodi väljakutsumisel kuulamise alustamiseks, kõik sõnumid määratud järjekorrast jõuavad vastavasse protsessorisse.

Üksiku sõnumi vastuvõtmiseks on interfeysifabrikus IMessagingComponentFactory olemas meetod CreateMessageReceiver, mis loob vastuvõtja, mis ootab sõnumit määratud järjekorrast:

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

Sõnumi saatmiseks on vajalik kasutada sama IMessagingComponentFactory ja luua sõnumi saatja:

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

Sõnumi seriaalimiseks ja deserialiseerimiseks on kolm valmis varianti: lihtne tekst, XML ja JSON, kuid vajadusel on võimalik rahulikult luua oma implementatsioonid liidestele IMessageSerializer ja IMessageDeserializer.

Olemegi püüdnud säilitada iga järjekorra halduri unikaalsed võimalused, näiteks ViennaNET.Messaging.MQSeriesQueue lubab saata mitte ainult tekstilisi, vaid ka baitide sõnumeid, ja ViennaNET.Messaging.RabbitMQQueue toetab marsruutimist ja järjekordade loomist 'otse'. Meie RabbitMQ adapteri ümber ringi on samuti rakendatud teatud sarnasus RPC-le: saadame sõnumi ja ootame vastust eraldi ajutisest järjekorrast, mis luuakse ainult ühe vastavas sõnumiks.

Siin on näide järjekordade kasutamisest peamiste ühendamisnäidete ja punktide osas.

ViennaNET.CallContext

Kasutame järjekordi mitte ainult erinevate süsteemide integreerimiseks, vaid ka mikroteenuste suhtlemiseks ühes rakenduses, näiteks saaga raames. See tõi kaasa vajaduse edastada koos sõnumiga selliseid abivõimalusi nagu kasutaja sisselogimise, päringu identifikaatori koheseks logimiseks, allika IP-aadress ja autoriseerimise andmed. Need andmed edastamiseks oleme välja töötanud raamatukogu ViennaNET.CallContext, mis võimaldab salvestada andmeid sisenevast teenuse päringust. Sel juhul ei ole oluline, kuidas päring tehti, kas järjekorra või HTTP kaudu. Siis, enne väljamineva päringu või sõnumi saatmist, võetakse kontekstist andmed ja kantakse päistesse. Nii et järgmine teenus saab abivõimalusi ja käsitseb neid samamoodi.

Aitäh tähelepanu eest, ootame teie kommentaare ja pull request'e!

Allikas: habr.com