Apa perbedaan EventEmitter dan antrean job di Node.js?

Question

IT Interview Practice · Accepted Answer

Pilih antara EventEmitter dan antrean job dengan menanyakan **di mana pekerjaan harus berjalan dan apa yang terjadi jika proses berhenti**.

EventEmitter memberi tahu listener dalam satu proses Node.js. Antrean yang tahan lama menyimpan pekerjaan untuk diproses worker kemudian. Keduanya memisahkan tanggung jawab, tetapi perilakunya saat gagal berbeda.

## 1. Ikuti alur notifikasi lokal

Misalnya sebuah komponen selesai melakukan inisialisasi dan ingin komponen lain dalam proses yang sama merespons. EventEmitter cocok untuk ini: daftarkan listener, lalu emit event.

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

Node.js memanggil listener yang terdaftar secara sinkron sesuai urutan pendaftaran. Event tidak disimpan untuk listener yang baru mendaftar kemudian, dan pekerjaan yang belum selesai tidak bertahan ketika proses gagal. [Events Node.js](https://nodejs.org/api/events.html).

Ini sesuai ketika notifikasi bersifat lokal dan boleh hilang atau dapat dibuat ulang. Mekanisme tersebut tidak cukup ketika bisnis mengharapkan pekerjaan tetap ada setelah pengirim berhenti.

## 2. Pahami pengaruh listener async

Listener async dapat memulai pekerjaan asinkron, tetapi emit tidak menunggu promise yang dikembalikannya. Karena itu, urutan pemanggilan belum tentu sama dengan urutan penyelesaian.

Kode sinkron yang berat pada CPU di dalam listener tetap menahan proses. Tangani error yang dilempar dan promise yang ditolak secara sengaja; captureRejections dapat mengarahkan penolakan ke penanganan error, tetapi tidak menyimpan atau mencoba ulang tugas.

Penambahan async mengubah cara listener mengerjakan tugas. Itu tidak mengubah event dalam memori menjadi antrean yang tahan lama.

## 3. Ikuti alur tugas dalam antrean

Sekarang bayangkan penyimpanan pesanan harus diikuti pembuatan faktur. Antrean menyediakan tempat untuk menyimpan instruksi ketika worker tidak tersedia atau sedang sibuk.

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

Producer mengirim job; worker memproses satu percobaan dan mencatat hasilnya. Worker dapat di-deploy dan ditambah terpisah dari API. Ketahanan data tetap bergantung pada penyimpanan dan konfigurasi antrean.

Dalam antrean dengan worker yang saling berbagi pekerjaan, satu worker menangani setiap percobaan. Ini berbeda dari menyiarkan event ke seluruh listener EventEmitter. Jika beberapa subscriber independen masing-masing membutuhkan event tersebut, pilih atau atur model pengiriman yang mendukung kebutuhan itu.

## 4. Periksa celah antara penyimpanan dan pengiriman ke antrean

Dengan EventEmitter, kegagalan setelah pesanan disimpan tetapi sebelum event dikirim dapat menghilangkan instruksi faktur. Antrean tahan lama melindungi job setelah menerimanya, tetapi tidak otomatis melindungi celah sebelumnya antara commit database dan pengiriman job.

Outbox menutup celah itu dengan menyimpan pesanan dan instruksinya dalam transaksi database yang sama. Publisher membaca outbox dan mengirim job kemudian.

Pengiriman dapat berulang jika publisher kehilangan konfirmasi. Berikan kunci bisnis yang stabil pada pembuatan faktur dan gunakan constraint unik atau implementasi idempoten lain. Mengulang percobaan tidak boleh membuat faktur kedua. [Job idempoten](https://docs.bullmq.io/patterns/idempotent-jobs).

## 5. Bandingkan pilihan dengan kebutuhan sebenarnya

| Kebutuhan | EventEmitter | Antrean job tahan lama |
| --- | --- | --- |
| Memberi tahu komponen dalam satu proses | Langsung dan ringan | Biasanya menambah infrastruktur yang tidak diperlukan. |
| Mempertahankan pekerjaan setelah pengirim berhenti | Tidak memiliki catatan tahan lama bawaan | Dapat dilakukan dengan penyimpanan dan pemulihan yang sesuai. |
| Mencoba ulang dan memeriksa pekerjaan yang menumpuk | Aplikasi harus membangunnya | Kemampuan umum antrean, dengan konfigurasi. |
| Menjalankan pekerjaan pada mesin lain | Bukan perannya | Worker dapat berjalan secara independen. |

Untuk contoh inisialisasi, saya akan menggunakan EventEmitter. Untuk pembuatan faktur yang harus pulih dari kegagalan, saya akan menggunakan antrean tahan lama serta menangani perpindahan dari database dan percobaan berulang.

Uji dengan menghentikan proses pada batas penting: sebelum pengiriman, setelah penerimaan, dan setelah efek bisnis terjadi. Hasilnya harus sesuai dengan jaminan yang diharapkan pengguna.

**Ingat:** notifikasi lokal → EventEmitter; pekerjaan latar belakang yang dapat dipulihkan → antrean tahan lama. Untuk efek penting, rancang juga perpindahan pekerjaan dan idempotensinya.

Kebutuhan	EventEmitter	Antrean job tahan lama
Memberi tahu komponen dalam satu proses	Langsung dan ringan	Biasanya menambah infrastruktur yang tidak diperlukan.
Mempertahankan pekerjaan setelah pengirim berhenti	Tidak memiliki catatan tahan lama bawaan	Dapat dilakukan dengan penyimpanan dan pemulihan yang sesuai.
Mencoba ulang dan memeriksa pekerjaan yang menumpuk	Aplikasi harus membangunnya	Kemampuan umum antrean, dengan konfigurasi.
Menjalankan pekerjaan pada mesin lain	Bukan perannya	Worker dapat berjalan secara independen.

1. Ikuti alur notifikasi lokal

2. Pahami pengaruh listener async

3. Ikuti alur tugas dalam antrean

4. Periksa celah antara penyimpanan dan pengiriman ke antrean

5. Bandingkan pilihan dengan kebutuhan sebenarnya

Pertanyaan terkait