io.vertx.core.json.JsonArray.encodePrettily()方法的使用及代码示例

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

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

JsonArray.encodePrettily介绍

[英]Encode the JSON array prettily as a string
[中]将JSON数组漂亮地编码为字符串

代码示例

代码示例来源:origin: vert-x3/vertx-examples

private void handleListProducts(RoutingContext routingContext) {
 JsonArray arr = new JsonArray();
 products.forEach((k, v) -> arr.add(v));
 routingContext.response().putHeader("content-type", "application/json").end(arr.encodePrettily());
}

代码示例来源:origin: vert-x3/vertx-examples

private void handleListProducts(RoutingContext routingContext) {
 JsonArray arr = new JsonArray();
 products.forEach((k, v) -> arr.add(v));
 routingContext.response().putHeader("content-type", "application/json").end(arr.encodePrettily());
}

代码示例来源:origin: eclipse-vertx/vert.x

@Test
public void testEncodePrettily() throws Exception {
 jsonArray.add("foo");
 jsonArray.add(123);
 jsonArray.add(1234l);
 jsonArray.add(1.23f);
 jsonArray.add(2.34d);
 jsonArray.add(true);
 byte[] bytes = TestUtils.randomByteArray(10);
 jsonArray.add(bytes);
 jsonArray.addNull();
 jsonArray.add(new JsonObject().put("foo", "bar"));
 jsonArray.add(new JsonArray().add("foo").add(123));
 String strBytes = Base64.getEncoder().encodeToString(bytes);
 String expected = "[ \"foo\", 123, 1234, 1.23, 2.34, true, \"" + strBytes + "\", null, {" + Utils.LINE_SEPARATOR +
  "  \"foo\" : \"bar\"" + Utils.LINE_SEPARATOR +
  "}, [ \"foo\", 123 ] ]";
 String json = jsonArray.encodePrettily();
 assertEquals(expected, json);
}

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

@Test
public void testEncodePrettily() throws Exception {
 jsonArray.add("foo");
 jsonArray.add(123);
 jsonArray.add(1234l);
 jsonArray.add(1.23f);
 jsonArray.add(2.34d);
 jsonArray.add(true);
 byte[] bytes = TestUtils.randomByteArray(10);
 jsonArray.add(bytes);
 jsonArray.addNull();
 jsonArray.add(new JsonObject().put("foo", "bar"));
 jsonArray.add(new JsonArray().add("foo").add(123));
 String strBytes = Base64.getEncoder().encodeToString(bytes);
 String expected = "[ \"foo\", 123, 1234, 1.23, 2.34, true, \"" + strBytes + "\", null, {" + Utils.LINE_SEPARATOR +
  "  \"foo\" : \"bar\"" + Utils.LINE_SEPARATOR +
  "}, [ \"foo\", 123 ] ]";
 String json = jsonArray.encodePrettily();
 assertEquals(expected, json);
}

代码示例来源:origin: org.eclipse.hono/hono-server

