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

Response.getResponseBody介绍

[英]Return the entire response body as a String.
[中]将整个响应主体作为字符串返回。

代码示例

代码示例来源：origin: alibaba/nacos

@Override
  public Integer onCompleted(Response response) throws Exception {
    if (response.getStatusCode() != HttpURLConnection.HTTP_OK) {
      Loggers.RAFT.error("[NACOS-RAFT] get peer failed: {}, peer: {}",
        response.getResponseBody(), peer.ip);
      peer.state = RaftPeer.State.FOLLOWER;
      return 1;
    }
    update(JSON.parseObject(response.getResponseBody(), RaftPeer.class));
    return 0;
  }
});

代码示例来源：origin: HubSpot/Singularity

throw new WebApplicationException(response.getResponseBody(Charsets.UTF_8.toString()), response.getStatusCode());
} else {
 return objectMapper.readValue(response.getResponseBodyAsStream(), clazz);

代码示例来源：origin: alibaba/nacos

@Override
  public Integer onCompleted(Response response) throws Exception {
    if (response.getStatusCode() != HttpURLConnection.HTTP_OK) {
      Loggers.RAFT.error("NACOS-RAFT vote failed: {}, url: {}", response.getResponseBody(), url);
      return 1;
    }
    RaftPeer peer = JSON.parseObject(response.getResponseBody(), RaftPeer.class);
    Loggers.RAFT.info("received approve from peer: {}", JSON.toJSONString(peer));
    peers.decideLeader(peer);
    return 0;
  }
});

代码示例来源：origin: alibaba/nacos

@Override
public Integer onCompleted(Response response) throws Exception {
  if (response.getStatusCode() != HttpURLConnection.HTTP_OK) {
    Loggers.RAFT.error("NACOS-RAFT beat failed: {}, peer: {}",
      response.getResponseBody(), server);
    MetricsMonitor.getLeaderSendBeatFailedException().increment();
    return 1;
  }
  peers.update(JSON.parseObject(response.getResponseBody(), RaftPeer.class));
  Loggers.RAFT.info("receive beat response from: {}", url);
  return 0;
}

代码示例来源：origin: stackoverflow.com

static CompletableFuture<Integer> AccessTheWebAsyncNio(){
  final AsyncHttpClient asyncHttpClient = new AsyncHttpClient();
  final CompletableFuture<Integer> promise = new CompletableFuture<>();
  asyncHttpClient
    .prepareGet("https://msdn.microsoft.com")
    .execute(new AsyncCompletionHandler<Response>(){
      @Override
      public Response onCompleted(Response resp) throws Exception {
        promise.complete(resp.getResponseBody().length());
        return resp;
      }
    });
  return promise;
}

代码示例来源：origin: alibaba/nacos

List<Datum> datumList = JSON.parseObject(response.getResponseBody(), new TypeReference<List<Datum>>() {
});

代码示例来源：origin: apache/incubator-pinot

@Override
 public BrokerResponse get(long timeout, TimeUnit unit)
   throws ExecutionException {
  try {
   LOGGER.debug("Sending query {} to {}", _query, _url);
   Response httpResponse = _response.get(timeout, unit);
   LOGGER.debug("Completed query, HTTP status is {}", httpResponse.getStatusCode());
   if (httpResponse.getStatusCode() != 200) {
    throw new PinotClientException(
      "Pinot returned HTTP status " + httpResponse.getStatusCode() + ", expected 200");
   }
   String responseBody = httpResponse.getResponseBody();
   return BrokerResponse.fromJson(OBJECT_READER.readTree(responseBody));
  } catch (Exception e) {
   throw new ExecutionException(e);
  }
 }
}

代码示例来源：origin: com.ning/async-http-client

public String getResponseBody(String charset) throws IOException {
  return response.getResponseBody(charset);
}

代码示例来源：origin: com.ning/async-http-client

public String getResponseBody() throws IOException {
  return response.getResponseBody();
}

代码示例来源：origin: HubSpot/Singularity

