Android 利用责任链模式来实现 剖析不同的json对象

1. 创建剖析类

2. class WebSocketParserChain {
3.     private val parsers = mutableListOf<WebSocketDataParser>()
5.     fun addParser(parser: WebSocketDataParser): WebSocketParserChain {
6.         parsers.add(parser)
7.         return this
8.     }
10.     fun parse(text: String): WebSocketResponseBaseBean<*>? {
11.         for (parser in parsers) {
12.             val result = parser.parse(text)
13.             if (result != null) {
14.                 return result
15.             }
16.         }
17.         return null
18.     }
19. }
22. /**
23. * 解析的接口
24. */
25. interface WebSocketDataParser {
26.     fun parse(text: String): WebSocketResponseBaseBean<*>?
27. }
29. /**
30. * 对象解析
31. */
32. class DataParser : WebSocketDataParser {
33.     override fun parse(text: String): WebSocketResponseBaseBean<*>? {
34.         return try {
35.             val objectType = object : TypeToken<WebSocketResponseBaseBean<Data>>() {}.type
36.             val webSocketBaseBean: WebSocketResponseBaseBean<*> = Gson().fromJson(text, objectType)
38.             // 如果解析后的 data 是对象（Data），直接返回结果
39.             if (webSocketBaseBean.data != null && webSocketBaseBean.data is Data) {
40.                 webSocketBaseBean
41.             } else {
42.                 XLog.e("DataParser----json解析对应的bean---${webSocketBaseBean.data}")
43.                 null // 如果 data 不是对象，返回 null 传递给下一个解析器
44.             }
45.         } catch (e: JsonSyntaxException) {
46.             XLog.e("DataParser----json解析异常---${e.message}")
47.             null // 如果解析失败，返回 null
48.         }
49.     }
50. }
52. /**
53. * string 解析
54. */
55. class StringParser: WebSocketDataParser {
56.     override fun parse(text: String): WebSocketResponseBaseBean<*>? {
57.         return try {
58.             val stringType = object : TypeToken<WebSocketResponseBaseBean<String>>() {}.type
59.             Gson().fromJson(text, stringType)
60.         } catch (e: JsonSyntaxException) {
61.             XLog.e("StringParser-----json异常---${e.message}")
62.             null
63.         }
64.     }
65. }
68. /**
69. * object 解析  默认解析  添加一个兜底方案 避免返回的data 既不是字符串 又不是对象
70. */
71. class ObjectParser: WebSocketDataParser {
72.     override fun parse(text: String): WebSocketResponseBaseBean<*>? {
73.         return try {
74.             val stringType = object : TypeToken<WebSocketResponseBaseBean<Any>>() {}.type
75.             Gson().fromJson(text, stringType)
76.         } catch (e: JsonSyntaxException) {
77.             XLog.e("ObjectParser-----json异常---${e.message}")
78.             null
79.         }
80.     }
81. }

复制代码

2.利用方法

1. override fun onMessage(text: String) {
2.         XLog.e("onMessage----text---$text")
3.         try {
4.             val parserChain = WebSocketParserChain()
5.                 .addParser(DataParser())   // 尝试解析为对象类型
6.                 .addParser(StringParser())   // 如果失败则尝试解析为字符串类型
7.                 .addParser(ObjectParser())   // 如果失败则尝试解析为Any类型 兜底方案
9.             val webSocketBaseBean = parserChain.parse(text)
12.             XLog.e("当前websocket数据为--$webSocketBaseBean------mListener---$mListener")
14.             if (webSocketBaseBean==null) {
15.                 return
16.             }
18.             // 判断 `code` 是否为 200
19.             if (webSocketBaseBean.code != 200) {
20.                 return
21.             }
23.             // 回调是否初始化
24.             if (mListener == null) {
25.                return
26.             }
28.             when (webSocketBaseBean.data) {
29.                 is Data -> {
30.                     val updateInfo = webSocketBaseBean.data as Data
31.                     mListener!!.downloadData(updateInfo)
32.                 }
34.                 is String -> {
35.                     when (webSocketBaseBean.type) {
37.                     }
38.                     val downloadUrl = webSocketBaseBean.data as String
39.                     XLog.e("------downloadUrl----$downloadUrl")
40.                     mListener!!.defaultRefresh()
41.                 }
43.                 else -> {
44.                     XLog.e("解析的data---${webSocketBaseBean.data}")
45.                 }
46.             }
47.         } catch (e: Exception) {
48.             XLog.e("解析异常: ${e.message}")
49.         }
51.     }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。