.put(ARRAY_DEVICES, devices));
fs.writeFile(filename, Buffer.factory.buffer(tenants.encodePrettily()), writeAttempt -> {
  if (writeAttempt.succeeded()) {
    log.trace("successfully wrote {} device identities to file {}", idCount.get(), filename);

代码示例来源:origin: sczyh30/vertx-kue

private void apiJobTypes(RoutingContext context) {
 kue.getAllTypes().setHandler(resultHandler(context, r -> {
  context.response()
   .putHeader("content-type", "application/json")
   .end(new JsonArray(r).encodePrettily());
 }));
}

代码示例来源:origin: org.eclipse.hono/hono-service-device-registry

vertx.fileSystem().writeFile(getConfig().getFilename(), Buffer.factory.buffer(tenants.encodePrettily()), writeHandler.completer());
return writeHandler.map(ok -> {
  dirty = false;

代码示例来源:origin: sczyh30/vertx-kue

private void apiFetchLog(RoutingContext context) {
 try {
  long id = Long.parseLong(context.request().getParam("id"));
  kue.getJobLog(id).setHandler(resultHandler(context, r -> {
   context.response().putHeader("content-type", "application/json")
    .end(r.encodePrettily());
  }));
 } catch (Exception e) {
  badRequest(context, e);
 }
}

代码示例来源:origin: org.eclipse.hono/hono-service-device-registry

vertx.fileSystem().writeFile(
    getConfig().getFilename(),
    Buffer.buffer(tenants.encodePrettily(), StandardCharsets.UTF_8.name()),
    writeHandler.completer());
return writeHandler.map(ok -> {

代码示例来源:origin: eclipse/hono

vertx.fileSystem().writeFile(
    getConfig().getFilename(),
    Buffer.buffer(tenants.encodePrettily(), StandardCharsets.UTF_8.name()),
    writeHandler.completer());
return writeHandler.map(ok -> {

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

@CodeTranslate
public void encodePrettily() throws Exception {
 JsonArray arr = new JsonArray().add("foo").add("bar");
 JsonTest.o = arr.encodePrettily();
}

代码示例来源:origin: folio-org/okapi

xmlMsg.append(" Tenant parameters: ");
if (tenantParameters != null) {
 xmlMsg.append(tenantParameters.encodePrettily());

代码示例来源:origin: sczyh30/vertx-kue

private void apiJobRange(RoutingContext context) {
 try {
  String order = context.request().getParam("order");
  if (order == null || !isOrderValid(order))
   order = "asc";
  Long from = Long.parseLong(context.request().getParam("from"));
  Long to = Long.parseLong(context.request().getParam("to"));
  kue.jobRange(from, to, order)
   .setHandler(resultHandler(context, r -> {
    String result = new JsonArray(r).encodePrettily();
    context.response()
     .putHeader("content-type", "application/json")
     .end(result);
   }));
 } catch (Exception e) {
  e.printStackTrace();
  badRequest(context, e);
 }
}

代码示例来源:origin: eclipse/hono

Future<Void> saveToFile() {
  if (!getConfig().isSaveToFile()) {
    return Future.succeededFuture();
  } else if (dirty) {
    return checkFileExists(true).compose(s -> {
      final JsonArray tenantsJson = new JsonArray();
      tenants.values().stream().forEach(tenant -> {
        tenantsJson.add(JsonObject.mapFrom(tenant));
      });
      final Future<Void> writeHandler = Future.future();
      vertx.fileSystem().writeFile(getConfig().getFilename(),
          Buffer.factory.buffer(tenantsJson.encodePrettily()), writeHandler.completer());
      return writeHandler.map(ok -> {
        dirty = false;
        log.trace("successfully wrote {} tenants to file {}", tenantsJson.size(),
            getConfig().getFilename());
        return (Void) null;
      }).otherwise(t -> {
        log.warn("could not write tenants to file {}", getConfig().getFilename(), t);
        return (Void) null;
      });
    });
  } else {
    log.trace("tenants registry does not need to be persisted");
    return Future.succeededFuture();
  }
}

代码示例来源:origin: sczyh30/vertx-kue

private void apiJobStateRange(RoutingContext context) {
 try {
  String order = context.request().getParam("order");
  if (order == null || !isOrderValid(order))
   order = "asc";
  Long from = Long.parseLong(context.request().getParam("from"));
  Long to = Long.parseLong(context.request().getParam("to"));
  String state = context.request().getParam("state");
  kue.jobRangeByState(state, from, to, order)
   .setHandler(resultHandler(context, r -> {
    String result = new JsonArray(r).encodePrettily();
    context.response()
     .putHeader("content-type", "application/json")
     .end(result);
   }));
 } catch (Exception e) {
  e.printStackTrace();
  badRequest(context, e);
 }
}

代码示例来源:origin: org.eclipse.hono/hono-service-device-registry

Future<Void> saveToFile() {
  if (!getConfig().isSaveToFile()) {
    return Future.succeededFuture();
  } else if (dirty) {
    return checkFileExists(true).compose(s -> {
      final JsonArray tenantsJson = new JsonArray();
      tenants.values().stream().forEach(tenant -> {
        tenantsJson.add(JsonObject.mapFrom(tenant));
      });
      final Future<Void> writeHandler = Future.future();
      vertx.fileSystem().writeFile(getConfig().getFilename(),
          Buffer.factory.buffer(tenantsJson.encodePrettily()), writeHandler.completer());
      return writeHandler.map(ok -> {
        dirty = false;
        log.trace("successfully wrote {} tenants to file {}", tenantsJson.size(),
            getConfig().getFilename());
        return (Void) null;
      }).otherwise(t -> {
        log.warn("could not write tenants to file {}", getConfig().getFilename(), t);
        return (Void) null;
      });
    });
  } else {
    log.trace("tenants registry does not need to be persisted");
    return Future.succeededFuture();
  }
}

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

@CodeTranslate
public void getJsonArray() {
 JsonObject obj = JsonTest.object;
 obj = JsonConverter.fromJsonObject(obj);
 JsonTest.o = obj.getJsonArray("foo").encodePrettily();
}

代码示例来源:origin: sczyh30/vertx-kue

private void apiJobTypeRange(RoutingContext context) {
 try {
  String order = context.request().getParam("order");
  if (order == null || !isOrderValid(order)) {
   order = "asc";
  }
  Long from = Long.parseLong(context.request().getParam("from"));
  Long to = Long.parseLong(context.request().getParam("to"));
  String state = context.request().getParam("state");
  String type = context.request().getParam("type");
  kue.jobRangeByType(type, state, from, to, order)
   .setHandler(resultHandler(context, r -> {
    String result = new JsonArray(r).encodePrettily();
    context.response()
     .putHeader("content-type", "application/json")
     .end(result);
   }));
 } catch (Exception e) {
  e.printStackTrace();
  badRequest(context, e);
 }
}

代码示例来源:origin: vert-x3/vertx-service-discovery

@Before
public void setUp() {
 services.clear();
 vertx = Vertx.vertx();
 AtomicBoolean done = new AtomicBoolean();
 server = vertx.createHttpServer()
   .requestHandler(request -> {
    if (request.path().equals("/v1/catalog/services")) {
     JsonObject result = new JsonObject();
     services.forEach(object ->
       result.put(object.getJsonObject("Service").getString("Service"), object.getJsonArray("tags", new JsonArray())));
     request.response().putHeader("X-Consul-Index", "42").end(result.encodePrettily());
    } else if (request.path().startsWith("/v1/health/service/")) {
     String service = request.path().substring("/v1/health/service/".length());
     JsonArray value = find(service);
     if (value != null) {
      request.response().putHeader("X-Consul-Index", "42").end(value.encodePrettily());
     } else {
      request.response().setStatusCode(404).end();
     }
    } else {
     request.response().setStatusCode(404).end();
    }
   })
   .listen(5601, ar -> done.set(ar.succeeded()));
 await().untilAtomic(done, is(true));
}

代码示例来源:origin: io.vertx/vertx-service-discovery-bridge-consul

@Before
public void setUp() {
 services.clear();
 vertx = Vertx.vertx();
 AtomicBoolean done = new AtomicBoolean();
 server = vertx.createHttpServer()
   .requestHandler(request -> {
    if (request.path().equals("/v1/catalog/services")) {
     JsonObject result = new JsonObject();
     services.forEach(object ->
       result.put(object.getJsonObject("Service").getString("Service"), object.getJsonArray("tags", new JsonArray())));
     request.response().putHeader("X-Consul-Index", "42").end(result.encodePrettily());
    } else if (request.path().startsWith("/v1/health/service/")) {
     String service = request.path().substring("/v1/health/service/".length());
     JsonArray value = find(service);
     if (value != null) {
      request.response().putHeader("X-Consul-Index", "42").end(value.encodePrettily());
     } else {
      request.response().setStatusCode(404).end();
     }
    } else {
     request.response().setStatusCode(404).end();
    }
   })
   .listen(5601, ar -> done.set(ar.succeeded()));
 await().untilAtomic(done, is(true));
}

相关文章