@Override
public Response onCompleted(Response response) throws Exception {
 LOG.trace("Webhook {} for {} completed with {} after {}", webhook.getUri(), update, response.getStatusCode(), JavaUtils.duration(start));
 if (response.hasResponseBody()) {
  LOG.trace("Webhook response message is: '{}'", response.getResponseBody());
 }
 if (JavaUtils.isHttpSuccess(response.getStatusCode()) || shouldDeleteUpdateOnFailure) {
  deleteWebhookUpdate();
 }
 if (completableFuture != null) {
  completableFuture.complete(response);
 }
 return response;
}

代码示例来源：origin: HubSpot/Singularity

private SingularityUserPermissionsResponse verifyUncached(String authHeaderValue) {
  try {
   Response response = asyncHttpClient.prepareGet(webhookAuthConfiguration.getAuthVerificationUrl())
     .addHeader("Authorization", authHeaderValue)
     .execute()
     .get();
   if (response.getStatusCode() > 299) {
    throw WebExceptions.unauthorized(String.format("Got status code %d when verifying jwt", response.getStatusCode()));
   } else {
    String responseBody = response.getResponseBody();
    SingularityUserPermissionsResponse permissionsResponse = objectMapper.readValue(responseBody, SingularityUserPermissionsResponse.class);
    if (!permissionsResponse.getUser().isPresent()) {
     throw WebExceptions.unauthorized(String.format("No user present in response %s", permissionsResponse));
    }
    if (!permissionsResponse.getUser().get().isAuthenticated()) {
     throw WebExceptions.unauthorized(String.format("User not authenticated (response: %s)", permissionsResponse));
    }
    permissionsCache.put(authHeaderValue, permissionsResponse);
    return permissionsResponse;
   }
  } catch (Throwable t) {
   throw new RuntimeException(t);
  }
 }
}

代码示例来源：origin: eBay/parallec

charset = ParallecGlobalConfig.httpResponseBodyDefaultCharset; 
  reply(response.getResponseBody(charset), false, null, null, statusCode,
      statusCodeInt, responseHeaders);
} catch (IOException e) {

代码示例来源：origin: com.github.mjeanroy/rest-assert-core

@Override
  protected String doGetContent() throws IOException {
    return response.getResponseBody();
  }
}

代码示例来源：origin: dhanji/sitebricks

@Override
 public String toString() {
  try {
   return response.getResponseBody();
  } catch (IOException e) {
   // TODO
   return "";
  }
 }
}

代码示例来源：origin: SeanDragon/protools

throw new HttpException("本次请求响应码不是200，是" + responseStatusCode);
String responseBody = response.getResponseBody();
if (log.isDebugEnabled()) {
  log.debug(responseBody);

代码示例来源：origin: resthub/resthub-spring-stack

/**
 * Get the response body as a string with charset as parameter
 */
public String getBody(String charset) {
  try {
    return ahcResponse.getResponseBody(charset);
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: resthub/resthub-spring-stack

@Override
  public <T> T readEntity(Response resp, TypeReference valueTypeRef, String charset) throws IOException {

    return JsonHelper.deserialize(resp.getResponseBody(charset), valueTypeRef);
  }
}

代码示例来源：origin: org.openhab.binding/org.openhab.binding.plex

@Override
public Response onCompleted(Response response) throws Exception {
  if (response.getStatusCode() != 200) {
    logger.error("Error while sending command to Plex: {}\r\n{}",
        response.getStatusText(),
        response.getResponseBody());
  }
  return response;
}

代码示例来源：origin: io.sphere/sphere-java-client

/** Serializes request and response, usually for logging or debugging purposes. */
public static String requestResponseToString(Request request, Response response) {
  try {
    return requestToString(request) + " :\n" +
        response.getStatusCode() + " " + response.getResponseBody(Charsets.UTF_8.name());
  } catch (IOException e) {
    throw toSphereException(e);
  }
}

代码示例来源：origin: nurkiewicz/rxjava-book-examples

Single<String> body(Response response) {
  return Single.create(subscriber -> {
    try {
      subscriber.onSuccess(response.getResponseBody());
    } catch (IOException e) {
      subscriber.onError(e);
    }
  });
}