博客> Rxswift网络请求使用
Rxswift网络请求使用
2019-12-12 04:13 评论:0 阅读:1093 zxc3731
ios MVVM RxSwift swift网络层

  基于rxswift实现响应式编程,使一个复杂的逻辑能在一个地方完成,这样的代码更加地方便阅读更加一目了然。当然它的作用并不仅限于此,还可以更方便地实现基于MVVM模式的项目。

  好了废话不多说,这篇文章主要是记录我在项目中利用rxswift实现网络请求的使用方法。网络请求库是Alamofire。   以登录为例,我的登录流程是这样的:   1.检查账号,密码输入的有效性,如果无效,弹出菊花提示;如果有效,下一步。   2.登录请求前一系列的处理,例如注销键盘第一响应者,弹出等待菊花.......   3.服务器请求   4.处理返回结果   步骤很简单,接下来贴出代码说明一下

// 首先我会在viewModel中初始化一个LoginInputStatus枚举类型的属性,用于提示账号和密码的有效性的状态,
// 例如一下

// viewModel里面的属性,初始化
lazy validMessage: LoginInputStatus =  LoginInputStatus.CanLogin
// 枚举
enum LoginInputStatus: String {
    case CanLogin = ""
    case WrongPhone = "手机号码不正确"
    case NilPhoneOrPwd = "手机号或密码不能为空"
    .......
    static func getMessage(user: String, pwd: String) -> LoginInputStatus {
        if user.characters.count != 11 {
            return LoginStatus.WrongPhone
        }
        else if user.characters.count == 0 || pwd.characters.count == 0 {
            return LoginStatus.NilPhoneOrPwd
        }
        ......
        else {
            return LoginStatus.CanLogin
        }
    }
}
// 组合两个信号,并订阅该组合信号
_ = Observable.combineLatest(self.vc.text_name.rx_text, self.vc.text_password.rx_text) { value1, value2 -> (String, String) in
            return (value1, value2)
            }
            .subscribeNext { (res: (String, String)) in
            self.validMessage = LoginStatus.getMessage(res.0, pwd: res.1)
        }.addDisposableTo(disposBag)

然后是封装我们的网络请求,代码类似于:

func getLogin() -> Observable<NetWorkResult>> {
        return Observable.create { [weak self] observer -> Disposable in
            let request = HLNetwork.shareNetwork().sendRequest(API, parameter: 请求参数, success: { [weak self](objc) in
                observer.onNext(NetWorkResult.value(数据))
            }) { (objc) in
                observer.onNext(NetWorkResult.error(objc))
            }
            return AnonymousDisposable {
                request.cancel()
            }
        }
    }```
接下来就是一整个流程了
```Objective-C
       _ = self.loginBtn.rx_tap
            .throttle(0.1, scheduler: MainScheduler.instance)
            .filter({ [weak self](_) -> Bool in
                if self!.vm.validMessage == LoginStatus.CanLogin {
                    return true
                }
                else {
                    MBProgressHUD.showError(self!.vm.validMessage.rawValue)
                    return false
                }
            })
            .doOn({ (ee) in
                self.text_name.resignFirstResponder()
                self.text_password.resignFirstResponder()
                MBProgressHUD.showMessage("登录中")
            })
            .flatMap{ self.vm.getLogin() }
            .subscribeNext({ [weak self](result) in
                MBProgressHUD.hideHUD()
                switch result {
                case .value(let value):
                    MBProgressHUD.showSuccess(value.Mess as String)
                    break
                case .error(let error):
                    MBProgressHUD.showError(error)
                    break
                }
            })
            .addDisposableTo(self.vm.disposBag)

   throttle意思是主线程操作下面的代码,0.1秒内值发生多次变化取最后一次变化的值,其实这里好奇怪,因为需要这样,菊花提示才会正常弹出,当初考虑过会不会是在非主线程操作的原因,用到observeOn,但是问题依然存在。而且这个问题在其他的类似请求中并不会出现,所以可以根据实际情况来判断是否需要加上去。   filter过滤操作,我需要在请求前过滤掉无效的请求参数。参数符合要求,则继续;不符合弹出菊花提示并终止这一次的点击。   doOn就是请求前的一系列的准备了,正如我上面所说,这里我注销了键盘的第一响应者并弹出等待菊花。   flatMap在这里的作用是请求服务器和信号的转换。将点击信号转换成getLogin返回的信号,该返回信号包含了我们想要的数据。   subscribeNext就是订阅事件了,如果不加上点击事件就不会触发。   addDisposableTo原理像以前的autoreleasepool,就是加入都一个地方,然后方便释放资源。   所以当我点击按钮,生产线启动,一步步进行直到有问题结束或者完成结束。   其实rxswift,MVVM这些真是见仁见智,我对这块感兴趣,所以也喜欢研究这方面,面试的时候也会说说rxswift的好处啊,MVVM的优势啊,但是几乎所有的面试官对这些都不怎么在意.......

收藏
0
sina weixin mail 回到顶部