NodeJS - Làm thế nào để dòng yêu cầu cơ thể mà không đệm

Question

Trong đoạn code dưới đây tôi không thể hiểu tại sao req.pipe (res) không hoạt động, và chưa ném một lỗi. Một linh cảm nói với tôi đó là do hành vi asynch của nodejs, nhưng đây là một trường hợp rất đơn giản mà không cần gọi lại.

Tôi đang thiếu gì?

http.createServer(function (req, res) { 

    res.writeHead(200, { 'Content-Type': 'text/plain' }); 

    res.write('Echo service: \nUrl: ' + req.url); 
    res.write('\nHeaders:\n' + JSON.stringify(req.headers, true, 2)); 

    res.write('\nBody:\n'); 

    req.pipe(res); // does not work 

    res.end(); 

}).listen(8000); 

Đây là curl:

➜ ldap-auth-gateway git:(master) ✗ curl -v -X POST --data "test.payload" --header "Cookie: token=12345678" --header "Content-Type:text/plain" localhost:9002 

Dưới đây là kết xuất debug (xem cơ thể đã được tải lên):

About to connect() to localhost port 9002 (#0) 
    Trying 127.0.0.1... 
    connected 
    Connected to localhost (127.0.0.1) port 9002 (#0) 
    POST/HTTP/1.1 
    User-Agent: curl/7.24.0 (x86_64-apple-darwin12.0) libcurl/7.24.0 OpenSSL/0.9.8x zlib/1.2.5 
    Host: localhost:9002 
    Accept: */* 
    Cookie: token=12345678 
    Content-Type:text/plain 
    Content-Length: 243360 
    Expect: 100-continue 

    HTTP/1.1 100 Continue 
    HTTP/1.1 200 OK 
    Content-Type: text/plain 
    Date: Sun, 04 Aug 2013 17:12:39 GMT 
    Connection: keep-alive 
    Transfer-Encoding: chunked 

Và các dịch vụ đáp ứng mà không lặp lại cơ thể yêu cầu:

Echo service: 
Url:/
Headers: 
{ 
    "user-agent": "curl/7.24.0 (x86_64-apple-darwin12.0) libcurl/7.24.0 OpenSSL/0.9.8x zlib/1.2.5", 
    "host": "localhost:9002", 
    "accept": "*/*", 
    "cookie": "token=12345678", 
    "content-type": "text/plain", 
    "content-length": "243360", 
    "expect": "100-continue" 
} 

... và gỡ lỗi curl cuối cùng là

Body: 
Connection #0 to host localhost left intact 
Closing connection #0 

Ngoài ra, khi tôi kiểm tra căng thẳng với thân yêu cầu lớn, tôi gặp lỗi EPIPE. Làm thế nào tôi có thể tránh điều này?

- CHỈNH SỬA: Qua thử và sai, tôi đã làm việc này và nó vẫn chỉ là vấn đề về thời gian. Mặc dù nó vẫn còn lạ, vì thời gian chờ làm cho tải trọng phải được trả lại, nhưng thời gian chờ không phải là minded. Nói cách khác cho dù tôi đặt thời gian chờ là 5 giây hoặc 500 giây, tải trọng được truyền lại đúng theo yêu cầu và kết nối bị chấm dứt.

Đây là chỉnh sửa:

http.createServer(function (req, res) { 

    try { 
     res.writeHead(200, { 'Content-Type': 'text/plain' }); 
     res.write('Echo service: ' + req.url + '\n' + JSON.stringify(req.headers, true, 2)); 
     res.write('\nBody:"\n'); 
     req.pipe(res); 
    } catch(ex) { 
     console.log(ex); 
     // how to change response code to error here? since headers have already been written? 
    } finally { 
     setTimeout((function() { 
     res.end(); 
     }), 500000); 
    } 

}).listen(TARGET_SERVER.port); 

?

Answer 1

Yêu cầu về ống để quay lại. Req là dòng có thể đọc được và phản ứng là một stream.It ghi nên làm việc

http.createServer(function (req, res) { 

     res.writeHead(200, { 'Content-Type': 'text/plain' });  
     res.write('Echo service: ' + req.url + '\n' + JSON.stringify(req.headers, true, 2)); 

     // pipe request body directly into the response body 
     req.pipe(res);  

    }).listen(9002); 

Answer 2

Vì vậy, đầu tiên, có vẻ như curl của bạn đã tắt, tên tập tin của dữ liệu gửi nên được bắt đầu bằng @as shown here. Bạn sẽ chỉ đăng tên tập tin nếu không.

Bên cạnh đó, Chandu đúng khi nói rằng cuộc gọi đến res.end() là vấn đề ở đây.

Vì IO không đồng bộ trong nút, khi bạn phát hành lệnh .pipe, điều khiển sẽ ngay lập tức được trả về ngữ cảnh hiện tại, trong khi đường ống hoạt động ở chế độ nền. Khi bạn gọi tới số res.end(), bạn đóng luồng, preventing any more data to be written.

Giải pháp ở đây là để cho .pipe kết thúc luồng, which is the default.

Tôi tưởng tượng rằng thời gian được phát bởi vì trên các máy khác nhau và kích thước dữ liệu khác nhau, IO không đồng bộ về mặt lý thuyết có thể hoàn thành (IO nhanh của tập dữ liệu nhỏ) trước khi sự kiện kết thúc trên luồng ghi được xử lý hoàn toàn.

Tôi muốn giới thiệu this blog post cho một số ngữ cảnh khác.