Πώς διαφέρει το EventEmitter από μια ουρά εργασιών στο Node.js;

Question

IT Interview Practice · Accepted Answer

Επιλέξτε EventEmitter ή ουρά ρωτώντας **πού πρέπει να τρέχει η εργασία και τι συμβαίνει όταν σταματά η διεργασία**.

Το EventEmitter ειδοποιεί listeners σε μία διεργασία Node.js. Μια μόνιμη ουρά κρατά εργασία για μεταγενέστερους workers. Και τα δύο χωρίζουν ευθύνες, αλλά έχουν διαφορετική συμπεριφορά αποτυχίας.

## 1. Ακολουθήστε μια τοπική ειδοποίηση

Ένα component ολοκληρώνει αρχικοποίηση και θέλει αντίδραση άλλων components στην ίδια διεργασία. Το EventEmitter ταιριάζει: καταχωρίζετε listeners και εκπέμπετε το event.

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

Το Node.js καλεί listeners συγχρονισμένα με τη σειρά καταχώρισης. Το event δεν αποθηκεύεται για μεταγενέστερους listeners και η ημιτελής εργασία χάνεται σε πτώση διεργασίας. [Node.js Events](https://nodejs.org/api/events.html).

Αυτό λειτουργεί για τοπική ειδοποίηση που μπορεί να χαθεί ή να ανακατασκευαστεί. Δεν επαρκεί όταν η εργασία πρέπει να επιβιώσει του αποστολέα.

## 2. Καταλάβετε τι αλλάζει ένας async listener

Ένας async listener ξεκινά ασύγχρονη εργασία, αλλά το emit δεν περιμένει το promise του. Η σειρά κλήσης επομένως δεν είναι απαραίτητα σειρά ολοκλήρωσης.

Βαρύς συγχρονισμένος υπολογισμός μέσα του εξακολουθεί να καθυστερεί τη διεργασία. Αντιμετωπίστε σκόπιμα exceptions και rejected promises· το captureRejections τα κατευθύνει σε χειρισμό σφαλμάτων, δεν αποθηκεύει ούτε επαναλαμβάνει την εργασία.

Το async αλλάζει τον τρόπο λειτουργίας του listener. Δεν μετατρέπει ένα συμβάν μνήμης σε μόνιμη ουρά.

## 3. Ακολουθήστε μια εργασία ουράς

Τώρα η αποθήκευση παραγγελίας πρέπει τελικά να δημιουργεί τιμολόγιο. Η ουρά φυλάσσει την οδηγία όταν workers λείπουν ή είναι απασχολημένοι.

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

Ο producer υποβάλλει job, ο worker επεξεργάζεται προσπάθεια και καταγράφει αποτέλεσμα. Οι workers αναπτύσσονται και κλιμακώνονται ανεξάρτητα από το API. Η ανθεκτικότητα παραμένει συνάρτηση αποθήκευσης και ρυθμίσεων.

Σε τυπική ουρά ανταγωνιστικών workers, ένας χειρίζεται κάθε προσπάθεια. Αυτό διαφέρει από broadcast σε όλους τους listeners. Αν κάθε ανεξάρτητος συνδρομητής χρειάζεται το event, επιλέξτε ή ρυθμίστε αντίστοιχο μοντέλο παράδοσης.

## 4. Ελέγξτε το κενό αποθήκευσης και enqueue

Με EventEmitter, πτώση μετά την αποθήκευση και πριν το emit μπορεί να χάσει την οδηγία τιμολόγησης. Η μόνιμη ουρά προστατεύει αποδεκτό job, όχι αυτόματα το προηγούμενο κενό μεταξύ commit και υποβολής.

Το outbox κλείνει το κενό αποθηκεύοντας παραγγελία και οδηγία στην ίδια συναλλαγή. Publisher διαβάζει το outbox και στέλνει αργότερα.

Αν χαθεί επιβεβαίωση, η παράδοση επαναλαμβάνεται. Δώστε στην τιμολόγηση σταθερό κλειδί και μοναδικό περιορισμό ή άλλη idempotent υλοποίηση. Επανάληψη προσπάθειας δεν πρέπει να δημιουργεί δεύτερο τιμολόγιο. [Idempotent jobs](https://docs.bullmq.io/patterns/idempotent-jobs).

## 5. Συγκρίνετε βάσει πραγματικής ανάγκης

| Απαίτηση | EventEmitter | Μόνιμη ουρά εργασιών |
| --- | --- | --- |
| Ειδοποίηση components μιας διεργασίας | Άμεσο και ελαφρύ | Συνήθως περιττή υποδομή. |
| Διατήρηση εκκρεμούς εργασίας μετά το σταμάτημα | Χωρίς ενσωματωμένη μόνιμη εγγραφή | Εφικτό με κατάλληλη αποθήκευση και ανάκαμψη. |
| Retry και έλεγχος backlog | Πρέπει να υλοποιηθούν στην εφαρμογή | Συνήθεις δυνατότητες ουράς με ρύθμιση. |
| Εκτέλεση σε άλλα μηχανήματα | Δεν είναι ο ρόλος του | Οι workers τρέχουν ανεξάρτητα. |

Για αρχικοποίηση θα χρησιμοποιούσα EventEmitter. Για τιμολόγηση που ανακάμπτει από σφάλματα, μόνιμη ουρά με σωστή παράδοση από τη βάση και αντιμετώπιση διπλών προσπαθειών.

Δοκιμάστε διακοπή πριν την υποβολή, μετά την αποδοχή και μετά την επιχειρησιακή επίδραση. Το αποτέλεσμα πρέπει να συμφωνεί με την εγγύηση προς τον χρήστη.

**Θυμηθείτε:** τοπική ειδοποίηση → EventEmitter· ανακτήσιμη εργασία παρασκηνίου → μόνιμη ουρά. Για κρίσιμες επιδράσεις σχεδιάστε και παράδοση και idempotency.

Απαίτηση	EventEmitter	Μόνιμη ουρά εργασιών
Ειδοποίηση components μιας διεργασίας	Άμεσο και ελαφρύ	Συνήθως περιττή υποδομή.
Διατήρηση εκκρεμούς εργασίας μετά το σταμάτημα	Χωρίς ενσωματωμένη μόνιμη εγγραφή	Εφικτό με κατάλληλη αποθήκευση και ανάκαμψη.
Retry και έλεγχος backlog	Πρέπει να υλοποιηθούν στην εφαρμογή	Συνήθεις δυνατότητες ουράς με ρύθμιση.
Εκτέλεση σε άλλα μηχανήματα	Δεν είναι ο ρόλος του	Οι workers τρέχουν ανεξάρτητα.

1. Ακολουθήστε μια τοπική ειδοποίηση

2. Καταλάβετε τι αλλάζει ένας async listener

3. Ακολουθήστε μια εργασία ουράς

4. Ελέγξτε το κενό αποθήκευσης και enqueue

5. Συγκρίνετε βάσει πραγματικής ανάγκης

Σχετικές ερωτήσεις