解析json类

src/main/scala/tools/json/JsonUtils.scala

+package tools.json
+
+import com.fasterxml.jackson.databind.ObjectMapper
+import com.fasterxml.jackson.module.scala.DefaultScalaModule
+
+
+import scala.collection.mutable
+import scala.util.{Failure, Success, Try}
+
+/**
+ * Created with IntelliJ IDEA.
+ * Class: Jackson
+ * Description: json解析类
+ * User: lin
+ * Date: 2021-07-19
+ * Time: 16:25
+ */
+object JsonUtils {
+  private val mapper = new ObjectMapper()
+  mapper.registerModule(DefaultScalaModule)
+
+  /**
+   * 解析一级key
+   *
+   * @param str 要解析的字符串
+   * @return 解析结果
+   */
+  def parseFirstKey(str: String): mutable.HashMap[String, String] = {
+    val map: mutable.HashMap[String, String] = mutable.HashMap()
+    Try {
+      // 获取所有节点
+      val node = mapper.readTree(str)
+      // 获取所有key
+      val keys = node.fieldNames()
+      // 循环所有节点
+      while (keys.hasNext) {
+        val next = keys.next()
+        // 解析一级key
+        map += (next -> node.get(next).toString)
+      }
+    } match {
+      case Success(value) => map
+      case Failure(exception) => map
+    }
+  }
+
+  /**
+   * 解析所有key
+   * 递归操作
+   *
+   * @param str 要解析的字符串
+   * @param res 解析结果map
+   * @return 返回res
+   */
+  def parseAllKey(str: String, res: mutable.HashMap[String, String]): mutable.HashMap[String, String] = {
+    Try {
+      // 获取所有节点
+      val node = mapper.readTree(str)
+      // 获取节点所有key
+      val keys = node.fieldNames()
+      // 循环读取所有key
+      while (keys.hasNext) {
+        val key = keys.next()
+        val chNode = node.get(key)
+        // 如果子节点是json对象,递归解析子节点
+        if (chNode.isObject) {
+          parseAllKey(chNode.toString, res)
+        }
+        else {
+          res += (key -> chNode.toString)
+        }
+      }
+    } match {
+      // 解析成功
+      case Success(value) => res
+      // 解析失败
+      case Failure(exception) => res
+    }
+  }
+
+  /**
+   * 对象转json
+   *
+   * @param bean 要转的对象
+   * @return json结果
+   */
+  def parseBeanToString(bean: Any): String = mapper.writeValueAsString(bean)
+
+  /**
+   * json转数组
+   *
+   * @param str json数组
+   * @return scala数组
+   */
+  def parseStringToArray(str: String): Array[Any] = mapper.readValue(str, classOf[Array[Any]])
+}