OkHttp3 Никогда тайм-аут на медленном интернете - PullRequest
Новая
       61

OkHttp3 Никогда тайм-аут на медленном интернете

12 голосов
/ 12 марта 2019

Прежде всего, я прочитал очень много вопросов относительно моего вопроса, но он никогда не дает мне решения.Вот некоторые из вопросов, которые я прочитал относительно моего вопроса.

Я также читал эту статью относительно моего вопроса, но он так и не дал мне решения.

Проблема:

Я использую библиотеку Okhhtp3 в своем приложении для веб-сервисов.Он работает нормально, но когда интернет-соединение медленное или ненадежное, оно застревает и никогда не прерывается или никогда не вызывает исключение или метод отказа.

Вот код клиента: 

OkHttpClient client = new OkHttpClient.Builder()
            .connectTimeout(20, TimeUnit.SECONDS)
            .writeTimeout(20, TimeUnit.SECONDS)
            .readTimeout(20, TimeUnit.SECONDS)
            .retryOnConnectionFailure(false)
            .build();

Как получить исключение тайм-аута или вызванный метод сбоя через 20 секунд?

Пожалуйста, помогите мне.Спасибо

Ответы [ 2 ]

8 голосов
/ 14 марта 2019

Как указал Тревор Халворсон, вы можете установить callTimeout во время создания клиента следующим образом: 

OkHttpClient client = new OkHttpClient.Builder()
            .connectTimeout(20, TimeUnit.SECONDS)
            .callTimeout(20, TimeUnit.SECONDS)
            .writeTimeout(20, TimeUnit.SECONDS)
            .readTimeout(20, TimeUnit.SECONDS)
            .retryOnConnectionFailure(false)
            .build();

Я лично проверил в фиктивном проекте с использованием версии 3.14.0 из okhttp3: 

implementation 'com.squareup.okhttp3:okhttp:3.14.0'

И установка тайм-аута на 5 секунд и мой эмулятор подключение к GPRS и плохое подключение Я получаю 

java.net.SocketExcpetion: Socket closed: timeout

enter image description here

Это моя полная пустышка : 

package com.example.shadowsheep.myapplication;

import android.os.Bundle;
import android.util.Log;
import android.widget.TextView;

import java.io.IOException;
import java.io.InterruptedIOException;
import java.util.concurrent.TimeUnit;

import androidx.appcompat.app.AppCompatActivity;
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

public class MainActivity extends AppCompatActivity {

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        final TextView helloTextView = findViewById(R.id.helloTextView);

        OkHttpClient client = new OkHttpClient.Builder()
                .connectTimeout(5, TimeUnit.SECONDS)
                .callTimeout(5, TimeUnit.SECONDS)
                .writeTimeout(5, TimeUnit.SECONDS)
                .readTimeout(5, TimeUnit.SECONDS)
                .retryOnConnectionFailure(false)
                .build();

        Request request = new Request.Builder()
                .url("https://www.versionestabile.it/blog")
                .build();

        client.newCall(request).enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                e.printStackTrace();
                Log.d("OKHTTP3", e.getMessage());
                // You get this failure
                runOnUiThread(() -> helloTextView.setText("TIMEOUT - FAILURE -> " + e.getMessage()));
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                try {
                    final String _body = response.body().string();
                    Log.d("OKHTTP3", _body);
                    runOnUiThread(() -> {
                        helloTextView.setText(_body);
                    });
                } catch (InterruptedIOException e) {
                    runOnUiThread(() -> {
                        // Or this exception depending when timeout is reached
                        helloTextView.setText("TIMEOUT EXCEPTION->"+ e.getCause() + ": " + e.getMessage());
                    });
                }
            }
        });
    }
}

IЯ также дам вам мое приложение build.gradle file. 

apply plugin: 'com.android.application'

android {
    compileSdkVersion 28
    defaultConfig {
        applicationId "com.example.shadowsheep.myapplication"
        minSdkVersion 24
        targetSdkVersion 28
        versionCode 1
        versionName "1.0"
        testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
    }
    buildTypes {
        release {
            minifyEnabled false
            proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
        }
    }
    compileOptions {
        sourceCompatibility 1.8
        targetCompatibility 1.8
    }
}

