org.vertx.java.core.json.JsonObject类的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(10.6k)|赞(0)|评价(0)|浏览(227)

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

JsonObject介绍

[英]Represents a JSON object
[中]表示JSON对象

代码示例

代码示例来源：origin: io.vertx/vertx-platform

private void addToHA(String deploymentID, String moduleName, JsonObject conf, int instances) {
 JsonObject moduleConf = new JsonObject().putString("dep_id", deploymentID);
 moduleConf.putString("module_name", moduleName);
 if (conf != null) {
  moduleConf.putObject("conf", conf);
 }
 moduleConf.putNumber("instances", instances);
 synchronized (haMods) {
  haMods.addObject(moduleConf);
 }
 clusterMap.put(nodeID, haInfo.encode());
}

代码示例来源：origin: org.vert-x/vertx-core

private JsonObject setDefaults(JsonObject config) {
 config = config.copy();
 //Set the defaults
 if (config.getNumber("session_timeout") == null) {
  config.putNumber("session_timeout", 5 * 1000); // 5 seconds default
 }
 if (config.getBoolean("insert_JSESSIONID") == null) {
  config.putBoolean("insert_JSESSIONID", true);
 }
 if (config.getNumber("heartbeat_period") == null) {
  config.putNumber("heartbeat_period", 5l * 1000);
 }
 if (config.getNumber("max_bytes_streaming") == null) {
  config.putNumber("max_bytes_streaming", 128 * 1024);
 }
 if (config.getString("prefix") == null) {
  config.putString("prefix", "/");
 }
 if (config.getString("library_url") == null) {
  config.putString("library_url", "http://cdn.sockjs.org/sockjs-0.2.1.min.js");
 }
 if (config.getArray("disabled_transports") == null) {
  config.putArray("disabled_transports", new JsonArray());
 }
 return config;
}

代码示例来源：origin: io.vertx/vertx-platform

@Override
 public void handle(String nodeID, JsonObject haInfo, boolean failed) {
  JsonObject jsid = haInfo.getObject("server_id");
  if (jsid != null) {
   ServerID sid = new ServerID(jsid.getInteger("port"), jsid.getString("host"));
   eb.cleanSubsForServerID(sid);
  }
 }
});

代码示例来源：origin: org.vert-x/vertx-core

public JsonObject copy() {
 return new JsonObject(encode());
}

代码示例来源：origin: io.vertx/vertx-testframework

public void testComplete() {
 JsonObject jsonObject = new JsonObject().putString(EventFields.TYPE_FIELD, EventFields.TEST_COMPLETE_EVENT)
  .putString(EventFields.TEST_COMPLETE_NAME_FIELD, "unused");
 sendMessage(jsonObject);
}

代码示例来源：origin: net.kuujo/xync

/**
 * Counts the number of items in a list.
 */
