Как синхронизировать запросы в nodeJs?

Question

[Пётр]

В приложении есть одно сокет событие, которое нужно обрабатывать синхронно.

socket.on('something', data=>{
  //тут много логики, но суть такова:
  //запрос в бд и файл, обработка и на основе полученных данных запись
  //не допускать последующих событий, пока данные не запишутся 
})

Как это сделать?

Answer 1

[Дмитрий Беляев]

я бы так сделал:

let tasks = Promise.resolve();
socket.on('something', data => {
  tasks = tasks.then(async () => {
    //тут много логики, но суть такова:
    //запрос в бд и файл, обработка и на основе полученных данных запись
    //не допускать последующих событий, пока данные не запишутся 
  }).catch(e => {
    // обработка ошибок, чтоб процесс не прерывался
  });
});

Естественно, если нужна синхронизация еще и между потоками, то не спасет, только в пределах 1 процесса
если все же многопоточность нужна, то:
1. складываем наши задачи в очередь в redis (RPUSH)
2. разбираем задачи процессами воркерами по одной (LPOP)

Comments

[Пётр]

Спасибо, принцип понял.
Единственное, у меня node v6, которую пока не могу обновить до 8ой версии из-за ряда сторонних зависимостей.
Надо искать решение на https://caolan.github.io/async/

Answer 2

[Владимир Скибин]

Используйте очереди