资讯频道 → 编程语言
阅读更多

0顶
1踩

编程语言

原创新闻 当Kotlin遇见RxJava多数据源

2017-05-25 10:19 by 副主编 jihong10102006 评论(0) 有6277人浏览
Kotlin RxJava 数据源

声明：ITeye资讯文章的版权属于ITeye网站所有，严禁任何网站转载本文，否则必将追究法律责任！

引用
作者：Code4Android
来源：http://blog.csdn.net/xiehuimx/article/details/72643606

温馨提醒

阅读本文最好有Kotlin基础，若没有基础，可参考之前文章Kotlin初探，使用Kotlin优雅的开发Android应用，以及RxJava基础（本文基于RxJava2），当然我也会尽可能详细解释让你顺利阅读本文。
源码传送门

写在前面

最近几天回过头，看了之前的总结RxJava操作符系列，感觉对Rxjava多数据源的处理不是很理解，所以在总结学习一波。大家都知道，最近Kotlin语言一直占据热搜榜，褒贬不一，但我想说，不管有什么想法都要抛在脑后，毕竟Google爸爸出手，你不情愿也要跟随它的步伐。鉴于此，本篇对RxJava多数据源的总结是基于Kotlin语言，也让大家明白，使用Kotlin开发应用并不是不能使用Java库，现在有一部分人担心，Kotlin第三方库那么少，如果使用Kotlin开发那不是给自己找罪受，其实你完全错了，当你说这话的时候，我敢断定你都还没有接触Kotlin，因为Koltin有一个最重要的优势就是和Java绝对兼容。

多数据源处理操作符

在RxJava中多数据源处理的操作符很多，但是最经典的就要数merge,contact，zip了。如果对这三个操作符不是很熟悉的话，可以去查看它的使用，当然如果你懒得去看，我也会简单提一下。merge操作符可以处理多个Observable发送的数据，它是一个异步操作，不保证数据发送的顺序，即有可能出现数据交叉，当一个Observable发送了onError后，未执行的Observable不在继续执行，直接执行merge的onError方法。

contact操作符执行时一个同步操作，严格按照contact中传入Observable先后执行，即前面的先执行后面的后执行，并且最终发送的数据也是有序的，即第一个Observable的数据发送完毕再发送第二个，依次类推。

zip操作符和contact和merge有了本质的区别，它会将每个Observable个数据项分布对应返回一个Observable再发送，最终发送的数据量与最小数据长度相同。

使用场景分析

假如现在我们有三种商品，有一个查询商品信息的接口，根据接口可以查询该商品的价格以及出售地点。商品实体类 
data class Goods(var id:Int,var price: Int, var address: String)

在Kotlin语言中，实体类创建用data class 关键词，我们不需要和Java一样创建get/set方法，只需一行代码搞定。

