Android Rxjava教程:清晰 简洁 易懂的Rxjava入门教程

前言

  • Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点,深受各大 Android开发者的欢迎。

image

  • 本文主要:

    1. 面向 刚接触Rxjava的初学者
    2. 提供了一份 清晰、简洁、易懂的Rxjava入门教程

    涵盖 基本介绍、原理 & 具体使用等

    1. 解决的是初学者不理解Rxjava原理 & 不懂得如何使用的问题

希望你们会喜欢。

  1. 本文主要基于Rxjava 2.0
  2. 如果读者还没学习过Rxjava 1.0也没关系,因为Rxjava 2.0只是在Rxjava 1.0上增加了一些新特性,本质原理 & 使用基本相同
  3. 接下来的时间,我将持续推出 AndroidRxjava 2.0 的一系列文章,包括原理、操作符、应用场景、背压等等 ,有兴趣可以继续关注Kenny_星星之火的安卓开发笔记!!

image


目录

image


1. 定义

  • RxJavaGitHub 的介绍:

RxJava:a library for composing asynchronous and event-based programs using observable sequences for the Java VM
// 翻译:RxJava 是一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库
  • 总结:RxJava 是一个 基于事件流、实现异步操作的库

2. 作用

实现异步操作

类似于 Android中的 AsyncTaskHandler作用


3. 特点

由于 RxJava的使用方式是:基于事件流的链式调用,所以使得 RxJava

  • 逻辑简洁
  • 实现优雅
  • 使用简单

更重要的是,随着程序逻辑的复杂性提高,它依然能够保持简洁 & 优雅


4. 原理

4.1 生活例子引入

  • 我用一个生活例子引入 & 讲解 Rxjava原理: 顾客到饭店吃饭

image

image

4.2 Rxjava原理介绍

  • Rxjava原理 基于 一种扩展的观察者模式

  • Rxjava的扩展观察者模式中有4个角色:

角色作用类比
被观察者(Observable)产生事件顾客
观察者(Observer)接收事件,并给出响应动作厨房
订阅(Subscribe)连接 被观察者 & 观察者服务员
事件(Event)被观察者 & 观察者 沟通的载体菜式
  • 具体原理

请结合上述 顾客到饭店吃饭 的生活例子理解:

image

image

RxJava原理可总结为:被观察者 (Observable) 通过 订阅(Subscribe) 按顺序发送事件 给观察者 (Observer), 观察者(Observer) 按顺序接收事件 & 作出对应的响应动作。具体如下图:

image

至此,RxJava原理讲解完毕。


5. 基本使用

  • 本文只关注 RxJava的基本使用,更深入的RxJava使用请继续关注Carson_Ho的RxJava系列
  • Rxjava的使用方式有两种:
    1. 分步骤实现:该方法主要为了深入说明Rxjava的原理 & 使用,主要用于演示说明
    2. 基于事件流的链式调用:主要用于实际使用

5.1 方式1:分步骤实现

5.1.1 使用步骤

image

5.1.2 步骤详解

步骤1:创建被观察者 (Observable )& 生产事件

  • 即 顾客入饭店 - 坐下餐桌 - 点菜
  • 具体实现

        // 1\. 创建被观察者 Observable 对象Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {// create() 是 RxJava 最基本的创造事件序列的方法// 此处传入了一个 OnSubscribe 对象参数// 当 Observable 被订阅时,OnSubscribe 的 call() 方法会自动被调用,即事件序列就会依照设定依次被触发// 即观察者会依次调用对应事件的复写方法从而响应事件// 从而实现被观察者调用了观察者的回调方法 & 由被观察者向观察者的事件传递,即观察者模式// 2\. 在复写的subscribe()里定义需要发送的事件@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {// 通过 ObservableEmitter类对象产生事件并通知观察者// ObservableEmitter类介绍// a. 定义:事件发射器// b. 作用:定义需要发送的事件 & 向观察者发送事件emitter.onNext(1);emitter.onNext(2);emitter.onNext(3);emitter.onComplete();}});<--扩展:RxJava 提供了其他方法用于 创建被观察者对象Observable -->
// 方法1:just(T...):直接将传入的参数依次发送出来Observable observable = Observable.just("A", "B", "C");// 将会依次调用:// onNext("A");// onNext("B");// onNext("C");// onCompleted();// 方法2:from(T[]) / from(Iterable<? extends T>) : 将传入的数组 / Iterable 拆分成具体对象后,依次发送出来String[] words = {"A", "B", "C"};Observable observable = Observable.from(words);// 将会依次调用:// onNext("A");// onNext("B");// onNext("C");// onCompleted();

