Java BodyCodec类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中io.vertx.ext.web.codec.BodyCodec类的典型用法代码示例。如果您正苦于以下问题：Java BodyCodec类的具体用法？Java BodyCodec怎么用？Java BodyCodec使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

BodyCodec类属于io.vertx.ext.web.codec包，在下文中一共展示了BodyCodec类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: buildRequest

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
private HttpRequest<JsonObject> buildRequest(String requestURI, RequestParameters parameters) {
  HttpRequest<JsonObject> request = client.post(requestURI)
                                          .as(BodyCodec.jsonObject())
                                          .putHeader("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8")
                                          .setQueryParam("properties", parameters.getProperties().toString())
                                          .setQueryParam("pipelineLanguage", parameters.getLanguage().name());
  if (options.getUsername() != null && options.getPassword() != null) {
    request.putHeader("Authorization",
                      "Basic " + Base64.getEncoder().encodeToString(String.join(":", options.getUsername(), options.getPassword()).getBytes()));
  }
  if (parameters.getPattern() != null) {
    request.setQueryParam("pattern", parameters.getPattern())
           .setQueryParam("filter", String.valueOf(parameters.isFilter()));
  }
  return request;
}

开发者ID:shikeio，项目名称:vertx-corenlp-client，代码行数:17，代码来源:CoreNLPClientImpl.java

示例2: getAddressSpace

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
/**
 * get address space by address space name vie rest api
 *
 * @param name name of address space
 * @return
 * @throws InterruptedException
 */
public JsonObject getAddressSpace(String name) throws Exception {
    CompletableFuture<JsonObject> responsePromise = new CompletableFuture<>();
    return doRequestNTimes(initRetry, () -> {
        client.get(endpoint.getPort(), endpoint.getHost(), addressSpacesPath + "/" + name)
                .as(BodyCodec.jsonObject())
                .putHeader(HttpHeaders.AUTHORIZATION.toString(), authzString)
                .send(ar -> {
                    if (ar.succeeded()) {
                        responsePromise.complete(responseHandler(ar));
                    } else {
                        Logging.log.warn("Error when getting address space {}", name);
                        responsePromise.completeExceptionally(ar.cause());
                    }
                });
        return responsePromise.get(30, TimeUnit.SECONDS);
    });
}

开发者ID:EnMasseProject，项目名称:enmasse，代码行数:25，代码来源:AddressApiClient.java

示例3: getValueForCompany

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
private Future<Double> getValueForCompany(WebClient client, String company, int numberOfShares) {
  // Create the future object that will  get the value once the value have been retrieved
  Future<Double> future = Future.future();

  //----
  client.get("/?name=" + encode(company))
      .as(BodyCodec.jsonObject())
      .send(ar -> {
    if (ar.succeeded()) {
      HttpResponse<JsonObject> response = ar.result();
      if (response.statusCode() == 200) {
        double v = numberOfShares * response.body().getDouble("bid");
        future.complete(v);
      } else {
        future.complete(0.0);
      }
    } else {
      future.fail(ar.cause());
    }
  });
  // ---

  return future;
}

开发者ID:cescoffier，项目名称:vertx-microservices-workshop，代码行数:25，代码来源:PortfolioServiceImpl.java

示例4: testInsertion

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testInsertion(TestContext tc) {
  Async async = tc.async();

  vertx.eventBus().publish("portfolio", createBuyOperation());


  WebClient.create(vertx).get(8081, "localhost", "/")
      .as(BodyCodec.jsonArray())
      .send(tc.asyncAssertSuccess(response -> {
    tc.assertEquals(response.statusCode(), 200);
    tc.assertEquals(response.body().size(), 1);
    async.complete();
  }));

}

开发者ID:cescoffier，项目名称:vertx-microservices-workshop，代码行数:17，代码来源:AuditVerticleTest.java

