Android中RX2出现NetworkOnMainThreadException：能否无需AsyncTask/Runnable运行代码？

嘿，我来帮你捋清楚这个问题！你现在遇到的核心问题是代码执行的时机完全搞反了，这也是很多刚用RxJava的开发者容易踩的坑。

为什么会抛出异常？ #

你现在的代码里，当Presenter调用getObservableConnection()的时候，那些URL.openConnection()、connection.connect()的网络请求代码，会立刻在调用它的线程（也就是主线程）执行，而你后面加的subscribeOn(Schedulers.newThread())是订阅之后才会生效的——它管不到Observable创建阶段就已经执行完的网络操作！

简单说：你的网络请求根本没交给RxJava的线程池去跑，而是直接在主线程同步执行了，这当然会触发Android的NetworkOnMainThreadException。

怎么修改才能正常运行？ #

你需要把网络请求的逻辑包装到Observable的创建流程里，让RxJava来负责在指定线程执行这个耗时操作。这里给你两种常用的写法：

写法一：用 Observable.fromCallable()（推荐，简洁）

这个方法专门用来包装有返回值、且可能抛出异常的同步操作，非常适合你的场景：

@Override
public Observable<Boolean> getObservableConnection(String filter) {
    final int MILISECONDS = 3000;
    return Observable.fromCallable(() -> {
        URL myUrl = new URL("http://flickr.com");
        URLConnection connection = myUrl.openConnection();
        connection.setConnectTimeout(MILISECONDS);
        connection.connect();
        return true;
    }).onErrorReturn(throwable -> {
        // 捕获所有异常，返回false表示网络不通
        throwable.printStackTrace();
        Log.d("error en testinternet", throwable.toString());
        return false;
    }).subscribeOn(Schedulers.io()) // 用IO线程池，比newThread更高效（复用线程）
      .observeOn(AndroidSchedulers.mainThread());
}

写法二：用 Observable.create()（更灵活）

如果需要更精细地控制事件发射，可以用这个方式：

@Override
public Observable<Boolean> getObservableConnection(String filter) {
    final int MILISECONDS = 3000;
    return Observable.create(emitter -> {
        try {
            URL myUrl = new URL("http://flickr.com");
            URLConnection connection = myUrl.openConnection();
            connection.setConnectTimeout(MILISECONDS);
            connection.connect();
            emitter.onNext(true);
            emitter.onComplete();
        } catch (Exception e) {
            e.printStackTrace();
            Log.d("error en testinternet", e.toString());
            emitter.onNext(false);
            emitter.onComplete();
            // 如果你想把异常传递给观察者处理，也可以调用emitter.onError(e)
        }
    }).subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread());
}

额外提醒 #

• 尽量用Schedulers.io()代替Schedulers.newThread()：IO线程池会复用空闲线程，避免频繁创建销毁线程带来的性能开销，更适合网络、文件读写这类IO密集型操作。
• 记住RxJava的核心：subscribeOn指定的是Observable内部逻辑执行的线程，而不是订阅后的线程——所以必须让耗时操作放在Observable的内部逻辑里，才能被正确调度。

内容的提问来源于stack exchange，提问作者Ornitologo