Kako koordinirati cron opravilo med več vozlišči NestJS?

Question

IT Interview Practice · Accepted Answer

Najprej določite pomen »cronjob izvaja samo eno vozlišče«. **Preprečevanje sočasnega izvajanja in preprečevanje ponovljenega poslovnega učinka sta različni zahtevi.** Skupni razporejevalnik usklajuje izvajanje; sama operacija mora ostati varna po sesutju in ponovitvi.

Vzemimo dnevno izdajanje računov na treh vozliščih NestJS. Želimo izvesti načrtovano delo, ne da bi ob ponovnem zagonu izvajalca nastal še en račun.

## 1. Razumite, zakaj opravilo zaženejo vsa vozlišča

Vsak primerek aplikacije registrira svojo funkcijo cron. Ob načrtovanem času se lahko vsak zažene neodvisno:

```text
00:00 -> Node A -> invoice task
      -> Node B -> invoice task
      -> Node C -> invoice task
```

Lokalna zastavica isRunning obstaja samo v enem procesu. NestJS waitForCompletion lahko prepreči prekrivanje klicev v tem primerku, ne uskladi pa drugih vozlišč. Enaka zastavica na vseh treh vozliščih še vedno pomeni tri ločene odločitve. [Načrtovanje NestJS](https://docs.nestjs.com/techniques/task-scheduling).

Zato potrebujemo skupno mesto, ki določi, katero delo obstaja in kdo ga sme obdelati.

## 2. Izberite model usklajevanja

| Primer | Možnost za oceno | Preostala odgovornost |
| --- | --- | --- |
| Platforma že ponuja načrtovana opravila | Načrtovanje izvajajte zunaj spletnih primerkov | Nastavite prekrivanje, obnovo in izpuščene zagone. |
| Ekipa že upravlja BullMQ | Skupni Job Scheduler in namenska vrsta | Nastavite skupno sočasnost in varne ponovitve. |
| Obstoječe opravilo mora ostati na vozliščih aplikacije | Skupni zaklep ali časovno omejen najem | Pravilno obravnavajte lastništvo, potek in zastarele izvajalce. |

Pri računih je skupni razporejevalnik s stabilnim ID-jem praktična možnost, če Redis in BullMQ že obstajata. Razpored ločite od izvajalcev, da dodajanje spletnih vozlišč ne ustvarja neodvisnih razporedov.

V podprti različici BullMQ nastavite globalno sočasnost namenske vrste na ena. To omeji aktivna opravila med izvajalci; lokalna sočasnost ena pri vsakem še vedno omogoča, da več izvajalcev obdeluje različna opravila. [Globalna sočasnost](https://docs.bullmq.io/guide/queues/global-concurrency).

Odločite se, kaj narediti, če včerajšnje delo še teče: počakati, preskočiti ali združiti izvedbe. Določite časovni pas in ali je treba po izpadu nadoknaditi izpuščene poslovne datume.

## 3. Zaščitite račun, ne samo opravila

Recimo, da izvajalec ustvari račun in se sesuje pred zapisom zaključka opravila. Obnova lahko opravilo ponovi, čeprav račun že obstaja.

```text
[Create invoice] -> [Crash before completion]
                              |
                            [Retry]
                              |
                  [Same business key: reuse result]
```

Uporabite stabilen poslovni ključ, na primer stranko in obračunsko obdobje. Pri lokalni bazi lahko omejitev enoličnosti in transakcija povežeta izdelavo računa z zapisom končane izvedbe. Ponovitev nato najde obstoječi rezultat, namesto da ustvari nov račun.

Pri zunanjem ponudniku uporabite njegov ključ idempotentnosti, kadar ga podpira, in uskladite negotove izide. Sam ID opravila ali ohranjen zapis o njem ni trajno jamstvo, da se poslovno dejanje ne more ponoviti. [Idempotentna opravila](https://docs.bullmq.io/patterns/idempotent-jobs).

## 4. Spoznajte jamstva in omejitve zaklepa

Skupni zaklep je treba pridobiti atomsko. Uporabite žeton lastništva, veljavnost in obnavljanje; sprostite ga samo, če se žeton še ujema. Sicer bi star izvajalec lahko sprostil zaklep novega.

Potek ustvari drug primer: ustavljen izvajalec nadaljuje po izteku najema, ko novi že teče. Kritični zapisi lahko potrebujejo fencing tokens, naraščajoče številke lastništva, ki jih cilj preveri in zavrne zastarele izvajalce. Zgolj dolg timeout tveganja ne odpravi.

Če usklajevanje ni na voljo, določite, ali opravilo počaka, namesto da teče brez lastništva. Pri pomembnih posledicah je to pogosto varnejše.

## 5. Preverite odpovedne scenarije

Testirajte več vozlišč, sesutje po izdelavi računa, premor daljši od najema, izgubo povezave Redis in postopno namestitev. Beležite poslovni datum, izvajalca, poskus in izid, da ločite ponovljene poskuse od ponovljenih učinkov.

**Zapomnite si:** uskladite razpored → omejite skupno izvajanje → omogočite varno ponovitev poslovnega dejanja → testirajte obnovo. »Eno aktivno opravilo« samo po sebi ne dokazuje natanko enega poslovnega učinka.

Primer	Možnost za oceno	Preostala odgovornost
Platforma že ponuja načrtovana opravila	Načrtovanje izvajajte zunaj spletnih primerkov	Nastavite prekrivanje, obnovo in izpuščene zagone.
Ekipa že upravlja BullMQ	Skupni Job Scheduler in namenska vrsta	Nastavite skupno sočasnost in varne ponovitve.
Obstoječe opravilo mora ostati na vozliščih aplikacije	Skupni zaklep ali časovno omejen najem	Pravilno obravnavajte lastništvo, potek in zastarele izvajalce.

1. Razumite, zakaj opravilo zaženejo vsa vozlišča

2. Izberite model usklajevanja

3. Zaščitite račun, ne samo opravila

4. Spoznajte jamstva in omejitve zaklepa

5. Preverite odpovedne scenarije

Povezana vprašanja