Miten koordinoit cron-työtä usean NestJS-solmun välillä?

Question

IT Interview Practice · Accepted Answer

Määritä ensin, mitä ”vain yksi solmu suorittaa cronjobin” tarkoittaa. **Samanaikaisen suorituksen ja toistuvan liiketoimintavaikutuksen estäminen ovat eri vaatimuksia.** Yhteinen ajastin koordinoi; toiminnon on oltava turvallinen myös kaatumisen ja uusinnan jälkeen.

Ajatellaan päivittäistä laskutusta kolmella NestJS-solmulla. Työ pitää tehdä ilman uutta laskua workerin käynnistyessä uudelleen.

## 1. Ymmärrä kaikkien solmujen käynnistyminen

Jokainen instanssi rekisteröi oman cron-callbackin. Ajankohtana kukin voi aloittaa itsenäisesti:

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

Paikallinen isRunning on vain yhdessä prosessissa. NestJS waitForCompletion estää päällekkäisyyden samassa instanssissa, ei muilla solmuilla. Kolme lippua ovat edelleen kolme päätöstä. [NestJS-ajastus](https://docs.nestjs.com/techniques/task-scheduling).

Tarvitsemme yhteisen paikan päättämään työstä ja sen suorittajasta.

## 2. Valitse koordinointimalli

| Tilanne | Arvioitava vaihtoehto | Jäljelle jäävä vastuu |
| --- | --- | --- |
| Alusta tarjoaa ajastetut työt | Ajastus web-instanssien ulkopuolelle | Päällekkäisyys, palautus ja väliin jääneet ajot. |
| Tiimi käyttää BullMQ:ta | Yhteinen Job Scheduler ja oma jono | Yhteinen rinnakkaisuus ja turvalliset uusinnat. |
| Työn on pysyttävä sovellussolmuilla | Yhteinen lukko tai lease | Omistajuus, vanheneminen ja vanhat workerit. |

Jos Redis ja BullMQ ovat jo käytössä, vakaan ID:n yhteinen ajastin on käytännöllinen. Erota aikataulu workereista, jotta web-solmun lisäys ei luo uutta itsenäistä aikataulua.

Tuetussa BullMQ-versiossa aseta oman jonon globaali rinnakkaisuus yhteen. Se rajaa aktiiviset työt kaikissa workereissa; paikallinen yksi sallii yhä monien workerien eri työt. [Globaali rinnakkaisuus](https://docs.bullmq.io/guide/queues/global-concurrency).

Päätä odotus, ohitus tai yhdistäminen, jos eilinen työ jatkuu. Määritä aikavyöhyke ja puuttuvien liiketoimintapäivien täydentäminen katkon jälkeen.

## 3. Suojaa laskua, älä vain työtä

Worker voi luoda laskun ja kaatua ennen valmistumismerkintää. Palautus voi toistaa työn laskun jo ollessa olemassa.

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

Käytä vakaata avainta, kuten asiakasta ja laskutuskautta. Yksikäsitteisyysrajoite ja transaktio voivat yhdistää laskun valmistumismerkintään. Uusinta löytää aiemman tuloksen uuden laskun sijaan.

Ulkopuolisella toimittajalla käytä tuettua idempotenssiavainta ja selvitä epävarmat tulokset. Pelkkä job ID tai säilytetty jonotietue ei takaa ikuisesti kertaluonteista liiketoimintavaikutusta. [Idempotentit työt](https://docs.bullmq.io/patterns/idempotent-jobs).

## 4. Tunne lukon rajat

Yhteinen lukko otetaan atomisesti. Käytä omistajatunnusta, vanhenemista ja uusimista; vapauta vain tunnuksen täsmätessä. Muuten vanha worker voisi vapauttaa uuden lukon.

Vanhenemisen jälkeen pysähtynyt worker voi jatkaa uuden jo työskennellessä. Kriittiset kirjoitukset voivat tarvita fencing-tunnuksia: kasvavia omistajanumeroita, joilla kohde hylkää vanhat workerit. Pitkä timeout ei poista riskiä.

Koordinoinnin puuttuessa päätä, odottaako työ vai suorittaako ilman omistajuutta. Odotus on usein turvallisempi merkittäville toimille.

## 5. Testaa virhetilanteet

Kokeile useita solmuja, kaatumista laskun jälkeen, leasea pidempää taukoa, Redis-yhteyskatkoa ja asteittaista julkaisua. Kirjaa päivä, worker, yritys ja tulos erottaaksesi uusintayritykset uusista vaikutuksista.

**Muista:** yhteinen ajastus → yhteisen suorituksen raja → turvallinen liiketoimintauusinta → palautustesti. ”Yksi aktiivinen työ” ei todista täsmälleen yhtä vaikutusta.

Tilanne	Arvioitava vaihtoehto	Jäljelle jäävä vastuu
Alusta tarjoaa ajastetut työt	Ajastus web-instanssien ulkopuolelle	Päällekkäisyys, palautus ja väliin jääneet ajot.
Tiimi käyttää BullMQ:ta	Yhteinen Job Scheduler ja oma jono	Yhteinen rinnakkaisuus ja turvalliset uusinnat.
Työn on pysyttävä sovellussolmuilla	Yhteinen lukko tai lease	Omistajuus, vanheneminen ja vanhat workerit.

1. Ymmärrä kaikkien solmujen käynnistyminen

2. Valitse koordinointimalli

3. Suojaa laskua, älä vain työtä

4. Tunne lukon rajat

5. Testaa virhetilanteet

Aiheeseen liittyvät kysymykset