Сбой асинхронных запросов IBM-Watson

я реализую асинхронный запрос Watson Assistant v2 (без потока, так как это не требуется). но я получаю сбой из-за сетевого вызова в основном потоке. что означает, что этот вызов не называется асинхронным на Android.

«android.os.NetworkOnMainThreadException» — это исключение возникает, когда приложение пытается выполнить сетевую операцию в своем основном потоке.

код:-

  public void sendMessage(String message){
        Log.d("TAG","message :"+message+", session id:"+sessionId);
        MessageInput input = new MessageInput.Builder()
                .messageType("text")
                .text(message)
                .build();
        MessageOptions options = new MessageOptions.Builder(assistanID, sessionId)
                .input(input)
                .build();
        assistant.message(options).enqueue(new ServiceCallback<MessageResponse>() {
            @Override
            public void onResponse(MessageResponse response) {
                System.out.println(response);
                Gson gson = new Gson();

                GsonWatson gsonparse = gson.fromJson(String.valueOf(response), GsonWatson.class);
                mainActivity.messageRecievedFromAssistant(gsonparse.getOutput().getGeneric().get(0).getText());
            }
            @Override
            public void onFailure(Exception e) {

            }
        });
    }





 android.os.NetworkOnMainThreadException
        at android.os.StrictMode$AndroidBlockGuardPolicy.onNetwork(StrictMode.java:1513)
        at java.net.Inet6AddressImpl.lookupHostByName(Inet6AddressImpl.java:117)
        at java.net.Inet6AddressImpl.lookupAllHostAddr(Inet6AddressImpl.java:105)
        at java.net.InetAddress.getAllByName(InetAddress.java:1154)
        at okhttp3.Dns$1.lookup(Dns.java:40)
        at okhttp3.internal.connection.RouteSelector.resetNextInetSocketAddress(RouteSelector.java:185)
        at okhttp3.internal.connection.RouteSelector.nextProxy(RouteSelector.java:149)
        at okhttp3.internal.connection.RouteSelector.next(RouteSelector.java:84)
        at okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:214)
        at okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:135)
        at okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:114)
        at okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
        at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
        at okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
        at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
        at okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
        at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:126)
        at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
        at okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
        at okhttp3.RealCall.execute(RealCall.java:77)
        at com.ibm.watson.developer_cloud.service.security.IamTokenManager.callIamApi(IamTokenManager.java:187)
        at com.ibm.watson.developer_cloud.service.security.IamTokenManager.requestToken(IamTokenManager.java:108)
        at com.ibm.watson.developer_cloud.service.security.IamTokenManager.getToken(IamTokenManager.java:78)
        at com.ibm.watson.developer_cloud.service.WatsonService.setAuthentication(WatsonService.java:375)
        at com.ibm.watson.developer_cloud.service.WatsonService.createCall(WatsonService.java:206)
        at com.ibm.watson.developer_cloud.service.WatsonService.createServiceCall(WatsonService.java:240)
        at com.ibm.watson.developer_cloud.assistant.v2.Assistant.message(Assistant.java:151)
        at com.XXX.IBMwatson.sendMessage(IBMwatson.java:78)
        at com.XXX.ibmwatson.MainActivity$onCreate$1.onClick(MainActivity.kt:39)
        at android.view.View.performClick(View.java:6597)
        at android.view.View.performClickInternal(View.java:6574)
        at android.view.View.access$3100(View.java:778)
        at android.view.View$PerformClick.run(View.java:25885)
        at android.os.Handler.handleCallback(Handler.java:873)
        at android.os.Handler.dispatchMessage(Handler.java:99)
        at android.os.Looper.loop(Looper.java:193)
        at android.app.ActivityThread.main(ActivityThread.java:6669)
        at java.lang.reflect.Method.invoke(Native Method)
        at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:493)
        at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:858)
  • немного покопался в исходном коде сервиса Watson. один из вызовов, сделанных в фоновом режиме, выполняется в основном потоке

class: XXX\files-2.1\com.ibm.watson.developer_cloud\core\6.13.2\673b89ba561c095131da91c327c99800f12b6d9f\core-6.13.2-sources.jar!\com\ibm\watson\developer_cloud\service\security\IamTokenManager.java

метод: callIamApi:187

line:187:- okhttp3.Response response = call.execute();

этот вызов выполняется в основном потоке.

Какой у вас код? Вы используете этот SDK? github.com/watson-developer-cloud/java-sdk/tree/master/… Стек показывает, что Assistant API V1 используется

data_henrik 25.02.2019 10:22
compile 'com.ibm.watson.developer_cloud:java-sdk:6.13.2' .
Jolson Da Costa 25.02.2019 12:20

вам нужно добавить код, чтобы мы увидели, в чем проблема

German Attanasio 26.02.2019 05:46

@GermanAttanasio пожалуйста, посмотри на это сейчас

Jolson Da Costa 26.02.2019 06:17

@JolsonDaCosta Мне удалось воссоздать проблему, так что спасибо, что обратили на нее мое внимание. Я собираюсь создать проблему в репозитории Java SDK для отслеживания и опубликую здесь ссылку, чтобы вы могли следовать ей.

Logan Patiño 26.02.2019 16:31
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
0
5
198
1

Ответы 1

В настоящее время это ошибка в Java SDK, где, как вы указали, вызов аутентификации через IAM все еще выполняется в основном потоке. Эта ошибка в настоящее время задокументирована здесь.

Тем временем, в качестве обходного пути, вы можете явно обернуть вызов в новый поток. Один из способов сделать это — использовать AsyncTask. Ниже приведен пример:

private class MessageTask extends AsyncTask<String, Void, String> {
  @Override
  protected String doInBackground(String... params) {
    MessageInput input = new MessageInput.Builder()
      .messageType("text")
      .text(params[0])
      .build();
    MessageOptions options = new MessageOptions.Builder(assistantId, sessionId)
      .input(input)
      .build();
    assistant.message(options).enqueue(new ServiceCallback<MessageResponse>() {
      @Override
      public void onResponse(MessageResponse response) {
        Log.d("Response: ", response.toString());
      }
      @Override
      public void onFailure(Exception e) {}
    });
    return "sent message successfully";
  }
}

где вы просто называете это так:

new MessageTask().execute("This is an example message");

Другие вопросы по теме