Alamofire-Response

一.默認(rèn)Response-DefaultDataResponse

  • 返回二進(jìn)制數(shù)據(jù)Data鲫惶,響應(yīng)示例:
        SessionManager.default.request(urlString).response { (response) in
            print("\(response)")
        }
  • 查看源碼:
    public func response(queue: DispatchQueue? = nil, completionHandler: @escaping (DefaultDataResponse) -> Void) -> Self {
        delegate.queue.addOperation {
            (queue ?? DispatchQueue.main).async {
                var dataResponse = DefaultDataResponse(
                    request: self.request,
                    response: self.response,
                    data: self.delegate.data,
                    error: self.delegate.error,
                    timeline: self.timeline
                )
                dataResponse.add(self.delegate.metrics)
                completionHandler(dataResponse)
            }
        }
        return self
    }
  • 在這里將self.request,self.response,self.delegate.data,self.delegate.error,self.timeline,整合成DefaultDataResponse對象,同時(shí)將dataResponse交給了DispatchQueue.main主隊(duì)列回調(diào)出去寸潦,方便用戶在請求回調(diào)中處理UI事件。
  • 很明顯您市,DefaultDataResponse傳遞到外面的是原始的二進(jìn)制數(shù)據(jù),
class DataTaskDelegate: TaskDelegate, URLSessionDataDelegate {
    var dataTask: URLSessionDataTask { return task as! URLSessionDataTask }
    override var data: Data? {
        if dataStream != nil {
            return nil
        } else {
            return mutableData
        }
    }
  • 那么這些數(shù)據(jù)什么時(shí)候賦值的?
    func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, didReceive data: Data) {
        if initialResponseTime == nil { initialResponseTime = CFAbsoluteTimeGetCurrent() }
        if let dataTaskDidReceiveData = dataTaskDidReceiveData {
            dataTaskDidReceiveData(session, dataTask, data)
        } else {
            if let dataStream = dataStream {
                dataStream(data)
            } else {
                //處理數(shù)據(jù)
                mutableData.append(data)
            }
            let bytesReceived = Int64(data.count)
            totalBytesReceived += bytesReceived
            let totalBytesExpected = dataTask.response?.expectedContentLength ?? NSURLSessionTransferSizeUnknown
            progress.totalUnitCount = totalBytesExpected
            progress.completedUnitCount = totalBytesReceived
            if let progressHandler = progressHandler {
                progressHandler.queue.async { progressHandler.closure(self.progress) }
            }
        }
    }
  • func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, didReceive data: Data)方法瓶珊,收到數(shù)據(jù)的時(shí)候鹅士,就將mutableData.append(data)追加到了mutableData中,然后通過response中的completionHandler(dataResponse)回調(diào)給用戶轰胁。
  • 至于error的傳遞和賦值谒主,同上查找方法可知,在收到錯(cuò)誤的時(shí)候赃阀,賦值self.error
func urlSession(_ session: URLSession, task: URLSessionTask, didCompleteWithError error: Error?) {
        if let taskDidCompleteWithError = taskDidCompleteWithError {
            taskDidCompleteWithError(session, task, error)
        } else {
            if let error = error {
                //賦值error
                if self.error == nil { self.error = error }
                if
                    let downloadDelegate = self as? DownloadTaskDelegate,
                    let resumeData = (error as NSError).userInfo[NSURLSessionDownloadTaskResumeData] as? Data
                {
                    downloadDelegate.resumeData = resumeData
                }
            }
            queue.isSuspended = false
        }
    }

通過上面的分析霎肯,可能會(huì)有疑問,這么強(qiáng)大的框架榛斯,只是原封不動(dòng)的把二進(jìn)制數(shù)據(jù)傳出來观游,會(huì)不會(huì)有點(diǎn)low? 查看其他的response可知,Alamofire還有針對響應(yīng)數(shù)據(jù)的序列化操作

二. DataResponse

1. 自定義序列化器

  • 此處自定義了responseSerializer序列化器驮俗,返回序列化后的數(shù)據(jù)Result<value>
        SessionManager.default.request(urlString).response(responseSerializer: DataResponseSerializer<String>.init(serializeResponse: { (reques, response, data, error) -> Result<String> in
            print("原始數(shù)據(jù):\(String(describing: response ?? nil))")
            return .success("請求數(shù)據(jù)成功")
        })) { (dataResponse) in
            print("\(dataResponse)")
        }
        SessionManager.default.request(urlString).response { (response) in
            print("\(response)")
        }
  • 源碼分析:
    public func response<T: DataResponseSerializerProtocol>(
        queue: DispatchQueue? = nil,
        responseSerializer: T,
        completionHandler: @escaping (DataResponse<T.SerializedObject>) -> Void)
        -> Self
    {
        delegate.queue.addOperation {
            let result = responseSerializer.serializeResponse(
                self.request,
                self.response,
                self.delegate.data,
                self.delegate.error
            )
            var dataResponse = DataResponse<T.SerializedObject>(
                request: self.request,
                response: self.response,
                data: self.delegate.data,
                result: result,
                timeline: self.timeline
            )
            dataResponse.add(self.delegate.metrics)
            (queue ?? DispatchQueue.main).async { completionHandler(dataResponse) }
        }
        return self
    }
  • 首先序列化數(shù)據(jù)懂缕,let result = responseSerializer.serializeResponse,返回Result<Value>類型,通過局部變量result保存:
