深入理解Moya设计

关于Moya

Moya是一个网络抽象层,它在底层将Alamofire进行封装,对外提供更简洁的接口供开发者调用。在以往的Objective-C中,大部分开发者会使用AFNetwork进行网络请求,当业务复杂一些时,会对AFNetwork进行二次封装,编写一个适用于自己项目的网络抽象层。在Objective-C中,有著名的YTKNetwork,它将AFNetworking封装成抽象父类,然后根据每一种不同的网络请求,都编写不同的子类,子类继承父类,来实现请求业务。Moya在项目层次中的地位,有点类似于YTKNetwork。可以看下图对比

但是如果单纯把Moya等同于swift版的YTKNetwork,那就是比较错误的想法了。Moya的设计思路和YTKNetwork差距非常大。上面我在介绍YTKNetwork时在强调子类和父类,继承,是因为YTKNetwork是比较经典的利用OOP思想(面向对象)设计的产物。基于swift的Moya虽然也有使用到继承,但是它的整体上是以POP思想(Protocol Oriented Programming,面向协议编程)为主导的。

面向协议编程(POP)

在阅读Moya源码之前,如果对POP有一定了解,那么理解其Moya会事半功倍的效果。在Objective-C也有协议,一般是让对象遵守协议,然后实现协议规定的方法,通过这种方式来对类实现扩展。POP其实就是把这种思路进一步强化。很多时候事物具备多样化的特质,而这些特质是无法单纯从一个类中继承而来的。为了解决这个痛点,C++有了多继承,即一个子类可以继承多种父类,这些被继承的父类之间不一定有关联。但是这依然会有其他问题,比如子类继承父类后,不一定需要用到所有的父类方法和属性,等于子类拥有了一些毫无用处的属性和方法。比如父类进行了修改,那么很难避免影响到子类。C++的多继承还会带来菱形缺陷,什么是菱形缺陷?本节的下方我会放两个链接,方便大家查阅。而Swift则引入了面向协议编程,通过协议来规定事物的实现。通过遵守不同的协议,来对一个类或者结构体或者枚举进行定制,它只需要实现协议所规定的属性或方法即可,有点类似于搭建积木,取每一块有需求的模块,进行组合拼接,相对于OOP,其耦合性更低,也为代码的维护和拓展提供更多的可能性。关于POP思想大致是这样,下面是王巍关于POP的两篇文章,值得读一番。
面向协议编程与 Cocoa 的邂逅 (上)
面向协议编程与 Cocoa 的邂逅 (下)

Moya的模块组成

由于Moya是使用POP来设计的一个网络抽象层,因此他整体的逻辑结构并没有明显的继承关系。Moya的核心代码,可以分成以下几个模块

Provider

provider是一个提供网络请求服务的提供者。通过一些初始化配置之后,在外部可以直接用provider来发起request。

Request

在使用Moya进行网络请求时,第一步需要进行配置,来生成一个Request。首先按照官方文档,创建一个枚举,遵守TargetType协议,并实现协议所规定的属性。为什么要创建枚举来遵守协议,而不像Objective-C那样创建类来遵守协议呢?其实使用类或者结构体也是可以的,这里猜测使用枚举的原因是因为swift的枚举功能比Objective-C强大许多,枚举结合switch语句,使得API管理起来比较方便。
Request的生成过程如下图

我们根据上图,结合代码来分析其Request的生成过程。
根据创建了一个遵守TargetType协议的名为Myservice的枚举,我们完成了如下几个变量的设置。

baseURL
path
method
sampleData
task
headers

提供了这些网络请求的“基本材料”之后,就可以进一步配置去生成所需要的请求。看上图的第一个箭头,通过了一个EndpointClosure生成了endPoint。endPoit是一个对象,把网络请求所需的一些属性和方法进行了包装,在EndPoint类中有如下属性:

