实现java非阻塞http请求的两种方式

public voidokhttp() {
    Request request = newRequest.Builder()
        .url()
        .post(RequestBody.create(MediaType.parse("application/json"), content))
        .build();

      OkHttpClient client = newOkHttpClient.Builder()
          .connectionPool(new ConnectionPool(50, 5, TimeUnit.MINUTES))
          .readTimeout(5, TimeUnit.SECONDS)
          .connectTimeout(5, TimeUnit.SECONDS)
          .build();

      client.newCall(request).enqueue(newCallback() {
        @Override
        public voidonFailure(Call call, IOException e) {
          log.info("error:" +e.toString());
        }

        @Override
        public void onResponse(Call call, Response response) throwsIOException {
          log.info("success:" +response.body().string());
        }
      });
  }

public static Mono<String>webClient(){
        ReactorClientHttpConnector connector = newReactorClientHttpConnector(
                options -> options.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 3000)
                        .compression(true)
                        .afterNettyContextInit(ctx ->{
                            ctx.addHandlerLast(new ReadTimeoutHandler(3000, TimeUnit.MILLISECONDS));
                        }));

        WebClient client =WebClient.builder()
                    .defaultHeader(HttpHeaders.CONTENT_TYPE, API_MIME_TYPE)
                    .defaultHeader(HttpHeaders.USER_AGENT, USER_AGENT)
                    .clientConnector(connector)
                    .build();
　　　　 returnclient.get()
                .uri()
                .retrieve()
                .bodyToMono(String.class)
                .doOnError(e -> logger.info("error:" +e))
                .doOnSuccess(result -> logger.info("result" +result));
    }