本文整理汇总了Java中io.vertx.reactivex.ext.web.client.WebClient类的典型用法代码示例。如果您正苦于以下问题:Java WebClient类的具体用法?Java WebClient怎么用?Java WebClient使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
WebClient类属于io.vertx.reactivex.ext.web.client包,在下文中一共展示了WebClient类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: start
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Override
public void start(Future<Void> startFuture) throws Exception {
webClient = WebClient.create(vertx);
targets = config().getJsonArray("targets",
DEFAULT_TARGETS)
.stream()
.map(JsonObject.class::cast)
.collect(Collectors.toList());
vertx.createHttpServer()
.requestHandler(this::findBestOffer)
.rxListen(8080)
.subscribe((server, error) -> {
if (error != null) {
logger.error("Could not start the best offer " +
"service", error);
startFuture.fail(error);
} else {
logger.info("The best offer service is running " +
"on port 8080");
startFuture.complete();
}
});
}
开发者ID:jponge,项目名称:oracle-javamag-vertx-rxjava,代码行数:26,代码来源:BestOfferServiceVerticle.java
示例2: computeEvaluation
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
private void computeEvaluation(WebClient webClient, Handler<AsyncResult<Double>> resultHandler) {
// We need to call the service for each company in which we own shares
Flowable.fromIterable(portfolio.getShares().entrySet())
// For each, we retrieve the value
.flatMapSingle(entry -> getValueForCompany(webClient, entry.getKey(), entry.getValue()))
// We accumulate the results
.toList()
// And compute the sum
.map(list -> list.stream().mapToDouble(x -> x).sum())
// We report the result or failure
.subscribe((sum, err) -> {
if (err != null) {
resultHandler.handle(Future.failedFuture(err));
} else {
resultHandler.handle(Future.succeededFuture(sum));
}
});
}
开发者ID:cescoffier,项目名称:vertx-kubernetes-workshop,代码行数:19,代码来源:PortfolioServiceImpl.java
示例3: computeEvaluation
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
private void computeEvaluation(WebClient webClient, Handler<AsyncResult<Double>> resultHandler) {
// We need to call the service for each company in which we own shares
Flowable.fromIterable(portfolio.getShares().entrySet())
// For each, we retrieve the value
.flatMapSingle(entry -> getValueForCompany(webClient, entry.getKey(), entry.getValue()))
// We accumulate the results
.toList()
// And compute the sum
.map(list -> list.stream().mapToDouble(x -> x).sum())
// We report the result or failure
.subscribe((sum, err) -> {
if (err != null) {
System.out.println("Evaluation of the portfolio failed " + err.getMessage());
resultHandler.handle(Future.failedFuture(err));
} else {
System.out.println("Evaluation of the portfolio succeeeded");
resultHandler.handle(Future.succeededFuture(sum));
}
});
}
开发者ID:cescoffier,项目名称:vertx-kubernetes-workshop,代码行数:21,代码来源:PortfolioServiceImpl.java
示例4: getValueForCompany
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
private Single<Double> getValueForCompany(WebClient client, String company, int numberOfShares) {
//TODO
//----
return client.get("/?name=" + encode(company))
.as(BodyCodec.jsonObject())
.rxSend()
.map(HttpResponse::body)
.map(json -> json.getDouble("bid"))
.map(val -> val * numberOfShares);
// return Single.just(0.0);
// ---
}
开发者ID:cescoffier,项目名称:vertx-kubernetes-workshop,代码行数:17,代码来源:PortfolioServiceImpl.java
示例5: whenServiceRequestedWithoutPathParam_expectNoServiceRequestAndBadRequest
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
@KnotxConfiguration("knotx-service-adapter-http-test.json")
public void whenServiceRequestedWithoutPathParam_expectNoServiceRequestAndBadRequest(
TestContext context) throws Exception {
Async async = context.async();
// given
final WebClient mockedWebClient = PowerMockito.spy(webClient());
HttpClientFacade clientFacade = new HttpClientFacade(mockedWebClient,
getConfiguration());
// when
Single<ClientResponse> result = clientFacade.process(new AdapterRequest(), HttpMethod.GET);
// then
result
.doOnError(error -> {
context.assertEquals(error.getClass().getSimpleName(),
AdapterServiceContractException.class.getSimpleName());
Mockito.verify(mockedWebClient, Mockito.times(0))
.request(Matchers.any(), Matchers.anyInt(), Matchers.anyString(),
Matchers.anyString());
})
.subscribe(
response -> context.fail("Error should occur!"),
error -> async.complete());
}
开发者ID:Cognifide,项目名称:knotx,代码行数:27,代码来源:HttpClientFacadeTest.java
示例6: whenDoPostSecureWithoutCSRF_expectForbidden
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
@KnotxConfiguration("test-server-csrf.json")
public void whenDoPostSecureWithoutCSRF_expectForbidden(
TestContext context) {
Async async = context.async();
createPassThroughKnot("test-splitter");
createPassThroughKnot("test-assembler");
createSimpleKnot("some-knot", "test", null);
MultiMap body = MultiMap.caseInsensitiveMultiMap().add("field", "value");
WebClient client = WebClient.create(Vertx.newInstance(vertx.vertx()));
client.post(KNOTX_SERVER_PORT, KNOTX_SERVER_ADDRESS, "/content/local/simple.html")
.sendForm(body, ar -> {
if (ar.succeeded()) {
context.assertEquals(HttpResponseStatus.FORBIDDEN.code(), ar.result().statusCode());
async.complete();
} else {
context.fail(ar.cause());
async.complete();
}
});
}
开发者ID:Cognifide,项目名称:knotx,代码行数:25,代码来源:KnotxServerCsrfTest.java
示例7: whenDoPostPublicWithoutCSRF_expectOk
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
@KnotxConfiguration("test-server-csrf.json")
public void whenDoPostPublicWithoutCSRF_expectOk(
TestContext context) {
Async async = context.async();
createPassThroughKnot("test-splitter");
createPassThroughKnot("test-assembler");
createSimpleKnot("some-knot", "test", null);
MultiMap body = MultiMap.caseInsensitiveMultiMap().add("field", "value");
WebClient client = WebClient.create(Vertx.newInstance(vertx.vertx()));
client.post(KNOTX_SERVER_PORT, KNOTX_SERVER_ADDRESS, "/content/local/public.html")
.sendForm(body, ar -> {
if (ar.succeeded()) {
context.assertEquals(HttpResponseStatus.OK.code(), ar.result().statusCode());
async.complete();
} else {
context.fail(ar.cause());
async.complete();
}
});
}
开发者ID:Cognifide,项目名称:knotx,代码行数:25,代码来源:KnotxServerCsrfTest.java
示例8: testGet
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
public void testGet() {
int times = 5;
waitFor(times);
HttpServer server = vertx.createHttpServer(new HttpServerOptions().setPort(8080));
server.requestStream().handler(req -> req.response().setChunked(true).end("some_content"));
try {
server.listen(ar -> {
client = WebClient.wrap(vertx.createHttpClient(new HttpClientOptions()));
Single<HttpResponse<Buffer>> single = client
.get(8080, "localhost", "/the_uri")
.as(BodyCodec.buffer())
.rxSend();
for (int i = 0; i < times; i++) {
single.subscribe(resp -> {
Buffer body = resp.body();
assertEquals("some_content", body.toString("UTF-8"));
complete();
}, this::fail);
}
});
await();
} finally {
server.close();
}
}
开发者ID:vert-x3,项目名称:vertx-web,代码行数:27,代码来源:Rx2Test.java
示例9: testPost
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
public void testPost() {
int times = 5;
waitFor(times);
HttpServer server = vertx.createHttpServer(new HttpServerOptions().setPort(8080));
server.requestStream().handler(req -> req.bodyHandler(buff -> {
assertEquals("onetwothree", buff.toString());
req.response().end();
}));
try {
server.listen(ar -> {
client = WebClient.wrap(vertx.createHttpClient(new HttpClientOptions()));
Observable<Buffer> stream = Observable.just(Buffer.buffer("one"), Buffer.buffer("two"), Buffer.buffer("three"));
Single<HttpResponse<Buffer>> single = client
.post(8080, "localhost", "/the_uri")
.rxSendStream(stream);
for (int i = 0; i < times; i++) {
single.subscribe(resp -> complete(), this::fail);
}
});
await();
} finally {
server.close();
}
}
开发者ID:vert-x3,项目名称:vertx-web,代码行数:26,代码来源:Rx2Test.java
示例10: testResponseMissingBody
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
public void testResponseMissingBody() throws Exception {
int times = 5;
waitFor(times);
HttpServer server = vertx.createHttpServer(new HttpServerOptions().setPort(8080));
server.requestStream().handler(req -> req.response().setStatusCode(403).end());
try {
server.listen(ar -> {
client = WebClient.wrap(vertx.createHttpClient(new HttpClientOptions()));
Single<HttpResponse<Buffer>> single = client
.get(8080, "localhost", "/the_uri")
.rxSend();
for (int i = 0; i < times; i++) {
single.subscribe(resp -> {
assertEquals(403, resp.statusCode());
assertNull(resp.body());
complete();
}, this::fail);
}
});
await();
} finally {
server.close();
}
}
开发者ID:vert-x3,项目名称:vertx-web,代码行数:26,代码来源:Rx2Test.java
示例11: testResponseBodyAsAsJsonMapped
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
public void testResponseBodyAsAsJsonMapped() throws Exception {
JsonObject expected = new JsonObject().put("cheese", "Goat Cheese").put("wine", "Condrieu");
HttpServer server = vertx.createHttpServer(new HttpServerOptions().setPort(8080));
server.requestStream().handler(req -> req.response().end(expected.encode()));
try {
server.listen(ar -> {
client = WebClient.wrap(vertx.createHttpClient(new HttpClientOptions()));
Single<HttpResponse<WineAndCheese>> single = client
.get(8080, "localhost", "/the_uri")
.as(BodyCodec.json(WineAndCheese.class))
.rxSend();
single.subscribe(resp -> {
assertEquals(200, resp.statusCode());
assertEquals(new WineAndCheese().setCheese("Goat Cheese").setWine("Condrieu"), resp.body());
testComplete();
}, this::fail);
});
await();
} finally {
server.close();
}
}
开发者ID:vert-x3,项目名称:vertx-web,代码行数:24,代码来源:Rx2Test.java
示例12: testErrorHandling
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
public void testErrorHandling() throws Exception {
try {
client = WebClient.wrap(vertx.createHttpClient(new HttpClientOptions()));
Single<HttpResponse<WineAndCheese>> single = client
.get(-1, "localhost", "/the_uri")
.as(BodyCodec.json(WineAndCheese.class))
.rxSend();
single.subscribe(resp -> fail(), error -> {
assertEquals(IllegalArgumentException.class, error.getClass());
testComplete();
});
await();
} catch (Throwable t) {
fail();
}
}
开发者ID:vert-x3,项目名称:vertx-web,代码行数:18,代码来源:Rx2Test.java
示例13: retrievePrice
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
public static void retrievePrice(WebClient pricer, Map.Entry<String, Object> entry, Future<JsonObject> future) {
pricer.post("/prices")
.rxSendJson(new JsonObject()
.put("name", entry.getKey())
.put("quantity", entry.getValue())
).subscribe(
resp -> future.complete(resp.bodyAsJsonObject()),
future::fail
);
}
开发者ID:cescoffier,项目名称:vertx-openshift-shopping-hol,代码行数:11,代码来源:Shopping.java
示例14: start
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Override
public void start() {
circuit = CircuitBreaker.create("circuit-breaker", vertx,
new CircuitBreakerOptions()
.setFallbackOnFailure(true)
.setMaxFailures(3)
.setResetTimeout(5000)
.setTimeout(1000)
);
Router router = Router.router(vertx);
router.route("/health").handler(rc -> rc.response().end("OK"));
router.route("/").handler(this::getShoppingList);
ServiceDiscovery.create(vertx, discovery -> {
// Get pricer-service
Single<WebClient> s1 = HttpEndpoint
.rxGetWebClient(discovery, svc -> svc.getName().equals("pricer-service"));
// Get shopping-backend
Single<WebClient> s2 = HttpEndpoint
.rxGetWebClient(discovery, svc -> svc.getName().equals("shopping-backend"));
// When both services have been retrieved
Single.zip(s1, s2, (p, s) -> {
shopping = s;
pricer = p;
return vertx.createHttpServer()
.requestHandler(router::accept)
.listen(8080);
}).subscribe();
});
}
开发者ID:cescoffier,项目名称:vertx-kubernetes-live-coding-devoxx-ma,代码行数:37,代码来源:MyShoppingList.java
示例15: main
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
public static void main(String[] args) {
Vertx vertx = Vertx.vertx();
WebClient client = WebClient.create(vertx);
HttpServer server = vertx.createHttpServer();
server
// 1 - Transform the sequence of request into a stream
.requestStream().toFlowable()
// 2 - For each request, call the twitter API
.flatMapCompletable(req ->
client.getAbs("https://twitter.com/vertx_project")
.rxSend()
// 3 - Extract the body as string
.map(HttpResponse::bodyAsString)
// 4 - In case of a failure
.onErrorReturn(t -> "Cannot access the twitter " +
"feed: " + t.getMessage())
// 5 - Write the response
.doOnSuccess(res -> req.response().end(res))
// 6 - Just transform the restul into a completable
.toCompletable()
)
// 7 - Never forget to subscribe to a reactive type,
// or nothing happens
.subscribe();
server.listen(8080);
}
开发者ID:jponge,项目名称:oracle-javamag-vertx-rxjava,代码行数:28,代码来源:RXTwitterFeedApplication.java
示例16: start
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Override
public void start() {
circuit = CircuitBreaker.create("circuit-breaker", vertx,
new CircuitBreakerOptions()
.setFallbackOnFailure(true)
.setMaxFailures(3)
.setResetTimeout(5000)
.setTimeout(1000)
);
Router router = Router.router(vertx);
router.route("/health").handler(rc -> rc.response().end("OK"));
router.route("/").handler(this::getShoppingList);
ServiceDiscovery.create(vertx, discovery -> {
// Get pricer-service
Single<WebClient> s1 =
HttpEndpoint.rxGetWebClient(discovery,
svc -> svc.getName().equals("pricer-service"));
// Get shopping-backend
Single<WebClient> s2 =
HttpEndpoint.rxGetWebClient(discovery,
svc -> svc.getName().equals("shopping-backend"));
Single.zip(s1, s2, (p, s) -> {
pricer = p;
shopping = s;
return vertx.createHttpServer()
.requestHandler(router::accept)
.listen(8080);
}).subscribe();
});
}
开发者ID:cescoffier,项目名称:vertx-reactive-summit-2017,代码行数:37,代码来源:MyShoppingList.java
示例17: evaluate
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Override
public void evaluate(Handler<AsyncResult<Double>> resultHandler) {
// TODO
// ----
Single<WebClient> quotes = HttpEndpoint.rxGetWebClient(discovery, rec -> rec.getName().equals("quote-generator"));
quotes.subscribe((client, err) -> {
if (err != null) {
resultHandler.handle(Future.failedFuture(err));
} else {
computeEvaluation(client, resultHandler);
}
});
// ---
}
开发者ID:cescoffier,项目名称:vertx-kubernetes-workshop,代码行数:15,代码来源:PortfolioServiceImpl.java
示例18: whenSupportedStaticPathServiceRequested_expectRequestExecutedAndResponseOKWithBody
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
@KnotxConfiguration("knotx-service-adapter-http-test.json")
public void whenSupportedStaticPathServiceRequested_expectRequestExecutedAndResponseOKWithBody(
TestContext context) throws Exception {
Async async = context.async();
// given
final WebClient mockedWebClient = PowerMockito.spy(webClient());
HttpClientFacade clientFacade = new HttpClientFacade(mockedWebClient,
getConfiguration());
final JsonObject expectedResponse = new JsonObject(FileReader.readText("first-response.json"));
// when
Single<ClientResponse> result = clientFacade
.process(payloadMessage(REQUEST_PATH, new ClientRequest()), HttpMethod.GET);
// then
result
.doOnSuccess(response -> {
context.assertEquals(HttpResponseStatus.OK.code(), response.getStatusCode());
context.assertEquals(expectedResponse, response.getBody().toJsonObject());
Mockito.verify(mockedWebClient, Mockito.times(1))
.request(HttpMethod.GET, PORT, DOMAIN, REQUEST_PATH);
})
.subscribe(
response -> async.complete(),
error -> context.fail(error.getMessage())
);
}
开发者ID:Cognifide,项目名称:knotx,代码行数:29,代码来源:HttpClientFacadeTest.java
示例19: whenSupportedDynamicPathServiceRequested_expectRequestExecutedAndResponseOKWithBody
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
@KnotxConfiguration("knotx-service-adapter-http-test.json")
public void whenSupportedDynamicPathServiceRequested_expectRequestExecutedAndResponseOKWithBody(
TestContext context) throws Exception {
Async async = context.async();
// given
final WebClient mockedWebClient = PowerMockito.spy(webClient());
HttpClientFacade clientFacade = new HttpClientFacade(mockedWebClient,
getConfiguration());
final JsonObject expectedResponse = new JsonObject(FileReader.readText("first-response.json"));
final ClientRequest request = new ClientRequest()
.setParams(MultiMap.caseInsensitiveMultiMap().add("dynamicValue", "first"));
// when
Single<ClientResponse> result =
clientFacade.process(payloadMessage("/services/mock/{param.dynamicValue}.json", request),
HttpMethod.GET);
// then
result
.doOnSuccess(response -> {
context.assertEquals(HttpResponseStatus.OK.code(), response.getStatusCode());
context.assertEquals(expectedResponse, response.getBody().toJsonObject());
Mockito.verify(mockedWebClient, Mockito.times(1))
.request(HttpMethod.GET, PORT, DOMAIN, REQUEST_PATH);
})
.subscribe(
response -> async.complete(),
error -> context.fail(error.getMessage())
);
}
开发者ID:Cognifide,项目名称:knotx,代码行数:32,代码来源:HttpClientFacadeTest.java
示例20: whenUnsupportedPathServiceRequested_expectNoServiceRequestAndBadRequest
import io.vertx.reactivex.ext.web.client.WebClient; //导入依赖的package包/类
@Test
@KnotxConfiguration("knotx-service-adapter-http-test.json")
public void whenUnsupportedPathServiceRequested_expectNoServiceRequestAndBadRequest(
TestContext context) throws Exception {
Async async = context.async();
// given
final WebClient mockedWebClient = PowerMockito.spy(webClient());
HttpClientFacade clientFacade = new HttpClientFacade(mockedWebClient,
getConfiguration());
// when
Single<ClientResponse> result =
clientFacade
.process(payloadMessage("/not/supported/path", new ClientRequest()), HttpMethod.GET);
// then
result
.doOnError(error -> {
context.assertEquals(UnsupportedServiceException.class, error.getClass());
Mockito.verify(mockedWebClient, Mockito.times(0))
.request(Matchers.any(), Matchers.anyInt(), Matchers.anyString(),
Matchers.anyString());
})
.subscribe(
response -> context.fail("Error should occur!"),
error -> async.complete()
);
}
开发者ID:Cognifide,项目名称:knotx,代码行数:29,代码来源:HttpClientFacadeTest.java
注:本文中的io.vertx.reactivex.ext.web.client.WebClient类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论