本文整理了Java中com.alibaba.fastjson.JSONObject
类的一些代码示例,展示了JSONObject
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JSONObject
类的具体详情如下:
包路径:com.alibaba.fastjson.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) {
内容来源于网络,如有侵权,请联系作者删除!