Kuo EventEmitter skiriasi nuo užduočių eilės Node.js aplinkoje?

Question

IT Interview Practice · Accepted Answer

Rinkdamiesi EventEmitter arba darbų eilę klauskite, **kur turi vykti darbas ir kas nutiks procesui sustojus**.

EventEmitter praneša klausytojams viename Node.js procese. Patvari eilė išsaugo darbą vėlesniam darbuotojų apdorojimui. Abu atskiria atsakomybes, bet gedimo atveju elgiasi skirtingai.

## 1. Sekite vietinį pranešimą

Tarkime, komponentas baigė inicializavimą ir nori kitų to paties proceso komponentų reakcijos. EventEmitter čia natūralus: užregistruokite klausytojus ir išsiųskite įvykį.

```text
[One process]
emit("ready") -> Listener A
              -> Listener B
```

Node.js kviečia klausytojus sinchroniškai registravimo tvarka. Įvykis nesaugomas vėliau prisijungiantiems klausytojams, o nebaigtas darbas neišlieka procesui sugedus. [Node.js Events](https://nodejs.org/api/events.html).

Tai tinka, kai pranešimas vietinis ir gali būti prarastas arba atkurtas. Nepakanka, kai verslas tikisi, kad darbas išliks sustojus siuntėjui.

## 2. Supraskite async klausytojo poveikį

Async klausytojas gali pradėti asinchroninį darbą, bet emit nelaukia grąžinto promise. Kvietimo tvarka todėl nebūtinai yra užbaigimo tvarka.

CPU imlus sinchroninis kodas klausytojuje vis tiek stabdo procesą. Sąmoningai tvarkykite išmestas klaidas ir atmestus pažadus; captureRejections gali nukreipti atmetimus į klaidų tvarkymą, bet darbo neišsaugo ir nekartoja.

Async keičia klausytojo darbo būdą. Jis nepaverčia įvykio atmintyje patvaria eile.

## 3. Sekite darbą eilėje

Dabar tarkime, kad išsaugojus užsakymą vėliau būtina sukurti sąskaitą. Eilė leidžia laikyti instrukciją, kai darbuotojai užimti ar nepasiekiami.

```text
[Producer] -> [Durable queue] -> [Available worker]
                    |                   |
              [Pending work]      [Result / retry]
```

Siuntėjas pateikia darbą, darbuotojas atlieka bandymą ir įrašo rezultatą. Darbuotojus galima diegti ir plėsti atskirai nuo API. Patvarumas vis tiek priklauso nuo eilės saugyklos ir nustatymų.

Įprastoje konkuruojančių darbuotojų eilėje kiekvieną bandymą apdoroja vienas darbuotojas. Tai skiriasi nuo įvykio siuntimo visiems EventEmitter klausytojams. Jei keli nepriklausomi prenumeratoriai turi gauti kiekvienas savo įvykį, pasirinkite arba nustatykite tokį pristatymo modelį.

## 4. Patikrinkite tarpą tarp saugojimo ir įtraukimo į eilę

Naudojant EventEmitter gedimas po užsakymo išsaugojimo, bet prieš įvykio siuntimą, gali prarasti sąskaitos instrukciją. Patvari eilė saugo darbą jį priėmusi, tačiau automatiškai nesaugo ankstesnio tarpo tarp bazės patvirtinimo ir pateikimo.

Outbox uždaro tarpą išsaugodamas užsakymą ir instrukciją vienoje bazės transakcijoje. Siuntėjas perskaito outbox ir darbą perduoda vėliau.

Pristatymas gali kartotis siuntėjui praradus patvirtinimą. Sąskaitai suteikite stabilų verslo raktą ir unikalumo apribojimą ar kitą idempotentišką realizaciją. Pakartotas bandymas neturi sukurti antros sąskaitos. [Idempotentiški darbai](https://docs.bullmq.io/patterns/idempotent-jobs).

## 5. Palyginkite su tikru poreikiu

| Reikalavimas | EventEmitter | Patvari darbų eilė |
| --- | --- | --- |
| Pranešti komponentams viename procese | Tiesioginis ir lengvas | Dažniausiai prideda nereikalingą infrastruktūrą. |
| Išlaikyti darbą siuntėjui sustojus | Nėra įgimto patvaraus įrašo | Galima su tinkamu saugojimu ir atkūrimu. |
| Kartoti ir tikrinti susikaupusį darbą | Turi sukurti programa | Įprastos eilės funkcijos, kurias reikia nustatyti. |
| Vykdyti kitose mašinose | Ne jo paskirtis | Darbuotojai gali veikti nepriklausomai. |

Inicializavimui rinkčiausi EventEmitter. Sąskaitoms, kurios turi atsigauti po gedimo, — patvarią eilę, sutvarkydamas perdavimą iš bazės ir pasikartojančius bandymus.

Bandykite stabdyti procesą svarbiose ribose: prieš pateikimą, po priėmimo ir po verslo poveikio. Rezultatas turi atitikti naudotojui žadamą garantiją.

**Prisiminkite:** vietinis pranešimas → EventEmitter; atkuriamas foninis darbas → patvari eilė. Kritiniams poveikiams suprojektuokite ir perdavimą, ir idempotentiškumą.

Reikalavimas	EventEmitter	Patvari darbų eilė
Pranešti komponentams viename procese	Tiesioginis ir lengvas	Dažniausiai prideda nereikalingą infrastruktūrą.
Išlaikyti darbą siuntėjui sustojus	Nėra įgimto patvaraus įrašo	Galima su tinkamu saugojimu ir atkūrimu.
Kartoti ir tikrinti susikaupusį darbą	Turi sukurti programa	Įprastos eilės funkcijos, kurias reikia nustatyti.
Vykdyti kitose mašinose	Ne jo paskirtis	Darbuotojai gali veikti nepriklausomai.

1. Sekite vietinį pranešimą

2. Supraskite async klausytojo poveikį

3. Sekite darbą eilėje

4. Patikrinkite tarpą tarp saugojimo ir įtraukimo į eilę

5. Palyginkite su tikru poreikiu

Susiję klausimai