private void doListSize(final Message<JsonObject> message) {
 final String name = message.body().getString("name");
 if (name == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No name specified."));
  return;
 }
 try {
  int result = manager.getList(formatKey(name)).size();
  message.reply(new JsonObject().putString("status", "ok").putNumber("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

代码示例来源：origin: org.vert-x/vertx-core

public void handle(HttpServerRequest req) {
  if (log.isTraceEnabled()) log.trace("In Info handler");
  req.response.headers().put("Content-Type", "application/json; charset=UTF-8");
  req.response.headers().put("Cache-Control", "no-store, no-cache, must-revalidate, max-age=0");
  JsonObject json = new JsonObject();
  json.putBoolean("websocket", websocket);
  json.putBoolean("cookie_needed", config.getBoolean("insert_JSESSIONID"));
  json.putArray("origins", new JsonArray().add("*:*"));
  // Java ints are signed, so we need to use a long and add the offset so
  // the result is not negative
  json.putNumber("entropy", RAND_OFFSET + new Random().nextInt());
  setCORS(req);
  req.response.end(json.encode());
 }
};

代码示例来源：origin: net.kuujo/xync

@Override
public void getDeploymentInfo(final String deploymentID, final Handler<AsyncResult<JsonObject>> resultHandler) {
 for (Map.Entry<String, String> entry : clusterMap.entrySet()) {
  JsonObject haInfo = new JsonObject(entry.getValue());
  JsonArray deployments = haInfo.getArray("deployments");
  if (deployments != null) {
   for (Object dep : deployments) {
    JsonObject deployment = (JsonObject) dep;
    if (deployment.getString("id").equals(deploymentID)) {
     new DefaultFutureResult<JsonObject>(deployment.putString("node", entry.getKey())).setHandler(resultHandler);
     return;
    }
   }
  }
 }
 new DefaultFutureResult<JsonObject>(new VertxException("Invalid deployment ID.")).setHandler(resultHandler);
}

代码示例来源：origin: net.kuujo/xync

@Override
public void isDeployed(final String deploymentID, final Handler<AsyncResult<Boolean>> resultHandler) {
 Set<String> nodes = manager.getNodes();
 for (Map.Entry<String, String> entry : clusterMap.entrySet()) {
  JsonObject haInfo = new JsonObject(entry.getValue());
  String nodeID = haInfo.getString("node");
  JsonArray deployments = haInfo.getArray("deployments");
  for (Object deployment : deployments) {
   JsonObject deploymentInfo = (JsonObject) deployment;
   if (deploymentInfo.getString("id").equals(deploymentID) && (nodes.contains(nodeID) || deploymentInfo.getBoolean("ha", false))) {
    new DefaultFutureResult<Boolean>(true).setHandler(resultHandler);
    return;
   }
  }
 }
 new DefaultFutureResult<Boolean>(false).setHandler(resultHandler);
}

代码示例来源：origin: net.kuujo/xync

@Override
 public void handle(AsyncResult<Void> result) {
  if (result.succeeded()) {
   log.info("Successfully undeployed HA deployment " + deploymentInfo.getString("id") + " as there is no quorum");
   addWorkerVerticleToHADeployList(deploymentID, deploymentInfo.getString("main"), deploymentInfo.getObject("config"),
     deploymentInfo.getInteger("instances"), deploymentInfo.getBoolean("multi-threaded", false), new AsyncResultHandler<String>() {
    @Override
    public void handle(AsyncResult<String> result) {
     if (result.succeeded()) {
      log.info("Successfully redeployed worker verticle " + deploymentInfo.getString("main") + " after quorum was re-attained");
     } else {
      log.error("Failed to redeploy worker verticle " + deploymentInfo.getString("main") + " after quorum was re-attained", result.cause());
     }
    }
   });
  } else {
   log.error("Failed to undeploy deployment on lost quorum", result.cause());
  }
 }
});

代码示例来源：origin: com.englishtown/vertx-mod-jersey

/**
 * The key store path when using ssl
 *
 * @return the key store path
 */
@Override
public String getKeyStorePath() {
  return config.getString(CONFIG_KEY_STORE_PATH, "server-keystore.jks");
}

代码示例来源：origin: net.kuujo/xync

@Override
 public void handle(AsyncResult<JsonObject> result) {
  if (result.failed()) {
   message.reply(new JsonObject().putString("status", "error").putString("message", result.cause().getMessage()));
  } else {
   message.reply(new JsonObject().putString("status", "ok").putObject("result", result.result()));
  }
 }
});

代码示例来源：origin: OlivierCroisier/LP4J

/**
 * {@inheritDoc}
 *
 * @param brightness The desired brightness. Must not be null.
 */
@Override
public void setBrightness(Brightness brightness) {
  if (brightness == null) {
    throw new IllegalArgumentException("Brightness must not be null");
  }
  JsonObject params = new JsonObject()
      .putNumber("b", brightness.getBrightness());
  publishEvent(OutputEventType.BRGHT, params);
}

