1. 需求场景

2. 功能说明

即，同时向2个数据源获取数据 -> 合并数据 -> 统一展示到客户端

3. 具体实现

此处采用Merge（）&Zip（）操作符进行讲解，其中：

Merge（）例子 ：实现较为简单的从（网络 + 本地）获取数据 & 统一展示Zip（）例子：结合Retrofit与RxJava，实现较为复杂的合并2个网络请求向2个服务器获取数据 & 统一展示

3.1 采用 Merge（）操作符

// 用于存放最终展示的数据String result = "数据源来自 = " ;/** 设置第1个Observable：通过网络获取数据* 此处仅作网络请求的模拟**/Observable<String> network = Observable.just("网络");/** 设置第2个Observable：通过本地文件获取数据* 此处仅作本地文件请求的模拟**/Observable<String> file = Observable.just("本地文件");/** 通过merge（）合并事件 & 同时发送事件**/Observable.merge(network, file).subscribe(new Observer<String>() {@Overridepublic void onSubscribe(Disposable d) {}@Overridepublic void onNext(String value) {Log.d(TAG, "数据源有： "+ value );result += value + "+";}@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}// 接收合并事件后，统一展示@Overridepublic void onComplete() {Log.d(TAG, "获取数据完成");Log.d(TAG, result );}});

测试结果

3.2 采用Zip（）操作符

功能说明

在该例中，我将结合结合Retrofit与RxJava，实现：

从不同数据源（2个服务器）获取数据，即合并网络请求的发送统一显示结果

实现方案

采用Get方法 对 金山词霸API发送2个网络请求（将英文翻译成中文，翻译2次） & 将2次翻译的结果一起显示。

采用Gson进行数据解析

步骤说明

添加依赖创建 接收服务器返回数据 的类创建 用于描述网络请求 的接口创建 Retrofit 实例创建 网络请求接口实例 并 配置网络请求参数发送网络请求发送网络请求对返回的数据进行处理步骤实现

步骤1： 添加依赖

a. 在Gradle加入Retrofit库的依赖

build.gradle

dependencies {// Android 支持 Rxjava// 此处一定要注意使用RxJava2的版本compile 'io.reactivex.rxjava2:rxjava:2.0.1'compile 'io.reactivex.rxjava2:rxandroid:2.0.1'// Android 支持 Retrofitcompile 'com.squareup.retrofit2:retrofit:2.1.0'// 衔接 Retrofit & RxJava// 此处一定要注意使用RxJava2的版本compile 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0'// 支持Gson解析compile 'com.squareup.retrofit2:converter-gson:2.1.0'}

b. 添加 网络权限

AndroidManifest.xml

<uses-permission android:name="android.permission.INTERNET"/>

步骤2：创建 接收服务器返回数据 的类

金山词霸API的数据格式说明如下：

// URL模板/ajax.php// URL实例/ajax.php?a=fy&f=auto&t=auto&w=hello%20world// 参数说明：// a：固定值 fy// f：原文内容类型，日语取 ja，中文取 zh，英语取 en，韩语取 ko，德语取 de，西班牙语取 es，法语取 fr，自动则取 auto// t：译文内容类型，日语取 ja，中文取 zh，英语取 en，韩语取 ko，德语取 de，西班牙语取 es，法语取 fr，自动则取 auto// w：查询内容

根据 金山词霸API 的数据格式，创建 接收服务器返回数据 的类：

为了演示是两个网络请求，所以对应设置2个接收服务器的数据类

<-- Translation1.java -->public class Translation1 {private int status;private content content;private static class content {private String from;private String to;private String vendor;private String out;private int errNo;}//定义 输出返回数据 的方法public String show() {return ("第1次翻译=" + content.out);}}<-- Translation2.java -->public class Translation2 {private int status;private content content;private static class content {private String from;private String to;private String vendor;private String out;private int errNo;}//定义 输出返回数据 的方法public String show() {return ("第2次翻译=" + content.out);}}

步骤3：创建 用于描述网络请求 的接口

采用注解+Observable<...>接口描述 网络请求参数

GetRequest_Interface.java

public interface GetRequest_Interface {// 网络请求1@GET("ajax.php?a=fy&f=auto&t=auto&w=hi%20world")Observable<Translation1> getCall();// 网络请求2@GET("ajax.php?a=fy&f=auto&t=auto&w=hi%20china")Observable<Translation2> getCall_2();// 注解里传入 网络请求 的部分URL地址// Retrofit把网络请求的URL分成了两部分：一部分放在Retrofit对象里，另一部分放在网络请求接口里// 如果接口里的url是一个完整的网址，那么放在Retrofit对象里的URL可以忽略// 采用Observable<...>接口// getCall()是接受网络请求数据的方法}

接下来的步骤均在MainActivity.java内实现（请看注释）

MainActivity.java

public class MainActivity extends AppCompatActivity {private static final String TAG = "Rxjava";// 定义Observable接口类型的网络请求对象Observable<Translation1> observable1;Observable<Translation2> observable2;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);// 步骤1：创建Retrofit对象Retrofit retrofit = new Retrofit.Builder().baseUrl("/") // 设置 网络请求 Url.addConverterFactory(GsonConverterFactory.create()) //设置使用Gson解析(记得加入依赖).addCallAdapterFactory(RxJava2CallAdapterFactory.create()) // 支持RxJava.build();// 步骤2：创建 网络请求接口 的实例GetRequest_Interface request = retrofit.create(GetRequest_Interface.class);// 步骤3：采用Observable<...>形式 对 2个网络请求 进行封装observable1 = request.getCall().subscribeOn(Schedulers.io()); // 新开线程进行网络请求1observable2 = request.getCall_2().subscribeOn(Schedulers.io());// 新开线程进行网络请求2// 即2个网络请求异步 & 同时发送// 步骤4：通过使用Zip（）对两个网络请求进行合并再发送Observable.zip(observable1, observable2,new BiFunction<Translation1, Translation2, String>() {// 注：创建BiFunction对象传入的第3个参数 = 合并后数据的数据类型@Overridepublic String apply(Translation1 translation1,Translation2 translation2) throws Exception {return translation1.show() + " & " +translation2.show();}}).observeOn(AndroidSchedulers.mainThread()) // 在主线程接收 & 处理数据.subscribe(new Consumer<String>() {// 成功返回数据时调用@Overridepublic void accept(String combine_infro) throws Exception {// 结合显示2个网络请求的数据结果Log.d(TAG, "最终接收到的数据是：" + combine_infro);}}, new Consumer<Throwable>() {// 网络请求错误时调用@Overridepublic void accept(Throwable throwable) throws Exception {System.out.println("登录失败");}});}}

测试结果

china不翻译改为welcome