步骤2:创建观察者 (Observer )并 定义响应事件的行为

  • 即 开厨房 - 确定对应菜式
  • 发生的事件类型包括:Next事件、Complete事件 & Error事件。具体如下:

image

  • 具体实现


<--方式1:采用Observer 接口 -->// 1\. 创建观察者 (Observer )对象Observer<Integer> observer = new Observer<Integer>() {// 2\. 创建对象时通过对应复写对应事件方法 从而 响应对应事件// 观察者接收事件前,默认最先调用复写 onSubscribe()@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");}// 当被观察者生产Next事件 & 观察者接收到时,会调用该复写方法 进行响应@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件作出响应" + value);}// 当被观察者生产Error事件& 观察者接收到时,会调用该复写方法 进行响应@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}// 当被观察者生产Complete事件& 观察者接收到时,会调用该复写方法 进行响应@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}};<--方式2:采用Subscriber 抽象类 -->
// 说明:Subscriber类 = RxJava 内置的一个实现了 Observer 的抽象类,对 Observer 接口进行了扩展// 1\. 创建观察者 (Observer )对象
Subscriber<Integer> subscriber = new Subscriber<Integer>() {// 2\. 创建对象时通过对应复写对应事件方法 从而 响应对应事件// 观察者接收事件前,默认最先调用复写 onSubscribe()@Overridepublic void onSubscribe(Subscription s) {Log.d(TAG, "开始采用subscribe连接");}// 当被观察者生产Next事件 & 观察者接收到时,会调用该复写方法 进行响应@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件作出响应" + value);}// 当被观察者生产Error事件& 观察者接收到时,会调用该复写方法 进行响应@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}// 当被观察者生产Complete事件& 观察者接收到时,会调用该复写方法 进行响应@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}};<--特别注意:2种方法的区别,即Subscriber 抽象类与Observer 接口的区别 -->
// 相同点:二者基本使用方式完全一致(实质上,在RxJava的 subscribe 过程中,Observer总是会先被转换成Subscriber再使用)
// 不同点:Subscriber抽象类对 Observer 接口进行了扩展,新增了两个方法:// 1\. onStart():在还未响应事件前调用,用于做一些初始化工作// 2\. unsubscribe():用于取消订阅。在该方法被调用后,观察者将不再接收 & 响应事件// 调用该方法前,先使用 isUnsubscribed() 判断状态,确定被观察者Observable是否还持有观察者Subscriber的引用,如果引用不能及时释放,就会出现内存泄露

步骤3:通过订阅(Subscribe)连接观察者和被观察者

  • 即 顾客找到服务员 - 点菜 - 服务员下单到厨房 - 厨房烹调
  • 具体实现

observable.subscribe(observer);// 或者 observable.subscribe(subscriber);
  • 扩展说明

<-- Observable.subscribe(Subscriber) 的内部实现 -->public Subscription subscribe(Subscriber subscriber) {subscriber.onStart();// 步骤1中 观察者  subscriber抽象类复写的方法,用于初始化工作onSubscribe.call(subscriber);// 通过该调用,从而回调观察者中的对应方法从而响应被观察者生产的事件// 从而实现被观察者调用了观察者的回调方法 & 由被观察者向观察者的事件传递,即观察者模式// 同时也看出:Observable只是生产事件,真正的发送事件是在它被订阅的时候,即当 subscribe() 方法执行时
}

5.2 方式2:优雅的实现方法 - 基于事件流的链式调用

  • 上述的实现方式是为了说明Rxjava的原理 & 使用
  • 在实际应用中,会将上述步骤&代码连在一起,从而更加简洁、更加优雅,即所谓的 RxJava基于事件流的链式调用

// RxJava的链式操作Observable.create(new ObservableOnSubscribe<Integer>() {// 1\. 创建被观察者 & 生产事件@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {emitter.onNext(1);emitter.onNext(2);emitter.onNext(3);emitter.onComplete();}}).subscribe(new Observer<Integer>() {// 2\. 通过通过订阅(subscribe)连接观察者和被观察者// 3\. 创建观察者 & 定义响应事件的行为@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");}// 默认最先调用复写的 onSubscribe()@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件"+ value +"作出响应"  );}@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}});}
}注:整体方法调用顺序:观察者.onSubscribe()> 被观察者.subscribe()> 观察者.onNext()>观察者.onComplete() 

