java - ProtocolException:流的意外结束

Question

我一直在处理一个反复出现的问题，我感到非常沮丧。我正在尝试通过我在网上找到的模板 php web 服务连接到我的数据库，方法是向它发送 JSONObjects。尝试从服务器获取响应代码时，我不断收到 IOException 或 ProtocolException，原因是“流的意外结束”。错误消息真的很神秘，我不知道错误是在 java 还是 PHP 代码中。我把代码贴出来了，大家可以看看:

堆栈跟踪:

java.net.ProtocolException: unexpected end of stream
     at com.android.okhttp.internal.http.HttpConnection$FixedLengthSink.close(HttpConnection.java:314)
     at com.android.okhttp.internal.http.HttpEngine.readResponse(HttpEngine.java:781)
     at com.android.okhttp.internal.huc.HttpURLConnectionImpl.execute(HttpURLConnectionImpl.java:443)
     at com.android.okhttp.internal.huc.HttpURLConnectionImpl.getResponse(HttpURLConnectionImpl.java:388)
     at com.android.okhttp.internal.huc.HttpURLConnectionImpl.getResponseCode(HttpURLConnectionImpl.java:501)
     at ske.matej.project.JSONParser.getJSONFromUrl(JSONParser.java:56)
     at ske.matej.project.UserFunctions.loginUser(UserFunctions.java:35)
     at ske.matej.project.LoginActivity$AttemptLogin.doInBackground(LoginActivity.java:145)
     at ske.matej.project.LoginActivity$AttemptLogin.doInBackground(LoginActivity.java:121)
     at android.os.AsyncTask$2.call(AsyncTask.java:295)
     at java.util.concurrent.FutureTask.run(FutureTask.java:237)
     at android.os.AsyncTask$SerialExecutor$1.run(AsyncTask.java:234)
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1113)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:588)
     at java.lang.Thread.run(Thread.java:818)

JSONParser.java(我用注释标记了违规行)

import android.util.Log;

import org.json.JSONException;
import org.json.JSONObject;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;


public class JSONParser {

    private JSONObject jsonObj = new JSONObject();
    private JSONObject json = new JSONObject();
    private String email;
    private String username;
    private String password;
    private int objLength;
    private static InputStream is = null;

    public JSONParser() {
        //Default constructor intentionally left empty for now
    }

    public JSONObject getJSONFromUrl(String _url, JSONObject params) {

        // Making HTTP request
        try {
            URL url = new URL(_url);
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();

            byte[] bytearray = params.toString().getBytes("UTF-8");

            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.setRequestMethod("POST");
            conn.setFixedLengthStreamingMode(bytearray.length);
            //conn.setRequestProperty("User-Agent", "GYUserAgentAndroid");
            conn.setRequestProperty("Content-Length", Integer.toString(bytearray.length));
            conn.setRequestProperty("Content-Type", "application/json");
            //conn.setUseCaches(false);

            System.out.println("Byte array length: "+bytearray.length);

            //The offending line                
            int responseCodeHTTP = conn.getResponseCode(); 

            System.out.println("Responsecode HTTP "+responseCodeHTTP);

            OutputStream os = conn.getOutputStream();
            os.write(bytearray);
            os.flush();

            if (responseCodeHTTP == HttpURLConnection.HTTP_OK) {
                try {
                    is = new BufferedInputStream(conn.getInputStream());
                    BufferedReader reader = new BufferedReader(new InputStreamReader(
                            is, "UTF-8"), 8);
                    StringBuilder sb = new StringBuilder();
                    String line = null;
                    while ((line = reader.readLine()) != null) {
                        sb.append(line);
                    }
                    is.close();
                    json = new JSONObject(sb.toString());
                    Log.e("JSON", json.toString());
                }
                catch (JSONException e) {
                    e.printStackTrace();
                }
            }

        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }

        return json;

    }

    public byte[] getJSONBytes() {
        try {
            return jsonObj.toString().getBytes("UTF-8");
        }
        catch(UnsupportedEncodingException e) {
            e.printStackTrace();
            return null;
        }
    }
}

index.php(我还没有对代码做太多改动，只是想暂时建立一个连接)

<?php
 
