feign.Util.toByteArray()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(8.0k)|赞(0)|评价(0)|浏览(141)

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

Util.toByteArray介绍

[英]Adapted from com.google.common.io.ByteStreams.toByteArray().
[中]

代码示例

代码示例来源：origin: com.marvinformatics.feign/feign-mock

  1. public MockClient add(RequestKey requestKey, int status, InputStream responseBody) throws IOException {
  2.   return add(requestKey, status, Util.toByteArray(responseBody));
  3. }

代码示例来源：origin: com.marvinformatics.feign/feign-mock

  1. public MockClient ok(RequestKey requestKey, InputStream responseBody) throws IOException {
  2.   return ok(requestKey, Util.toByteArray(responseBody));
  3. }

代码示例来源：origin: palantir/conjure-java-runtime

  1. @Override
  2.   public void encode(Object object, Type bodyType, RequestTemplate template) throws EncodeException {
  3.     if (bodyType.equals(InputStream.class)) {
  4.       try {
  5.         template.body(Util.toByteArray((InputStream) object), StandardCharsets.UTF_8);
  6.       } catch (IOException e) {
  7.         throw new RuntimeException(e);
  8.       }
  9.     } else {
  10.       delegate.encode(object, bodyType, template);
  11.     }
  12.   }
  13. }

代码示例来源：origin: com.palantir.conjure.java.runtime/conjure-java-jaxrs-client

  1. @Override
  2.   public void encode(Object object, Type bodyType, RequestTemplate template) throws EncodeException {
  3.     if (bodyType.equals(InputStream.class)) {
  4.       try {
  5.         template.body(Util.toByteArray((InputStream) object), StandardCharsets.UTF_8);
  6.       } catch (IOException e) {
  7.         throw new RuntimeException(e);
  8.       }
  9.     } else {
  10.       delegate.encode(object, bodyType, template);
  11.     }
  12.   }
  13. }

代码示例来源：origin: com.palantir.remoting3/jaxrs-clients

  1. @Override
  2.   public void encode(Object object, Type bodyType, RequestTemplate template) throws EncodeException {
  3.     if (bodyType.equals(InputStream.class)) {
  4.       try {
  5.         template.body(Util.toByteArray((InputStream) object), StandardCharsets.UTF_8);
  6.       } catch (IOException e) {
  7.         throw new RuntimeException(e);
  8.       }
  9.     } else {
  10.       delegate.encode(object, bodyType, template);
  11.     }
  12.   }
  13. }

代码示例来源：origin: com.palantir.remoting/feign-config

  1. @Override
  2.   public void encode(Object object, Type bodyType, RequestTemplate template) throws EncodeException {
  3.     if (bodyType.equals(InputStream.class)) {
  4.       try {
  5.         template.body(Util.toByteArray((InputStream) object), StandardCharsets.UTF_8);
  6.       } catch (IOException e) {
  7.         throw new RuntimeException(e);
  8.       }
  9.     } else {
  10.       delegate.encode(object, bodyType, template);
  11.     }
  12.   }
  13. }

代码示例来源：origin: com.palantir.remoting/feign-config

  1. @Override
  2.   public Object decode(Response response, Type type) throws IOException, FeignException {
  3.     if (type.equals(InputStream.class)) {
  4.       byte[] body = Util.toByteArray(response.body().asInputStream());
  5.       return new ByteArrayInputStream(body);
  6.     } else {
  7.       return delegate.decode(response, type);
  8.     }
  9.   }
  10. }

代码示例来源：origin: palantir/conjure-java-runtime

  1. @Override
  2. public String readInputStream(InputStream data) {
  3.   try {
  4.     return new String(Util.toByteArray(data), StandardCharsets.UTF_8);
  5.   } catch (IOException e) {
  6.     throw new RuntimeException(e);
  7.   }
  8. }

代码示例来源：origin: palantir/conjure-java-runtime

  1. @Override
  2. public String readInputStream(InputStream data) {
  3.   try {
  4.     return new String(Util.toByteArray(data), StandardCharsets.UTF_8);
  5.   } catch (IOException e) {
  6.     throw new RuntimeException(e);
  7.   }
  8. }

代码示例来源：origin: com.palantir.conjure.java.runtime/conjure-java-jaxrs-client

  1. @Override
  2.   public Object decode(Response response, Type type) throws IOException, FeignException {
  3.     if (type.equals(InputStream.class)) {
  4.       byte[] body = response.body() != null ? Util.toByteArray(response.body().asInputStream()) : new byte[0];
  5.       return new ByteArrayInputStream(body);
  6.     } else {
  7.       return delegate.decode(response, type);
  8.     }
  9.   }
  10. }

代码示例来源：origin: palantir/conjure-java-runtime

  1. @Override
  2.   public Object decode(Response response, Type type) throws IOException, FeignException {
  3.     if (type.equals(InputStream.class)) {
  4.       byte[] body = response.body() != null ? Util.toByteArray(response.body().asInputStream()) : new byte[0];
  5.       return new ByteArrayInputStream(body);
  6.     } else {
  7.       return delegate.decode(response, type);
  8.     }
  9.   }
  10. }

代码示例来源：origin: com.palantir.remoting3/jaxrs-clients

  1. @Override
  2.   public Object decode(Response response, Type type) throws IOException, FeignException {
  3.     if (type.equals(InputStream.class)) {
  4.       byte[] body = response.body() != null ? Util.toByteArray(response.body().asInputStream()) : new byte[0];
  5.       return new ByteArrayInputStream(body);
  6.     } else {
  7.       return delegate.decode(response, type);
  8.     }
  9.   }
  10. }