public struct DataResponseSerializer<Value>: DataResponseSerializerProtocol {
    public typealias SerializedObject = Value
    public var serializeResponse: (URLRequest?, HTTPURLResponse?, Data?, Error?) -> Result<Value>
    public init(serializeResponse: @escaping (URLRequest?, HTTPURLResponse?, Data?, Error?) -> Result<Value>) {
        self.serializeResponse = serializeResponse
    }
}
  • 調(diào)用DataResponse整合數(shù)據(jù)王凑,返回?cái)?shù)據(jù)多了一個(gè)result搪柑,這個(gè)就是我們序列化后的數(shù)據(jù),然后將數(shù)據(jù)回調(diào)到主線程索烹。由于我們自定義了序列化器工碾,所以在外部序列化的時(shí)候,我們可以對返回的數(shù)據(jù)進(jìn)行預(yù)處理百姓,以滿足我們的需求渊额。

2.自帶responseJSON

        SessionManager.default
            .request(urlString)
            .response { (response) in
                print(response)
            }.responseJSON { (jsonResponse) in
                print(jsonResponse)
        }
  • 源碼分析:
    public func responseJSON(
        queue: DispatchQueue? = nil,
        options: JSONSerialization.ReadingOptions = .allowFragments,
        completionHandler: @escaping (DataResponse<Any>) -> Void)
        -> Self
    {
        return response(
            queue: queue,
            responseSerializer: DataRequest.jsonResponseSerializer(options: options),
            completionHandler: completionHandler
        )
    }
  • responseSerializer傳入DataRequest.jsonResponseSerializer(options: options)序列化參數(shù)
    public static func jsonResponseSerializer(
        options: JSONSerialization.ReadingOptions = .allowFragments)
        -> DataResponseSerializer<Any>
    {
        return DataResponseSerializer { _, response, data, error in
            return Request.serializeResponseJSON(options: options, response: response, data: data, error: error)
        }
    }
  • 繼續(xù)Request.serializeResponseJSON
    public static func serializeResponseJSON(
        options: JSONSerialization.ReadingOptions,
        response: HTTPURLResponse?,
        data: Data?,
        error: Error?)
        -> Result<Any>
    {
        guard error == nil else { return .failure(error!) }

        if let response = response, emptyDataStatusCodes.contains(response.statusCode) { return .success(NSNull()) }

        guard let validData = data, validData.count > 0 else {
            return .failure(AFError.responseSerializationFailed(reason: .inputDataNilOrZeroLength))
        }

        do {
            let json = try JSONSerialization.jsonObject(with: validData, options: options)
            return .success(json)
        } catch {
            return .failure(AFError.responseSerializationFailed(reason: .jsonSerializationFailed(error: error)))
        }
    }
  • 有木有發(fā)現(xiàn),我們自定義的序列化器和系統(tǒng)實(shí)現(xiàn)的serializeResponseJSON序列化如出一轍。本質(zhì)上都是傳入一個(gè)序列化參數(shù)旬迹,對數(shù)據(jù)進(jìn)行處理火惊。

三.DefaultDownloadResponseDownloadResponse

  • DefaultDownloadResponse
    public func response(
        queue: DispatchQueue? = nil,
        completionHandler: @escaping (DefaultDownloadResponse) -> Void)
        -> Self
    {
        delegate.queue.addOperation {
            (queue ?? DispatchQueue.main).async {
                var downloadResponse = DefaultDownloadResponse(
                    request: self.request,
                    response: self.response,
                    temporaryURL: self.downloadDelegate.temporaryURL,
                    destinationURL: self.downloadDelegate.destinationURL,
                    resumeData: self.downloadDelegate.resumeData,
                    error: self.downloadDelegate.error,
                    timeline: self.timeline
                )
                downloadResponse.add(self.delegate.metrics)
                completionHandler(downloadResponse)
            }
        }
        return self
    }
  • DownloadResponse
public func response<T: DownloadResponseSerializerProtocol>(
        queue: DispatchQueue? = nil,
        responseSerializer: T,
        completionHandler: @escaping (DownloadResponse<T.SerializedObject>) -> Void)
        -> Self
    {
        delegate.queue.addOperation {
            let result = responseSerializer.serializeResponse(
                self.request,
                self.response,
                self.downloadDelegate.fileURL,
                self.downloadDelegate.error
            )
            var downloadResponse = DownloadResponse<T.SerializedObject>(
                request: self.request,
                response: self.response,
                temporaryURL: self.downloadDelegate.temporaryURL,
                destinationURL: self.downloadDelegate.destinationURL,
                resumeData: self.downloadDelegate.resumeData,
                result: result,
                timeline: self.timeline
            )
            downloadResponse.add(self.delegate.metrics)
            (queue ?? DispatchQueue.main).async { completionHandler(downloadResponse) }
        }
        return self
    }
  • 序列化
