{"id":89150,"date":"2024-12-21T01:51:06","date_gmt":"2024-12-20T22:21:06","guid":{"rendered":"https:\/\/nabfollower.com\/blog\/how-to-prevent-race-conditions-in-a-nodejs-system-using-mutexes-and-rabbitmq-3mkn\/"},"modified":"2024-12-21T01:51:06","modified_gmt":"2024-12-20T22:21:06","slug":"how-to-prevent-race-conditions-in-a-nodejs-system-using-mutexes-and-rabbitmq-3mkn","status":"publish","type":"post","link":"https:\/\/nabfollower.com\/blog\/how-to-prevent-race-conditions-in-a-nodejs-system-using-mutexes-and-rabbitmq-3mkn\/","title":{"rendered":"\u0646\u062d\u0648\u0647 \u062c\u0644\u0648\u06af\u06cc\u0631\u06cc \u0627\u0632 \u0634\u0631\u0627\u06cc\u0637 \u0645\u0633\u0627\u0628\u0642\u0647 \u062f\u0631 \u0633\u06cc\u0633\u062a\u0645 Node.js \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Mutexes \u0648 RabbitMQ"},"content":{"rendered":"

Summarize this content to 400 words in Persian Lang <\/p>\n

\u062f\u0631 \u0633\u06cc\u0633\u062a\u0645 \u0647\u0627\u06cc \u062a\u0648\u0632\u06cc\u0639 \u0634\u062f\u0647\u060c \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u0627\u0632 \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u062f\u0627\u062f\u0647 \u0647\u0627 \u062f\u0631 \u0686\u0646\u062f\u06cc\u0646 \u0641\u0631\u0622\u06cc\u0646\u062f \u0647\u0645\u0632\u0645\u0627\u0646 \u0628\u0633\u06cc\u0627\u0631 \u0645\u0647\u0645 \u0627\u0633\u062a. \u0647\u0646\u06af\u0627\u0645 \u0628\u0631\u062e\u0648\u0631\u062f \u0628\u0627 \u0639\u0645\u0644\u06cc\u0627\u062a \u062d\u0633\u0627\u0633 \u0645\u0627\u0646\u0646\u062f \u0628\u0631\u062f\u0627\u0634\u062a \u062d\u0633\u0627\u0628\u060c \u0634\u0631\u0627\u06cc\u0637 \u0645\u0633\u0627\u0628\u0642\u0647 \u0645\u06cc \u062a\u0648\u0627\u0646\u062f \u0645\u0646\u062c\u0631 \u0628\u0647 \u062e\u0631\u0627\u0628\u06cc \u062f\u0627\u062f\u0647 \u0647\u0627 \u06cc\u0627 \u0627\u062e\u062a\u0644\u0627\u0641\u0627\u062a \u0645\u0627\u0644\u06cc \u0634\u0648\u062f. \u0627\u06cc\u0646 \u0645\u0642\u0627\u0644\u0647 \u0646\u062d\u0648\u0647 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 mutexes (\u0642\u0641\u0644\u200c\u0647\u0627\u06cc \u062d\u0630\u0641 \u0645\u062a\u0642\u0627\u0628\u0644) \u0628\u0627 RabbitMQ \u0648 Node.js \u0631\u0627 \u0628\u0631\u0627\u06cc \u0645\u062f\u06cc\u0631\u06cc\u062a \u0627\u06cc\u0645\u0646 \u0639\u0645\u0644\u06cc\u0627\u062a \u0647\u0645\u0632\u0645\u0627\u0646 \u0648 \u062f\u0631 \u0639\u06cc\u0646 \u062d\u0627\u0644 \u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0627\u0631\u0622\u0645\u062f \u062d\u0627\u0641\u0638\u0647 \u062a\u0648\u0636\u06cc\u062d \u0645\u06cc\u200c\u062f\u0647\u062f.<\/p>\n

\u0645\u0634\u06a9\u0644<\/p>\n

\u0633\u0646\u0627\u0631\u06cc\u0648\u06cc\u06cc \u0631\u0627 \u062a\u0635\u0648\u0631 \u06a9\u0646\u06cc\u062f \u06a9\u0647 \u062f\u0631 \u0622\u0646 \u0686\u0646\u062f\u06cc\u0646 \u06a9\u0627\u0631\u06af\u0631 RabbitMQ \u062f\u0631\u062e\u0648\u0627\u0633\u062a \u0647\u0627\u06cc \u0628\u0631\u062f\u0627\u0634\u062a \u0627\u0632 \u06cc\u06a9 \u062d\u0633\u0627\u0628 \u0631\u0627 \u0628\u0647 \u0637\u0648\u0631 \u0647\u0645\u0632\u0645\u0627\u0646 \u067e\u0631\u062f\u0627\u0632\u0634 \u0645\u06cc \u06a9\u0646\u0646\u062f. \u0628\u062f\u0648\u0646 \u0647\u0645\u06af\u0627\u0645 \u0633\u0627\u0632\u06cc \u0645\u0646\u0627\u0633\u0628\u060c \u062f\u0648 \u06a9\u0627\u0631\u06af\u0631 \u0645\u0645\u06a9\u0646 \u0627\u0633\u062a \u0645\u0648\u062c\u0648\u062f\u06cc \u0627\u0648\u0644\u06cc\u0647 \u06cc\u06a9\u0633\u0627\u0646\u06cc \u0631\u0627 \u0628\u062e\u0648\u0627\u0646\u0646\u062f\u060c \u0645\u0628\u0627\u0644\u063a \u0645\u062a\u0641\u0627\u0648\u062a\u06cc \u0631\u0627 \u06a9\u0645 \u06a9\u0646\u0646\u062f \u0648 \u0633\u067e\u0633 \u062d\u0633\u0627\u0628 \u0631\u0627 \u0628\u0647 \u0631\u0648\u0632 \u06a9\u0646\u0646\u062f \u06a9\u0647 \u0645\u0646\u062c\u0631 \u0628\u0647 \u0645\u0648\u062c\u0648\u062f\u06cc \u0646\u0627\u062f\u0631\u0633\u062a \u0634\u0648\u062f.<\/p>\n

\u0645\u062b\u0627\u0644 \u0634\u0631\u0627\u06cc\u0637 \u0645\u0633\u0627\u0628\u0642\u0647:<\/p>\n

\u0645\u0648\u062c\u0648\u062f\u06cc \u0627\u0648\u0644\u06cc\u0647: 1000 \u062f\u0644\u0627\u0631
\n\u06a9\u0627\u0631\u06af\u0631 A \u0645\u0648\u062c\u0648\u062f\u06cc \u0631\u0627 \u0645\u06cc \u062e\u0648\u0627\u0646\u062f: 1000 \u062f\u0644\u0627\u0631
\n\u06a9\u0627\u0631\u06af\u0631 B \u0645\u0648\u062c\u0648\u062f\u06cc \u0631\u0627 \u0645\u06cc \u062e\u0648\u0627\u0646\u062f: 1000 \u062f\u0644\u0627\u0631
\n\u06a9\u0627\u0631\u06af\u0631 A 300 \u062f\u0644\u0627\u0631 \u0631\u0627 \u06a9\u0645 \u0645\u06cc \u06a9\u0646\u062f \u0648 \u0645\u0648\u062c\u0648\u062f\u06cc \u0631\u0627 \u0628\u0647 \u0631\u0648\u0632 \u0645\u06cc \u06a9\u0646\u062f: 700 \u062f\u0644\u0627\u0631
\n\u06a9\u0627\u0631\u06af\u0631 B 200 \u062f\u0644\u0627\u0631 \u0631\u0627 \u06a9\u0645 \u0645\u06cc \u06a9\u0646\u062f \u0648 \u0645\u0648\u062c\u0648\u062f\u06cc \u0631\u0627 \u0628\u0647 \u0631\u0648\u0632 \u0645\u06cc \u06a9\u0646\u062f: 800 \u062f\u0644\u0627\u0631 (\u0631\u0648\u0646\u0648\u06cc\u0633\u06cc \u0628\u0647 \u0631\u0648\u0632 \u0631\u0633\u0627\u0646\u06cc \u06a9\u0627\u0631\u06af\u0631 A)<\/p>\n

\u0645\u0648\u062c\u0648\u062f\u06cc \u0646\u0647\u0627\u06cc\u06cc: 800 \u062f\u0644\u0627\u0631 (\u0628\u0627\u06cc\u062f 500 \u062f\u0644\u0627\u0631 \u0628\u0648\u062f).<\/p>\n

\u0631\u0627\u0647 \u062d\u0644: \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Mutexes<\/p>\n

\u06cc\u06a9 mutex \u062a\u0636\u0645\u06cc\u0646 \u0645\u06cc \u06a9\u0646\u062f \u06a9\u0647 \u0641\u0642\u0637 \u06cc\u06a9 \u06a9\u0627\u0631\u06af\u0631 \u0645\u06cc \u062a\u0648\u0627\u0646\u062f \u062f\u0631 \u0647\u0631 \u0632\u0645\u0627\u0646 \u0639\u0645\u0644\u06cc\u0627\u062a \u0631\u0648\u06cc \u06cc\u06a9 \u062d\u0633\u0627\u0628 \u062e\u0627\u0635 \u0631\u0627 \u067e\u0631\u062f\u0627\u0632\u0634 \u06a9\u0646\u062f. \u062f\u0631 \u0627\u06cc\u0646\u062c\u0627 \u0646\u062d\u0648\u0647 \u067e\u06cc\u0627\u062f\u0647 \u0633\u0627\u0632\u06cc \u0631\u0627\u0647 \u062d\u0644 \u0645\u0628\u062a\u0646\u06cc \u0628\u0631 mutex \u062f\u0631 \u0633\u06cc\u0633\u062a\u0645 Node.js \u0645\u0628\u062a\u0646\u06cc \u0628\u0631 RabbitMQ \u0622\u0645\u062f\u0647 \u0627\u0633\u062a.<\/p>\n

\u067e\u06cc\u0627\u062f\u0647 \u0633\u0627\u0632\u06cc \u06af\u0627\u0645 \u0628\u0647 \u06af\u0627\u0645<\/p>\n

\u067e\u06cc\u0634 \u0646\u06cc\u0627\u0632\u0647\u0627<\/p>\n

\u0628\u0633\u062a\u0647 \u0647\u0627\u06cc \u0644\u0627\u0632\u0645 \u0631\u0627 \u0646\u0635\u0628 \u06a9\u0646\u06cc\u062f:<\/p>\n

npm install async-mutex amqplib<\/p>\n

\u0648\u0627\u0631\u062f \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0634\u0648\u06cc\u062f<\/p>\n

\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/p>\n

async-mutex: \u06cc\u06a9 mutex \u0628\u0627 \u06a9\u0627\u0631\u0628\u0631\u06cc \u0622\u0633\u0627\u0646 \u0628\u0631\u0627\u06cc \u0639\u0645\u0644\u06cc\u0627\u062a \u0646\u0627\u0647\u0645\u0632\u0645\u0627\u0646 \u0627\u0631\u0627\u0626\u0647 \u0645\u06cc \u062f\u0647\u062f.
\namqplib: \u062a\u0639\u0627\u0645\u0644 \u0628\u0627 RabbitMQ \u0631\u0627 \u0641\u0639\u0627\u0644 \u0645\u06cc \u06a9\u0646\u062f.<\/p>\n

\u067e\u06cc\u0627\u062f\u0647 \u0633\u0627\u0632\u06cc \u06a9\u062f<\/p>\n

\u062f\u0631 \u0632\u06cc\u0631 \u0627\u062c\u0631\u0627\u06cc \u06a9\u0627\u0645\u0644\u060c \u0627\u0632 \u062c\u0645\u0644\u0647 \u0645\u062f\u06cc\u0631\u06cc\u062a \u062d\u0627\u0641\u0638\u0647 \u0642\u0648\u06cc \u0628\u0631\u0627\u06cc \u067e\u0627\u06a9\u0633\u0627\u0632\u06cc mutex \u0622\u0648\u0631\u062f\u0647 \u0634\u062f\u0647 \u0627\u0633\u062a.<\/p>\n

\u0627\u0644\u0641 \u0645\u062f\u06cc\u0631\u06cc\u062a \u0645\u0648\u062a\u06a9\u0633<\/p>\n

\u0645\u0627 \u0627\u0632 \u0646\u0642\u0634\u0647 \u0628\u0631\u0627\u06cc \u062d\u0641\u0638 mutexes \u062f\u0631 \u0647\u0631 \u062d\u0633\u0627\u0628 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0645\u06cc \u06a9\u0646\u06cc\u0645. Mutexe \u0647\u0627 \u062f\u0631 \u0635\u0648\u0631\u062a \u062f\u0631\u062e\u0648\u0627\u0633\u062a \u0627\u06cc\u062c\u0627\u062f \u0645\u06cc \u0634\u0648\u0646\u062f \u0648 \u0632\u0645\u0627\u0646\u06cc \u06a9\u0647 \u062f\u06cc\u06af\u0631 \u0645\u0648\u0631\u062f \u0646\u06cc\u0627\u0632 \u0646\u06cc\u0633\u062a\u0646\u062f \u062d\u0630\u0641 \u0645\u06cc \u0634\u0648\u0646\u062f.<\/p>\n

\u0628 \u0628\u0647\u06cc\u0646\u0647 \u0633\u0627\u0632\u06cc \u062d\u0627\u0641\u0638\u0647<\/p>\n

\u0628\u0631\u0627\u06cc \u062c\u0644\u0648\u06af\u06cc\u0631\u06cc \u0627\u0632 \u0646\u0641\u062e \u062d\u0627\u0641\u0638\u0647\u060c \u0645\u0627 \u0627\u062c\u0631\u0627 \u0645\u06cc \u06a9\u0646\u06cc\u0645:<\/p>\n

Idle Timeouts: \u067e\u0633 \u0627\u0632 5 \u062f\u0642\u06cc\u0642\u0647 mutexe\u0647\u0627 \u0631\u0627 \u0628\u0631\u0627\u06cc \u062d\u0633\u0627\u0628 \u0647\u0627\u06cc \u063a\u06cc\u0631\u0641\u0639\u0627\u0644 \u0628\u0647 \u0637\u0648\u0631 \u062e\u0648\u062f\u06a9\u0627\u0631 \u062d\u0630\u0641 \u06a9\u0646\u06cc\u062f.
\n\u067e\u0627\u06a9\u0633\u0627\u0632\u06cc \u062f\u0648\u0631\u0647 \u0627\u06cc: \u06cc\u06a9 \u0641\u0631\u0622\u06cc\u0646\u062f \u067e\u0633 \u0632\u0645\u06cc\u0646\u0647 \u062a\u0636\u0645\u06cc\u0646 \u0645\u06cc \u06a9\u0646\u062f \u06a9\u0647 mutexe\u0647\u0627\u06cc \u0642\u062f\u06cc\u0645\u06cc \u0647\u0631 1 \u062f\u0642\u06cc\u0642\u0647 \u062d\u0630\u0641 \u0645\u06cc \u0634\u0648\u0646\u062f.<\/p>\n

\u062c \u067e\u06cc\u0627\u062f\u0647 \u0633\u0627\u0632\u06cc \u06a9\u0627\u0645\u0644<\/p>\n

const { Mutex } = require(‘async-mutex’);
\nconst amqp = require(‘amqplib’);<\/p>\n

\/\/ Mutex for account operations with automatic cleanup
\nconst accountMutexes = new Map(); \/\/ Store one mutex per account
\nconst accountTimeouts = new Map(); \/\/ Store timeout references for cleanup
\nconst CLEANUP_INTERVAL_MS = 60000; \/\/ 1-minute cleanup interval
\nconst IDLE_TIMEOUT_MS = 300000; \/\/ 5-minute idle timeout per account<\/p>\n

\/\/ Function to get or create a mutex for a specific account
\nfunction getAccountMutex(accountId) {
\n if (!accountMutexes.has(accountId)) {
\n const mutex = new Mutex();
\n accountMutexes.set(accountId, mutex);
\n resetAccountTimeout(accountId); \/\/ Start idle timeout cleanup
\n }
\n return accountMutexes.get(accountId);
\n}<\/p>\n

\/\/ Function to reset idle timeout for an account
\nfunction resetAccountTimeout(accountId) {
\n if (accountTimeouts.has(accountId)) {
\n clearTimeout(accountTimeouts.get(accountId));
\n }<\/p>\n

const timeout = setTimeout(() => {
\n accountMutexes.delete(accountId);
\n accountTimeouts.delete(accountId);
\n console.log(`Mutex for account ${accountId} removed due to inactivity.`);
\n }, IDLE_TIMEOUT_MS);<\/p>\n

accountTimeouts.set(accountId, timeout);
\n}<\/p>\n

\/\/ Periodic cleanup process
\nfunction startPeriodicCleanup() {
\n setInterval(() => {
\n accountTimeouts.forEach((_, accountId) => {
\n if (!accountMutexes.has(accountId)) {
\n accountTimeouts.delete(accountId);
\n }
\n });
\n }, CLEANUP_INTERVAL_MS);<\/p>\n

console.log(`Periodic cleanup started: checking every ${CLEANUP_INTERVAL_MS \/ 1000} seconds.`);
\n}<\/p>\n

\/\/ Simulated database of accounts
\nconst accounts = {
\n “123”: { balance: 1000 },
\n “456”: { balance: 2000 },
\n};<\/p>\n

\/\/ Process withdrawal
\nasync function processWithdrawal(accountId, amount) {
\n const mutex = getAccountMutex(accountId);
\n const release = await mutex.acquire();<\/p>\n

try {
\n console.log(`Processing withdrawal for account ${accountId}`);
\n const account = accounts[accountId];<\/p>\n

if (!account) {
\n throw new Error(‘Account not found’);
\n }<\/p>\n

if (account.balance < amount) {
\n throw new Error(‘Insufficient funds’);
\n }<\/p>\n

account.balance -= amount;
\n console.log(`Withdrawal successful! New balance for account ${accountId}: ${account.balance}`);
\n } catch (error) {
\n console.error(`Error processing withdrawal for account ${accountId}:`, error.message);
\n } finally {
\n release();
\n resetAccountTimeout(accountId);
\n }
\n}<\/p>\n

\/\/ RabbitMQ message handler
\nasync function handleMessage(message) {
\n const { accountId, amount } = JSON.parse(message.content.toString());
\n await processWithdrawal(accountId, amount);
\n}<\/p>\n

\/\/ Connect to RabbitMQ and consume messages
\n(async () => {
\n const connection = await amqp.connect(‘amqp:\/\/localhost’);
\n const channel = await connection.createChannel();<\/p>\n

const queueName = ‘withdrawals’;
\n await channel.assertQueue(queueName, { durable: true });<\/p>\n

console.log(`Waiting for messages in queue: ${queueName}`);<\/p>\n

channel.consume(queueName, async (msg) => {
\n if (msg) {
\n await handleMessage(msg);
\n channel.ack(msg); \/\/ Acknowledge message after processing
\n }
\n });<\/p>\n

startPeriodicCleanup(); \/\/ Start periodic cleanup
\n})();<\/p>\n

\u0648\u0627\u0631\u062f \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0634\u0648\u06cc\u062f<\/p>\n

\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/p>\n

\u0686\u06af\u0648\u0646\u0647 \u06a9\u0627\u0631 \u0645\u06cc \u06a9\u0646\u062f<\/p>\n

Mutex \u0648\u06cc\u0698\u0647 \u062d\u0633\u0627\u0628:<\/p>\n

\u0647\u0631 \u062d\u0633\u0627\u0628 \u062f\u0627\u0631\u0627\u06cc mutex (accountMutexes) \u062e\u0648\u062f \u0627\u0633\u062a \u06a9\u0647 \u0627\u0645\u06a9\u0627\u0646 \u0647\u0645\u0632\u0645\u0627\u0646\u06cc \u0627\u0645\u0646 \u0631\u0627 \u0628\u0631\u0627\u06cc \u062d\u0633\u0627\u0628 \u0647\u0627\u06cc \u0645\u062e\u062a\u0644\u0641 \u0641\u0631\u0627\u0647\u0645 \u0645\u06cc \u06a9\u0646\u062f.
\nMutexe\u0647\u0627 \u062f\u0631 \u0635\u0648\u0631\u062a \u062f\u0633\u062a\u0631\u0633\u06cc \u0628\u0631\u0627\u06cc \u0627\u0648\u0644\u06cc\u0646 \u0628\u0627\u0631 \u0628\u0647 \u0635\u0648\u0631\u062a \u067e\u0648\u06cc\u0627 \u0627\u06cc\u062c\u0627\u062f \u0645\u06cc \u0634\u0648\u0646\u062f.<\/p>\n

\u0628\u062e\u0634 \u0628\u062d\u0631\u0627\u0646\u06cc:<\/p>\n

\u062a\u0627\u0628\u0639 processWithdrawal mutex \u0631\u0627 \u0642\u0641\u0644 \u0645\u06cc \u06a9\u0646\u062f \u062a\u0627 \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u062d\u0627\u0635\u0644 \u0634\u0648\u062f \u06a9\u0647 \u0641\u0642\u0637 \u06cc\u06a9 \u06a9\u0627\u0631\u06af\u0631 \u0645\u06cc \u062a\u0648\u0627\u0646\u062f \u0645\u0648\u062c\u0648\u062f\u06cc \u062d\u0633\u0627\u0628 \u0631\u0627 \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u062f.<\/p>\n

\u0645\u062f\u06cc\u0631\u06cc\u062a \u062d\u0627\u0641\u0638\u0647:<\/p>\n

Idle Timeout: mutexes \u0631\u0627 \u067e\u0633 \u0627\u0632 5 \u062f\u0642\u06cc\u0642\u0647 \u0639\u062f\u0645 \u0641\u0639\u0627\u0644\u06cc\u062a \u062d\u0630\u0641 \u0645\u06cc \u06a9\u0646\u062f.
\n\u067e\u0627\u06a9\u0633\u0627\u0632\u06cc \u062f\u0648\u0631\u0647\u200c\u0627\u06cc: \u06cc\u06a9 \u0641\u0631\u0622\u06cc\u0646\u062f \u067e\u0633\u200c\u0632\u0645\u06cc\u0646\u0647 \u0647\u0631 \u062f\u0642\u06cc\u0642\u0647 \u0627\u062c\u0631\u0627 \u0645\u06cc\u200c\u0634\u0648\u062f \u062a\u0627 mutexe\u200c\u0647\u0627\u06cc \u0642\u062f\u06cc\u0645\u06cc \u06cc\u0627 \u0628\u06cc\u200c\u0627\u0631\u062c\u0627\u0639 \u0631\u0627 \u067e\u0627\u06a9 \u06a9\u0646\u062f.<\/p>\n

\u0645\u0632\u0627\u06cc\u0627<\/p>\n

\u067e\u06cc\u0634\u06af\u06cc\u0631\u06cc \u0627\u0632 \u0634\u0631\u0627\u06cc\u0637 \u0645\u0633\u0627\u0628\u0642\u0647:<\/p>\n

\u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u062d\u0627\u0635\u0644 \u0645\u06cc \u06a9\u0646\u062f \u06a9\u0647 \u0641\u0642\u0637 \u06cc\u06a9 \u06a9\u0627\u0631\u06af\u0631 \u062f\u0631 \u06cc\u06a9 \u0632\u0645\u0627\u0646 \u0628\u0631\u062f\u0627\u0634\u062a \u0647\u0627\u06cc \u062d\u0633\u0627\u0628 \u0645\u0639\u06cc\u0646 \u0631\u0627 \u067e\u0631\u062f\u0627\u0632\u0634 \u0645\u06cc \u06a9\u0646\u062f.<\/p>\n

\u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0627\u0631\u0622\u0645\u062f \u062d\u0627\u0641\u0638\u0647:<\/p>\n

\u0628\u0647 \u0637\u0648\u0631 \u062e\u0648\u062f\u06a9\u0627\u0631 mutexe \u0647\u0627 \u0631\u0627 \u0628\u0631\u0627\u06cc \u062d\u0633\u0627\u0628 \u0647\u0627\u06cc \u063a\u06cc\u0631 \u0641\u0639\u0627\u0644 \u062d\u0630\u0641 \u0645\u06cc \u06a9\u0646\u062f \u0648 \u0627\u0632 \u0646\u0641\u062e \u062d\u0627\u0641\u0638\u0647 \u062c\u0644\u0648\u06af\u06cc\u0631\u06cc \u0645\u06cc \u06a9\u0646\u062f.<\/p>\n

\u062a\u0648\u0627\u0646 \u0639\u0645\u0644\u06cc\u0627\u062a\u06cc \u0628\u0627\u0644\u0627:<\/p>\n

\u067e\u0631\u062f\u0627\u0632\u0634 \u0647\u0645\u0632\u0645\u0627\u0646 \u062d\u0633\u0627\u0628\u200c\u0647\u0627\u06cc \u0645\u062e\u062a\u0644\u0641 \u0628\u06cc\u200c\u062a\u0623\u062b\u06cc\u0631 \u0627\u0633\u062a \u0648 \u0645\u0642\u06cc\u0627\u0633\u200c\u067e\u0630\u06cc\u0631\u06cc \u0633\u06cc\u0633\u062a\u0645 \u0631\u0627 \u062d\u0641\u0638 \u0645\u06cc\u200c\u06a9\u0646\u062f.<\/p>\n

\u0645\u062f\u06cc\u0631\u06cc\u062a \u062e\u0637\u0627\u0647\u0627\u06cc \u0642\u0648\u06cc:<\/p>\n

\u0645\u062f\u06cc\u0631\u06cc\u062a \u0635\u062d\u06cc\u062d \u062e\u0637\u0627\u0647\u0627\u06cc \u062d\u0633\u0627\u0628 \u0648 \u0622\u0632\u0627\u062f\u0633\u0627\u0632\u06cc \u0642\u0641\u0644 \u062f\u0631 \u0628\u0644\u0648\u06a9 \u0646\u0647\u0627\u06cc\u06cc \u062a\u0636\u0645\u06cc\u0646 \u0645\u06cc \u06a9\u0646\u062f \u06a9\u0647 \u0633\u06cc\u0633\u062a\u0645 \u062b\u0627\u0628\u062a \u0645\u06cc \u0645\u0627\u0646\u062f.<\/p>\n

\u062e\u0631\u0648\u062c\u06cc \u0646\u0645\u0648\u0646\u0647<\/p>\n

\u067e\u06cc\u0627\u0645 \u0647\u0627\u06cc \u0635\u0641 \u0648\u0631\u0648\u062f\u06cc:<\/p>\n

{ “accountId”: “123”, “amount”: 100 }
\n{ “accountId”: “456”, “amount”: 200 }
\n{ “accountId”: “123”, “amount”: 300 }<\/p>\n

\u0648\u0627\u0631\u062f \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0634\u0648\u06cc\u062f<\/p>\n

\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/p>\n

\u062e\u0631\u0648\u062c\u06cc \u06a9\u0646\u0633\u0648\u0644:<\/p>\n

Waiting for messages in queue: withdrawals
\nPeriodic cleanup started: checking every 60 seconds.
\nProcessing withdrawal for account 123
\nWithdrawal successful! New balance for account 123: 900
\nProcessing withdrawal for account 456
\nWithdrawal successful! New balance for account 456: 1800
\nProcessing withdrawal for account 123
\nWithdrawal successful! New balance for account 123: 600
\nMutex for account 123 removed due to inactivity.
\nMutex for account 456 removed due to inactivity.<\/p>\n

\u0648\u0627\u0631\u062f \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0634\u0648\u06cc\u062f<\/p>\n

\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/p>\n

\u0646\u062a\u06cc\u062c\u0647 \u06af\u06cc\u0631\u06cc<\/p>\n

\u0628\u0627 \u062a\u0631\u06a9\u06cc\u0628 mutexe\u0647\u0627 \u0628\u0627 RabbitMQ\u060c \u0645\u06cc \u062a\u0648\u0627\u0646\u06cc\u062f \u0628\u0627 \u062e\u06cc\u0627\u0644 \u0631\u0627\u062d\u062a \u0639\u0645\u0644\u06cc\u0627\u062a \u0647\u0645\u0632\u0645\u0627\u0646 \u062f\u0631 \u0633\u06cc\u0633\u062a\u0645 \u0647\u0627\u06cc Node.js \u0631\u0627 \u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0646\u06cc\u062f.<\/p>\n

\u0627\u0636\u0627\u0641\u0647 \u06a9\u0631\u062f\u0646 \u0648\u0642\u0641\u0647 \u0647\u0627\u06cc \u0628\u06cc\u06a9\u0627\u0631 \u0648 \u067e\u0627\u06a9\u0633\u0627\u0632\u06cc \u062f\u0648\u0631\u0647 \u0627\u06cc \u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0627\u0631\u0622\u0645\u062f \u062d\u0627\u0641\u0638\u0647 \u0631\u0627 \u062a\u0636\u0645\u06cc\u0646 \u0645\u06cc \u06a9\u0646\u062f \u0648 \u0627\u06cc\u0646 \u0631\u0627\u0647 \u062d\u0644 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0645\u0648\u0627\u0631\u062f \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u062f\u0631 \u062f\u0646\u06cc\u0627\u06cc \u0648\u0627\u0642\u0639\u06cc \u0645\u0642\u06cc\u0627\u0633 \u067e\u0630\u06cc\u0631 \u0648 \u0642\u0648\u06cc \u0645\u06cc \u06a9\u0646\u062f.<\/p>\n

\n
\n

\u062f\u0631 \u0633\u06cc\u0633\u062a\u0645 \u0647\u0627\u06cc \u062a\u0648\u0632\u06cc\u0639 \u0634\u062f\u0647\u060c \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u0627\u0632 \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u062f\u0627\u062f\u0647 \u0647\u0627 \u062f\u0631 \u0686\u0646\u062f\u06cc\u0646 \u0641\u0631\u0622\u06cc\u0646\u062f \u0647\u0645\u0632\u0645\u0627\u0646 \u0628\u0633\u06cc\u0627\u0631 \u0645\u0647\u0645 \u0627\u0633\u062a. \u0647\u0646\u06af\u0627\u0645 \u0628\u0631\u062e\u0648\u0631\u062f \u0628\u0627 \u0639\u0645\u0644\u06cc\u0627\u062a \u062d\u0633\u0627\u0633 \u0645\u0627\u0646\u0646\u062f \u0628\u0631\u062f\u0627\u0634\u062a \u062d\u0633\u0627\u0628\u060c \u0634\u0631\u0627\u06cc\u0637 \u0645\u0633\u0627\u0628\u0642\u0647 \u0645\u06cc \u062a\u0648\u0627\u0646\u062f \u0645\u0646\u062c\u0631 \u0628\u0647 \u062e\u0631\u0627\u0628\u06cc \u062f\u0627\u062f\u0647 \u0647\u0627 \u06cc\u0627 \u0627\u062e\u062a\u0644\u0627\u0641\u0627\u062a \u0645\u0627\u0644\u06cc \u0634\u0648\u062f. \u0627\u06cc\u0646 \u0645\u0642\u0627\u0644\u0647 \u0646\u062d\u0648\u0647 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 mutexes (\u0642\u0641\u0644\u200c\u0647\u0627\u06cc \u062d\u0630\u0641 \u0645\u062a\u0642\u0627\u0628\u0644) \u0628\u0627 RabbitMQ \u0648 Node.js \u0631\u0627 \u0628\u0631\u0627\u06cc \u0645\u062f\u06cc\u0631\u06cc\u062a \u0627\u06cc\u0645\u0646 \u0639\u0645\u0644\u06cc\u0627\u062a \u0647\u0645\u0632\u0645\u0627\u0646 \u0648 \u062f\u0631 \u0639\u06cc\u0646 \u062d\u0627\u0644 \u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0627\u0631\u0622\u0645\u062f \u062d\u0627\u0641\u0638\u0647 \u062a\u0648\u0636\u06cc\u062d \u0645\u06cc\u200c\u062f\u0647\u062f.<\/p>\n<\/blockquote>\n

\n
\n

\u0641\u0647\u0631\u0633\u062a \u0645\u0637\u0627\u0644\u0628<\/p>\nToggle<\/span><\/path><\/svg><\/svg><\/span><\/span><\/span><\/a><\/span><\/div>\n