com.alibaba.fastjson.JSONObject类的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(11.2k)|赞(0)|评价(0)|浏览(329)

本文整理了Java中com.alibaba.fastjson.JSONObject类的一些代码示例,展示了JSONObject类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JSONObject类的具体详情如下:
包路径:com.alibaba.fastjson.JSONObject
类名称:JSONObject

JSONObject介绍

暂无

代码示例

代码示例来源:origin: alibaba/nacos

public static void onPublish(JSONObject json, boolean increaseTerm) throws Exception {
  Datum datum = JSON.parseObject(json.getString("datum"), Datum.class);
  RaftPeer source = JSON.parseObject(json.getString("source"), RaftPeer.class);
  onPublish(datum, source, increaseTerm);
}

代码示例来源:origin: alibaba/nacos

@RequestMapping("/domCount")
public JSONObject domCount(HttpServletRequest request) {
  JSONObject result = new JSONObject();
  result.put("count", domainsManager.getDomCount());
  return result;
}

代码示例来源:origin: alibaba/nacos

@Override
public <T> T deserialze(DefaultJSONParser parser, Type type, Object fieldName) {
  JSONObject jsonObj = (JSONObject) parser.parse();
  String checkType = jsonObj.getString("type");
  if (StringUtils.equals(checkType, AbstractHealthChecker.Http.TYPE)) {
    return (T) JSON.parseObject(jsonObj.toJSONString(), AbstractHealthChecker.Http.class);
  }
  if (StringUtils.equals(checkType, AbstractHealthChecker.Tcp.TYPE)) {
    return (T) JSON.parseObject(jsonObj.toJSONString(), AbstractHealthChecker.Tcp.class);
  }
  if (StringUtils.equals(checkType, AbstractHealthChecker.Mysql.TYPE)) {
    return (T) JSON.parseObject(jsonObj.toJSONString(), AbstractHealthChecker.Mysql.class);
  }
  return null;
}

代码示例来源:origin: alibaba/nacos

@RequestMapping("/getLeader")
public JSONObject getLeader(HttpServletRequest request, HttpServletResponse response) {
  JSONObject result = new JSONObject();
  result.put("leader", JSONObject.toJSONString(RaftCore.getLeader()));
  return result;
}

代码示例来源:origin: hs-web/hsweb-framework

@Override
  public SingleDictParser build(String config) {
    Objects.requireNonNull(config, "config is null");
    JSONObject object = JSON.parseObject(config);
    String type = object.getString("type");
    switch (type) {
      case "simple":
        return object.getObject("parser", SimpleSingleDictParser.class);
      case "script":
        // TODO: 17-5-25
      default:
        throw new UnsupportedOperationException(config);
    }
  }
}

代码示例来源:origin: alibaba/Sentinel

private JSONArray buildRequestLimitData(Set<String> namespaceSet) {
    JSONArray array = new JSONArray();
    for (String namespace : namespaceSet) {
      array.add(new JSONObject()
        .fluentPut("namespace", namespace)
        .fluentPut("currentQps", GlobalRequestLimiter.getCurrentQps(namespace))
        .fluentPut("maxAllowedQps", GlobalRequestLimiter.getMaxAllowedQps(namespace))
      );
    }
    return array;
  }
}

代码示例来源:origin: alibaba/nacos

@NeedAuth
@RequestMapping("/beat")
public JSONObject beat(HttpServletRequest request, HttpServletResponse response) throws Exception {
  String entity = new String(IoUtils.tryDecompress(request.getInputStream()), "UTF-8");
  String value = Arrays.asList(entity).toArray(new String[1])[0];
  value = URLDecoder.decode(value, "UTF-8");
  JSONObject json = JSON.parseObject(value);
  JSONObject beat = JSON.parseObject(json.getString("beat"));
  RaftPeer peer = RaftCore.HeartBeat.receivedBeat(beat);
  return JSON.parseObject(JSON.toJSONString(peer));
}

代码示例来源:origin: hs-web/hsweb-framework

@GetMapping(value = "/{modelId}/json")
@Authorize(action = Permission.ACTION_GET)
public Object getEditorJson(@PathVariable String modelId) {
  JSONObject modelNode;
  Model model = repositoryService.getModel(modelId);
  if (model == null) throw new NullPointerException("模型不存在");
  if (StringUtils.isNotEmpty(model.getMetaInfo())) {
    modelNode = JSON.parseObject(model.getMetaInfo());
  } else {
    modelNode = new JSONObject();
    modelNode.put(MODEL_NAME, model.getName());
  }
  modelNode.put(MODEL_ID, model.getId());
  modelNode.put("model", JSON.parse(new String(repositoryService.getModelEditorSource(model.getId()))));
  return modelNode;
}