public struct DownloadResponseSerializer<Value>: DownloadResponseSerializerProtocol {
    public typealias SerializedObject = Value
    public var serializeResponse: (URLRequest?, HTTPURLResponse?, URL?, Error?) -> Result<Value>
    public init(serializeResponse: @escaping (URLRequest?, HTTPURLResponse?, URL?, Error?) -> Result<Value>) {
        self.serializeResponse = serializeResponse
    }
}
  • DefaultDownloadResponseDownloadResponse,對于序列化的處理與DefaultDataResponseDataResponse大同小異;
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末奔垦,一起剝皮案震驚了整個(gè)濱河市屹耐,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌宴倍,老刑警劉巖张症,帶你破解...
    沈念sama閱讀 217,734評論 6 505
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異鸵贬,居然都是意外死亡俗他,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,931評論 3 394
  • 文/潘曉璐 我一進(jìn)店門阔逼,熙熙樓的掌柜王于貴愁眉苦臉地迎上來兆衅,“玉大人,你說我怎么就攤上這事嗜浮∠勰叮” “怎么了?”我有些...
    開封第一講書人閱讀 164,133評論 0 354
  • 文/不壞的土叔 我叫張陵危融,是天一觀的道長畏铆。 經(jīng)常有香客問我,道長吉殃,這世上最難降的妖魔是什么辞居? 我笑而不...
    開封第一講書人閱讀 58,532評論 1 293
  • 正文 為了忘掉前任,我火速辦了婚禮蛋勺,結(jié)果婚禮上瓦灶,老公的妹妹穿的比我還像新娘。我一直安慰自己抱完,他們只是感情好贼陶,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,585評論 6 392
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著巧娱,像睡著了一般碉怔。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上禁添,一...
    開封第一講書人閱讀 51,462評論 1 302
  • 那天眨层,我揣著相機(jī)與錄音,去河邊找鬼上荡。 笑死,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的酪捡。 我是一名探鬼主播叁征,決...
    沈念sama閱讀 40,262評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼逛薇!你這毒婦竟也來了捺疼?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 39,153評論 0 276
  • 序言:老撾萬榮一對情侶失蹤永罚,失蹤者是張志新(化名)和其女友劉穎啤呼,沒想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體呢袱,經(jīng)...
    沈念sama閱讀 45,587評論 1 314
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡官扣,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,792評論 3 336
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了羞福。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片惕蹄。...
    茶點(diǎn)故事閱讀 39,919評論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖治专,靈堂內(nèi)的尸體忽然破棺而出卖陵,到底是詐尸還是另有隱情,我是刑警寧澤张峰,帶...
    沈念sama閱讀 35,635評論 5 345
  • 正文 年R本政府宣布泪蔫,位于F島的核電站,受9級特大地震影響喘批,放射性物質(zhì)發(fā)生泄漏撩荣。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,237評論 3 329
  • 文/蒙蒙 一谤祖、第九天 我趴在偏房一處隱蔽的房頂上張望婿滓。 院中可真熱鬧,春花似錦粥喜、人聲如沸凸主。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,855評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽卿吐。三九已至,卻和暖如春锋华,著一層夾襖步出監(jiān)牢的瞬間嗡官,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,983評論 1 269
  • 我被黑心中介騙來泰國打工毯焕, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留衍腥,地道東北人磺樱。 一個(gè)月前我還...
    沈念sama閱讀 48,048評論 3 370
  • 正文 我出身青樓,卻偏偏與公主長得像婆咸,于是被迫代替她去往敵國和親竹捉。 傳聞我的和親對象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,864評論 2 354

推薦閱讀更多精彩內(nèi)容

  • 在上兩篇中研究了下Alamofire的請求發(fā)起過程以及在請求發(fā)起過程中一些有用的功能,本篇來看看數(shù)據(jù)接受的環(huán)節(jié) r...
    好有魔力閱讀 698評論 0 4
  • 上幾篇介紹了Alamofire的SessionManager,SessionDelegate,Request等等尚骄。...
    king_jensen閱讀 683評論 0 4
  • response為數(shù)據(jù)請求響應(yīng)結(jié)果块差,封裝了URLRequest、時(shí)間軸倔丈、請求錯(cuò)誤信息憨闰,請求成功的數(shù)據(jù)等信息,方便開...
    yahibo閱讀 621評論 0 4
  • ??????Alamofire專題目錄需五,歡迎及時(shí)反饋交流 ??????Alamofire (1)—— URLSession必備...
  • 一鹉动、Response 1、Response: 信息保存者警儒,面向?qū)ο?點(diǎn)擊response 點(diǎn)擊self.deleg...
    Code_人生閱讀 233評論 1 3