Hogyan koordináljunk cron feladatot több NestJS-csomópont között?

Question

IT Interview Practice · Accepted Answer

Először tisztázd, mit jelent, hogy „csak egy csomópont futtatja a cronjobot”. **Az egyidejű végrehajtás és az ismételt üzleti hatás megakadályozása külön követelmény.** A közös ütemező koordinál, de a műveletnek összeomlás és újrapróbálás után is biztonságosnak kell lennie.

Vegyünk három NestJS-csomóponton futó napi számlázást. A feladatnak le kell futnia anélkül, hogy egy worker újraindulása újabb számlát készítene.

## 1. Értsd meg, miért indul el minden csomóponton

Minden alkalmazáspéldány saját cron callbacket regisztrál. Az ütemezett időpontban mind önállóan elindulhat:

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

A helyi isRunning jelző csak egy folyamatban létezik. A NestJS waitForCompletion ott megakadályozhatja az átfedést, de más csomópontokat nem koordinál. Ugyanaz a jelző három helyen továbbra is három külön döntés. [NestJS-ütemezés](https://docs.nestjs.com/techniques/task-scheduling).

Ezért közös hely kell annak eldöntésére, milyen munka létezik és ki dolgozhatja fel.

## 2. Válassz koordinációs modellt

| Helyzet | Értékelendő lehetőség | Megmaradó felelősség |
| --- | --- | --- |
| A platform már ad ütemezett feladatokat | Ütemezés a webpéldányokon kívül | Átfedés, helyreállítás és kimaradt futások beállítása. |
| A csapat már üzemeltet BullMQ-t | Közös Job Scheduler és külön sor | Közös konkurencia és biztonságos ismétlés. |
| A feladatnak az alkalmazáscsomópontokon kell maradnia | Közös zár vagy időkorlátos bérlet | Tulajdonos, lejárat és elavult workerek kezelése. |

Ha Redis és BullMQ már van, stabil ütemezőazonosítójú közös scheduler jó jelölt. Válaszd külön az ütemezést a workerektől, hogy új webcsomópont ne hozzon új önálló ütemezést.

Támogatott BullMQ-verzión a külön sor globális konkurenciáját állítsd egyre. Ez minden worker között korlátozza az aktív feladatokat; workerenként egy helyi konkurencia mellett még többen futhatnak külön feladattal. [Globális konkurencia](https://docs.bullmq.io/guide/queues/global-concurrency).

Döntsd el, mi legyen, ha a tegnapi munka még fut: várakozás, kihagyás vagy összevonás. Rögzítsd az időzónát és a leállás alatt kimaradt üzleti napok pótlását.

## 3. A számlát védd, ne csak a feladatot

Tegyük fel, a worker elkészíti a számlát, majd a befejezés rögzítése előtt összeomlik. A helyreállítás újrafuttathatja a feladatot, noha a számla létezik.

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

Használj stabil üzleti kulcsot, például ügyfél és számlázási időszak. Helyi adatbázisban egyediségi korlát és tranzakció kapcsolhatja össze a számlakészítést a befejezett futással. Az ismétlés így a meglévő eredményt találja meg.

Külső szolgáltatónál használd az idempotenciakulcsát, ha támogatott, és egyeztesd a bizonytalan kimeneteket. A sorbeli feladatazonosító vagy megőrzött feladatrekord önmagában nem tartós garancia az üzleti ismétlés ellen. [Idempotens feladatok](https://docs.bullmq.io/patterns/idempotent-jobs).

## 4. Ismerd a zár garanciáit és korlátait

A közös zárat atomikusan kell megszerezni. Használj tulajdonosi tokent, lejáratot és megújítást; csak egyező tokennel engedd el. Különben a régi worker feloldhatja az új zárát.

A lejárat új esetet teremt: a megállított worker folytatja, miután bérlete lejárt és az új már fut. Kritikus írásokhoz fencing token kellhet: növekvő tulajdonosi szám, amellyel a cél elutasítja az elavult workert. Hosszú timeout önmagában nem szünteti meg a veszélyt.

Ha nincs koordináció, döntsd el, várjon-e a feladat tulajdonjog nélküli futás helyett. Fontos következményű munkánál ez gyakran biztonságosabb.

## 5. Vizsgáld a hibás eseteket

Tesztelj több csomópontot, számlakészítés utáni összeomlást, bérletnél hosszabb szünetet, Redis-kapcsolatvesztést és gördülő telepítést. Rögzíts üzleti dátumot, workert, próbálkozást és eredményt, hogy az ismételt próbát megkülönböztesd az ismételt hatástól.

**Emlékezz:** közös ütemezés → közös végrehajtási korlát → biztonságosan ismételhető üzleti művelet → helyreállítási teszt. Az „egy aktív feladat” nem bizonyít pontosan egy üzleti hatást.

Helyzet	Értékelendő lehetőség	Megmaradó felelősség
A platform már ad ütemezett feladatokat	Ütemezés a webpéldányokon kívül	Átfedés, helyreállítás és kimaradt futások beállítása.
A csapat már üzemeltet BullMQ-t	Közös Job Scheduler és külön sor	Közös konkurencia és biztonságos ismétlés.
A feladatnak az alkalmazáscsomópontokon kell maradnia	Közös zár vagy időkorlátos bérlet	Tulajdonos, lejárat és elavult workerek kezelése.

1. Értsd meg, miért indul el minden csomóponton

2. Válassz koordinációs modellt

3. A számlát védd, ne csak a feladatot

4. Ismerd a zár garanciáit és korlátait

5. Vizsgáld a hibás eseteket

Kapcsolódó kérdések