public typealias SampleResponseClosure = () -> EndpointSampleResponse

    open let url: String
    open let sampleResponseClosure: SampleResponseClosure
    open let method: Moya.Method
    open let task: Task
    open let httpHeaderFields: [String: String]?

可以很直观地看出来,EndPoint这几个属性可以和上面通过TargetTpye配置的变量对应起来。那么这个过程在代码中做了哪些事?
在MoyaProvider类里,有如下声明

/// Closure that defines the endpoints for the provider.
    public typealias EndpointClosure = (Target) -> Endpoint<Target>
    
    open let endpointClosure: EndpointClosure

声明了一个闭包,参数为Target,它是一个泛型,然后返回一个EndPoint。endPoint是一个类,它对请求的参数和动作进行了包装,下面会对它进行详细说明,先继续看endpointClosure做了什么。

endpointClosure: @escaping EndpointClosure = MoyaProvider.defaultEndpointMapping

在MoyaProvider的初始化方法里,调用其扩展的类方法defaultEndpointMapping输入Target作为参数,返回了一个endPoint对象。

public final class func defaultEndpointMapping(for target: Target) -> Endpoint<Target> {
        return Endpoint(
            url: URL(target: target).absoluteString,sampleResponseClosure: { .networkResponse(200,target.sampleData) },method: target.method,task: target.task,httpHeaderFields: target.headers
        )
    }

Target就是一开始进行配置的枚举,通过点语法取出Target的变量,完成endPoint的初始化。这里可能对于url和sampleResponseClosure会感到一些疑惑。url初始化,可以进入URL+Moya.swift查看,它对NSURL类进行构造器的扩展,让其具备根据Moya的TargetType来进行初始化的能力。

/// Initialize URL from Moya's `TargetType`.
    init<T: TargetType>(target: T) {
        // When a TargetType's path is empty,URL.appendingPathComponent may introduce trailing /,which may not be wanted in some cases
        if target.path.isEmpty {
            self = target.baseURL
        } else {
            self = target.baseURL.appendingPathComponent(target.path)
        }
    }

sampleResponseClosure是一个和网络请求返回假数据相关的闭包,这里可以先忽略,不影响对Moya生成Request过程的理解。
我们知道了MoyaProvider.defaultEndpointMapping可以返回endPoint对象后,重新看一遍这句

endpointClosure: @escaping EndpointClosure = MoyaProvider.defaultEndpointMapping

使用@escaping把endpointClosure声明为逃逸闭包,我们可以把

EndpointClosure = MoyaProvider.defaultEndpointMapping

转换为

(Target) -> Endpoint<Target> = func defaultEndpointMapping(for target: Target) -> Endpoint<Target>

再进一步转换,等号左边的可以写成一个常规的闭包表达式

{(Target)->Endpoint<Target> in
    return Endpoint(
            url: URL(target: target).absoluteString,httpHeaderFields: target.headers
        )
}

即endpointClosure这个闭包,传入了Target作为参数,该闭包可以返回一个endPoint对象,如何获取到闭包返回的endPoint对象?MoyaProvider提供了这么一个方法

/// Returns an `Endpoint` based on the token,method,and parameters by invoking the `endpointClosure`.
    open func endpoint(_ token: Target) -> Endpoint<Target> {
        return endpointClosure(token)
    }

以上就是关于TargetType通过endpointClosure转化为endPoint的过程。

下一步就是把利用requestClosure,传入endPoint,然后生成request。request生成过程和endPoint很相似。

在MoyaProvider中声明:

/// Closure that decides if and what request should be performed
    public typealias RequestResultClosure = (Result<URLRequest,MoyaError>) -> Void
    open let requestClosure: RequestClosure

然后在MoyaProvider的初始化方法里有很相似的一句

requestClosure: @escaping RequestClosure = MoyaProvider.defaultRequestMapping,

进入查看defaultRequestMapping方法

