json数组解析

private String collectDataJson(String dataListJson){

        String topic = HBPHelper.getTopic(HBPCollectorConstant.PIPELINE_INFO, 1);

        JSONObject resObj = JSON.parseObject(dataListJson);
        if (false==resObj.containsKey("data")) {
            return "参数不符合规范";
        }
        Object data = resObj.get("data");
        if (data instanceof JSONArray) {
            JSONArray jsonArray = (JSONArray) data;
            LOG.info("start to collect data,data num is [{}]", jsonArray.size());
            for (int i=0;i<jsonArray.size();i++) {
                String jsonString = jsonArray.getString(i);
                if (jsonString.length() < PB_LENGTH) {
                    return "pb数据长度应大于" + PB_LENGTH;
                }
                byte[] jsonByte = HBPHelper.decode(jsonString);
                KafkaUtil.getINSTANCE().getByteProducer(topic).send(jsonByte);
            }
        }
        return "OK";
    }