org.vertx.java.core.json.JsonObject.encode()方法的使用及代码示例

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

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

JsonObject.encode介绍

暂无

代码示例

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

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

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

protected int getBodyLength() {
 if (body == null) {
  return 1;
 } else {
  String strJson = body.encode();
  encoded = strJson.getBytes(CharsetUtil.UTF_8);
  return 1 + 4 + encoded.length;
 }
}

代码示例来源：origin: net.kuujo/vertigo-utils

@Override
public <T> T deserializeObject(JsonObject json, Class<T> type) {
 try {
  return mapper.readValue(json.encode(), type);
 } catch (Exception e) {
  throw new DeserializationException(e.getMessage());
 }
}

代码示例来源：origin: net.kuujo/vertigo-utils

@Override
public <T> T deserializeObject(JsonObject json, TypeReference<T> type) {
 try {
  return mapper.readValue(json.encode(), type);
 } catch (Exception e) {
  throw new DeserializationException(e.getMessage());
 }
}

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

public Buffer call(JsonObject in) {
  try {
   return new Buffer(in.encode().getBytes(charset));
  }
  catch (UnsupportedEncodingException e) {
   throw new RuntimeException("Unable to encode JSON (charset="+charset+")",e);
  }
 }
};

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

/** Create uploader for JsonObject */
public static Action1<HttpClientRequest> uploadJson(JsonObject src, String charset) throws UnsupportedEncodingException {
 String contentType="text/json;charset="+charset;
 return uploadBody(contentType,src.encode().getBytes(charset));    
}

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

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

代码示例来源：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: io.vertx/vertx-testframework

private void sendMessage(JsonObject msg) {
 EventLog.addEvent("Sending message: " + msg.encode());
 try {
  vertx.eventBus().publish(TestBase.EVENTS_ADDRESS, msg);
 } catch (Exception e) {
  log.error("Failed to send message", e);
 }
}

代码示例来源：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: net.kuujo/xync

@Override
public void undeployVerticleAs(final String deploymentID, final Handler<AsyncResult<Void>> doneHandler) {
 synchronized (haInfo) {
  // Undeploy the deployment.
  String internalID = internalIDs.getString(deploymentID);
  internalIDs.removeField(deploymentID);
  if (internalID != null) {
   container.undeployVerticle(internalID, doneHandler);
   deploymentIDs.removeField(internalID);
  } else {
   new DefaultFutureResult<Void>(new PlatformManagerException("Invalid deployment.")).setHandler(doneHandler);
  }
  // Remove the deployment from HA.
  Iterator<Object> iter = deployments.iterator();
  while (iter.hasNext()) {
   JsonObject deploymentInfo = (JsonObject) iter.next();
   if (deploymentInfo.getString("id").equals(deploymentID)) {
    iter.remove();
   }
  }
 }
 clusterMap.put(node, haInfo.encode());
}

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

@Override
public void undeployModuleAs(final String deploymentID, final Handler<AsyncResult<Void>> doneHandler) {
 synchronized (haInfo) {
  // Undeploy the deployment.
  String internalID = internalIDs.getString(deploymentID);
  internalIDs.removeField(deploymentID);
  if (internalID != null) {
   container.undeployModule(internalID, doneHandler);
   deploymentIDs.removeField(internalID);
  } else {
   new DefaultFutureResult<Void>(new PlatformManagerException("Invalid deployment.")).setHandler(doneHandler);
  }
  // Remove the deployment from HA.
  Iterator<Object> iter = deployments.iterator();
  while (iter.hasNext()) {
   JsonObject deploymentInfo = (JsonObject) iter.next();
   if (deploymentInfo.getString("id").equals(deploymentID)) {
    iter.remove();
   }
  }
 }
 clusterMap.put(node, haInfo.encode());
}

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

private void deliverMessage(SockJSSocket sock, String address, Message<JsonObject> jsonMessage) {
 JsonObject envelope = new JsonObject().putString("address", address).putObject("body", jsonMessage.body);
 if (jsonMessage.replyAddress != null) {
  envelope.putString("replyAddress", jsonMessage.replyAddress);
 }
 sock.writeBuffer(new Buffer(envelope.encode()));
}

代码示例来源：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 start() {
 this.haInfo = new JsonObject();
 haInfo.putString("node", nodeID);
 haInfo.putString("group", group);
 this.deployments = new JsonArray();
 haInfo.putArray("deployments", deployments);
 this.deploymentIDs = new JsonObject();
 haInfo.putObject("external", deploymentIDs);
 this.internalIDs = new JsonObject();
 haInfo.putObject("internal", internalIDs);
 clusterMap.put(node, haInfo.encode());
}

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

private void addVerticleToHA(String deploymentID, String internalID, String main, JsonObject conf, int instances, boolean ha) {
 JsonObject info = new JsonObject()
   .putString("id", deploymentID)
   .putString("type", "verticle")
   .putString("group", group)
   .putString("main", main)
   .putObject("config", conf)
   .putNumber("instances", instances)
   .putBoolean("ha", ha);
 synchronized (haInfo) {
  deployments.addObject(info);
  deploymentIDs.putString(internalID, deploymentID);
  internalIDs.putString(deploymentID, internalID);
 }
 clusterMap.put(node, haInfo.encode());
}

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

private void addModuleToHA(String deploymentID, String internalID, String moduleName, JsonObject conf, int instances, boolean ha) {
 JsonObject info = new JsonObject()
   .putString("id", deploymentID)
   .putString("type", "module")
   .putString("group", group)
   .putString("module", moduleName)
   .putObject("config", conf)
   .putNumber("instances", instances)
   .putBoolean("ha", ha);
 synchronized (haInfo) {
  deployments.addObject(info);
  deploymentIDs.putString(internalID, deploymentID);
  internalIDs.putString(deploymentID, internalID);
 }
 clusterMap.put(node, haInfo.encode());
}

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

private void addWorkerVerticleToHA(String deploymentID, String internalID, String main, JsonObject conf, int instances, boolean multiThreaded, boolean ha) {
 JsonObject info = new JsonObject()
   .putString("id", deploymentID)
   .putString("type", "verticle")
   .putString("group", group)
   .putString("main", main)
   .putObject("config", conf)
   .putNumber("instances", instances)
   .putBoolean("worker", true)
   .putBoolean("multi-threaded", multiThreaded)
   .putBoolean("ha", ha);
 synchronized (haInfo) {
  deployments.addObject(info);
  deploymentIDs.putString(internalID, deploymentID);
  internalIDs.putString(deploymentID, internalID);
 }
 clusterMap.put(node, haInfo.encode());
}

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

private void doSendOrPub(final boolean send, final SockJSSocket sock, final String address,
             final JsonObject jsonObject, final String replyAddress) {
 if (log.isDebugEnabled()) {
  log.debug("Received msg from client in bridge. address:"  + address + " message:" + jsonObject.encode());

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

clusterMap.put(nodeID, haInfo.encode());
quorumTimerID = vertx.setPeriodic(QUORUM_CHECK_PERIOD, new Handler<Long>() {
 @Override

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

JSONObject

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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