if($_POST != null) {
	
	echo json_encode("Status: 200");
	
	if (isset($_POST['tag']) && $_POST['tag'] != '') {
    // Get tag
    $tag = $_POST['tag'];
 
    // Include Database handler
    require_once 'DB_Functions.php';
    $db = new DB_Functions();
    // response Array
    $response = array("tag" => $tag, "success" => 0, "error" => 0);
 
    // check for tag type
    if ($tag == 'login') {
        // Request type is check Login
        $email = $_POST['email'];
        $password = $_POST['password'];
 
        // check for user
        $user = $db->getUserByEmailAndPassword($email, $password);
		
		
		//FOR TESTING PURPOSES: REMOVE LATER
		$user = false;
		
		
        if ($user != false) {
            // user found
            // echo json with success = 1
            $response["success"] = 1;
            $response["user"]["fname"] = $user["firstname"];
            $response["user"]["lname"] = $user["lastname"];
            $response["user"]["email"] = $user["email"];
        $response["user"]["uname"] = $user["username"];
            $response["user"]["uid"] = $user["unique_id"];
            $response["user"]["created_at"] = $user["created_at"];
 
            echo json_encode($response);
        } else {
            // user not found
            // echo json with error = 1
            $response["error"] = 1;
            $response["error_msg"] = "Incorrect email or password!";
            echo json_encode($response);
        }
    }
  else if ($tag == 'chgpass'){
  $email = $_POST['email'];
 
  $newpassword = $_POST['newpas'];
 
  $hash = $db->hashSSHA($newpassword);
        $encrypted_password = $hash["encrypted"]; // encrypted password
        $salt = $hash["salt"];
  $subject = "Change Password Notification";
         $message = "Hello User,nnYour Password is sucessfully changed.nnRegards,nLearn2Crack Team.";
          $from = "contact@learn2crack.com";
          $headers = "From:" . $from;
    if ($db->isUserExisted($email)) {
 
 $user = $db->forgotPassword($email, $encrypted_password, $salt);
if ($user) {
         $response["success"] = 1;
          mail($email,$subject,$message,$headers);
         echo json_encode($response);
}
else {
$response["error"] = 1;
echo json_encode($response);
}
 
            // user is already existed - error response
 
        }
           else {
 
            $response["error"] = 2;
            $response["error_msg"] = "User not exist";
             echo json_encode($response);
 
}
}
else if ($tag == 'forpass'){
$forgotpassword = $_POST['forgotpassword'];
 
$randomcode = $db->random_string();
 
$hash = $db->hashSSHA($randomcode);
        $encrypted_password = $hash["encrypted"]; // encrypted password
        $salt = $hash["salt"];
  $subject = "Password Recovery";
         $message = "Hello User,nnYour Password is sucessfully changed. Your new Password is $randomcode . Login with your new Password and change it in the User Panel.nnRegards,nLearn2Crack Team.";
          $from = "contact@learn2crack.com";
          $headers = "From:" . $from;
    if ($db->isUserExisted($forgotpassword)) {
 
 $user = $db->forgotPassword($forgotpassword, $encrypted_password, $salt);
if ($user) {
         $response["success"] = 1;
          mail($forgotpassword,$subject,$message,$headers);
         echo json_encode($response);
}
else {
$response["error"] = 1;
echo json_encode($response);
}
 
            // user is already existed - error response
 
        }
           else {
 
            $response["error"] = 2;
            $response["error_msg"] = "User not exist";
             echo json_encode($response);
 
}
 
}
else if ($tag == 'register') {
        // Request type is Register new user
        $fname = $_POST['fname'];
        $lname = $_POST['lname'];
        $email = $_POST['email'];
        $uname = $_POST['uname'];
        $password = $_POST['password'];
 
        // check if user is already existed
        if ($db->isUserExisted($email)) {
            // user is already existed - error response
            $response["error"] = 2;
            $response["error_msg"] = "User already existed";
            echo json_encode($response);
        }
           else if(!$db->validEmail($email)){
            $response["error"] = 3;
            $response["error_msg"] = "Invalid Email Id";
            echo json_encode($response);
}
else {
            // store user
            $user = $db->storeUser($fname, $lname, $email, $uname, $password);
            if ($user) {
                // user stored successfully
            $response["success"] = 1;
            $response["user"]["fname"] = $user["firstname"];
            $response["user"]["lname"] = $user["lastname"];
            $response["user"]["email"] = $user["email"];
        $response["user"]["uname"] = $user["username"];
            $response["user"]["uid"] = $user["unique_id"];
            $response["user"]["created_at"] = $user["created_at"];
               mail($email,$subject,$message,$headers);
 
                echo json_encode($response);
            } else {
                // user failed to store
                $response["error"] = 1;
                $response["error_msg"] = "JSON Error occured in Registartion";
                echo json_encode($response);
            }
        }
    } else {
         $response["error"] = 3;
         $response["error_msg"] = "JSON ERROR";
        echo json_encode($response);
    }
} else {
    echo "";
}
}
 
?>

非常感谢您能提供的任何帮助。特别是因为我仍然是 Android 开发和 PHP 的新手。

Answer 1

为了解决这个问题，我费了很大的劲。搜索了各种 S/O 帖子，我通过在请求中添加 header “Connection: close”解决了这个问题。我找到了解决方案 here

这样的事情将解决 java.net.ProtocolException: unexpected end of stream:

okHttpClient = new OkHttpClient.Builder()
            .addNetworkInterceptor(new Interceptor() {
                @Override
                public Response intercept(Chain chain) throws IOException {
                    Request request = chain.request().newBuilder().addHeader("Connection", "close").build();
                    return chain.proceed(request);
                }
            })
            .build();