public final class func defaultRequestMapping(for endpoint: Endpoint<Target>,closure: RequestResultClosure) {
        do {
            let urlRequest = try endpoint.urlRequest()
            closure(.success(urlRequest))
        } catch MoyaError.requestMapping(let url) {
            closure(.failure(MoyaError.requestMapping(url)))
        } catch MoyaError.parameterEncoding(let error) {
            closure(.failure(MoyaError.parameterEncoding(error)))
        } catch {
            closure(.failure(MoyaError.underlying(error,nil)))
        }
    }

和endpointClosure类似,我们经过转换,可以得到requestClosure的表达式为

{(endpoint:Endpoint<Target>,closure:RequestResultClosure) in
   do {
       let urlRequest = try endpoint.urlRequest()
       closure(.success(urlRequest))
   } catch MoyaError.requestMapping(let url) {
       closure(.failure(MoyaError.requestMapping(url)))
   } catch MoyaError.parameterEncoding(let error) {
       closure(.failure(MoyaError.parameterEncoding(error)))
   } catch {
       closure(.failure(MoyaError.underlying(error,nil)))
   }

}

整体上使用do-catch语句来初始化一个urlRequest,根据不同结果向闭包传入不同的参数。一开始使用try来调用endpoint.urlRequest(),如果抛出错误,会切换到catch语句中去。endpoint.urlRequest()这个方法比较长,这里就不放出来,感兴趣可自行到Moya核心代码里的Endpoint.swift里查看。它其实做的事情很简单,就是根据前面说到的endpoint的那些属性来初始化一个NSURLRequest的对象。

以上就是上方图中所画的,根据TargetType最终生成Request的过程。很多人会感到疑惑,为什么搞得这么麻烦,直接一步到位,传一些必要参数生成Request不就完了?为什么还要再增加endPoint这么一个节点?根据Endpoint类所提供的一些方法来看,个人认为应该是为了更灵活地配置网络请求,以适应更多样化的业务需求。Endpoint类还有几个方法

/// Convenience method for creating a new `Endpoint` with the same properties as the receiver,but with added HTTP header fields.
    open func adding(newHTTPHeaderFields: [String: String]) -> Endpoint<Target> 
    
        /// Convenience method for creating a new `Endpoint` with the same properties as the receiver,but with replaced `task` parameter.
    open func replacing(task: Task) -> Endpoint<Target>

借用这些方法,在endpointClosure中可以给一些网络请求添加请求头,替换请求参数,让这些请求配置更加灵活。

我们看完了整个Request生成过程,那么通过requestClosure生成的的Request是如何被外部拿到的呢?这就是我们下一步要探讨的,Provider发送请求实现过程。在下一节里将会看到如何使用这个Request。

Provider发送请求

我们再来看一下官方文档里说明的Moya的基本使用步骤

  1. 创建枚举,遵守TargetType协议,实现规定的属性。
  2. 初始化 provider = MoyaProvider<Myservice>()
  3. 调用provider.request,在闭包里处理请求结果。

其中第一步我们在上方已经说明完了,MoyaProvider的初始化我们只说明了一小部分。在此不准备一口气初始化方法中剩余的部分讲完,这又会涉及很多东西,同时理解起来会比较麻烦。在后面的代码解读中,如果有涉及到相关属性,再回到初始化方法中一个一个突破。

open func request(_ target: Target,callbackQueue: DispatchQueue? = .none,progress: ProgressBlock? = .none,completion: @escaping Completion) -> Cancellable {

        let callbackQueue = callbackQueue ?? self.callbackQueue
        return requestNormal(target,callbackQueue: callbackQueue,progress: progress,completion: completion)
    }

直接从这里可能看不出什么,再追溯到requestNormal中去
这个方法内容比较长,其中一些插件相关的代码,和测试桩的代码,暂且跳过不做说明,暂时不懂他们并不会成为理解provider.request的阻碍,它们属于可选内容,而不是必须的。

let endpoint = self.endpoint(target)

生成了endPoint对象,这个很好理解,前面已经做过说明。
查看performNetworking闭包