代码示例来源：origin: com.englishtown/vertx-mod-cassandra

@Inject
public JsonCassandraConfigurator(Container container) {
  this(container.config().getObject("cassandra", new JsonObject()), container);
}

代码示例来源：origin: net.kuujo/xync

@Override
public void getAssignment(final String deploymentID, final Handler<AsyncResult<String>> resultHandler) {
 for (Map.Entry<String, String> entry : clusterMap.entrySet()) {
  JsonObject haInfo = new JsonObject(entry.getValue());
  JsonObject internalIDs = haInfo.getObject("internal");
  if (internalIDs != null && internalIDs.containsField(deploymentID)) {
   new DefaultFutureResult<String>(entry.getKey()).setHandler(resultHandler);
   return;
  }
 }
 new DefaultFutureResult<String>(new VertxException("Invalid deployment ID.")).setHandler(resultHandler);
}

代码示例来源：origin: net.kuujo/xync

private void checkFailover(String failedNodeID, JsonObject theHAInfo) {
 try {
  JsonArray deployments = theHAInfo.getArray("deployments");
  String group = theHAInfo.getString("group");
  String chosen = chooseHashedNode(group, failedNodeID.hashCode());
  if (chosen != null && chosen.equals(this.node)) {
   log.info("Node " + failedNodeID + " has failed. This node will deploy " + deployments.size() + " deployments from that node.");
   if (deployments != null) {
    for (Object obj: deployments) {
     JsonObject deployment = (JsonObject)obj;
     if (deployment.getBoolean("ha", false)) {
      processFailover(deployment);
     }
    }
   }
   // Failover is complete! We can now remove the failed node from the cluster map
   clusterMap.remove(failedNodeID);
  }
 } catch (Throwable t) {
  log.error("Failed to handle failover", t);
 }
}

代码示例来源：origin: io.vertx/vertx-platform

private void checkFailover(String failedNodeID, JsonObject theHAInfo) {
 try {
  JsonArray deployments = theHAInfo.getArray("mods");
  String group = theHAInfo.getString("group");
  String chosen = chooseHashedNode(group, failedNodeID.hashCode());
  if (chosen != null && chosen.equals(this.nodeID)) {
   if (deployments != null && deployments.size() > 0) {
    log.info("Node " + failedNodeID + " has failed. This node will deploy " + deployments.size() + " deployments from that node.");
    for (Object obj: deployments) {
     JsonObject app = (JsonObject)obj;
     processFailover(app);
    }
   }
   // Failover is complete! We can now remove the failed node from the cluster map
   clusterMap.remove(failedNodeID);
   callFailoverCompleteHandler(failedNodeID, theHAInfo, true);
  }
 } catch (Throwable t) {
  log.error("Failed to handle failover", t);
  callFailoverCompleteHandler(failedNodeID, theHAInfo, false);
 }
}

代码示例来源：origin: io.vertx/vertx-platform

public void removeFromHA(String depID) {
 synchronized (haMods) {
  Iterator<Object> iter = haMods.iterator();
  while (iter.hasNext()) {
   Object obj = iter.next();
   JsonObject mod = (JsonObject)obj;
   if (mod.getString("dep_id").equals(depID)) {
    iter.remove();
   }
  }
 }
 clusterMap.put(nodeID, haInfo.encode());
}

代码示例来源：origin: org.vert-x/vertx-core

@Override
public String toString() {
 return encode();
}

代码示例来源：origin: org.vert-x/vertx-core

public void handle(final HttpServerRequest req) {
  if (log.isTraceEnabled()) log.trace("EventSource transport, get: " + req.uri);
  String sessionID = req.params().get("param0");
  Session session = getSession(config.getLong("session_timeout"), config.getLong("heartbeat_period"), sessionID, sockHandler);
  session.register(new EventSourceListener(config.getInteger("max_bytes_streaming"), req, session));
 }
});

内容来源于网络，如有侵权，请联系作者删除！

JSONObject

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com