http.request 发送服务请求

http.request返回一个可写流http.ClientRequest ，可以调用 req.write()发送到服务端，如果发送到是一个文件流，则需要设置文件头'Connection': 'keep-alive'保持长链接，否则就只触发一次data事件，只链接一次也是短链接到特性，'Connection': 'keep-alive'为http1.0标准，在实际开发中就碰到这样一个问题，因为未设置keep-alive 服务端data只触发了一次，而在fs.createReadStream中data事件里req.write第二次时报错，因为如果不设置保持链接则默认为短链接，调用一次write后服务会自动调用end来关闭链接。

let option ={
          host:"127.0.0.1",   //请求host
          path:"/uploadFile",  //请求链接
          port:3000,            //端口
          method:"POST",  //请求类型
          headers:{。   //请求头
            
                'Content-Type': 'application/octet-stream',  //数据格式为二进制数据流
                'Transfer-Encoding': 'chunked',  //传输方式为分片传输
                'Connection': 'keep-alive'。    //这个比较重要为保持链接。
          }
      }
      let req  = http.request(option);
                 
                 fs.createReadStream(path.join(__dirname,"line.png"))
                   .on("open",chunk=>{
                   })
                   .on("data",chunk=>{
                       req.write(chunk);  //发送数据
                   })
                   .on("end",()=>{
                      req.end();   //发送结束
                   })

服务端接收

ctx.req 拿到nodejs原始request值，因为reqeust被发送时是一个stream可读流，所以可用data事件去监听。

  app.use(router.post("/uploadFile",(ctx,next)=>{
    //let data = fs.createReadStream(ctx)
       //ctx.req.setEncoding="binary";
       let url=path.join(__dirname,"/test/");
       let file = path.join(url,"node.tar.gz")
       let chunks='';
       
         ctx.req.on("data",function(d){
            let da = d.toString("utf8")
            debugger
         }).on("close",function(e){
            debugger
         }).on("error",function(){
             debugger
         }).on("end",function(){
             debugger
         })

       next();
}))