if cancellableToken.isCancelled {
                self.cancelCompletion(pluginsWithCompletion,target: target)
                return
            }

如果取消请求,则调用取消完成的回调,并return,不在执行闭包内下面的语句。
在这个闭包里传入了参数(requestResult: Result<URLRequest,MoyaError>),这里用到了Result,想深入了解,可自行研究,这里简单说一下Result是干什么的。Result使用枚举方式,提供一些运行处理的结果,如下,很容易能看懂它所表达的意思。

switch requestResult {
            case .success(let urlRequest):
                request = urlRequest
            case .failure(let error):
                pluginsWithCompletion(.failure(error))
                return
            }

如果请求成功,会拿到URLRequest,如果失败,会使用插件去处理失败回调。

// Allow plugins to modify request
            let preparedRequest = self.plugins.reduce(request) { $1.prepare($0,target: target) }

使用插件对请求进行完善

cancellableToken.innerCancellable = self.performRequest(target,request: preparedRequest,completion: networkCompletion,endpoint: endpoint,stubBehavior: stubBehavior)

这里的self.performRequest就是进行实际的网络请求,内部代码比较多,但是思路很简单,使用Alamofire的SessionManager来发送请求。
配置完成后就可以调用requestClosure(endpoint,performNetworking),执行这个闭包获取到上方所说的Request,来执行具体的网络请求了。

Response

在使用Alamofire发送请求时,定义了闭包来处理请求的响应。Response这个类对于请求结果,提供了一些加工方法,比如data转json,图片转换等。

Plugins

Moya提供了一个插件协议PluginType,协议里规定了几种方法,阐明了插件的应用区域。

/// Called to modify a request before sending
    func prepare(_ request: URLRequest,target: TargetType) -> URLRequest

    /// Called immediately before a request is sent over the network (or stubbed).
    func willSend(_ request: RequestType,target: TargetType)

    /// Called after a response has been received,but before the MoyaProvider has invoked its completion handler.
    func didReceive(_ result: Result<Moya.Response,MoyaError>,target: TargetType)

    /// Called to modify a result before completion
    func process(_ result: Result<Moya.Response,target: TargetType) -> Result<Moya.Response,MoyaError>
  • prepare可以在请求之前对request进行修改。
  • willSend在请求发送之前的一瞬间调用,这个可以用来添加请求时转圈圈的Toast
  • didReceive在接收到请求响应时,且MoyaProvider的completion handler之前调用。
  • process在completion handler之前调用,用来修改请求结果

可以通过以下图来直观地理解插件调用时机

使用插件的方式,让代码仅保持着主干逻辑,使用者根据业务需求自行加入插件来配置自己的网络业务层,这样做更加灵活,低耦合。Moya提供了4种插件

  • AccessTokenPluginOAuth的Token验证
  • CredentialsPlugin证书
  • NetworkActivityPlugin网络请求状态
  • NetworkLoggerPlugin网络日志

可以根据需求编写自己的插件,选取NetworkActivityPlugin来查看插件内部构成。

public final class NetworkActivityPlugin: PluginType {

    public typealias NetworkActivityClosure = (_ change: NetworkActivityChangeType,_ target: TargetType) -> Void
    let networkActivityClosure: NetworkActivityClosure

    public init(networkActivityClosure: @escaping NetworkActivityClosure) {
        self.networkActivityClosure = networkActivityClosure
    }

    public func willSend(_ request: RequestType,target: TargetType) {
        networkActivityClosure(.began,target)
    }

    public func didReceive(_ result: Result<Moya.Response,target: TargetType) {
        networkActivityClosure(.ended,target)
    }
}

插件内部结构很简单,除了自行定义的一些变量外,就是遵守PluginType协议后,去实现协议规定的方法,在特定方法内做自己需要做的事。因为PluginType它已经有一个协议扩展,把方法的默认实现都完成了,在具体插件内不一定需要实现所有的协议方法,仅根据需要实现特定方法即可。
写好插件之后,使用起来也比较简答,MoyaProvider的初始化方法中,有个形参plugins: [PluginType] = [],把网络请求中需要用到的插件加入数组中。

