为什么Node.js的restful api没有从Java Android接收这个输出流？

Question

我有一个类audio sender，它连接到nodejs服务器，并以POST方法模式上传音频文件。

public class AudioSender implements Callable<JSONObject> {

String outputFile;

AudioSender(String fileLocation){
    outputFile=fileLocation;
}

public JSONObject call(){
    URL url = null;
    HttpURLConnection urlConnection = null;
    InputStream audioInputStream=null;
    JSONObject response=null;
    byte buffer[]=new byte[16];
    try {
        url = new URL("http://192.168.0.106:3000/upload");
    } catch (MalformedURLException e) {
        e.printStackTrace();
    } finally {
        try {
            urlConnection = (HttpURLConnection) url.openConnection();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            urlConnection.setDoOutput(true);
            urlConnection.setChunkedStreamingMode(16);
            urlConnection.setRequestProperty("Content-Type","multipart/form-data");
            urlConnection.setRequestProperty("Connection", "Keep-Alive");
            urlConnection.setRequestProperty("Cache-Control", "no-cache");
            urlConnection.setRequestProperty(
                    "Content-Type", "multipart/form-data;boundary=*****");
            try {
                OutputStream out = new BufferedOutputStream(urlConnection.getOutputStream());
                try {
                    audioInputStream = new BufferedInputStream(new FileInputStream(outputFile));
                    Log.d("hello","audioinputstream");
                } catch (FileNotFoundException e) {
                    e.printStackTrace();
                } finally {

                    while(audioInputStream.read(buffer)!=-1) {
                        out.write(buffer);
                        Log.d("buffer",buffer.toString());
                    }
                    try {
                        audioInputStream.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
                InputStream in = new BufferedInputStream(urlConnection.getInputStream());
                StringBuilder total = new StringBuilder();
                while(in.read(buffer)!=-1)
                    total.append(buffer);
                    Log.d("response",total.toString());
                try {
                    response = new JSONObject(total.toString());
                }catch(JSONException e){
                    Log.e("Response Parse Error", "Could not parse malformed JSON");
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    return response;
}

这是执行AudioSender Callable的上载。

public void upload() {
    JSONObject response=null;
    AudioSender sender=new AudioSender(outputFile);
    FutureTask<JSONObject> uploadTask=new FutureTask<JSONObject>(sender);
    ExecutorService executorService= Executors.newFixedThreadPool(1);
    executorService.execute(uploadTask);
    Log.d("s","was here");
    while(true){
        if(uploadTask.isDone()){
            try{
                response=uploadTask.get();
            }catch(InterruptedException|ExecutionException e){
                e.printStackTrace();
                Log.e("ee","ee",e.getCause());

            }
        }
    }
}

我很清楚这不是node JS的错误，但这里是服务器代码：app.post（“/upload”,function（req,res）{console.log（“someone called！”）；req.on（“data”,function（chunk）{console.log（“res”）；console.log（chunk）；}）；req.on（“end”,function（）{console.log（“done！”）；res.send（{“name”：“sg”}）；}）；

当我调用upload（）时，服务器控制台将打印某人被调用！搞定了！

我在调试时发现，我确实收到了来自服务器的响应json对象。我不知道out.write（buffer）是否完成了这项工作，但是调试它显示buffer值正在改变，并且与我的音频文件的大小一致。

请不要建议使用离子或其他任何东西。

Answer 1

我通过如下方式设置URLConnection来解决这些问题：

            boundary = "===" + System.currentTimeMillis() + "===";
            urlConnection.setUseCaches(false);
            urlConnection.setDoOutput(true);    // indicates POST method
            urlConnection.setDoInput(true);
            urlConnection.setRequestProperty("Content-Type","multipart/form-data; boundary=" + boundary);