Archiwum kategorii: Patterns

SMessaging – prosta architektura oparta o wiadomości

Nie ukrywam, że od dawna podoba mi się podejście do budowy aplikacji w oparciu o wiadomości. Zdecydowałem się zebrać wszystkie mi znane materiały i napisać prosty framework (przynajmniej narazie prosty), którego zadaniem będzie umożliwienie budowy aplikacji w oparciu o wiadomości i handlery.

Dzięki temu w łatwy sposób możemy w naszej aplikacji zaimplementować CQRS ale nie tylko. W internecie można znaleźć bardzo wiele implementacji tego patternu ale ja chciałem maksymalnie uprościć architekturę, przecież nie zawsze nasza aplikacja musi być tak skomplikowana aby implementować odrazu CQRS.

Kod zarówno frameworka jak i przykład wykorzystania w aplikacji znajdziecie na GitHubie. Przedstawię w skrócie przykładową implementację w oparciu o prosty system rezerwacji.

Zaczynamy od kontrolera WebAPI, gdzie wstrzykujemy interfejs IMessaging:

To jest już pierwsza równica w budowaniu aplikacji w oparciu o wiadomości. Tradycyjnie tu mielibyśmy jakiś serwis aplikacyjny lub odrazu repozytorium dostępu do DB i w metodach robili jakieś operacje CRUD. Natomiast w tym podejściu zawsze do kontrolera będzie wstrzykiwany jeden interfejs, którego zadaniem jest przekazanie wiadomości przychodzącej „gdzieś” dalej, a przecież każdy request od użytkownika, każdy json, który leci do naszego API to tak naprawdę jakaś wiadomość, np. CreateOrder, GetOrder czy ShowListOfCars.

W takim podejściu nie ważne czy implementacja jest w serwisie, czy może w zupełnie innym miejscu. Bardzo upraszcza to kontroler WebAPI, jego odpowiedzialność to teraz tylko odebrać wiadomość, przekazać ją dalej i obsłużyć wynik lub ewentualny wyjątek:

Czy nie jest prościej?

Obsługę wiadomości implementujemy w handlerze, w dowolnym miejscu naszej aplikacji:

Zadaniem handlera jest wykonać daną operację i zwrócić wynik w postaci bardzo prostej struktury MessageResult. Dla operacji typu command czyli takich, które zmieniają stan aplikacji będzie to wyglądało podobnie ale wynik nie będzie potrzebny:

W taki sposób nasza aplikacja właściwie „sama” implementuje część patternów CQRS, stosując podejście handler per wiadomość właściwie w naturalny sposób odeseparowywujemy wiadomości pobierające dane od zmieniających stan aplikacji.

Aby włączyć framework należy go dodać w klasie konfigurującej zależności, w przypadku ASP.NET Core w klasie Startup:

To chyba tyle jeśli chodzi o prosty przykład. W przyszłości planuję rozwinąć framework o obsługę prostej kolejki i możliwość przesyłania wiadomości po sieci tak aby możliwe było zbudowanie rozproszonego systemu. Zapraszam do pobierania kodu z GitHuba.

Framework jest również dostępny do pobrania w NuGet.