总结

Moya可以说非常swift式的一个框架,最大的优点是使用面向协议的思想,让使用者能以搭积木的方式配置自己的网络抽象层。提供了插件机制,在保持主干网络请求逻辑的前提下,让开发者根据自身业务需求,定制自己的插件,在合适的位置加入到网络请求的过程中。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


软件简介:蓝湖辅助工具,减少移动端开发中控件属性的复制和粘贴.待开发的功能:1.支持自动生成约束2.开发设置页面3.做一个浏览器插件,支持不需要下载整个工程,可即时操作当前蓝湖浏览页面4.支持Flutter语言模板生成5.支持更多平台,如Sketch等6.支持用户自定义语言模板
现实生活中,我们听到的声音都是时间连续的,我们称为这种信号叫模拟信号。模拟信号需要进行数字化以后才能在计算机中使用。目前我们在计算机上进行音频播放都需要依赖于音频文件。那么音频文件如何生成的呢?音频文件的生成过程是将声音信息采样、量化和编码产生的数字信号的过程,我们人耳所能听到的声音频率范围为(20Hz~20KHz),因此音频文件格式的最大带宽是20KHZ。根据奈奎斯特的理论,音频文件的采样率一般在40~50KHZ之间。奈奎斯特采样定律,又称香农采样定律。...............
前言最近在B站上看到一个漂亮的仙女姐姐跳舞视频,循环看了亿遍又亿遍,久久不能离开!看着小仙紫姐姐的蹦迪视频,除了一键三连还能做什么?突发奇想,能不能把舞蹈视频转成代码舞呢?说干就干,今天就手把手教大家如何把跳舞视频转成代码舞,跟着仙女姐姐一起蹦起来~视频来源:【紫颜】见过仙女蹦迪吗 【千盏】一、核心功能设计总体来说,我们需要分为以下几步完成:从B站上把小姐姐的视频下载下来对视频进行截取GIF,把截取的GIF通过ASCII Animator进行ASCII字符转换把转换的字符gif根据每
【Android App】实战项目之仿抖音的短视频分享App(附源码和演示视频 超详细必看)
前言这一篇博客应该是我花时间最多的一次了,从2022年1月底至2022年4月底。我已经将这篇博客的内容写为论文,上传至arxiv:https://arxiv.org/pdf/2204.10160.pdf欢迎大家指出我论文中的问题,特别是语法与用词问题在github上,我也上传了完整的项目:https://github.com/Whiffe/Custom-ava-dataset_Custom-Spatio-Temporally-Action-Video-Dataset关于自定义ava数据集,也是后台
因为我既对接过session、cookie,也对接过JWT,今年因为工作需要也对接了gtoken的2个版本,对这方面的理解还算深入。尤其是看到官方文档评论区又小伙伴表示看不懂,所以做了这期视频内容出来:视频在这里:本期内容对应B站的开源视频因为涉及的知识点比较多,视频内容比较长。如果你觉得看视频浪费时间,可以直接阅读源码:goframe v2版本集成gtokengoframe v1版本集成gtokengoframe v2版本集成jwtgoframe v2版本session登录官方调用示例文档jwt和sess
【Android App】实战项目之仿微信的私信和群聊App(附源码和演示视频 超详细必看)
用Android Studio的VideoView组件实现简单的本地视频播放器。本文将讲解如何使用Android视频播放器VideoView组件来播放本地视频和网络视频,实现起来还是比较简单的。VideoView组件的作用与ImageView类似,只是ImageView用于显示图片,VideoView用于播放视频。...
采用MATLAB对正弦信号,语音信号进行生成、采样和内插恢复,利用MATLAB工具箱对混杂噪声的音频信号进行滤波
随着移动互联网、云端存储等技术的快速发展,包含丰富信息的音频数据呈现几何级速率增长。这些海量数据在为人工分析带来困难的同时,也为音频认知、创新学习研究提供了数据基础。在本节中,我们通过构建生成模型来生成音频序列文件,从而进一步加深对序列数据处理问题的了解。
基于yolov5+deepsort+slowfast算法的视频实时行为检测。1. yolov5实现目标检测,确定目标坐标 2. deepsort实现目标跟踪,持续标注目标坐标 3. slowfast实现动作识别,并给出置信率 4. 用框持续框住目标,并将动作类别以及置信度显示在框上
数字电子钟设计本文主要完成数字电子钟的以下功能1、计时功能(24小时)2、秒表功能(一个按键实现开始暂停,另一个按键实现清零功能)3、闹钟功能(设置闹钟以及到时响10秒)4、校时功能5、其他功能(清零、加速、星期、八位数码管显示等)前排提示:前面几篇文章介绍过的内容就不详细介绍了,可以看我专栏的前几篇文章。PS.工程文件放在最后面总体设计本次设计主要是在前一篇文章 数字电子钟基本功能的实现 的基础上改编而成的,主要结构不变,分频器将50MHz分为较低的频率备用;dig_select
1.进入官网下载OBS stdioOpen Broadcaster Software | OBS (obsproject.com)2.下载一个插件,拓展OBS的虚拟摄像头功能链接:OBS 虚拟摄像头插件.zip_免费高速下载|百度网盘-分享无限制 (baidu.com)提取码:6656--来自百度网盘超级会员V1的分享**注意**该插件必须下载但OBS的根目录(应该是自动匹配了的)3.打开OBS,选中虚拟摄像头选择启用在底部添加一段视频录制选择下面,进行录制.
Meta公司在9月29日首次推出一款人工智能系统模型:Make-A-Video,可以从给定的文字提示生成短视频。基于**文本到图像生成技术的最新进展**,该技术旨在实现文本到视频的生成,可以仅用几个单词或几行文本生成异想天开、独一无二的视频,将无限的想象力带入生活
音频信号叠加噪声及滤波一、前言二、信号分析及加噪三、滤波去噪四、总结一、前言之前一直对硬件上的内容比较关注,但是可能是因为硬件方面的东西可能真的是比较杂,而且需要渗透的东西太多了,所以学习进展比较缓慢。因为也很少有单纯的硬件学习研究,总是会伴随着各种理论需要硬件做支撑,所以还是想要慢慢接触理论学习。但是之前总找不到切入点,不知道从哪里开始,就一直拖着。最近稍微接触了一点信号处理,就用这个当作切入点,开始接触理论学习。二、信号分析及加噪信号处理选用了matlab做工具,选了一个最简单的语音信号处理方
腾讯云 TRTC 实时音视频服务体验,从认识 TRTC 到 TRTC 的开发实践,Demo 演示& IM 服务搭建。
音乐音频分类技术能够基于音乐内容为音乐添加类别标签,在音乐资源的高效组织、检索和推荐等相关方面的研究和应用具有重要意义。传统的音乐分类方法大量使用了人工设计的声学特征,特征的设计需要音乐领域的知识,不同分类任务的特征往往并不通用。深度学习的出现给更好地解决音乐分类问题提供了新的思路,本文对基于深度学习的音乐音频分类方法进行了研究。首先将音乐的音频信号转换成声谱作为统一表示,避免了手工选取特征存在的问题,然后基于一维卷积构建了一种音乐分类模型。
C++知识精讲16 | 井字棋游戏(配资源+视频)【赋源码,双人对战】
本文主要讲解如何在Java中,使用FFmpeg进行视频的帧读取,并最终合并成Gif动态图。
在本篇博文中,我们谈及了 Swift 中 some、any 关键字以及主关联类型(primary associated types)的前世今生,并由浅及深用简明的示例向大家讲解了它们之间的奥秘玄机。