scala中的json封装

挺费劲的，java和scala的返回方式为了统一，需要封装scala的返回方式 ，需要一个listmap，但是如果是java可以直接将listMap放入json中就可以了，但是scala不行，我们也不能将对象直接装成jsonstring，这样的话，我们在放入json后，会自动加上转义字符，可以使用listbuffer 然后转array

package flinkonkafka import net.minidev.json.JSONObject import net.minidev.json.parser.JSONParser import com.alibaba.fastjson.JSON import com.alibaba.fastjson.serializer.SerializerFeature import scala.beans.BeanProperty import scala.collection.mutable import scala.collection.mutable.{ArrayBuffer, ListBuffer} import scala.collection.JavaConversions.bufferAsJavaList /*** * @Author BaronND * @Description 从kafka上获取的json解析 * @Date 2020/6/11 * @Param * @return **/ class RequestJson{} case class result(@BeanProperty code:String,@BeanProperty value:String) object RequestJson{ def main(args: Array[String]): Unit = { var resultMap = Map("CF402" -> "-0.037855187404791296", "CF327" -> "0.06558579235761422", "CF401" -> "-0.030836201749878455", "CF33" -> "-0.008973041330299265") var a=getArrayObj(resultMap) var b=getArrayObjs(resultMap) println(a) println(b) } //计算参数 def getStringJson(s: String): mutable.Map[String, Object] = { val jsonobj = JSON.parseObject(s) val jsonParm = jsonobj.getJSONObject("parameter") var parameter=jsonToMap(jsonParm.toString)//请求参数封装 JSON.toJSONString(parameter, SerializerFeature.WriteMapNullValue) parameter } //返回原来的json def callBackJson(requestJSON:String,handleTs:Long,map:Map[String,String],message:String) ={ import com.alibaba.fastjson.JSONObject val js = JSON.parseObject(requestJSON) val jsonObj :JSONObject= new JSONObject() var rs=mutable.Map[String, Object]() var data=getArrayObj(map) val jsonResult = js.getJSONObject("result") jsonResult.put("data",data) jsonResult.put("message",message) js.put("result", jsonResult) js.put("handleTs",handleTs) js } //获取计算参数 def getCallBackUrl(s: String):String = { import com.alibaba.fastjson.JSON val jsonobj = JSON.parseObject(s) val jsonParm = jsonobj.getString("callbackUrl") jsonParm } //对应的json转map def jsonToMap(svdInfo: String) = { val parserJson = new JSONParser() val jsonObj: JSONObject = parserJson.parse(svdInfo).asInstanceOf[JSONObject] val jsonKey = jsonObj.keySet() val iter = jsonKey.iterator() val map: mutable.HashMap[String, Object] = new mutable.HashMap[String, Object]() while (iter.hasNext) { val instance = iter.next() val value = jsonObj.get(instance).toString map.put(instance, value) } map } //将获取的map对象封装成对应的array[result] 结果：[Lflinkonkafka.result;@bd8db5a def getArrayObj(map:Map[String,String])={ var ll=new ListBuffer[result] // val array = ArrayBuffer[result]() map.map(m => { var r= new result(m._1,m._2) // array.add(r) ll.add(r) }) ll.toArray } //将获取的map对象封装成对应的array[result]:结果：ArrayBuffer(result(CF402,-0.037855187404791296), result(CF327,0.06558579235761422)) def getArrayObjs(map:Map[String,String])={ val array = ArrayBuffer[result]() map.map(m => { var r= new result(m._1,m._2) array.add(r) }) array } }