Phát Iteratee throttling

Question

Tôi đang viết một khung phát thanh web trực tuyến bằng scala và Play. Tôi đang dựa vào Iterate để thực sự phát trực tuyến, nhưng tôi đang gặp sự cố khi cố ngăn chặn một khách hàng tham lam tải xuống dữ liệu quá nhanh và tiêu thụ luồng cho tất cả khách hàng. Để làm như vậy, tôi đã cố gắng để tạo ra một Enumeratee sẽ tăng tốc độ nhanh chóng Enumerator sản xuất dữ liệu. Dưới đây là những gì Enumeratee của tôi trông giống như

val throttlingIteratee = Iteratee.foldM[Array[Byte], Array[Byte]](new Array[Byte](0)) { 
(result, chunk) => 
    val prom = Promise[Array[Byte]]() 
    timer.schedule(new TimerTask{ 
    def run() = prom.success(result ++ chunk) 
    },1000) 
    prom.future  
} 

private val chunker = Enumeratee.grouped( 
    Traversable.take[Array[Byte]](31792) &>> throttlingIteratee 
) 

Ý tưởng là tôi sử dụng tác vụ hẹn giờ để tạo điều chỉnhTạo và ghép nối với chức năng Enumeratee.grouped. Điều này có vẻ hoạt động khá tốt, nhưng tôi đang gặp khó khăn trong việc tìm ra giá trị để sử dụng cho kích thước chunk. Tôi muốn có khối sản phẩm này với tốc độ tương tự như các lần phát âm thanh. Tệp âm thanh của tôi được mã hóa ở 82kpbs và tôi đã cố gắng tính toán theo byte, nhưng giá trị tôi đưa ra dường như quá nhỏ và âm thanh phát nhanh hơn dữ liệu được truyền trực tuyến.

Câu hỏi của tôi là hai lần. Cách tiếp cận cơ bản mà tôi có là một cách tốt nhất? Và nếu nó là, làm thế nào để tôi đi về thiết lập kích thước chunk về tỷ lệ bit của tập tin âm thanh.

Answer 1

Một vài điều:

• 1 kbps = 1000 bits per second = 125 byte mỗi giây. Vì vậy, trong trường hợp của bạn 10,250 byte mỗi giây.
• Tôi không thấy bất kỳ sự cố nào với mã của bạn. Tôi cho rằng bạn đã loại bỏ mã để xử lý các lỗi cho sự rõ ràng.
• Tôi không biết trường hợp sử dụng của bạn, nhưng tôi cho rằng việc đặt loại điều chỉnh này có thể dễ dàng thực hiện hơn trong proxy hoặc máy chủ web thay vì trong mã của bạn.