创建模拟网络请求 
object NetRequest {
    //模拟网络请求
    fun getGoodsObservable(id: Int): Observable<Goods> {
fun getGoodsObservable(id: Int): Observable<Goods> {
        return Observable.create {
            source ->
            Thread.sleep(Random().nextInt(1000).toLong())
            var data = Goods(id, Random().nextInt(20), "地址${id}")
            source.onNext(data)
            source.onComplete()
            Log.e("getGoodsObservable:", "${id}")
        }
    }
}

在上面我们创建了一个单例类，在Kotlin中使用object修饰类时即给我们自动创建了一个单例对象。在每一句代码结尾我们不需要再和Java一样写一个分号“；”来结束，什么也不用写。

Observable.create使用的是lambda表达式，在Kotlin语言中是支持lambda表达式的。source 就是ObservableEmitter，所以我们可以调用onNext发送数据。为了更准确的模拟网络请求，使用Thread.sleep随机的延迟，模拟网络请求的时间。 
  fun getGoodsObservable(id: Int): Observable<Goods> {
        return Observable.create {
            source ->
            Thread.sleep(Random().nextInt(1000).toLong())
            var data = Goods(id, Random().nextInt(20), "地址${id}")
            source.onNext(data)
            source.onComplete()
            Log.e("getGoodsObservable:", "${id}")
        }

当然由于subscribe只有一个参数，所以我们也可以这样写。也就是省略了source ->，此时it就表示该参数数据。 
return Observable.create {
            Thread.sleep(Random().nextInt(1000).toLong())
            var data = Goods(id, Random().nextInt(20), "地址${id}")
            it.onNext(data)
            it.onComplete()
            Log.e("getGoodsObservable:", "${id}")
        }

在java中实现如下 
  return Observable.create(new ObservableOnSubscribe<Goods>() {

            @Override
            public void subscribe(@NonNull ObservableEmitter<Goods> e) throws Exception {
             //处理逻辑
            }
        });

merge

准备好了请求操作，开始使用merge看看执行的效果。 
  fun executeMerge() {
        Observable.merge(getGoodsObservable(1).subscribeOn(Schedulers.newThread()),
                getGoodsObservable(2).subscribeOn(Schedulers.newThread()),
                getGoodsObservable(3).subscribeOn(Schedulers.newThread()))
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .toList()
                .subscribe({
                    Log.e(TAG, it.toString())
                }, {
                    Log.e(TAG, it.toString())
                })
    }

merge中有三个网络请求操作，并通过subscribeOn(Schedulers.newThread())将网络请求切换到线程中执行，数据都请求成功后，再通过observeOn(AndroidSchedulers.mainThread())切换到主线程请求数据。为了三请求都成功后，我们在更新UI，所以通过toList()将请求的数据转换成List一块发送。在上面的subscribe依然使用的lambda表达式，subscribe（{}，{}）中第一个括号是onSuccess回调，里面的it是接收到的List< Goods >数据，第二个括号是onError回调，it表示异常Throwable对象。
subscribe部分Java代码 
.subscribe(new Consumer<List<Goods>>() {
                    @Override
                    public void accept(@NonNull List<Goods> goodses) throws Exception {

                    }
                }, new Consumer<Throwable>() {
                    @Override
                    public void accept(@NonNull Throwable throwable) throws Exception {

                    }
                });

当然如果你想使用RxJava2中onSubscribe(@NonNull Disposable d) ，你可以这样使用subscribe 
.subscribe(object : SingleObserver<List<Goods>> {
                    override fun onSubscribe(d: Disposable?) {
                    }
                    override fun onError(e: Throwable?) {
                    }
                    override fun onSuccess(t: List<Goods>?) {
                    }
                })

为了观察，我们将请求成功的数据显示在界面上，我们创建一个Button，TextView。 
class MainActivity : AppCompatActivity(), View.OnClickListener {

    val TAG = "MainActivity"
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        setSupportActionBar(toolbar)
        //加入这句import kotlinx.android.synthetic.main.activity_main.*
        //不用再findViewById,可直接使用
        merge.setOnClickListener(this)

    }
    override fun onClick(v: View) {
        when (v.id) {
            R.id.merge -> {
                executeMerge()
            }
        }
        //when 关键字和Java中的Switch关键词是类似的，
        //只不过它比Java中的Switch强大的多，可以接收任何参数，
        //然后判断使用,也可以如下使用
        when (v) {
            merge -> {
            }
        }
    }
}

contact

我们点击执行几次发现，返回的List的数据并不是按照merge参数的先后顺序执行的，它是并发的，最终的顺序，是由网络请求的快慢决定的，请求返回数据越快也就表示该数据最早发送，即在List中最靠前。那么此时出现一个问题，如果我想返回数据的List顺序严格按照位置的先后顺序呢？那此时使用merge的话，是不太现实了。当然前面我们提到contact可以使用。那么直接将merge更改为contact执行以下试试， 
    fun executeContact() {
        Observable.concat(getGoodsObservable(1).subscribeOn(Schedulers.newThread()),
                getGoodsObservable(2).subscribeOn(Schedulers.newThread()),
                getGoodsObservable(3).subscribeOn(Schedulers.newThread()))
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .toList()
                .subscribe({
                    Log.e(TAG, it.toString())
                }, {
                    Log.e(TAG, it.toString())
                })
    }

的确，发现无论执行多少次List的数据都能按照contact中Observable顺序发送，我们想要的效果可以实现了，不过你会发现，效率太差了，这是同步执行啊，只有第一个请求成功，才会去请求第二个，然后第三个，假如一次请求需要一秒，那三次请求至少三秒啊，不能忍。

zip

鉴于上面两种方式的利弊，如果我们既想如merge一样并发执行，又想和contact一样保证顺序，是不是有点强迫症的意思，当然强大的zip就能实现我们想要的效果。如下实现。 
    fun executeZip() {
        Observable.zip(getGoodsObservable(1),
                getGoodsObservable(2),
                getGoodsObservable(3),
                Function3<Goods, Goods, Goods, List<Goods>>
                { goods0, goods1, goods2 ->
                    val list = ArrayList<Goods>()
                    list.add(goods0)
                    list.add(goods1)
                    list.add(goods2)
                    list
                }).subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe({
                    Log.e(TAG, it.toString())
                }, {
                    Log.e(TAG, it.toString())
                })
    }

既然实现了，那我们运行几次，发现完美的实现了我们想要的效果，即并发的执行了，也保证了我们请求数据的顺序性。

在回调中运用RxJava

在上面我们的单个网络请求是一个同步的请求，如果我们的网络请求封装了，在线程中请求，请求成功后在主线程中回调，那我们又该如何创建呢使用呢？
先来模拟一个子线程请求网络，请求成功回调数据给主线程。 
    fun getGoods(ctx:Context,id: Int,callbacks:(goods:Goods)->Unit): Unit {
        ctx.doAsync {
            Thread.sleep(Random().nextInt(1000).toLong())
            var data = Goods(id, Random().nextInt(20), "地址${id}")
            ctx.runOnUiThread {
                callbacks(data)
            }
        }
    }

getGoods传了三个参数，第一个Context对象，第二个是商品ID,第三个参数是一个函数，(goods:Goods)->Unit表示第三个参数的类型是一个参数为Goods类型并且返回Unit的函数。使用doAsync 模拟异步请求，请求成功后runOnUiThread 切换到UI线程。然后callbacks（data）将数据回调。这种使用方式比Java中回调优美好用太多了。
接下来就开始在回调成功后创建Observable 
  fun getGoodsCallBack(id: Int): Observable<Goods> {
        var subscrbe: ObservableEmitter<Goods>? = null
        var o = Observable.create<Goods> {
            subscrbe = it
        }
        //Kotlin特性
        getGoods(this@MainActivity, id) {
            subscrbe?.onNext(it)
        }
        return o
    }
    fun executeZipCallBack() {
        Observable.zip(getGoodsCallBack(1).subscribeOn(Schedulers.newThread()),
                getGoodsCallBack(2).subscribeOn(Schedulers.newThread()),
                getGoodsCallBack(3).subscribeOn(Schedulers.newThread()),
                Function3<Goods, Goods, Goods, List<Goods>>
                { goods0, goods1, goods2 ->
                    val list = ArrayList<Goods>()
                    list.add(goods0)
                    list.add(goods1)
                    list.add(goods2)
                    list
                }).subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe({
                    Log.e(TAG, it.toString())
                }, {
                    Log.e(TAG, it.toString())
                })
    }

ok,到这里回调情况下创建使用RxJava也介绍完毕，到此本篇文章就结束了，有问题欢迎指出，内容杂乱，多多担待，Hava a wonderful day.
0
顶
1
踩
评论 共 0 条 请登录后发表评论

发表评论

您还没有登录,请您登录后再发表评论

相关推荐

