Tapahtumapohjaiset mikropalvelut

MicrocosmWorks suunnittelee tapahtumavetoisia järjestelmiä kestävien viestinvälittäjien, kuten Apache Kafkan tai Amazon EventBridgen, avulla. Nämä välittäjät säilyttävät tapahtumat, kunnes kuluttajat ovat käsitelleet ne onnistuneesti, varmistaen, ettei tietoa katoa käyttökatkojen aikana. Toteutamme dead-letter-jonot, eksponentiaaliset viivästetyt uudelleenyrityskäytännöt ja katkaisijat, jotta epäonnistuva mikropalvelu ei tuki koko tapahtumaputkea. Kun alavirran palvelu palautuu, se käsittelee automaattisesti rästissä olevat tapahtumat ilman manuaalista puuttumista.

Tapahtumapohjainen kommunikaatio on parempi valinta, kun palvelusi eivät tarvitse välitöntä vastausta, kun sinun on irrotettava käyttöönottosyklit toisistaan, tai kun yksi toiminto laukaisee useita jatkoprosesseja. MicrocosmWorks suosittelee tyypillisesti tapahtumapohjaisia malleja tilausten käsittelyyn, ilmoitusputkiin ja analytiikan keruuseen, samalla kun synkroniset API:t pidetään käyttäjille suunnatuille kyselyille, jotka vaativat alle sekunnin vastauksia. Monet rakentamamme tuotantojärjestelmät käyttävät hybridiä lähestymistapaa synkronisilla lukutoiminnoilla ja asynkronisilla kirjoitustoiminnoilla.

MicrocosmWorks hyödyntää osiointiavaimiin perustuvaa järjestystä Kafka topicsissa varmistaakseen, että kaikki tietylle entiteetille (kuten tietty tilaus tai käyttäjä) tarkoitetut tapahtumat käsitellään peräkkäin saman kuluttajaistanssin toimesta. Skenaarioissa, jotka edellyttävät entiteettien välistä järjestystä, toteutamme saga orchestratoreita, joissa on idempotentit tapahtumankäsittelijät, ja jotka voivat turvallisesti käsitellä uudelleen epäjärjestyksessä olevia viestejä. Upotamme myös vektorikellot tai järjestysnumerot tapahtumakuormiin, jotta kuluttajat voivat havaita ja selvittää järjestysristiriidat.

MicrocosmWorks toteuttaa Saga-mallin kompensoivilla transaktioilla, joissa jokainen microservice julkaisee domain events -tapahtumia suoritettuaan paikallisen transaktionsa, ja alavirran palvelut reagoivat vastaavasti tai käynnistävät rollback compensations -toimenpiteitä vian sattuessa. Yhdistämme tämän outbox pattern -malliin, joka kirjoittaa tapahtumat atomisesti paikalliseen outbox table -tauluun liiketoimintatiedon rinnalla, ja julkaisee ne sitten luotettavasti message brokeriin. Tämä saavuttaa eventual consistency -tilan ilman two-phase commits -menetelmän suorituskyky- ja luotettavuusrangaistuksia.

MicrocosmWorks varustaa jokaisen tapahtuman korrelaatiotunnuksilla ja hajautetun jäljityksen otsikoilla OpenTelemetryn avulla, mikä mahdollistaa liiketoimintatransaktion koko elinkaaren visualisoinnin kaikkien osallistuvien mikropalveluiden yli työkaluissa kuten Jaeger tai Grafana Tempo. Rakennamme myös reaaliaikaisia tapahtumavirran hallintapaneeleja, jotka näyttävät suoritustehoa, kuluttajan viivettä ja käsittelyviivettä palvelukohtaisesti, tehden pullonkaulojen paikantamisesta helppoa. Standardi observointipinonimme sisältää strukturoitua lokitusta tapahtumametadatalla, jotta mikä tahansa yksittäinen tapahtuma voidaan jäljittää tuottajasta jokaiseen kuluttajaan sekunneissa.