Làm cách nào để giới hạn tốc độ tải lên từ máy chủ trong node.js?

Question

Làm cách nào để giới hạn tốc độ tải lên từ máy chủ trong node.js?

Đây có phải là tùy chọn không?

Tình huống: Tôi đang viết một số phương pháp để cho phép người dùng tự động tải tệp lên máy chủ của tôi. Tôi muốn giới hạn tốc độ tải lên (ví dụ) 50kB/s (cấu hình khóa học).

Answer 1

Tôi không nghĩ rằng bạn có thể buộc khách hàng phát trực tiếp ở tốc độ được xác định trước, tuy nhiên bạn có thể kiểm soát "tốc độ trung bình" của toàn bộ quá trình.

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; 
} 

Đây là mã giả, nhưng bạn có thể nhận được điểm. Có thể có một cách khác, và tốt hơn, cách mà tôi không biết. Trong trường hợp như vậy, tôi hy vọng người khác sẽ chỉ ra.

Lưu ý rằng nó cũng không chính xác lắm và bạn có thể muốn có một chỉ số khác với tốc độ trung bình.

Answer 2

Thay vì tự lăn, cách bình thường để thực hiện điều này trong sản xuất là cho phép trình cân bằng tải hoặc máy chủ nhập của bạn điều chỉnh các yêu cầu gửi đến. Xem http://en.wikipedia.org/wiki/Bandwidth_throttling. Nó không phải thường là một cái gì đó một ứng dụng cần phải xử lý chính nó.

Answer 3

Sử dụng throttle mô-đun để kiểm soát các đường ống dòng tốc độ

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);