这种 基于事件流的链式调用,使得RxJava

  • 逻辑简洁
  • 实现优雅
  • 使用简单

更重要的是,随着程序逻辑的复杂性提高,它依然能够保持简洁 & 优雅。所以,一般建议使用这种基于事件流的链式调用方式实现RxJava

特别注意

RxJava 2.x 提供了多个函数式接口 ,用于实现简便式的观察者模式。具体如下:

image

Consumer为例:实现简便式的观察者模式

Observable.just("hello").subscribe(new Consumer<String>() {// 每次接收到Observable的事件都会调用Consumer.accept()@Overridepublic void accept(String s) throws Exception {System.out.println(s);}});

6. 实例说明

我将用一个实际工程实例来演示 Rxjava的使用

6.1 方式1:分步骤实现

步骤1:加入依赖

    compile 'io.reactivex.rxjava2:rxjava:2.0.1'compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

步骤2:直接在MainActivity.java中实现下述步骤

  1. 创建被观察者 (Observable )& 生产事件
  2. 创建观察者 (Observer )并 定义响应事件的行为
  3. 通过订阅(Subscribe)连接观察者和被观察者

public class MainActivity extends AppCompatActivity {private static final String TAG = "Rxjava";@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);// 步骤1:创建被观察者 Observable & 生产事件
// 即 顾客入饭店 - 坐下餐桌 - 点菜//  1\. 创建被观察者 Observable 对象Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {// 2\. 在复写的subscribe()里定义需要发送的事件@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {// 通过 ObservableEmitter类对象产生事件并通知观察者// ObservableEmitter类介绍// a. 定义:事件发射器// b. 作用:定义需要发送的事件 & 向观察者发送事件emitter.onNext(1);emitter.onNext(2);emitter.onNext(3);emitter.onComplete();}});// 步骤2:创建观察者 Observer 并 定义响应事件行为
// 即 开厨房 - 确定对应菜式Observer<Integer> observer = new Observer<Integer>() {// 通过复写对应方法来 响应 被观察者@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");}// 默认最先调用复写的 onSubscribe()@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件"+ value +"作出响应"  );}@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}};// 步骤3:通过订阅(subscribe)连接观察者和被观察者// 即 顾客找到服务员 - 点菜 - 服务员下单到厨房 - 厨房烹调observable.subscribe(observer);
  • 测试结果

image

6.2 方式2:基于事件流的链式调用方式

public class MainActivity extends AppCompatActivity {private static final String TAG = "Rxjava";@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);// RxJava的流式操作Observable.create(new ObservableOnSubscribe<Integer>() {// 1\. 创建被观察者 & 生产事件@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {emitter.onNext(1);emitter.onNext(2);emitter.onNext(3);emitter.onComplete();}}).subscribe(new Observer<Integer>() {// 2\. 通过通过订阅(subscribe)连接观察者和被观察者// 3\. 创建观察者 & 定义响应事件的行为@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");}// 默认最先调用复写的 onSubscribe()@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件"+ value +"作出响应"  );}@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}});}
}
  • 测试效果
    实现效果同上

    image


7. 额外说明

7.1 被观察者 Observable的subscribe()具备多个重载的方法

    public final Disposable subscribe() {}// 表示观察者不对被观察者发送的事件作出任何响应(但被观察者还是可以继续发送事件)public final Disposable subscribe(Consumer<? super T> onNext) {}// 表示观察者只对被观察者发送的Next事件作出响应public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError) {} // 表示观察者只对被观察者发送的Next事件 & Error事件作出响应public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {}// 表示观察者只对被观察者发送的Next事件、Error事件 & Complete事件作出响应public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) {}// 表示观察者只对被观察者发送的Next事件、Error事件 、Complete事件 & onSubscribe事件作出响应public final void subscribe(Observer<? super T> observer) {}// 表示观察者对被观察者发送的任何事件都作出响应

7.2 可采用 Disposable.dispose() 切断观察者 与 被观察者 之间的连接

  • 即观察者 无法继续 接收 被观察者的事件,但被观察者还是可以继续发送事件
  • 具体使用


// 主要在观察者 Observer中 实现Observer<Integer> observer = new Observer<Integer>() {// 1\. 定义Disposable类变量private Disposable mDisposable;@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");// 2\. 对Disposable类变量赋值mDisposable = d;}@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件"+ value +"作出响应"  );if (value == 2) {// 设置在接收到第二个事件后切断观察者和被观察者的连接mDisposable.dispose();Log.d(TAG, "已经切断了连接:" + mDisposable.isDisposed());}}@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}};
  • 效果图

image


8. 总结

  • 本文主要对 Rxjava 的入门知识进行讲解,包括基本介绍、原理 & 具体使用等
  • 接下来,我将持续推出 AndroidRxjava 2.0 的一系列文章,包括原理、操作符、应用场景、背压等等

image


 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/42200.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Revit2018下载和安装教程

Revit2018下载地址&#xff1a;https://pan.baidu.com/s/1YMUfuRs1sd3B6wEL5y9EZg 下载方法&#xff1a;复制下载链接&#xff0c;粘贴至浏览器网址栏打开&#xff0c;点击保存到网盘&#xff0c;打开网盘客户端&#xff0c;找到刚保存的Revit安装包&#xff0c;下载到电脑上&a…

水壶接水烧水教程

写一下前因后果&#xff0c;是个不错的故事 起因 公司一直有免费的大桶水供应&#xff0c;直到那一天&#xff0c;负责此事的尹经理涉嫌学历造假&#xff0c;被开除&#xff0c;大桶水断供。 初步解决 虽然没有大桶水&#xff0c;但同学们总是要喝水的&#xff0c;总买小瓶…

AI2019下载Adobe Illustrator CC2019安装教程

Illustrator&#xff08;简称“AI”&#xff09;是一款非常强大的矢量图制图软件&#xff0c;在平面设计、UI设计、广告设计等诸多行业都有广泛的应用&#xff0c;并且作为必备软件有它的不可替代性&#xff1b; 但很多朋友在开始安装AI软件的时候却遇到种种困难&#xff0c;为…

android轮播图实现方案,Android轮播图实现教程

ListView的headerView设置为轮播图之后结合上/下拉刷新/加载的模式成为现在大多数APP的一个必须具备的功能,对于许多初学者来说想要实现轮播图这样一个集线程睡眠、自动处理、替换过程中刷新UI界面的组合功能非常困难,没有思路,感觉无从下手,去搜索各种实现方案,发现目前充…

PS2015下载PSCC2015安装教程

PSCC2015&#xff08;64位&#xff09;下载链接&#xff1a;https://pan.baidu.com/s/1FTRjQmYaDgaJVQZtO7vT0w PSCC2015&#xff08;32位&#xff09;下载链接&#xff1a;https://pan.baidu.com/s/1FsJ8wq9tdcbjnjv55tqDaA PSCC2015.5&#xff08;64位&#xff09;下载链接&a…

Elasticsearch教程应用场景

Elasticsearch 使用 1. 搜索使用 1.1 搜索请求的结构体 现在我们已经看到了一些基本知识&#xff0c;让我们尝试一下更加真实的数据集&#xff08;结构化数据&#xff09;。我准备了关于金庸先生的小 说的 JSON 文档样本。每个文档都有以下模式&#xff1a; // 样本一 { …

3dmax2009下载3dmax2009安装教程

3dmax2009&#xff08;32/64位&#xff09;下载&#xff1a;https://pan.baidu.com/s/1SarHkl3RCxeqSVBnYHG8XA 【安装包下载方法】&#xff1a;复制下载链接&#xff0c;粘贴至浏览器网址栏&#xff08;非搜索框哈&#xff09;打开&#xff0c;无提取码&#xff0c;保存至网盘…

Spring Cloud入门到实战系列教程

本教程由猿天地尹吉欢进行整理&#xff0c;欢迎大家转载分享&#xff0c;请注明文章出处。 文章对应源码地址&#xff1a;https://github.com/yinjihuan/spring-cloud #Spring Cloud Eureka Spring Cloud Eureka 初探 Spring Cloud Eureka 增加权限认证 Spring Cloud Eureka …

代码审查软件 Gerrit的安装教程

一、简单介绍 Gerrit&#xff0c;一种免费、开放源代码的代码审查软件&#xff0c;使用网页界面。利用网页浏览器&#xff0c;同一个团队的软件程序员可以相互审阅彼此修改后的程序代码&#xff0c;决定是否能够提交&#xff0c;退回或者继续修改。 二、软件安装 需要安装的环…

Typora导出word文件教程

使用typora可能会遇到需要导出word文件的需求。我们在typora中进行如下操作 如果你是第一次导出word文件&#xff0c;那么他会提示你让你安装pandoc这样一个插件&#xff0c;我提供一个地址 各种操作系统的的pandoc插件我都放在这里面&#xff0c;window系统一般下载倒数第二个…

PS2018下载PSCC2018安装教程

PSCC2018&#xff08;64位&#xff09;下载链接&#xff1a;https://pan.baidu.com/s/1gV9RmsgUdeJ8AXwMXo9aaQ 【下载方法】复制下载链接&#xff0c;粘贴纸浏览器网址栏&#xff08;无提取码&#xff09;打开&#xff0c;保存到网盘&#xff0c;打开网盘客户端&#xff0c;下…

搭建网站教程

建立一个属于自己的网站大致分为以下几个流程 一.购买域名 1.首先来到阿里云&#xff0c;搜一个你想要买的网址 2.来到这一个界面后选择一个域名进行购买 后到域名列表&#xff0c;此处可以看到你已经购买的域名。 点击未实名认证&#xff0c;进入实名认证界面完善自己信息&…

Spring Boot入门到实战系列教程

本教程由猿天地尹吉欢进行整理&#xff0c;欢迎大家转载分享&#xff0c;请注明文章出处。 #Spring Boot 相关课程推荐&#xff1a; Spring Boot从入门到精通课程 Spring Boot Web开发前端性能调优 从零开始手写百度云盘搜索系统实战课程 spring boot开发rest api实战课程 …

微服务中的短信服务如何设计?

发送短信功能&#xff0c;在开发过程中是最常见的需求。用户登录验证码的发送&#xff0c;活动促销短信的发送等。本Chat将带领你深入的去学习如何设计和实现一个通用的基础短信服务&#xff0c;采用Spring Boot开发短信服务&#xff0c;最终会注册到Spring Cloud微服务体系中&…

Revit2020下载Revit2020安装教程

Revit2020下载地址&#xff1a;https://pan.baidu.com/s/11Y4CMBlyY3XiUp4-YRWTdA 下载方法&#xff1a;复制下载链接&#xff0c;粘贴至浏览器网址栏打开&#xff0c;点击保存到网盘&#xff0c;打开百度网盘客户端&#xff0c;找到刚保存的Revit安装包&#xff0c;下载到电脑…

内网穿透NPS使用教程

下载NPS相关的服务端安装包、客户端安装包&#xff08;选择版本号为&#xff1a;v0.26.9&#xff09;&#xff1b; 下载地址&#xff1a;Releases ehang-io/nps GitHub 备注&#xff1a;NPS使用相关官网文档地址&#xff1a;Document nps服务端安装说明&#xff1a; 1、在…

PSCS6下载和安装教程

PS CS6&#xff08;64位32位&#xff09;下载链接&#xff1a;https://pan.baidu.com/s/1z0qqFvZTKJHJ2NdJHGAvjA 【下载方法】复制下载链接&#xff0c;粘贴纸浏览器网址栏&#xff08;无提取码&#xff09;打开&#xff0c;保存到网盘&#xff0c;打开网盘客户端&#xff0c;…

湖北省智能科教研究会走进璞华,调研璞公英教学平台个性化教学新模式

2023年5月9日&#xff0c;热烈祝贺湖北省智能科教研究会红5月智能科教走进璞华集团活动圆满成功。会议上&#xff0c;大家畅所欲言&#xff0c;对教育体制改革与教育信息化产品创新&#xff0c;科技成果转化、产教融合、资源互补、学生能力培养等方面展开充分沟通和探讨。 5月9…

【PTA~21年GPLT团体程序天梯赛-L1题】

文章目录 L1-01 人与神~5题解 L1-02 两小时学完C语言~5题解 L1-03 强迫症~10题解 L1-04 降价提醒机器人~10题解 L1-05 大笨钟的心情~15题解 L1-06 吉老师的回归~15题解 L1-07 天梯赛的善良~20题解 L1-08 乘法口诀数列~20题解 持续更新中...每日一言&#xff1a; login登陆系统~…

PTA团体程序天梯赛-练习集

PTA团体程序天梯赛-练习集 L1-002 打印沙漏L1-003 个位数统计L1-004 计算摄氏温度L1-005 考试座位号L1-006 连续因子 L1-002 打印沙漏 本题要求你写个程序把给定的符号打印成沙漏的形状。例如给定17个“*”&#xff0c;要求按下列格式打印 ************ *****所谓“沙漏形状…