代码示例来源:origin: alibaba/nacos

private Cluster getClusterFromJson(String json) {
  JSONObject object = JSON.parseObject(json);
  String type = object.getJSONObject("healthChecker").getString("type");
  AbstractHealthChecker abstractHealthCheckConfig;
  if (type.equals(HealthCheckType.HTTP.name())) {
    abstractHealthCheckConfig = JSON.parseObject(object.getString("healthChecker"), AbstractHealthChecker.Http.class);
  } else if (type.equals(HealthCheckType.TCP.name())) {
    abstractHealthCheckConfig = JSON.parseObject(object.getString("healthChecker"), AbstractHealthChecker.Tcp.class);
  } else if (type.equals(HealthCheckType.MYSQL.name())) {
    abstractHealthCheckConfig = JSON.parseObject(object.getString("healthChecker"), AbstractHealthChecker.Mysql.class);
  } else {
    throw new IllegalArgumentException("can not prase cluster from json: " + json);
  }
  Cluster cluster = JSON.parseObject(json, Cluster.class);
  cluster.setHealthChecker(abstractHealthCheckConfig);
  return cluster;
}

代码示例来源:origin: alibaba/canal

@Override
  protected RdsBackupPolicy processResult(HttpResponse response) throws Exception {
    String result = EntityUtils.toString(response.getEntity());
    JSONObject jsonObj = JSON.parseObject(result);
    RdsBackupPolicy policy = new RdsBackupPolicy();
    policy.setBackupRetentionPeriod(jsonObj.getString("BackupRetentionPeriod"));
    policy.setBackupLog(jsonObj.getString("BackupLog").equalsIgnoreCase("Enable"));
    policy.setLogBackupRetentionPeriod(jsonObj.getIntValue("LogBackupRetentionPeriod"));
    policy.setPreferredBackupPeriod(jsonObj.getString("PreferredBackupPeriod"));
    policy.setPreferredBackupTime(jsonObj.getString("PreferredBackupTime"));
    return policy;
  }
}

代码示例来源:origin: TommyLemon/APIJSON