示例5: receiveResponseAsJsonObject

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
public void receiveResponseAsJsonObject(WebClient client) {
  client
    .get(8080, "myserver.mycompany.com", "/some-uri")
    .as(BodyCodec.jsonObject())
    .send(ar -> {
      if (ar.succeeded()) {
        HttpResponse<JsonObject> response = ar.result();

        JsonObject body = response.body();

        System.out.println("Received response with status code" + response.statusCode() + " with body " + body);
      } else {
        System.out.println("Something went wrong " + ar.cause().getMessage());
      }
    });
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:17，代码来源:WebClientExamples.java

示例6: receiveResponseAsJsonPOJO

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
public void receiveResponseAsJsonPOJO(WebClient client) {
  client
    .get(8080, "myserver.mycompany.com", "/some-uri")
    .as(BodyCodec.json(User.class))
    .send(ar -> {
      if (ar.succeeded()) {
        HttpResponse<User> response = ar.result();

        User user = response.body();

        System.out.println("Received response with status code" + response.statusCode() + " with body " +
          user.getFirstName() + " " + user.getLastName());
      } else {
        System.out.println("Something went wrong " + ar.cause().getMessage());
      }
    });
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:18，代码来源:WebClientExamples.java

示例7: HttpRequestImpl

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
HttpRequestImpl(WebClientImpl client, HttpMethod method, String protocol, boolean ssl, int port, String host, String
        uri, BodyCodec<T> codec, WebClientOptions options) {
  this.client = client;
  this.method = method;
  this.protocol = protocol;
  this.codec = codec;
  this.port = port;
  this.host = host;
  this.uri = uri;
  this.ssl = ssl;
  this.followRedirects = options.isFollowRedirects();
  this.options = options;
  if (options.isUserAgentEnabled()) {
    headers = new CaseInsensitiveHeaders().add(HttpHeaders.USER_AGENT, options.getUserAgent());
  }
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:17，代码来源:HttpRequestImpl.java

示例8: subscriptionFetch

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
private void subscriptionFetch() {
	if (this.shuttingDown || this.shutdownCompleted) {
		this.shutdownCompleted = true;
		return;
	}
	this.logger.info("Fetch " + Utils.getDateString(new Date()));
	final JsonArray body = this.getConnectBody();
	final HttpRequest<Buffer> request = this.initWebPostRequest(Constants.URL_CONNECT);
	request.as(BodyCodec.jsonArray()).sendJson(body, this::subscriptionResult);

}

开发者ID:Stwissel，项目名称:vertx-sfdc-platformevents，代码行数:12，代码来源:CometD.java

示例9: shouldFindAll

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void shouldFindAll(TestContext context) {
  Async async = context.async();
  webClient.get("/api/dependencies").as(BodyCodec.jsonArray()).send(response -> {
    if (response.succeeded()) {
      assertThat(response.result().statusCode(), is(200));
      JsonArray payload = response.result().body();
      assertThat(payload.size(), is(2));
      async.complete();
    } else {
      context.fail(response.cause());
      async.complete();
    }
  });
}

开发者ID:vert-x3，项目名称:vertx-starter，代码行数:16，代码来源:DependencyResourceIntTest.java

示例10: shouldFindAll

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void shouldFindAll(TestContext context) {
  Async async = context.async();
  webClient.get("/api/versions").as(BodyCodec.jsonArray()).send(response -> {
    if (response.succeeded()) {
      assertThat(response.result().statusCode(), is(200));
      JsonArray payload = response.result().body();
      assertThat(payload.size(), is(4));
      async.complete();
    } else {
      context.fail(response.cause());
      async.complete();
    }
  });
}

开发者ID:vert-x3，项目名称:vertx-starter，代码行数:16，代码来源:VersionResourceIntTest.java

示例11: testRecordCreation

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testRecordCreation(TestContext testContext) {
  Record record = HttpEndpoint.createRecord("some-name", "123.456.789.111", 80, null);
  assertThat(record.getLocation().getString(Record.ENDPOINT)).isEqualTo("http://123.456.789.111:80/");

  record = HttpEndpoint.createRecord("some-name", "123.456.789.111", 80, "foo");
  assertThat(record.getLocation().getString(Record.ENDPOINT)).isEqualTo("http://123.456.789.111:80/foo");

  record = HttpEndpoint.createRecord("some-name", "123.456.789.111", 80, "foo", new JsonObject().put("language", "en"));
  assertThat(record.getLocation().getString(Record.ENDPOINT)).isEqualTo("http://123.456.789.111:80/foo");
  assertThat(record.getMetadata().getString("language")).isEqualTo("en");

  record = HttpEndpoint.createRecord("some-name", "acme.org");
  assertThat(record.getLocation().getString(Record.ENDPOINT)).isEqualTo("http://acme.org:80/");

  SelfSignedCertificate selfSignedCertificate = SelfSignedCertificate.create();
  vertx.createHttpServer(new HttpServerOptions()
    .setHost("127.0.0.1")
    .setSsl(true)
    .setKeyCertOptions(selfSignedCertificate.keyCertOptions())
  ).requestHandler(request -> {
    request.response().end(new JsonObject().put("url", request.absoluteURI()).encode());
  }).listen(0, testContext.asyncAssertSuccess(server -> {

    Record sslRecord = HttpEndpoint.createRecord("http-bin", true, "127.0.0.1", server.actualPort(), "/get", null);
    ServiceReference reference = discovery.getReferenceWithConfiguration(sslRecord, new HttpClientOptions()
      .setSsl(true)
      .setTrustAll(true)
      .setVerifyHost(false)
      .toJson());

    WebClient webClient = WebClient.wrap(reference.get());
    webClient.get("/get").as(BodyCodec.jsonObject()).send(testContext.asyncAssertSuccess(resp -> {
      assertEquals("https://127.0.0.1:" + server.actualPort() + "/get", resp.body().getString("url"));
    }));
  }));
}

开发者ID:vert-x3，项目名称:vertx-service-discovery，代码行数:38，代码来源:HttpEndpointTest.java

示例12: receiveResponseAsWriteStream

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
public void receiveResponseAsWriteStream(WebClient client, WriteStream<Buffer> writeStream) {
  client
    .get(8080, "myserver.mycompany.com", "/some-uri")
    .as(BodyCodec.pipe(writeStream))
    .send(ar -> {
      if (ar.succeeded()) {

        HttpResponse<Void> response = ar.result();

        System.out.println("Received response with status code" + response.statusCode());
      } else {
        System.out.println("Something went wrong " + ar.cause().getMessage());
      }
    });
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:16，代码来源:WebClientExamples.java

示例13: receiveResponseAndDiscard

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
public void receiveResponseAndDiscard(WebClient client) {
  client
    .get(8080, "myserver.mycompany.com", "/some-uri")
    .as(BodyCodec.none())
    .send(ar -> {
      if (ar.succeeded()) {

        HttpResponse<Void> response = ar.result();

        System.out.println("Received response with status code" + response.statusCode());
      } else {
        System.out.println("Something went wrong " + ar.cause().getMessage());
      }
    });
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:16，代码来源:WebClientExamples.java

示例14: testResponseBodyAsAsJsonObject

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testResponseBodyAsAsJsonObject() throws Exception {
  JsonObject expected = new JsonObject().put("cheese", "Goat Cheese").put("wine", "Condrieu");
  server.requestHandler(req -> req.response().end(expected.encode()));
  startServer();
  HttpRequest<Buffer> get = client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath");
  get
    .as(BodyCodec.jsonObject())
    .send(onSuccess(resp -> {
    assertEquals(200, resp.statusCode());
    assertEquals(expected, resp.body());
    testComplete();
  }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:16，代码来源:WebClientTest.java

示例15: testResponseBodyAsAsJsonMapped

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testResponseBodyAsAsJsonMapped() throws Exception {
  JsonObject expected = new JsonObject().put("cheese", "Goat Cheese").put("wine", "Condrieu");
  server.requestHandler(req -> req.response().end(expected.encode()));
  startServer();
  HttpRequest<Buffer> get = client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath");
  get
    .as(BodyCodec.json(WineAndCheese.class))
    .send(onSuccess(resp -> {
    assertEquals(200, resp.statusCode());
    assertEquals(new WineAndCheese().setCheese("Goat Cheese").setWine("Condrieu"), resp.body());
    testComplete();
  }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:16，代码来源:WebClientTest.java

示例16: testResponseBodyAsAsJsonArray

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testResponseBodyAsAsJsonArray() throws Exception {
  JsonArray expected = new JsonArray().add("cheese").add("wine");
  server.requestHandler(req -> req.response().end(expected.encode()));
  startServer();
  HttpRequest<Buffer> get = client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath");
  get
    .as(BodyCodec.jsonArray())
    .send(onSuccess(resp -> {
      assertEquals(200, resp.statusCode());
      assertEquals(expected, resp.body());
      testComplete();
    }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:16，代码来源:WebClientTest.java

示例17: testResponseBodyAsAsJsonArrayMapped

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testResponseBodyAsAsJsonArrayMapped() throws Exception {
  JsonArray expected = new JsonArray().add("cheese").add("wine");
  server.requestHandler(req -> req.response().end(expected.encode()));
  startServer();
  HttpRequest<Buffer> get = client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath");
  get
    .as(BodyCodec.json(List.class))
    .send(onSuccess(resp -> {
      assertEquals(200, resp.statusCode());
      assertEquals(expected.getList(), resp.body());
      testComplete();
    }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:16，代码来源:WebClientTest.java

示例18: testResponseBodyDiscarded

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testResponseBodyDiscarded() throws Exception {
  server.requestHandler(req -> req.response().end(TestUtils.randomAlphaString(1024)));
  startServer();
  HttpRequest<Buffer> get = client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath");
  get
    .as(BodyCodec.none())
    .send(onSuccess(resp -> {
    assertEquals(200, resp.statusCode());
    assertEquals(null, resp.body());
    testComplete();
  }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:15，代码来源:WebClientTest.java

示例19: testResponseBodyUnmarshallingError

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testResponseBodyUnmarshallingError() throws Exception {
  server.requestHandler(req -> req.response().end("not-json-object"));
  startServer();
  HttpRequest<Buffer> get = client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath");
  get
    .as(BodyCodec.jsonObject())
    .send(onFailure(err -> {
    assertTrue(err instanceof DecodeException);
    testComplete();
  }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:14，代码来源:WebClientTest.java

示例20: testResponseMissingBody

import io.vertx.ext.web.codec.BodyCodec; //导入依赖的package包/类
private <R> void testResponseMissingBody(BodyCodec<R> codec) throws Exception {
  server.requestHandler(req -> req.response().setStatusCode(403).end());
  startServer();
  HttpRequest<Buffer> get = client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath");
  get
    .as(codec)
    .send(onSuccess(resp -> {
    assertEquals(403, resp.statusCode());
    assertNull(resp.body());
    testComplete();
  }));
  await();
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:14，代码来源:WebClientTest.java

注：本文中的io.vertx.ext.web.codec.BodyCodec类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java WorldGenGlowStone2类代码示例发布时间：2022-05-22

Java ODataJPAContext类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18011|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9588|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8136|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8520|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8424|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9323|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8387|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7820|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8375|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7369|2022-11-06

客服电话

电子邮件

Java BodyCodec类代码示例

示例1: buildRequest

示例2: getAddressSpace

示例3: getValueForCompany

示例4: testInsertion

示例5: receiveResponseAsJsonObject

示例6: receiveResponseAsJsonPOJO

示例7: HttpRequestImpl

示例8: subscriptionFetch

示例9: shouldFindAll

示例10: shouldFindAll

示例11: testRecordCreation

示例12: receiveResponseAsWriteStream

示例13: receiveResponseAndDiscard

示例14: testResponseBodyAsAsJsonObject

示例15: testResponseBodyAsAsJsonMapped

示例16: testResponseBodyAsAsJsonArray

示例17: testResponseBodyAsAsJsonArrayMapped

示例18: testResponseBodyDiscarded

示例19: testResponseBodyUnmarshallingError

示例20: testResponseMissingBody

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

juven/maven-bash-completion: Maven Bash

win7系统注册表编辑器打开的操作方法

route101/mastoinker: Quick image view as

CVE-2022-21509

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053