  • Kotlin

    Kotlin是JetBrains团队开发的一门基于 JVM 的，现代的、注重工程实用性的静态类型编程语言。Kotlin可以编译成Java字节码，也可以编译成JavaScript、Native、而且它是由 Jetbrains 开发的。Kotlin 编译为字节码，则...

  • 【新收录】CSDN日报 —— Kotlin 专场

    谷歌在 I/O 2017 开发者大区会上宣布了 Kotlin 成为安卓开发一级语言。那么，Kotlin 会取代 Java 么，你怎么看？

  • CSDN日报20170525 ——《狗蛋的寻亲之路，结识嵌入式世界的那只狗》

    当 Kotlin 遇见 RxJava 多数据源 作者： Code4Android 本篇对 RxJava 多数据源的总结是基于 Kotlin 语言，也让大家明白，使用 Kotlin 开发应用并不是不能使用 Java 库，现在有一部分人担心，Kotlin 第三方...

  • 2019年为android开发准备的面试题（含答案）

    Integer是int的包装类，int则是java的一种基本数据类型，Integer变量必须实例化才能使用，当new一个Integer时，实际是生成一个指向此对象的引用，而int是直接存储数据的值，Integer默认值是null，而int默认值是0 ...

  • Jetpack Room,Navigation,ViewModel