String tag = requestObject.getString(JSONRequest.KEY_TAG);
if (StringUtil.isNotEmpty(tag, true) == false) {
  throw new IllegalArgumentException("请在最外层设置tag!一般是Table名,例如 \"tag\": \"User\" ");
int version = requestObject.getIntValue(JSONRequest.KEY_VERSION);
if (zuo.biao.apijson.JSONObject.isTableKey(tag) && object.containsKey(tag) == false) {//tag是table名
  target = new JSONObject(true);
  target.put(tag, object);
} else {
  target = object;
requestObject.remove(JSONRequest.KEY_TAG);
requestObject.remove(JSONRequest.KEY_VERSION);
return parseCorrectRequest((JSONObject) target.clone());

代码示例来源:origin: hs-web/hsweb-framework

protected JobDataMap createJobDataMap(String parameters) {
  JobDataMap map = new JobDataMap();
  if (!StringUtils.isEmpty(parameters)) {
    JSONArray jsonArray = JSON.parseArray(parameters);
    for (int i = 0; i < jsonArray.size(); i++) {
      JSONObject o = jsonArray.getJSONObject(i);
      map.put(o.getString("key"), o.get("value"));
    }
  }
  return map;
}

代码示例来源:origin: TommyLemon/APIJSON

/**添加JSONObject的状态内容,一般用于错误提示结果
 * @param object
 * @param code
 * @param msg
 * @return
 */
public static JSONObject extendResult(JSONObject object, int code, String msg) {
  if (object == null) {
    object = new JSONObject(true);
  }
  if (object.containsKey(JSONResponse.KEY_CODE) == false) {
    object.put(JSONResponse.KEY_CODE, code);
  }
  String m = StringUtil.getString(object.getString(JSONResponse.KEY_MSG));
  if (m.isEmpty() == false) {
    msg = m + " ;\n " + StringUtil.getString(msg);
  }
  object.put(JSONResponse.KEY_MSG, msg);
  return object;
}

代码示例来源:origin: alibaba/nacos

@NeedAuth
@RequestMapping("/publish")
public String publish(HttpServletRequest request, HttpServletResponse response) throws Exception {
  response.setHeader("Content-Type", "application/json; charset=" + getAcceptEncoding(request));
  response.setHeader("Cache-Control", "no-cache");
  response.setHeader("Content-Encode", "gzip");
  String entity = IOUtils.toString(request.getInputStream(), "UTF-8");
  String value = Arrays.asList(entity).toArray(new String[1])[0];
  value = URLDecoder.decode(value, "UTF-8");
  JSONObject json = JSON.parseObject(value);
  RaftCore.doSignalPublish(json.getString("key"), json.getString("value"), json.getBooleanValue("locked"));
  return "ok";
}

代码示例来源:origin: hs-web/hsweb-framework

protected Set<Correlation> buildCorrelations(String correlations) {
  if (StringUtils.isEmpty(correlations)) {
    return new LinkedHashSet<>();
  }
  JSONArray correlationsConfig = JSON.parseArray(correlations);
  Set<Correlation> correlations1 = new LinkedHashSet<>();
  for (int i = 0; i < correlationsConfig.size(); i++) {
    JSONObject single = correlationsConfig.getJSONObject(i);
    String target = single.getString("target");
    String alias = single.getString("alias");
    String condition = single.getString("condition");
    Objects.requireNonNull(target);
    Objects.requireNonNull(condition);
    Correlation correlation = new Correlation(target, alias, condition);
    correlation.setJoin(Correlation.JOIN.valueOf(String.valueOf(single.getOrDefault("join", "LEFT")).toUpperCase()));
    JSONObject properties = single.getJSONObject("properties");
    if (properties != null) {
      properties.forEach(correlation::setProperty);
    }
    correlations1.add(correlation);
  }
  return correlations1;
}

代码示例来源:origin: alibaba/Tangram-Android

protected void parseCell(BaseCell cell, JSONObject json) {
  if (json != null) {
    cell.extras = json;
    cell.id = json.getString(KEY_BIZ_ID);
    if (TextUtils.isEmpty(cell.id) && json.containsKey(KEY_ID)) {
      cell.id = json.getString(KEY_ID);
    }
    cell.stringType = parseCellType(json);
    cell.typeKey = json.getString(KEY_TYPE_KEY);
    String reuseId = json.getString(KEY_TYPE_REUSEID);
    if (!TextUtils.isEmpty(reuseId)) {
      cell.typeKey = reuseId;
    }
    Integer position = json.getInteger(KEY_POSITION);
    if (position == null) {
      position = -1;
    }
    cell.position = position;
    JSONObject styleJson = json.getJSONObject(KEY_STYLE);
    Style style = new Style();
    cell.style = parseStyle(style, styleJson);
  } else {
    cell.extras = new JSONObject();
  }
}

代码示例来源:origin: hs-web/hsweb-framework

@Override
public AuthenticationBuilder json(String json) {
  JSONObject jsonObject = JSON.parseObject(json);
  user(jsonObject.getObject("user", SimpleUser.class));
  role(jsonObject.getJSONArray("roles").toJSONString());
  permission(jsonObject.getJSONArray("permissions").toJSONString());
  return this;
}

代码示例来源:origin: alibaba/nacos

@RequestMapping("/getAllListeners")
public JSONObject getAllListeners(HttpServletRequest request, HttpServletResponse response) {
  JSONObject result = new JSONObject();
  List<RaftListener> listeners = RaftCore.getListeners();
  JSONArray listenerArray = new JSONArray();
  for (RaftListener listener : listeners) {
    if (listener instanceof VirtualClusterDomain) {
      listenerArray.add(((VirtualClusterDomain) listener).getName());
    }
  }
  result.put("listeners", listenerArray);
  return result;
}

代码示例来源:origin: alibaba/Sentinel

@Override
public CommandResponse<String> handle(CommandRequest request) {
  JSONObject res = new JSONObject()
    .fluentPut("mode", ClusterStateManager.getMode())
    .fluentPut("lastModified", ClusterStateManager.getLastModified())
    .fluentPut("clientAvailable", isClusterClientSpiAvailable())
    .fluentPut("serverAvailable", isClusterServerSpiAvailable());
  return CommandResponse.ofSuccess(res.toJSONString());
}

代码示例来源:origin: alibaba/Sentinel

JSONObject body = JSON.parseObject(payload);
if (body.containsKey(KEY_MODE)) {
  int mode = body.getInteger(KEY_MODE);
  switch (mode) {
    case ClusterStateManager.CLUSTER_CLIENT:
      ClusterClientModifyRequest data = JSON.parseObject(payload, ClusterClientModifyRequest.class);
      Result<Boolean> res = checkValidRequest(data);
      if (res != null) {
      return Result.ofSuccess(true);
    case ClusterStateManager.CLUSTER_SERVER:
      ClusterServerModifyRequest d = JSON.parseObject(payload, ClusterServerModifyRequest.class);
      Result<Boolean> r = checkValidRequest(d);
      if (r != null) {

相关文章

微信公众号

最新文章

更多