{"id":31124,"date":"2019-10-31T21:39:36","date_gmt":"2019-10-31T18:39:36","guid":{"rendered":"https:\/\/prohoster.info\/blog\/stroitelnye-bloki-raspredelennyh-prilozhenij-vtoroe-priblizhenie\/"},"modified":"2019-10-31T21:39:36","modified_gmt":"2019-10-31T18:39:36","slug":"stroitelnye-bloki-raspredelennyh-prilozhenij-vtoroe-priblizhenie","status":"publish","type":"post","link":"https:\/\/prohoster.info\/et\/blog\/administrirovanie\/stroitelnye-bloki-raspredelennyh-prilozhenij-vtoroe-priblizhenie","title":{"rendered":"Jaotatud rakenduste ehitusplokid. Teine l\u00e4henemine","gt_translate_keys":[{"key":"rendered","format":"text"}]},"content":{"rendered":"

Teade<\/strong><\/p>\n

<\/p>\n

Kollegid, suve keskpaiku plaanin avaldada veel \u00fche artiklite seeria massiteenuse s\u00fcsteemide projekteerimise kohta: \"Eksperiment VTrade\" \u2014 katse kirjutada raamistiku kauplemiss\u00fcsteemide jaoks. Seerias k\u00e4sitletakse b\u00f6rsi, oksjoni ja poe loomise teooriat ja praktikat. Artikli l\u00f5pus kutsub autor \u00fcles h\u00e4\u00e4letama k\u00f5ige huvitavamate teemade \u00fcle.
\n<\/em><\/p>\n

<\/p>\n

\"Jaotatud<\/p>\n

<\/p>\n

See on viimane artikkel jaotise kohta jaotatud reaktiivsetest rakendustest Erlangu\/Elixiriga. S esimesest artiklist<\/a><\/noindex> v\u00f5ib leida reaktiivse arhitektuuri teoreetilised alused. Teine artikkel<\/a><\/noindex> illustreerib peamisi mustreid ja mehhanisme selliste s\u00fcsteemide loomisel.<\/p>\n

<\/p>\n

T\u00e4na k\u00e4sitleme koodibaasi ja projektide arengut \u00fcldiselt. <\/p>\n

<\/a><\/noindex><\/p>\n

Teenuste korraldamine<\/h2>\n

<\/p>\n

Reaalses elus teenuse arendamisel tuleb sageli \u00fchendada mitu suhtlemismustrit \u00fches kontrolleris. N\u00e4iteks teenus users, mis lahendab projekti kasutajaprofiilide haldamise \u00fclesandeid, peab vastama p\u00e4ringutele req-resp ja teatama profiilide uuendustest pub-sub kaudu. See juhtum on \u00fcsna lihtne: jagamise taga on \u00fcks kontroller, mis rakendab teenuse loogikat ja avaldab uuendusi.<\/p>\n

<\/p>\n

Situatsioon muutub keerulisemaks, kui peame rakendama t\u00f5rkevaru jaotatud teenust. Oletame, et kasutajate n\u00f5udmised on muutunud: <\/p>\n

<\/p>\n

    \n
  1. n\u00fc\u00fcd peab teenus t\u00f6\u00f6tlema p\u00e4ringuid 5 klastris\u00f5lmes, <\/li>\n
  2. olema v\u00f5imeline t\u00e4itma taustat\u00f6\u00f6tlus\u00fclesandeid, <\/li>\n
  3. ja suutma d\u00fcnaamiliselt hallata tellimuste loode profiili v\u00e4rskendustele.<\/li>\n<\/ol>\n

    <\/p>\n

    M\u00e4rkus:<\/em> Andmete j\u00e4rjepideva salvestamise ja kopeerimise k\u00fcsimust me ei aruta. Eeldame, et need k\u00fcsimused on varem lahendatud ja s\u00fcsteemis on juba olemas usaldusv\u00e4\u00e4rne ning skaleeritav salvestuskiht, millel on t\u00f6\u00f6tlejatel suhtlemismehhanismid.<\/p>\n

    <\/p>\n

    Kasutajate teenuse formaalne kirjeldus on muutunud keerulisemaks. Programmi seisukohalt on t\u00e4nu s\u00f5numside kasutamisele muudatused minimaalsed. Esimese n\u00f5ude t\u00e4itmiseks peame seadistama tasakaalustamise req-resp vahetuspunktis. <\/p>\n

    <\/p>\n

    Taustat\u00f6\u00f6de t\u00f6\u00f6tlemise n\u00f5udmine tekib sageli. Users'is v\u00f5ivad need olla kasutajate dokumentide kontrollimine, \u00fcles laaditud multimeedia t\u00f6\u00f6tlemine v\u00f5i andmete s\u00fcnkroonimine sotsiaalsete v\u00f5rgustikega. Need \u00fclesanded tuleb mingil viisil jaotada klastris ja nende t\u00e4itmise kulgu j\u00e4lgida. Seet\u00f5ttu on meil kaks lahenduse varianti: kas kasutada eelmise artikli \u00fclesannete jaotamise \u0448\u0430\u0431\u043b\u043e\u043d\u0438 v\u00f5i, kui see ei sobi, kirjutada kohandatud \u00fclesannete planeerija, mis hallataks meie vajaduste j\u00e4rgi. <\/p>\n

    <\/p>\n

    3. punkt n\u00f5uab pub-sub \u0448\u0430\u0431\u043b\u043e\u043d\u0438 laiendamist. Ja selle teostamiseks, p\u00e4rast pub-sub vahetuspunkti loomist, peame k\u00e4ivitama ka selle punkti kontrolleri meie teenuse raames. Seega, nagu me viiksime tellimise ja loobumise t\u00f6\u00f6tlemise loogika messaging kihist v\u00e4lja users'i rakendusse.<\/p>\n

    <\/p>\n

    Kokkuv\u00f5ttes n\u00e4itas \u00fclesande dekompositsioon, et n\u00f5uete rahuldamiseks peame k\u00e4ivitama 5 teenuse eksemplari erinevates s\u00f5lmedes ja looma t\u00e4iendava \u00fcksuse \u2013 pub-sub kontrolleri, mis vastutab tellimise eest.
    \n5 t\u00f6\u00f6tleja k\u00e4ivitamiseks ei ole teenuse koodi vaja muuta. Ainus lisategevus on tasakaalustamisreeglite seadistamine vahetuspunktis, millest r\u00e4\u00e4gime hiljem.
    \nLisaks on tekkinud t\u00e4iendav keerukus: pub-sub juht ja kohandatud \u00fclesannete ajastaja peavad t\u00f6\u00f6tama ainsas eksemplaris. J\u00e4llegi, messaging teenus, olles alus, peab pakkuma juhtimismehhanismi.<\/p>\n

    <\/p>\n

    Juhi valik<\/h3>\n

    <\/p>\n

    Jaotatud s\u00fcsteemides on juhi valik \u2013 menetlus, mille k\u00e4igus m\u00e4\u00e4ratakse ainus protsess, mis vastutab jaotatud koormuse t\u00f6\u00f6tlemise planeerimise eest. <\/p>\n

    <\/p>\n

    S\u00fcsteemides, mis ei kaldu keskendumisele, kasutatakse universaalseid algoritme ja konsensusel p\u00f5hinevaid algoritme, n\u00e4iteks paxos v\u00f5i raft.
    \nKuna messaging on vahendaja ja keskne element, siis teab ta k\u00f5igist teenuse kontrollijatest - juhtide kandidaatidest. Messaging v\u00f5ib m\u00e4\u00e4rata juhi ilma h\u00e4\u00e4letamiseta.<\/p>\n

    <\/p>\n

    K\u00f5ik teenused saavad p\u00e4rast k\u00e4ivitamist ja \u00fchendamist vahetuspunktiga s\u00fcsteemiteate #'$leader'{exchange = ?EXCHANGE, pid = LeaderPid, servers = Servers}<\/code>. Kui LeaderPid<\/code> on sama kui pid<\/code> praeguse protsessi puhul, m\u00e4\u00e4ratakse ta juhiks ja nimekiri Servers<\/code> k\u00e4tkeb endas k\u00f5iki s\u00f5lme ja nende parameetreid.
    \nKui klastris tekib uus s\u00f5lm ja varasem s\u00f5lm l\u00fclitatakse v\u00e4lja, saavad k\u00f5ik teenuse kontrollerid #'$slave_up'{exchange = ?EXCHANGE, pid = SlavePid, options = SlaveOpts}<\/code> ja #'$slave_down'{exchange = ?EXCHANGE, pid = SlavePid, options = SlaveOpts}<\/code> vastavalt.<\/p>\n

    <\/p>\n

    Seega teavad k\u00f5ik komponendid k\u00f5igist muudatustest ning klastris on igal hetkel tagatud \u00fcks juht.<\/p>\n

    <\/p>\n

    Vahekohtunikud<\/h2>\n

    <\/p>\n

    Kompaktsede hajutatud t\u00f6\u00f6tlemisprotsesside rakendamiseks ning juba olemasoleva arhitektuuri optimeerimise probleemide lahendamiseks on mugav kasutada vahekohtunikke.
    \nKuna teenuste koodi ei soovi muuta ja lahendada n\u00e4iteks t\u00e4iendava t\u00f6\u00f6tlemise, marsruutimise v\u00f5i s\u00f5numite logimise \u00fclesandeid, v\u00f5ib teenuse ette lisada proxy t\u00f6\u00f6tlija, mis t\u00e4idab kogu t\u00e4iendava t\u00f6\u00f6.<\/p>\n

    <\/p>\n

    Klassikaline n\u00e4ide pub-sub optimeerimise kohta on hajutatud rakendus, millel on \u00e4ri- s\u00fcda, mis genereerib uuenduste s\u00fcndmusi, n\u00e4iteks hinnamuutuse turul, ja juurdep\u00e4\u00e4su kiht \u2014 N serverit, mis pakuvad websocket API-d veebiklientidele.
    \nKui l\u00e4heneda probleemile otse, n\u00e4eb kliendi teenindamine v\u00e4lja j\u00e4rgmiselt:<\/p>\n

    <\/p>\n