Blokady rozproszone i algorytm Redlock
Bezpiecznie koordynuj wyłączny dostęp między instancjami i poznaj ograniczenia blokad rozproszonych
Blokady rozproszone i algorytm Redlock to bezpłatna lekcja Node.js Backend Development Bootcamp na CoddyKit. To lekcja 2 z 4. Możesz przeczytać całą lekcję poniżej za darmo — a potem ćwiczyć ją interaktywnie w przeglądarce z wbudowanym edytorem kodu i tutorem AI dostępnym 24/7. To część ścieżki edukacyjnej Node.js Backend Development Bootcamp, a Twój postęp synchronizuje się między webem a aplikacją CoddyKit. Kurs Node.js Backend Development Bootcamp zawiera 4 lekcji w sumie.
Części tej lekcji nie zostały jeszcze przetłumaczone i są wyświetlane po angielsku.
Why Distributed Locks?
When your Node.js API runs as a single process, a simple in-memory mutex is enough to serialize access to a critical section. But production backends run many instances behind a load balancer, often across multiple machines.
- Two pods may both try to charge the same invoice.
- Two workers may both pick up the same job from a queue.
- Two requests may both regenerate the same expensive cache entry (a cache stampede).
An in-memory lock lives inside one process only — the other instances know nothing about it. To coordinate exclusive access across instances you need a lock that lives in shared external storage, and Redis is a popular home for it.
A First (Naive) Redis Lock
The core primitive is the atomic SET key value NX PX ttl command. NX means "only set if the key does not exist", and PX sets an expiry in milliseconds so the lock auto-releases if the holder crashes.
- If
SETreturnsOK, you acquired the lock. - If it returns
null, someone else holds it.
The value must be a unique random token per acquisition — you will need it later to release safely.
const { createClient } = require('redis');
const crypto = require('crypto');
async function acquire(redis, key, ttlMs) {
const token = crypto.randomUUID();
// NX = set only if absent, PX = expiry in ms
const ok = await redis.set(key, token, { NX: true, PX: ttlMs });
return ok === 'OK' ? token : null;
}
// Usage sketch (needs a running Redis):
// const redis = createClient(); await redis.connect();
// const token = await acquire(redis, 'lock:invoice:42', 10000);
// if (token) { /* do exclusive work */ }Releasing Safely: Check-and-Delete
Releasing is the dangerous part. A naive DEL key can delete someone else's lock: if your work overran the TTL, the lock expired, another instance acquired it, and then your late DEL wipes their lock.
The fix: only delete if the stored value still equals your token. Check-then-delete must be atomic, so we run it as a Lua script — Redis executes scripts without interleaving other commands.
const RELEASE_LUA = `
if redis.call('get', KEYS[1]) == ARGV[1] then
return redis.call('del', KEYS[1])
else
return 0
end`;
async function release(redis, key, token) {
// Returns 1 if we owned and removed it, 0 otherwise
return redis.eval(RELEASE_LUA, { keys: [key], arguments: [token] });
}TTL: The Hardest Tuning Decision
The TTL is a bet on how long your critical section takes.
- Too short and the lock expires mid-work, allowing a second worker in — your mutual exclusion is broken.
- Too long and if a holder crashes, everyone waits the full TTL before anyone can proceed.
Rules of thumb: set the TTL to a few times your p99 critical-section duration, keep the protected work short, and for long tasks use a watchdog that periodically extends the lock instead of a single huge TTL.
Extending a Lock (Watchdog Pattern)
For work whose duration is uncertain, acquire a modest TTL and renew it on a timer while you still hold the lock. Like release, extension must be guarded by your token so you never extend a lock that has already moved on.
The watchdog runs at roughly one third of the TTL, giving you margin against clock jitter and GC pauses.
const EXTEND_LUA = `
if redis.call('get', KEYS[1]) == ARGV[1] then
return redis.call('pexpire', KEYS[1], ARGV[2])
else
return 0
end`;
function startWatchdog(redis, key, token, ttlMs) {
const timer = setInterval(async () => {
const ok = await redis.eval(EXTEND_LUA, {
keys: [key], arguments: [token, String(ttlMs)],
});
if (ok !== 1) clearInterval(timer); // lost the lock; stop renewing
}, Math.floor(ttlMs / 3));
return () => clearInterval(timer);
}Single-Node Redis Is a SPOF
Everything so far assumes one Redis node. That node is a single point of failure, so teams add a replica with failover. But Redis replication is asynchronous, and that quietly breaks mutual exclusion:
- Client A acquires the lock on the master.
- The master crashes before replicating the write to the replica.
- The replica is promoted; it has no record of the lock.
- Client B acquires "the same" lock on the new master.
Now two clients hold the lock simultaneously. The Redlock algorithm was designed to address this failover window.
The Redlock Algorithm
Redlock uses N independent Redis masters (typically 5), with no replication between them. To acquire a lock a client:
- Records the start time, then tries to
SET NX PXthe same key+token on all N nodes, using a short per-node timeout. - Counts successes. The lock is considered acquired only if it got a quorum (N/2 + 1, i.e. 3 of 5) and the total elapsed time is less than the TTL.
- The effective validity = TTL minus elapsed time minus a clock-drift allowance.
If it fails to reach quorum (or runs out of time), it unlocks all nodes and retries after a small random delay.
Using the redlock Library
You rarely implement Redlock by hand. The redlock npm package takes an array of independent Redis clients and exposes using(), which acquires, auto-extends, and releases the lock around your callback.
retryCount/retryDelaycontrol how hard it tries before giving up.using()hands you a signal — checksignal.abortedto detect that the lock was lost mid-work.
const Client = require('ioredis');
const Redlock = require('redlock').default;
const nodes = [
new Client({ host: 'redis-a' }),
new Client({ host: 'redis-b' }),
new Client({ host: 'redis-c' }),
];
const redlock = new Redlock(nodes, {
retryCount: 10,
retryDelay: 200, // ms between attempts
driftFactor: 0.01, // clock-drift allowance
});
async function chargeInvoice(id) {
await redlock.using([`lock:invoice:${id}`], 5000, async (signal) => {
await doCharge(id);
if (signal.aborted) throw signal.error; // lost the lock
});
}Fencing Tokens: The Real Safety Net
Martin Kleppmann's well-known critique: no lock based on timeouts can guarantee safety if a holder is paused (GC, VM stall) past the TTL. The lock expires, another client proceeds, and the paused client wakes up still believing it holds the lock.
The robust defense is a fencing token: a monotonically increasing number issued with each lock grant. The protected resource itself rejects any write carrying a token lower than the highest it has already seen — so a stale, paused writer is fenced out at the destination.
// Resource-side guard: reject writes with a stale fencing token.
function makeFencedStore() {
let highestSeen = 0;
const data = {};
return {
write(key, value, token) {
if (token <= highestSeen) {
throw new Error(`fenced: token ${token} <= ${highestSeen}`);
}
highestSeen = token;
data[key] = value;
return token;
},
};
}
const store = makeFencedStore();
store.write('balance', 100, 33); // ok, token 33
try {
store.write('balance', 999, 32); // stale writer, fenced out
} catch (e) {
console.log(e.message); // fenced: token 32 <= 33
}
console.log('stored:', store.write('balance', 200, 34)); // 34Locks vs. Idempotency
A lock reduces the chance of concurrent execution, but timeouts and failovers mean you can never make it a hard guarantee. Treat the lock as an optimization, not the last line of defense.
- Make the protected operation idempotent — running it twice produces the same result.
- Use database unique constraints or conditional updates (compare-and-set) so a duplicate write fails loudly.
- Use fencing tokens where the resource supports them.
Best practice: lock to avoid wasted work and contention, but design the system so a rare double-execution is still correct.
Do You Even Need Redlock?
Redlock adds operational cost: five independent Redis deployments, careful clock management, and retry tuning. The redis maintainers themselves note that for efficiency use cases (avoid doing the same work twice), a single-node lock is fine — an occasional double-run just wastes a little work.
- Efficiency lock (cache rebuild, dedup): single Redis SET NX PX is enough.
- Correctness lock (money, inventory): don't rely on any timeout lock alone — add idempotency and fencing, regardless of Redlock.
Reach for Redlock only when single-node HA failover is genuinely unacceptable and you cannot fence at the resource.
Quick Check
Test your understanding of distributed locking safety.
Recap
You learned how to coordinate exclusive access across Node.js instances — and where the limits are.
- Acquire with atomic
SET key token NX PX ttl; the token must be unique per acquisition. - Release and extend only via a token-checked Lua script so you never touch someone else's lock; renew long tasks with a watchdog.
- TTL is a tradeoff: too short breaks exclusion, too long delays recovery after a crash.
- Redlock uses a quorum across N independent masters to survive single-node failover, but it is still timeout-based.
- No timeout lock is safe against long pauses — add fencing tokens and idempotency for correctness-critical work.
- Use a single-node lock for efficiency; reserve Redlock for genuine HA needs.
Często zadawane pytania
Czy lekcja „Blokady rozproszone i algorytm Redlock” jest bezpłatna?
Tak — pełny tekst „Blokady rozproszone i algorytm Redlock” jest dostępny za darmo tutaj w sieci. Aby ćwiczyć ją interaktywnie (wbudowany edytor kodu i tutor AI dostępny 24/7) i odblokować resztę kursu Node.js Backend Development Bootcamp, przejdź na CoddyKit PRO. Kurs Node.js Backend Development Bootcamp zawiera 4 lekcji w sumie.
Co nauczysz się w „Blokady rozproszone i algorytm Redlock”?
Bezpiecznie koordynuj wyłączny dostęp między instancjami i poznaj ograniczenia blokad rozproszonych Ćwiczysz Node.js Backend Development Bootcamp z praktycznym kodem, który uruchamiasz bezpośrednio w przeglądarce, a tutor AI dostępny 24/7 odpowiada na Twoje pytania podczas pracy nad lekcją.
Czy potrzebuję doświadczenia, aby zacząć Node.js Backend Development Bootcamp?
Nie wymagamy żadnego doświadczenia. Node.js Backend Development Bootcamp w CoddyKit jest strukturyzowany dla początkujących i zaawansowanych użytkowników, więc możesz zacząć tutaj lub od początku i uczyć się w swoim tempie. To lekcja 2 z 4.
Ile czasu zajmuje lekcja „Blokady rozproszone i algorytm Redlock”?
Większość lekcji CoddyKit trwa około 5–10 minut. Każda lekcja to mały, interaktywny krok, dzięki czemu robisz systematyczne postępy i zawsze wracasz dokładnie do tego samego miejsca — na webie i w aplikacji.
Czy mogę pisać i uruchamiać kod w tej lekcji Node.js Backend Development Bootcamp?
Tak. Każda lekcja Node.js Backend Development Bootcamp zawiera wbudowany edytor kodu, więc piszesz i uruchamiasz prawdziwy kod bezpośrednio w przeglądarce i od razu otrzymujesz sprzężenie zwrotne od AI — bez konfiguracji na komputerze.
Wszystkie lekcje w tym kursie
- Strategie Cache-Aside, Write-Through i TTL
- Blokady rozproszone i algorytm Redlock
- Pub/Sub, strumienie i ograniczanie przepustowości z Redisem
- Zapobieganie lawinom żądań do cache i efektowi thundering herd