接口中转stream传输 request/response

CURLOPT_READFUNCTION    
    回调函数名。该函数应接受三个参数。第一个是 cURL resource；
    第二个是通过选项 CURLOPT_INFILE 传给 cURL 的 stream resource；
    第三个参数是最大可以读取的数据的数量。回 调函数必须返回一个字符串，长度小于或等于请求的数据量（第三个参数）。一般从传入的 stream resource读取。返回空字符串作为 EOF（文件结束） 信号。
CURLOPT_WRITEFUNCTION    
    回调函数名。该函数应接受两个参数。
    第一个是 cURL resource；
    第二个是要写入的数据字符串。数 据必须在函数中被保存。 
    函数必须准确返回写入数据的字节数，否则传输会被一个错误所中断。

A bit more documentation (without minimum version numbers):

-CURLOPT_WRITEFUNCTION
-CURLOPT_HEADERFUNCTION
Pass a function which will be called to write data or headers respectively. The callback function prototype:
long write_callback (resource ch, stringdata)

The ch argument is CURL session handle. The data argument is data received. Note that its size is variable. When writing data, as much data as possible will be returned in all invokes. When writing headers, exactly one complete header line is returned for better parsing.The function must return number of bytes actually taken care of. If that amount differs from the amount passed to this function, an error will occur.

-CURLOPT_READFUNCTION
  Pass a function which will be called to read data. The callback function prototype:

string read_callback (resource ch, resource fd,long length)

The ch argument is CURL session handle. The fd argument is file descriptor passed to CURL by CURLOPT_INFILE option. The length argument is maximum length which can be returned.The function must return string containing the data which were read. If length of the data is more than maximum length, it will be truncated to maximum length. Returning anything else than a string means an EOF.
[Note: there is more callbacks implemented in current cURL library but they aren't unfortunately implemented in php curl interface yet.]

<?php

function receiveResponse($curlHandle, $xmldata)
{
    var_dump($xmldata);
    flush();
    ob_flush();
    //需要准确返回读取的字节数
    return strlen($xmldata);
}

$ch = curl_init('http://jksong.cm/api.php?id=1&name=jksong');
curl_setopt($ch, CURLOPT_WRITEFUNCTION, "receiveResponse");
curl_exec($ch);
curl_close($ch);

<?php

for ($i=0;$i<10;$i++){

    var_dump(str_repeat("a", 20));
//var_dump(time());

    sleep(1);

    ob_flush();
    flush();
}

CloseableHttpClient client =HttpClients.createDefault();
        HttpGet httpGet = new HttpGet("http://jksong.cm/api.php");
        try (CloseableHttpResponse response1 =client.execute(httpGet)) {
            final HttpEntity entity =response1.getEntity();
            if (entity != null) {
                try (InputStream inputStream =entity.getContent()) {
                    //do something useful with the stream
                    //System.out.println(IOUtils.toString(inputStream));
BufferedInputStream bufferedInputStream = newBufferedInputStream(inputStream);
                    
                    int b = 0;
                    while ((b = inputStream.read()) != -1) {
                        System.out.println("===>"+(char)b);
                    }

                }
            }
        }

var http = require('http');
var body = '';

http.get("http://jksong.cm/api.php", function(res) {
    res.on('data', function(chunk) {
        body +=chunk;
        console.log(chunk);
    });
    res.on('end', function() {
        //all data has been downloaded
});
});

var fs = require('fs');
var http = require('axios');
//获取远端图片
http({
    method: 'get',
    url: 'http://jksong.cm/api.php',
    responseType: 'stream'})
    .then(function(response) {
        //console.log(response.data.read);
        response.data.pipe(fs.createWriteStream('ada_lovelace.txt'))
    });

//可以实时读取最新上传的数据
$handle = fopen("php://input", "rb");
$contents = '';
while (!feof($handle)) {
    $body = fread($handle, 8192);
    var_dump($body);
    file_put_contents("/tmp/a.txt", $body,FILE_APPEND);
}
fclose($handle);

#注意发送速率，由于服务端缓冲区的存在，太小时不容易测出实时接收的效果
curl --limit-rate 100k -L -X GET 'http://jksong.cm/api.php' -H 'Content-Type: application/x-rar-compressed' --data-binary '@/tmp/file.data'
curl --limit-rate 100k -L -X GET 'http://jksong.cm/api.php' -H 'Content-Type: application/x-rar-compressed' --data-urlencode 'song@/tmp/file.data'

curl --limit-rate 100k  -X POST 'http://127.0.0.1:8080/upload' -H 'Content-Type: application/x-sql' --data-binary '@/Users/siqi/Desktop/file.sql'>out.txt

    @RequestMapping(value = "/upload")
    publicIdNamePair upload(HttpServletRequest request)
        throwsIOException {

//实时读取上传的文件信息
        ServletInputStream inputStream =request.getInputStream();

        StringBuffer sb = newStringBuffer();
        ServletInputStream fis =inputStream;
        int b = 0;
        while ((b = fis.read()) != -1) {
            sb.appendCodePoint(b);
        }
        inputStream.close();
        System.out.println(sb.toString());

        IdNamePair idNamePair = newIdNamePair();
        idNamePair.setId(123);
        idNamePair.setName("蓝银草");

        returnidNamePair;
    }

<?php


$curl =curl_init();

curl_setopt_array($curl, array(
    CURLOPT_URL => "http://127.0.0.1:8080/upload",CURLOPT_RETURNTRANSFER => true,CURLOPT_ENCODING => "",CURLOPT_MAXREDIRS => 10,CURLOPT_TIMEOUT => 0,CURLOPT_FOLLOWLOCATION => true,CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,CURLOPT_CUSTOMREQUEST => "POST",CURLOPT_POSTFIELDS => file_get_contents("/Users/siqi/Desktop/file.sql"),CURLOPT_HTTPHEADER => array(
        "Content-Type: application/octet-stream",),));

$response = curl_exec($curl);

curl_close($curl);
echo $response;