ProtocolException: неожиданный конец потока

Я имею дело с проблемой, которая продолжает возвращаться, и я становлюсь довольно расстроенным. Я пытаюсь подключиться к своей базе данных через шаблон php webservice, который я нашел в сети, отправив его 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.

Источник

2 ответа

Я много боролся за решение этого вопроса. Искал различные сообщения S/O, но я решил проблему, добавив заголовок "Connection: close" в запросах. Я нашел решение здесь

Нечто подобное разрешит исключение java.net.ProtocolException: неожиданный конец потока:

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();
Источник

Изменить это:

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

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

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

чтобы:

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

//not any more offending line                
            int responseCodeHTTP = conn.getResponseCode(); 

            System.out.println("Responsecode HTTP "+responseCodeHTTP);
Источник
Другие вопросы по тегам