Jak se v Node.js liší EventEmitter od fronty úloh?

Question

IT Interview Practice · Accepted Answer

Mezi EventEmitter a frontou úloh vybírejte podle toho, **kde práce musí běžet a co se stane při zastavení procesu**.

EventEmitter upozorňuje listenery uvnitř jednoho procesu Node.js. Trvalá fronta ukládá práci pro pozdější zpracování workery. Oba oddělují odpovědnosti, ale jinak se chovají při selhání.

## 1. Sledujte lokální oznámení

Komponenta například dokončí inicializaci a chce vyvolat reakci dalších komponent ve stejném procesu. EventEmitter se hodí přirozeně: zaregistrujete listenery a vyšlete událost.

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

Node.js volá registrované listenery synchronně v pořadí registrace. Událost se neukládá pro pozdější listenery a nedokončená práce nepřežije pád procesu. [Node.js Events](https://nodejs.org/api/events.html).

To vyhovuje lokálnímu oznámení, které lze ztratit nebo zrekonstruovat. Nestačí to, pokud má práce přežít odesílatele.

## 2. Pochopte změnu s async listenerem

Async listener může zahájit asynchronní práci, ale emit nečeká na vrácený promise. Pořadí vyvolání proto nemusí být pořadím dokončení.

Výpočetně náročný synchronní kód v listeneru stále zdržuje proces. Záměrně řešte vyhozené chyby a zamítnuté promises; captureRejections může přesměrovat zamítnutí do zpracování chyb, ale úlohu neukládá ani neopakuje.

Async mění způsob práce listeneru. Neudělá z události v paměti trvalou frontu.

## 3. Sledujte úlohu ve frontě

Předpokládejme nyní, že uložení objednávky musí časem vytvořit fakturu. Fronta uchová instrukci, když jsou workery nedostupné nebo zaneprázdněné.

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

Producent zadá úlohu, worker provede pokus a zapíše výsledek. Workery lze nasazovat a škálovat zvlášť od API. Trvanlivost ovšem závisí na úložišti a konfiguraci fronty.

V obvyklé frontě soutěžících workerů zpracuje každý pokus jeden worker. To se liší od předání události všem listenerům EventEmitter. Pokud událost potřebuje každý z několika nezávislých odběratelů, vyberte nebo nastavte odpovídající model doručení.

## 4. Prověřte mezeru mezi uložením a zařazením

U EventEmitter může pád po uložení objednávky a před emit ztratit instrukci k faktuře. Trvalá fronta chrání přijatou úlohu, ale automaticky nechrání předchozí mezeru mezi databázovým commitem a odesláním.

Outbox tuto mezeru uzavírá uložením objednávky a instrukce v jedné databázové transakci. Publikující proces outbox přečte a později odešle úlohu.

Doručení se může opakovat, pokud publikující proces ztratí potvrzení. Vytváření faktury dejte stabilní obchodní klíč a unikátní omezení nebo jinou idempotentní implementaci. Opakovaný pokus nemá vytvořit druhou fakturu. [Idempotentní úlohy](https://docs.bullmq.io/patterns/idempotent-jobs).

## 5. Porovnejte možnosti se skutečnou potřebou

| Požadavek | EventEmitter | Trvalá fronta úloh |
| --- | --- | --- |
| Oznámit změnu komponentám jednoho procesu | Přímý a lehký | Obvykle zbytečná infrastruktura. |
| Uchovat čekající práci po zastavení odesílatele | Nemá vestavěný trvalý záznam | Možné s vhodným úložištěm a obnovou. |
| Opakovat a sledovat nahromaděnou práci | Musí vytvořit aplikace | Běžné možnosti front, které je nutné nastavit. |
| Spouštět práci na jiných strojích | Není jeho úlohou | Workery mohou běžet nezávisle. |

Pro inicializaci bych použil EventEmitter. Pro fakturaci, která se musí zotavit z chyb, trvalou frontu s vyřešeným předáním z databáze a opakovanými pokusy.

Testujte zastavením procesu na důležitých hranicích: před odesláním, po přijetí a po obchodním účinku. Výsledek má odpovídat očekávané záruce pro uživatele.

**Zapamatujte si:** lokální oznámení → EventEmitter; obnovitelná práce na pozadí → trvalá fronta. U kritických účinků navrhněte také předání a idempotenci.

Požadavek	EventEmitter	Trvalá fronta úloh
Oznámit změnu komponentám jednoho procesu	Přímý a lehký	Obvykle zbytečná infrastruktura.
Uchovat čekající práci po zastavení odesílatele	Nemá vestavěný trvalý záznam	Možné s vhodným úložištěm a obnovou.
Opakovat a sledovat nahromaděnou práci	Musí vytvořit aplikace	Běžné možnosti front, které je nutné nastavit.
Spouštět práci na jiných strojích	Není jeho úlohou	Workery mohou běžet nezávisle.

1. Sledujte lokální oznámení

2. Pochopte změnu s async listenerem

3. Sledujte úlohu ve frontě

4. Prověřte mezeru mezi uložením a zařazením

5. Porovnejte možnosti se skutečnou potřebou

Související otázky