代码示例来源：origin: com.netflix.feign/feign-core

  1. @Override
  2.  public Object decode(Response response, Type type) throws IOException {
  3.   if (response.status() == 404) return Util.emptyValueOf(type);
  4.   if (response.body() == null) return null;
  5.   if (byte[].class.equals(type)) {
  6.    return Util.toByteArray(response.body().asInputStream());
  7.   }
  8.   return super.decode(response, type);
  9.  }
  10. }

代码示例来源：origin: palantir/conjure-java-runtime

  1. @Test
  2. public void testDecodesAsInputStream() throws Exception {
  3.   String data = "data";
  4.   Response response = Response.create(200, "OK", ImmutableMap.of(), data, StandardCharsets.UTF_8);
  5.   InputStream decoded = (InputStream) inputStreamDelegateDecoder.decode(response, InputStream.class);
  6.   assertThat(new String(Util.toByteArray(decoded), StandardCharsets.UTF_8), is(data));
  7. }

代码示例来源：origin: palantir/conjure-java-runtime

  1. @Test
  2. public void testSupportsNullBody() throws Exception {
  3.   String data = "";
  4.   Response response = Response.create(200, "OK", ImmutableMap.of(), (Response.Body) null);
  5.   InputStream decoded = (InputStream) inputStreamDelegateDecoder.decode(response, InputStream.class);
  6.   assertThat(new String(Util.toByteArray(decoded), StandardCharsets.UTF_8), is(data));
  7. }

代码示例来源：origin: coveo/feign-error-decoder

  1. if (response.body() != null) {
  2.  try {
  3.   byte[] bodyData = Util.toByteArray(response.body().asInputStream());
  4.   responseCopy = responseCopy.toBuilder().body(bodyData).build();
  5.   T apiResponse = (T) decoder.decode(responseCopy, apiResponseClass);

代码示例来源：origin: palantir/conjure-java-runtime

  1. @Test
  2. public void testStandardClientsUseInputStreamDelegateDecoder() throws IOException {
  3.   String data = "bytes";
  4.   assertThat(Util.toByteArray(service.writeInputStream(data)), is(bytes(data)));
  5. }

代码示例来源：origin: palantir/conjure-java-runtime

  1. @Test
  2. public void testClientCanHandleEmptyInputStream() throws IOException {
  3.   String data = "";
  4.   assertThat(Util.toByteArray(service.writeInputStream(data)), is(bytes(data)));
  5. }

代码示例来源：origin: com.ofg/micro-infra-spring-base

  1. @Override
  2. protected Response logAndRebufferResponse(String configKey, feign.Logger.Level logLevel, Response response,
  3.                      long elapsedTime) throws IOException {
  4.   String requestId = requestIdProvider.getRequestId();
  5.   HttpData reqData = requestDataProvider.retrieve(requestId);
  6.   if (requestTraceable(reqData) && isNotSkipped(reqData)) {
  7.     byte[] bodyData = Util.toByteArray(response.body().asInputStream());
  8.     String content = new String(bodyData, StandardCharsets.UTF_8.name());
  9.     HttpData resData = new HttpData(extractHeaders(response), extractStatus(response), content);
  10.     Response rebufferedResponse = Response.create(response.status(), response.reason(), response.headers(),
  11.         bodyData);
  12.     requestResponseLogger.logObfuscatedResponse(reqData, resData, TAG);
  13.     requestDataProvider.remove(requestId);
  14.     return super.logAndRebufferResponse(configKey, logLevel, rebufferedResponse, elapsedTime);
  15.   } else {
  16.     log.debug("Cannot obfuscate response, matching request data lost");
  17.     return super.logAndRebufferResponse(configKey, logLevel, response, elapsedTime);
  18.   }
  19. }

代码示例来源：origin: com.netflix.feign/feign-core

  1. protected Response logAndRebufferResponse(String configKey, Level logLevel, Response response,
  2.                      long elapsedTime) throws IOException {
  3.  String reason = response.reason() != null && logLevel.compareTo(Level.NONE) > 0 ?
  4.    " " + response.reason() : "";
  5.  log(configKey, "<--- HTTP/1.1 %s%s (%sms)", response.status(), reason, elapsedTime);
  6.  if (logLevel.ordinal() >= Level.HEADERS.ordinal()) {
  7.   for (String field : response.headers().keySet()) {
  8.    for (String value : valuesOrEmpty(response.headers(), field)) {
  9.     log(configKey, "%s: %s", field, value);
  10.    }
  11.   }
  12.   int bodyLength = 0;
  13.   if (response.body() != null) {
  14.    if (logLevel.ordinal() >= Level.FULL.ordinal()) {
  15.     log(configKey, ""); // CRLF
  16.    }
  17.    byte[] bodyData = Util.toByteArray(response.body().asInputStream());
  18.    bodyLength = bodyData.length;
  19.    if (logLevel.ordinal() >= Level.FULL.ordinal() && bodyLength > 0) {
  20.     log(configKey, "%s", decodeOrDefault(bodyData, UTF_8, "Binary data"));
  21.    }
  22.    log(configKey, "<--- END HTTP (%s-byte body)", bodyLength);
  23.    return Response.create(response.status(), response.reason(), response.headers(), bodyData);
  24.   } else {
  25.    log(configKey, "<--- END HTTP (%s-byte body)", bodyLength);
  26.   }
  27.  }
  28.  return response;
  29. }

内容来源于网络，如有侵权，请联系作者删除！

Util

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com