Android rxjava与okhttp - NetworkOnMainThreadException

-1

我有时会得到异常 - android.os.NetworkOnMainThreadException，有时代码的作品。Android rxjava与okhttp - NetworkOnMainThreadException

这里是我的代码

Observable.create(new Observable.OnSubscribe<Response>() { 
     OkHttpClient client = new OkHttpClient(); 

     @Override 
     public void call(Subscriber<? super Response> subscriber) { 
      try { 
       Response response = client.newCall(request).execute(); 

       subscriber.onNext(response); 
       subscriber.onCompleted(); 
      } catch (IOException e) { 
       subscriber.onError(e); 
      } 

     } 
    }).subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .unsubscribeOn(Schedulers.io()) 
      .map(new Func1<Response, Res>() { 
       @Override 

       public Res call(Response response) { 

        String post = new Scanner(response.body().byteStream(), "UTF-8") 
          .useDelimiter("\\A").next(); 
        Log.d(TAG,post); 
        return model.deCryptData(post); 
       } 
      }) 

      .subscribe(new Action1<Res>() { 
       @Override 
       public void call(Res res) { ...

有时候结果是：

11月4日至19日：34：21.890 9763-9763 /？ W/System.err：android.os.NetworkOnMainThreadException 04-19 11：34：21.890 9763-9763 /？ W/System.err：在android.os.StrictMode $ AndroidBlockGuardPolicy.onNetwork（StrictMode.java:1273） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在libcore.io.BlockGuardOs.recvfrom（BlockGuardOs.java:249） 04-19 11：34：21.890 9763-9763 /？ W/System.err：at libcore.io.IoBridge.recvfrom（IoBridge.java:549） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.net.PlainSocketImpl.read（PlainSocketImpl.java:481） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.net.PlainSocketImpl.access $ 000（PlainSocketImpl.java:37） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.net.PlainSocketImpl $ PlainSocketInputStream.read（PlainSocketImpl.java:237） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在okio.Okio $ 2.read（Okio.java:138） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在okio.AsyncTimeout $ 2.read（AsyncTimeout.java:238） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在okio.RealBufferedSource.read（RealBufferedSource.java:45） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在okhttp3.internal.http.Http1xStream $ FixedLengthSource.read（Http1xStream.java:377） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在okio.RealBufferedSource.read（RealBufferedSource.java:45） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在okio.RealBufferedSource.exhausted（RealBufferedSource.java:55） 04-19 11：34：21.890 9763-9763 /？ W/System.err：at okio.InflaterSource.refill（InflaterSource.java:101） 04-19 11：34：21.890 9763-9763 /？ W/System.err：at okio.InflaterSource.read（InflaterSource.java:62） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在okio.GzipSource.read（GzipSource.java:80） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在okio.RealBufferedSource $ 1.read（RealBufferedSource.java:409） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.io.InputStreamReader.read（InputStreamReader.java:233） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.io.Reader.read（Reader.java:141） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.io.Reader.read（Reader.java:245） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.util.Scanner.readMore（Scanner.java:2068） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.util.Scanner.findDelimiterAfter（Scanner.java:2038） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.util.Scanner.setTokenRegion（Scanner.java:1953） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.util.Scanner.next（Scanner.java:965） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在java.util.Scanner.next（Scanner.java:941） 04-19 11：34：21.890 9763-9763 /？ W/System.err：在uz.newsign.mvp.ImplPresenter $ 3.call（ImplPresenter.java:121） 04-19 11：34：21.891 9763-9763 /？ W/System.err：在uz.newsign.mvp.ImplPresenter $ 3.call（ImplPresenter.java:115） 04-19 11：34：21.891 9763-9763 /？ W/System.err：在rx.internal.operators.OperatorMap $ MapSubscriber.onNext（OperatorMap.java:66） 04-19 11：34：21.891 9763-9763 /？ W/System.err：在rx.internal.operators.OperatorUnsubscribeOn $ 1.onNext（OperatorUnsubscribeOn.java:53） 04-19 11：34：21.891 9763-9763 /？ W/System.err：在rx.internal.operators.OperatorObserveOn $ ObserveOnSubscriber.call（OperatorObserveOn。java：227） 04-19 11：34：21.891 9763-9763 /？ W/System.err：在rx.android.schedulers.LooperScheduler $ ScheduledAction.run（LooperScheduler.java:107） 04-19 11：34：21.891 9763-9763 /？ W/System.err：at android.os.Handler.handleCallback（Handler.java:739） 04-19 11：34：21.891 9763-9763 /？ W/System.err：at android.os.Handler.dispatchMessage（Handler.java:95） 04-19 11：34：21.891 9763-9763 /？ W/System.err：在android.os.Looper.loop（Looper.java:148） 04-19 11：34：21.891 9763-9763 /？ W/System.err：在android.app.ActivityThread.main（ActivityThread.java:5441） 04-19 11：34：21.891 9763-9763 /？ W/System.err：在java.lang.reflect.Method.invoke（Native Method） 04-19 11：34：21.891 9763-9763 /？ W/System.err：at com.android.internal.os.ZygoteInit $ MethodAndArgsCaller.run（ZygoteInit.java:738） 04-19 11：34：21.891 9763-9763 /？ W/System.err：at com.android.internal.os.ZygoteInit.main（ZygoteInit.java:628） 04-19 11：34：21.891 9763-9763 /？ W/System.err：引起：rx.exceptions.OnErrorThrowable $ OnNextValue：OnError发出onNext值：okhttp3.Response.class 04-19 11：34：21.891 9763-9763 /？ W/System.err：在rx.internal.operators.OperatorMap $ MapSubscriber.onNext（OperatorMap.java:70） 04-19 11：34：21.891 9763-9763 /？ W/System.err：...更多

我在做什么错了？或者它的错误？

来源

2017-04-19 Muhammadjon Xasanov

你不能在主线程上进行网络调用。因此，对于网络，你应该使用工作线程在后台调用网络调用，完成工作后，只需获得响应并发布UI。

来源

2017-04-19 07:03:56

.subscribeOn（Schedulers.io（）） .observeOn（AndroidSchedulers.mainThread（）） - 它是你的答案？ –

-1

发生这种情况是因为您在进行实际工作的同一范围内（主线程）发出网络请求。如果网络请求在主线程上完成，那么您的主代码将被网络请求阻止，直到收到响应，这将导致应用程序出现意外行为。在处理网络请求时，建议您在其他线程上发出网络请求。你可以通过AsyncTask来完成。更多的信息：https://developer.android.com/reference/android/os/AsyncTask.html。

或者，您也可以使用谷歌的Volley库来处理线程问题。这里更多的信息：https://developer.android.com/training/volley/index.html

来源

2017-04-19 07:08:42

他正在与Rxjava合作，所以不需要异步任务或排队 –

谢谢。但之前我与asynctask合作，但现在我删除了所有旧的代码，现在我正在尝试用现代rxjava，rxandroid与okhttp编写其余api代码，但它不能正常工作 –

变化Schedulers.io()到Schedulers.newThread()

来源

2017-04-19 07:15:44

虽然此代码可能会回答问题，提供额外的[上下文]（https://meta.stackexchange.com/q/114762）关于_how_和/或_why_它解决了这个问题会提高答案的长期价值。请记住，你正在为将来的读者回答这个问题，而不仅仅是现在问的人！请[编辑]（http://stackoverflow.com/posts/43488977/edit）您的答案添加一个解释，并指出适用的限制和假设。它也不会提到为什么这个答案比其他答案更合适。 –

.subscribeOn(Schedulers.newThread()) 
.observeOn(AndroidSchedulers.mainThread())

订阅新的线程，并观察mainThread

来源

2017-04-19 07:18:29

尝试自行创建线程池和订阅就可以了。

ExecutorService webRequestsExecutor = Executors.newFixedThreadPool(1); 
    //Other stuff  
    .subscribeOn(Schedulers.from(webRequestsExecutor)) 
        .observeOn(AndroidSchedulers.mainThread()) 
        .unsubscribeOn(Schedulers.io())

来源

2017-04-19 07:20:30

我试过了，但不起作用 –

Android rxjava与okhttp - NetworkOnMainThreadException

回答

相关问题