Принудительный одиночный писатель базы данных в узле + Mongo

Question

Я денормализовал некоторые из данных, хранящихся в MongoDB, ради сокращения времени чтения. Это нужно обновлять, когда я выполняю операцию записи, чтобы он соответствовал базовым данным.

Чтобы избежать каких-либо условий гонки, я хочу, чтобы это было сделано в фоновом задании, которое было бы однопоточным. В Java я просто бросаю объекты Command в очередь и обрабатываю их по отдельности. Но в узле, всякий раз, когда я выполняю какую-либо операцию с БД, это произойдет асинхронно, и поэтому я остаюсь с проблемой состояния гонки.

Пример того, что я хочу сделать:

Применение темы

1. Вставить новый "Bid"
2. Поместите объект "BidPlaced" на очереди

фона Нить

1. Pop "BidPlaced"
2. Найти max (Цена) от всех торгов. Обновите Auction.highestBid.

Я все еще склоняюсь к модели параллелизма узла (в случае, если вы не могли сказать!). Как я могу добиться чего-то подобного в Node.js.

Answer 1

У меня есть подобное приложение, где я использую child_process раскошелиться фоновые задания так:

1. Вставить новый «Bid»
2. Помещенный «BidPlaced» объект на очереди

затем Я отправил бы дочернему процессу следующую заявку в очереди:

// Application Thread 
var child = cp.fork('the background thread module'); 
child.send(nextBid); 

На фоне нить прослушивания сообщения:

// Background Thread 
process.on('message', function(bid) { 
    // Do your background work 
    process.send(bid); 
}); 

Тогда прислушайтесь к завершению фона в программе:

// Application Thread 
child.on('message', function(lastBid) { 
    // Check the queue and do it again 
});