ВиеннаНЕТ: скуп библиотека за позадину. Део 2

Заједница програмера Раиффеисенбанк .НЕТ наставља са кратким прегледом садржаја ВиеннаНЕТ-а. О томе како и зашто смо дошли до овога, можете прочитати први део.

У овом чланку ћемо проћи кроз библиотеке које тек треба да се размотри за рад са дистрибуираним трансакцијама, редовима и базама података, које се могу наћи у нашем ГитХуб репозиторијуму (извори су овде), и Нугет пакети овде.

ВиеннаНЕТ.Сагас

Када се пројекат пребаци на ДДД и микросервисну архитектуру, онда када се пословна логика дистрибуира на различите сервисе, настаје проблем везан за потребу имплементације механизма дистрибуиране трансакције, јер многи сценарији често утичу на неколико домена одједном. Можете се детаљније упознати са таквим механизмима, нпр. у књизи „Мицросервицес Паттернс“, Крис Ричардсон.

У нашим пројектима имплементирали смо једноставан, али користан механизам: сагу, односно сагу засновану на оркестрацији. Његова суштина је следећа: постоји одређени пословни сценарио у коме је потребно секвенцијално обављати операције у различитим сервисима, а ако се у било ком кораку појаве проблеми, потребно је позвати процедуру враћања за све претходне кораке, где је обезбеђено. Тако, на крају саге, без обзира на успех, добијамо доследне податке у свим доменима.

Наша имплементација је и даље направљена у свом основном облику и није везана за коришћење било каквих метода интеракције са другим сервисима. Није тешко користити: само направите потомка основне апстрактне класе СагаБасе<Т>, где је Т ваша контекстуална класа у којој можете да ускладиштите почетне податке неопходне да би сага функционисала, као и неке међурезултате. Инстанца контекста ће бити прослеђена свим корацима током извршавања. Сама Сага је класа без стања, тако да се инстанца може ставити у ДИ као Синглетон да би се добиле потребне зависности.

Пример огласа:

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 – главни склопови који садрже основне интерфејсе и њихове имплементације, респективно. Погледајмо њихов садржај детаљније.

interfejs IEntityFactoryService и његову имплементацију EntityFactoryService су главна полазна тачка за рад са базом података, будући да се овде креирају Јединица рада, спремишта за рад са одређеним ентитетима, као и извршиоци команди и директни СКЛ упити. Понекад је згодно ограничити могућности класе за рад са базом података, на пример, да се обезбеди могућност само читања података. За такве случајеве IEntityFactoryService постоји предак – интерфејс IEntityRepositoryFactory, који само декларише метод за креирање спремишта.

За директан приступ бази података користи се механизам провајдера. Сваки ДБМС који користимо у нашим тимовима има своју имплементацију: ViennaNET.Orm.MSSQL, ViennaNET.Orm.Oracle, ViennaNET.Orm.SQLite, ViennaNET.Orm.PostgreSql.

Истовремено, више провајдера може бити регистровано у једној апликацији истовремено, што омогућава, на пример, у оквиру једног сервиса, без икаквих трошкова за модификацију инфраструктуре, да изврши корак по корак миграцију са један ДБМС у други. Механизам за избор потребне везе, а самим тим и провајдера за одређену класу ентитета (за коју се пише мапирање у табеле базе података) се имплементира кроз регистрацију ентитета у класу БоундедЦонтект (садржи метод за регистрацију ентитета домена) или његовог наследника. АпплицатионЦонтект (садржи методе за регистрацију ентитета апликације, директне захтеве и команде), где се идентификатор везе из конфигурације прихвата као аргумент:

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

Ако ИД везе није наведен, тада ће се користити веза под називом „подразумевана“.

Директно мапирање ентитета у табеле базе података је имплементирано коришћењем стандардних НХибернате алата. Можете користити опис и кроз кмл датотеке и кроз класе. За практично писање стуб репозиторијума у ​​јединичним тестовима, постоји библиотека ViennaNET.TestUtils.Orm.

Пуни примери коришћења ВиеннаНЕТ.Орм.* се могу наћи овде.

ВиеннаНЕТ.Мессагинг.*

Скуп библиотека за рад са редовима.

За рад са редовима изабран је исти приступ као и код разних ДБМС-а, односно максимално могући обједињени приступ у погледу рада са библиотеком, без обзира на коришћени менаџер редова. Библиотека ViennaNET.Messaging је управо одговоран за ово уједињење, и ViennaNET.Messaging.MQSeriesQueue, ViennaNET.Messaging.RabbitMQQueue и ViennaNET.Messaging.KafkaQueue садрже имплементације адаптера за ИБМ МК, РаббитМК и Кафка, респективно.

Када радите са редовима, постоје два процеса: примање поруке и њено слање.

Размислите о примању. Овде постоје 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 = ...});
}

Постоје три готове опције за серијализацију и десеријализацију поруке: само текст, КСМЛ и ЈСОН, али ако је потребно, можете лако да направите сопствене имплементације интерфејса IMessageSerializer и IMessageDeserializer.

Трудили смо се да сачувамо јединствене могућности сваког менаџера редова, нпр. ViennaNET.Messaging.MQSeriesQueue омогућава вам да шаљете не само текстуалне, већ и бајт поруке, и ViennaNET.Messaging.RabbitMQQueue подржава рутирање и чекање у покрету. Наш омотач адаптера за РаббитМК такође имплементира неки привид РПЦ-а: шаљемо поруку и чекамо одговор из посебног привременог реда, који се креира само за једну поруку одговора.

ovde је пример коришћења редова са основним нијансама повезивања.

ВиеннаНЕТ.ЦаллЦонтект

Редове користимо не само за интеграцију између различитих система, већ и за комуникацију између микросервиса исте апликације, на пример, у оквиру саге. Ово је довело до потребе да се заједно са поруком пренесу и помоћни подаци као што су пријава корисника, идентификатор захтева за евидентирање од краја до краја, изворна ИП адреса и подаци о ауторизацији. Да бисмо спровели прослеђивање ових података, развили смо библиотеку ViennaNET.CallContext, који вам омогућава да сачувате податке из захтева који улази у услугу. У овом случају, начин на који је захтев направљен, преко реда или преко Хттп-а, није битан. Затим, пре слања одлазног захтева или поруке, подаци се узимају из контекста и стављају у заглавља. Дакле, следећи сервис прима помоћне податке и њиме управља на исти начин.

Хвала вам на пажњи, радујемо се вашим коментарима и захтевима за повлачење!

Извор: ввв.хабр.цом