RxHttp中处理服务器返回数据的特殊格式解析

在开发Android应用时，我们经常需要处理服务器返回的数据。RxHttp作为一个强大的网络请求库，提供了灵活的数据解析机制。本文将探讨如何处理服务器返回的特殊数据格式，其中成功和失败的返回结构不一致的情况。

问题背景

在实际项目中，我们经常会遇到服务器返回数据的特殊格式：

• 请求成功时直接返回业务对象，如：

{
  "userId": "1",
  "name": "2",
  "age": 3
}

• 请求失败时返回错误信息对象：

{
  "code":"E1001",
  "msg":"密码错误"
}

这种格式与常见的统一封装格式不同（如包含code、msg、data的标准结构），给数据解析带来了挑战。

解决方案一：继承基类法

第一种解决方案是让所有业务数据类继承一个包含错误信息的基类：

open class BaseError : Serializable {
    var code: String? = null
    var msg: String? = null
}

class UserInfo : BaseError {
    var userId: Int = 0
    val name: String? = null
    val age: Int = 0
}

这样可以直接使用RxHttp的标准解析方式，然后在订阅时判断是否有错误：

RxHttp.postForm(AppConfig.URL_LOGIN)
    .toObservable<UserInfo>()
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ userInfo ->
        if (userInfo.code != null) {
            // 处理错误逻辑
        } else {
            // 处理成功逻辑
        }
    }, { throwable ->
        // 处理其他异常
    })

解决方案二：自定义解析器

如果需要统一处理错误逻辑，可以创建自定义解析器：

@Parser(name = "Response")
open class ResponseParser<T: BaseError> : TypeParser<T> {
    constructor() : super()
    constructor(type: Type) : super(type)

    @Throws(IOException::class)
    override fun onParse(response: okhttp3.Response): T {
        val data: T = response.convert(types[0])
        if (data.code != null) {
            throw ParseException(data.code, data.msg, response)
        }
        return data
    }
}

使用时：

RxHttp.postForm(AppConfig.URL_LOGIN)
    .toObservableResponse<UserInfo>()
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ userInfo ->
        // 处理成功逻辑
    }, { throwable ->
        // 统一处理错误
        val code = throwable.errorCode
        val msg = throwable.errorMsg
    })

解决方案三：完全自定义解析

如果需要更灵活的控制，可以完全自定义解析过程：

@Parser(name = "Result", wrappers = [PageList::class])
open class ResultParser<T> : TypeParser<T> {
    constructor() : super()
    constructor(type: Type) : super(type)

    @Throws(IOException::class)
    override fun onParse(response: okhttp3.Response): T {
        var str = response.body()?.string().str()
        if (response.isSuccessful) {
            // 处理成功响应
            if (str.isBlank() && types[0].typeName != String::class.java.name) {
                str = "{}"
            }
            return JSONObject.parseObject(str, types[0]) as T
        } else {
            // 处理错误响应
            val error = JSONObject.parseObject(str, BaseError::class.java)
            throw ParseException(error.code, error.msg, response)
        }
    }
}

注意事项

1. 使用自定义解析器时，响应日志可能不会自动输出，需要手动处理
2. 对于空响应体，需要特殊处理，如替换为"{}"
3. 如果需要处理响应头中的信息（如token），可以在解析器中统一处理
4. 类型安全需要注意，确保类型转换的安全性

总结

RxHttp提供了多种方式来处理特殊的服务器响应格式。开发者可以根据项目需求选择最适合的方案：

• 简单场景：使用继承基类法
• 需要统一错误处理：使用自定义解析器
• 需要完全控制解析过程：实现完整自定义解析

无论哪种方案，都要注意类型安全和异常处理，确保应用的健壮性。RxHttp的灵活设计使得它能够适应各种服务器接口规范，为Android网络请求开发提供了强大支持。