    Jetpack Gayhub地址 本页面内容仅为个人学习笔记，受限于微博的能力，可能存在一定概念或者理解上的问题。 [外链图片转存失败,源站可能有...[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-

  • [转载] 【汇总】Android知识清单

    服务器只提供数据接收接口，在多线程或多进程条件下，如何保证数据的有序到达？ 动态布局的理解 怎么去除重复代码？ 画出 Android 的大体架构图 Recycleview和ListView的区别 ListView图片加载错乱的原理...

  • Android高级面试全记录（刷题，不断补充完善）

    4.ContentProvider 进程(应用程序)间数据共享,数据源可以是sqlite,也可以是xml,相关类: ContentResolver(内容解析器), ContentObserver(数据 观察者) 5. 网络存储 天气数据的xml,json格式等等,通过...

  • 总结2022最全的BAT大厂面试题整理及分析

    熟练掌握java是很关键的，大公司不仅仅要求你会使用几个api，更多的是要你熟悉源码实现原理，甚至要你知道有哪些不足，怎么改进，还有一些java有关的一些算法，设计模式等等。这里整理的是一些与技术没有直接关系的...

  • 应该是史上最全最新Java和Android面试题目(自己总结和收集的)

    ConcurrentHashMap线程安全，引入“分段锁”概念，通过将整个map分为多个segment（类似HashTable）可以提供相同的线程安全，效率默认提供16倍 HashTable, HashMap，TreeMap区别？ 数组和链表的区别 ...

  • (源码)基于 Koa2 的 FEBLOG API.zip

    # 基于 Koa2 的 FEBLOG API ## 项目简介 FEBLOG API 是一个基于 Node.js 和 Koa2 框架的 RESTful API 服务器，支持多种关系型数据库（如 PostgreSQL、MySQL、MariaDB、SQLite、MSSQL），并使用 Sequelize 作为 ORM。项目支持跨域请求、JSON 数据传输、JWT 身份认证等功能，适用于构建前后端分离的应用。 ## 主要特性和功能 跨域支持通过配置支持跨域请求。 数据传输格式支持 applicationxwwwformurlencoded、multipartformdata、applicationjson 格式的 POST、PUT、DELETE 请求。 JWT 身份认证通过 JWT 实现用户身份认证。 数据库支持使用 Sequelize ORM 支持 PostgreSQL、MySQL、MariaDB、SQLite、MSSQL 等多种数据库。

  • 存储器实验资料.zip

    存储器实验资料.zip

  • (源码)基于 Python 的知乎热榜爬虫及数据处理项目.zip

    # 基于 Python 的知乎热榜爬虫及数据处理项目 ## 项目简介 本项目基于 Python 编程语言，旨在实现知乎热榜的定时跟踪以及相关数据的存储与查询操作。通过爬虫技术获取知乎热榜问题的详细信息，将数据存入数据库，同时提供一系列 SQL 查询示例帮助用户熟悉 SQL 基本语法，还包含使用 Selenium 实现 GPA 计算器的功能。 ## 项目的主要特性和功能 1. 知乎热榜爬虫定期爬取知乎热榜，获取问题摘要、描述、热度、访问人数、回答数量等基本信息，并将数据存入数据库。 2. 可定制爬虫逻辑用户可以选择删除已有代码从零开始编写，也可以完成代码填空实现相应功能。 3. GPA 计算器使用 Selenium 模拟点击登录 WebVPN，登录 info 并访问成绩单页面，查询成绩并计算每学期的绩点。 4. SQL 练习提供一系列基于 MySQL 数据库的 SQL 查询练习，帮助用户熟悉基本的 SQL 语法，如添加新列、数据填充、关键词查询等。

  • (源码)基于C语言的学生信息管理系统.zip

    # 基于C语言的学生信息管理系统 ## 项目简介 这是一个基于文本界面的学生信息管理系统，旨在通过简单的文本输入实现学生信息的添加、查找、修改和删除操作。系统采用链表数据结构存储学生信息，并支持文件读写功能以持久化存储数据。 ## 项目的主要特性和功能 ### 主要特性 1. 文本界面操作用户通过控制台输入指令完成操作。 2. 链表数据结构使用链表存储学生信息，方便信息的添加和删除。 3. 文件操作支持将学生信息数据保存到文件，以及从文件中读取数据。 ### 功能详解 登录验证用户需输入正确的学号和密码才能进入系统。 主界面展示显示系统主菜单，包括学生信息查找、删除、添加、修改和录入等功能。 学生信息查找根据学号查找学生信息。 学生信息删除根据学号删除学生信息。 学生信息添加可以添加新的学生信息到系统中。 学生信息修改可以修改已存在的学生信息。 学生信息录入展示所有存储的学生信息。 辅助功能

  • (源码)基于VS Code的px到rpx转换工具.zip

    # 基于VS Code的px到rpx转换工具 ## 项目简介 本项目是一款VS Code插件，旨在将前端代码里的单位px转换为rpx。当设计师在设计稿中使用px单位时，开发者能够借助该工具快速把代码中的px转换为小程序适用的rpx单位。它借助语法分析技术实现精准转换，避免误改其他属性里的px。 ## 项目的主要特性和功能 1. 自动转换功能能通过简单命令自动识别并转换style标签内所有声明中的px为rpx。 2. 精准转换利用语法分析，仅对真正的单位值进行转换，防止错误修改其他内容中的px字符。 3. 部分转换支持可选择部分样式代码进行转换，操作灵活便捷。 ## 安装使用步骤 假设用户已下载本项目源码文件且安装了VS Code环境。 1. 安装插件打开VS Code，进入侧边栏的扩展视图，搜索并安装“px2rpx”插件。 2. 重启VS Code安装完成后重启VS Code使插件生效。

  • test文件资包 传递使用

    test文件资包。传递使用

  • LCCC2701 智能车灯控制系统设计 20250329

    主控：AT89C52 显示：LCD1602 光照检测：光敏电阻 距离检测：超声波测距 远光灯 近光灯 按键（设置阈值） 1、使用光敏电阻实时检测环境光线强度，设置阈值判断是否开启远光灯； 2、利用超声波传感器测量迎面车辆距离，设置安全距离阈值，自动切换到近光灯； 3、加入延时功能（例如在检测到迎面车辆后等待3秒再切换灯光），以减少频繁切换，提升平滑性。 4、所选传感器模块、执行器模块、电源与接口电路等模块的型号需要是便宜的。

  • ESP32之阿里云OTA固件升级（源码）

    esp-idf-v5.3.2

  • 信息安全领域实战项目【信息安全领域】实战项目汇总：涵盖网络渗透测试、Web应用安全加固、企业安全策略制定等内容多个信息安全领域的实战

    内容概要：本文介绍了多个信息安全领域的实战项目，涵盖网络渗透测试、Web应用安全加固、企业安全策略制定与实施、恶意软件分析、数据泄露应急响应、物联网设备安全检测、区块链安全审计和云安全防护。每个项目都详细描述了其目标和具体实施步骤，包括信息收集、漏洞扫描、利用和修复、安全配置、风险评估、制度建设、培训教育、样本获取与分析、事件响应、遏制措施、调查取证、数据恢复、安全检测、架构分析、智能合约审计、共识机制审查、云环境评估、访问管理、网络安全防护等方面。 适合人群：信息安全从业者、IT管理人员、安全顾问、系统管理员、开发人员以及对信息安全感兴趣的人员。 使用场景及目标：①为信息安全从业人员提供实际操作指导，帮助其掌握不同场景下的安全防护技能；②为企业提供全面的信息安全保障方案，确保其信息系统和数据的安全性；③为开发人员提供安全编码和系统设计的最佳实践指南，提高应用程序的安全性；④为安全研究人员提供深入分析恶意软件和区块链系统的工具和方法。 阅读建议：读者可以根据自身需求选择感兴趣的部分进行深入学习，建议结合实际案例进行实践操作，同时关注最新的安全技术和法规要求，以确保所学知识与时俱进并能应用于实际工作中。

  • (源码)基于C语言和STM32F0系列微控制器的宏键盘系统.zip

    # 基于C语言和STM32F0系列微控制器的宏键盘系统 ## 项目简介 本项目是基于C语言和STM32F0系列微控制器开发的宏键盘系统。该系统可让用户自定义宏按键，实现快速输入或自动化任务，涵盖硬件的GPIO输入输出控制、USB通信以及中断处理等功能。 ## 项目的主要特性和功能 宏定义用户能通过定义keymappings.h文件中的宏按键，自定义按键行为。 USB通信利用STM32F0系列微控制器的USB库，支持HID类通信。 GPIO控制实现对键盘按键读取和发送操作的控制。 中断处理可处理按键状态变化、USB通信等外部中断请求。 电源管理对微控制器的睡眠、停止和待机等电源模式进行管理。 ## 安装使用步骤 ### 硬件准备 确保STM32F0系列微控制器（如STM32F042K6）的GPIO引脚、USB接口等硬件连接正确。 保证所有必要外设（如LED、按键）正确连接且可用。 ### 软件准备 下载并解压项目源代码。

Global site tag (gtag.js) - Google Analytics