A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

哥们,RxAndroid很好很强大!!





          注:前面说到了Rxjava,介于我们是Android开发人员,有RxAndroid的话我们肯定使用RxAndroid来实现业务啊,今天我就从我项目中抽取一段解析网页的逻辑来说明RxAndroid处理业务的简洁强大之处,可能例子简单,但是适合初学者是不。。。


RxAndroid是啥,他和RxJAva有啥关系


RxAndroid 是 RxJava 的 Android 绑定。其实使用起来也差不多,但是在android中好使,比方说更新主线程UI


上例子

需求:我要使用Jsoup抓取网页源码,然后解析,然后把其中我需要的元素封装到bean中,供我的阅读类App使用,代码如下:


//TODO 下面开始使用rxandroid 进行编程,采用jsoup-1.8.3.jar采集网页 并获取网页上的内容
// 添加   compile 'io.reactivex:rxandroid:1.0.1'
        //第一步 创建一个Observable<被观察者>对象,调用create方法
        Observable.create(new Observable.OnSubscribe<ResponseArticlesListEntity>() {
            @Override
            public void call(Subscriber<? super ResponseArticlesListEntity> subscriber) {

                try {
            //使用Jsoup抓取网页源码
                    Document result = Jsoup.connect(articleEntity.href).userAgent("Mozilla/4.0 (compatible; MSIE 9.0; Windows NT 6.1; Trident/5.0)").get();
                    Elements postHeads = null;
                    Elements postContent1s = null;
                    switch (article_type) {
                        case JITANG:
                            postHeads = result.getElementsByClass("PostHead");
                            postContent1s = result.getElementsByClass("PostContent1");
                            break;
                        case HEIMA:
                        case HONGHEI:
                            postHeads = result.getElementsByClass("ATitle");//获得标题
                            postContent1s = result.getElementsByClass("ADesc");//获得内容简介
                            break;

                    }


                    List<ArticleEntity> list = new ArrayList<ArticleEntity>(postHeads.size());
                    ResponseArticlesListEntity responseArticlesListEntity = new ResponseArticlesListEntity();
                    for (int i = 0; i < postHeads.size(); i++) {
                        ArticleEntity lz13 = new ArticleEntity();
                        lz13.Type=article_type==ARTICLE_TYPE.JITANG?0:(article_type==ARTICLE_TYPE.HEIMA?1:2);
                        Element postHead = postHeads.get(i);
                        Element a = postHead.getElementsByTag("a").get(0);
                        lz13.href = a.attr("href");
                        lz13.title = a.text();
                        Element postContent1 = postContent1s.get(i);
                        lz13.text = postContent1.text().replace(lz13.title, "");
                        String[] split = lz13.text.split("\\s{2,}");//匹配至少两次     //匹配任何空白字符,包括空格、制表符、换页符等。与 [ \f\n\r\t\v] 等效
                        StringBuffer sb = new StringBuffer();
                        for (String s : split) {
                            if (TextUtils.isEmpty(s)) {
                                continue;
                            }
                            if (lz13.title.equals(s)) {
                                continue;
                            }
                            if (s.matches("\\d{4}-\\d{2}-\\d{2} \\d{2}:\\d{2}:\\d{2}")) {
                                //2016-02-01 14:54:27
                                continue;
                            }
                            if (s.startsWith("文/")) {
                                lz13.auth = s;
                                continue;
                            }
                            sb.append("        ").append(s).append("<br/>");
                        }
                        int index = sb.lastIndexOf("<br/>");
                        if (index == -1) continue;

                        lz13.text = sb.substring(0, sb.lastIndexOf("<br/>") - 1) + "......";
                        list.add(lz13);
                    }


                    responseArticlesListEntity.setResult(list);
                    //网页解析成功,填充到bean后,执行onNext
                    subscriber.onNext(responseArticlesListEntity);
                } catch (Exception e) {
                    e.printStackTrace();
                    //网页解析失败,填充到bean后,执行onNext(null)
                    subscriber.onNext(null);
                }
            }


        })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())//规定到主线程中运行
                .subscribe(new Action1<ResponseArticlesListEntity>() {
            @Override
            public void call(ResponseArticlesListEntity responseArticlesListEntity) {
                //这里就是主线程,通过接口吧数据返回到Activity或者Fragment中显示并更新UI
                if (null == responseArticlesListEntity) {
                    loadedListener.onError(null);
                } else {
                    loadedListener.onSuccess(event_tag, responseArticlesListEntity);
                }
            }
        });


从上面的例子我们可以看出,这个业务逻辑很简单就实现了,并且不用一些runui之类的方法,直接刷新UI效果,并且一目了然!!


这次也只是起一个抛砖引玉的作用,来介绍RXAndroid的使用,后面还有详细业务帖子,敬请期待!!



点评

很不错  发表于 2023-11-2 16:20

5 个回复

倒序浏览
好崇拜啊----我又学到了一定
回复 使用道具 举报
学习了,赞一个,棒棒的
回复 使用道具 举报
还没就业班,先看看,学习学习!谢谢分享
回复 使用道具 举报
asdasdasdasdasd
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马