¿Cómo limitaría la velocidad de carga del servidor en node.js?

Question

¿Cómo limitaría la velocidad de carga del servidor en node.js?

¿Es esto una opción?

Escenario: Estoy escribiendo algunos métodos para permitir a los usuarios subir automáticamente archivos a mi servidor. Quiero limitar la velocidad de carga a (por ejemplo) 50kB/s (configurable por supuesto).

Answer 1

No creo que pueda obligar a un cliente a transmitir a una velocidad predefinida, sin embargo, puede controlar la "velocidad promedio" de todo el proceso.

var startTime = Date.now(), 
    totalBytes = ..., //NOTE: you need the client to give you the total amount of incoming bytes 
    curBytes = 0; 

stream.on('data', function(chunk) { //NOTE: chunk is expected to be a buffer, if string look for different ways to get bytes written 
    curBytes += chunk.length; 
    var offsetTime = calcReqDelay(targetUploadSpeed); 
    if (offsetTime > 0) { 
     stream.pause(); 
     setTimeout(offsetTime, stream.resume); 
    } 
}); 

function calcReqDelay(targetUploadSpeed) { //speed in bytes per second 
    var timePassed = Date.now() - startTime; 
    var targetBytes = targetUploadSpeed * timePassed/1000; 
    //calculate how long to wait (return minus in case we actually should be faster) 
    return waitTime; 
} 

Esto es, por supuesto, un seudo código, pero probablemente entienda el punto. Puede haber otra, y mejor, forma que yo no sepa. En tal caso, espero que alguien más lo señale.

Tenga en cuenta que tampoco es muy preciso y es posible que desee tener una medida diferente de la velocidad promedio.

Answer 2

En lugar de enrollar el suyo, la forma normal de hacerlo en producción es permitir que el equilibrador de carga o el servidor de entrada aceleren las solicitudes entrantes. Ver http://en.wikipedia.org/wiki/Bandwidth_throttling. Por lo general, no es algo que una aplicación deba manejar sola.

Answer 3

Uso throttle módulo para controlar la velocidad de flujo de la tubería

npm install throttle

var Throttle = require('throttle'); 

// create a "Throttle" instance that reads at 1 b/s 
var throttle = new Throttle(1); 

req.pipe(throttle).pipe(gzip).pipe(res);