Как правильно реализовать паузу / возобновление в node.js для пользовательского EventEmitter - PullRequest
Новая
       13

Как правильно реализовать паузу / возобновление в node.js для пользовательского EventEmitter

3 голосов
/ 12 марта 2011

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

Учитывая этот код, как мне реализовать блокирующий вызов, пока paused не станет ложным? 

var   util = require('util')
    , events = require('events')
    , pg = require('pg')

// QueryHandler is an EventEmitter
function QueryHandler(sql) {
  this.paused = true

  pg.connect(connectionString, function(err, client) {
    // error handling ignored for sake of illustration
    var query = client.query(sql)

    query.on('row', function(row) {
      if (this.paused) {
        // Somehow block until paused === false
      }

      this.emit(row)
    }.bind(this))
  }.bind(this))
}

util.inherits(QueryHandler, events.EventEmitter)

QueryHandler.prototype.resume = function() {
  this.paused = false
}

Вот диаграмма взаимодействия, объясняющая, чего я пытаюсь достичь:

http://teksol.info.s3.amazonaws.com/reporting-service.png

  1. Веб-браузер запрашивает отчет у внешнего веб-сервера
  2. Интерфейс веб-сервера запрашивает у службы отчетов токен, относящийся к конкретному запросу
  3. Одновременно служба отчетов подключается к PostgreSQL и отправляет запрос
  4. Веб-сервер внешнего интерфейса возвращает URL-адрес и токен службы отчетов в веб-браузер.
  5. Веб-браузер отправляет Ajax-запрос (длинный опрос) службе отчетов с возвращенным токеном
  6. Служба отчетов направляет строки, когда они возвращаются в веб-браузер

Поскольку все асинхронно, шаг 3 может начать возвращать данные до подключения веб-браузера, что может привести к потере данных. Я мог бы буферизовать данные в памяти до тех пор, пока клиент не вернется, но я бы предпочел заблокировать передачу строк данных, так как это предотвратило бы использование ОЗУ. Или, может быть, я просто шучу, а оперативная память все еще будет использоваться в основной библиотеке? Во всяком случае, указатели оценили!

1 Ответ

2 голосов
/ 14 марта 2011

Если вы собираетесь блокировать в цикле обработки событий, я думаю, вам нужно подождать, пока API-интерфейсы веб-работников будут реализованы.

Я думаю, что сохранение строк происходит изpg - лучшая идея.

...