dependencies {
    implementation fileTree(dir: 'libs', include: ['*.jar'])
    implementation 'androidx.appcompat:appcompat:1.1.0-alpha03'
    implementation 'androidx.constraintlayout:constraintlayout:1.1.3'
    testImplementation 'junit:junit:4.12'
    androidTestImplementation 'androidx.test:runner:1.1.2-alpha02'
    androidTestImplementation 'androidx.test.espresso:espresso-core:3.2.0-alpha02'

    implementation 'com.squareup.okhttp3:okhttp:3.14.0'
}
1 голос
/ 04 апреля 2019

Мой тестовый пример тоже не будет работать, каждый раз он занимает более 30 секунд:

  • Эмулятор Android Nexus 4 (версия Android 4.1.2)
  • Windows 7 Безподключение к Интернету (убедитесь, что эмулятор не подключен к Интернету)

gradle: 

implementation 'com.squareup.okhttp3:okhttp:3.12.2'

defaultConfig {
    minSdkVersion 16
    targetSdkVersion 26
}
compileSdkVersion 27
buildToolsVersion '28.0.3'

java: 

public static class CheckIpAsyncTask extends util.android.os.AsyncTask<Void, Void, Void> {

@Override
    protected Void doInBackground(Void... voids) {
        try {
        Logger.i(TAG, "API::FBD::checkIpInfo, API_IPINFO = " + API_IPINFO);
        if (BuildConfig.DEBUG) {
            //ThreadUtil.sleep(10 * TimeUtil.SECOND);
        }

        Request req = new Request.Builder()
                .get()
                .url(API_IPINFO)
                .build();
        OkHttpClient client = new OkHttpClient.Builder()
                .connectTimeout(2, TimeUnit.SECONDS)
                .callTimeout(2, TimeUnit.SECONDS)
                .readTimeout(2, TimeUnit.SECONDS)
                .writeTimeout(2, TimeUnit.SECONDS)
                .build();
        Response response = client.newCall(req).execute();

        mHttpCode = response.code();
        if (mHttpCode == HttpURLConnection.HTTP_OK) {
            boolean appConnected = ServerHelper.checkAppConnected();
            if (!appConnected) {
                JSONObject res = new JSONObject(response.body().string().trim());
                mCountry = res.getString("country").toLowerCase();
                mIp = res.getString("ip").toLowerCase();
                Logger.i(TAG, "API::FBD::checkIpInfo, res = " + res);

                PreferenceHelper.get(mContext).setIpInfoApiCountry(mCountry);
                PreferenceHelper.get(mContext).setIpInfoApiHost(mIp);
            }
        }
    } catch (java.io.InterruptedIOException interruptedIOException) {
        Logger.e(TAG, "API::FBD::checkIpInfo, InterruptedIOException=" + interruptedIOException);
    } catch (Throwable ignored) {
        Logger.e(TAG, "API::FBD::checkIpInfo, Throwable=" + ignored);
    }
    return null;
}

logs: 

04-04 06:25:06.940 4492-4645/? I/Toolbox: [PLACE] at com.xy.ui.FbdUtil$CheckIpAsyncTask.doInBackground(FbdUtil.java:98)
                                          [FbdUtil]API::FBD::checkIpInfo, API_IPINFO = http://api.z.com:30070/servers/ipinfo
04-04 06:25:34.960 4492-4645/? E/Toolbox: [PLACE] at com.xy.ui.FbdUtil$CheckIpAsyncTask.doInBackground(FbdUtil.java:129)
                                          [FbdUtil]API::FBD::checkIpInfo, InterruptedIOException=java.io.InterruptedIOException: timeout

входит в Emulator Nexus 6 (версия Android 8.0): 

04-04 06:52:44.696 2624-3950/? I/Toolbox: [PLACE] at com.xy.ui.FbdUtil$CheckIpAsyncTask.doInBackground(FbdUtil.java:98)
                                          [FbdUtil]API::FBD::checkIpInfo, API_IPINFO = http://api.z.com:30070/servers/ipinfo
04-04 06:53:59.886 2624-3175/? E/Toolbox: [PLACE] at com.xy.ui.ForbiddenUtil$CheckIpAsyncTask.doInBackground(FbdUtil.java:129)
                                          [FbdUtil]API::FBD::checkIpInfo, InterruptedIOException=java.io.InterruptedIOException: timeout

Наконец, решение Дмитрия Зеновича в «Вопросе 6» работает для меня: 

.dns(hostname -> Single.fromCallable(() -> Arrays.asList(InetAddress.getAllByName(hostname)))
                            .timeout(2, TimeUnit.SECONDS)
                            .subscribeOn(Schedulers.io())
                            .observeOn(Schedulers.computation())
                            .onErrorReturnItem(new ArrayList<>())
                            .blockingGet())
...