feign.Request.headers()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(7.4k)|赞(0)|评价(0)|浏览(281)

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

Request.headers介绍

暂无

代码示例

代码示例来源：origin: liuyangming/ByteTCC

  1. private String getHeaderValue(Request req, String headerName) {
  2.   Map<String, Collection<String>> headers = req.headers();
  3.   Collection<String> values = headers.get(headerName);
  4.   String value = null;
  5.   if (values != null && values.isEmpty() == false) {
  6.     String[] array = new String[values.size()];
  7.     values.toArray(array);
  8.     value = array[0];
  9.   }
  10.   return value;
  11. }

代码示例来源：origin: liuyangming/ByteTCC

  1. private String getHeaderValue(Request req, String headerName) {
  2.   Map<String, Collection<String>> headers = req.headers();
  3.   Collection<String> values = headers.get(headerName);
  4.   String value = null;
  5.   if (values != null && values.isEmpty() == false) {
  6.     String[] array = new String[values.size()];
  7.     values.toArray(array);
  8.     value = array[0];
  9.   }
  10.   return value;
  11. }

代码示例来源：origin: spring-cloud/spring-cloud-sleuth

  1. @Override
  2. public String requestHeader(Request request, String name) {
  3.   Collection<String> result = request.headers().get(name);
  4.   return result != null && result.iterator().hasNext()
  5.       ? result.iterator().next() : null;
  6. }

代码示例来源：origin: spring-cloud-incubator/spring-cloud-alibaba

  1. private Request getModifyRequest(Request request) {
  2.   String xid = RootContext.getXID();
  3.   if (StringUtils.isEmpty(xid)) {
  4.     return request;
  5.   }
  6.   Map<String, Collection<String>> headers = new HashMap<>();
  7.   headers.putAll(request.headers());
  8.   List<String> fescarXid = new ArrayList<>();
  9.   fescarXid.add(xid);
  10.   headers.put(RootContext.KEY_XID, fescarXid);
  11.   return Request.create(request.method(), request.url(), headers, request.body(),
  12.       request.charset());
  13. }

代码示例来源：origin: spring-cloud/spring-cloud-sleuth

  1. @Override
  2. public Response execute(Request request, Request.Options options) throws IOException {
  3.   Map<String, Collection<String>> headers = new HashMap<>(request.headers());
  4.   Span span = handleSend(headers, request, null);
  5.   if (log.isDebugEnabled()) {
  6.     log.debug("Handled send of " + span);
  7.   }
  8.   Response response = null;
  9.   Throwable error = null;
  10.   try (Tracer.SpanInScope ws = this.tracer.withSpanInScope(span)) {
  11.     return response = this.delegate.execute(modifiedRequest(request, headers),
  12.         options);
  13.   }
  14.   catch (IOException | RuntimeException | Error e) {
  15.     error = e;
  16.     throw e;
  17.   }
  18.   finally {
  19.     handleReceive(span, response, error);
  20.     if (log.isDebugEnabled()) {
  21.       log.debug("Handled receive of " + span);
  22.     }
  23.   }
  24. }

代码示例来源：origin: spring-cloud/spring-cloud-sleuth

  1. new HashMap<>(request.headers()), request, fallbackSpan);
  2. tracingFeignClient().handleReceive(fallbackSpan, response, e);

代码示例来源：origin: wso2/msf4j

  1. @Override
  2. public void addHeader(String header, String value) {
  3.   Collection<String> existingValues = request.headers().get(header);
  4.   if (existingValues == null) {
  5.     existingValues = new ArrayList<>();
  6.   }
  7.   existingValues.add(value);
  8.   request.headers().put(header, existingValues);
  9. }

代码示例来源：origin: spring-cloud/spring-cloud-zookeeper

  1. private Map<String, Collection<String>> getUpdatedHeadersIfPossible(
  2.     Request request, ZookeeperDependency dependencyForAlias) {
  3.   if (dependencyForAlias != null) {
  4.     return Collections.unmodifiableMap(new HashMap<>(
  5.         dependencyForAlias.getUpdatedHeaders(request.headers())));
  6.   }
  7.   return request.headers();
  8. }

代码示例来源：origin: liuyangming/ByteJTA

  1. private String getHeaderValue(Request req, String headerName) {
  2.   Map<String, Collection<String>> headers = req.headers();
  3.   Collection<String> values = headers.get(headerName);
  4.   String value = null;
  5.   if (values != null && values.isEmpty() == false) {
  6.     String[] array = new String[values.size()];
  7.     values.toArray(array);
  8.     value = array[0];
  9.   }
  10.   return value;
  11. }

代码示例来源：origin: org.springframework.cloud/spring-cloud-sleuth-core

  1. @Override
  2. public String requestHeader(Request request, String name) {
  3.   Collection<String> result = request.headers().get(name);
  4.   return result != null && result.iterator().hasNext()
  5.       ? result.iterator().next() : null;
  6. }

代码示例来源：origin: liuyangming/ByteJTA

  1. private String getHeaderValue(Request req, String headerName) {
  2.   Map<String, Collection<String>> headers = req.headers();
  3.   Collection<String> values = headers.get(headerName);
  4.   String value = null;
  5.   if (values != null && values.isEmpty() == false) {
  6.     String[] array = new String[values.size()];
  7.     values.toArray(array);
  8.     value = array[0];
  9.   }
  10.   return value;
  11. }

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

  1. static Map<String, String> extractHeaders(Request request) {
  2.   return request.headers().entrySet().stream().collect(Collectors.toMap(
  3.       e -> e.getKey(),
  4.       e -> StringUtils.collectionToCommaDelimitedString(e.getValue())
  5.   ));
  6. }

代码示例来源：origin: spring-cloud/spring-cloud-openfeign

  1. @Override
  2.   public HttpHeaders getHeaders() {
  3.     Map<String, List<String>> headers = new HashMap<>();
  4.     Map<String, Collection<String>> feignHeaders = RibbonRequest.this.toRequest().headers();
  5.     for(String key : feignHeaders.keySet()) {
  6.       headers.put(key, new ArrayList<String>(feignHeaders.get(key)));
  7.     }
  8.     HttpHeaders httpHeaders = new HttpHeaders();
  9.     httpHeaders.putAll(headers);
  10.     return httpHeaders;
  11.   }
  12. };

代码示例来源：origin: org.springframework.cloud/spring-cloud-openfeign-core

  1. @Override
  2.   public HttpHeaders getHeaders() {
  3.     Map<String, List<String>> headers = new HashMap<>();
  4.     Map<String, Collection<String>> feignHeaders = RibbonRequest.this.toRequest().headers();
  5.     for(String key : feignHeaders.keySet()) {
  6.       headers.put(key, new ArrayList<String>(feignHeaders.get(key)));
  7.     }
  8.     HttpHeaders httpHeaders = new HttpHeaders();
  9.     httpHeaders.putAll(headers);
  10.     return httpHeaders;
  11.   }
  12. };

代码示例来源：origin: org.springframework.cloud/spring-cloud-openfeign-core

  1. private Request toRequest(Request request) {
  2.   Map<String, Collection<String>> headers = new LinkedHashMap<>(
  3.       request.headers());
  4.   return Request.create(request.httpMethod(), getUri().toASCIIString(), headers,
  5.       request.requestBody());
  6. }

代码示例来源：origin: spring-cloud/spring-cloud-openfeign

  1. private Request toRequest(Request request) {
  2.   Map<String, Collection<String>> headers = new LinkedHashMap<>(
  3.       request.headers());
  4.   return Request.create(request.httpMethod(), getUri().toASCIIString(), headers,
  5.       request.requestBody());
  6. }

代码示例来源：origin: wso2/msf4j

  1. private Request tracePreRequest(Request request, TraceEvent traceEvent) {
  2.   // set tracing headers to HTTP request
  3.   Map<String, Collection<String>> traceHeaders = new HashMap<>();
  4.   traceHeaders.putAll(request.headers());
  5.   traceHeaders.put(TracingConstants.TRACE_ID_HEADER, Collections.singletonList(traceEvent.getTraceId()));
  6.   traceHeaders.put(TracingConstants.TRACE_ORIGIN_ID_HEADER, Collections.singletonList(traceEvent.getOriginId()));
  7.   // publish event to DAS
  8.   TracingUtil.pushToDAS(traceEvent, dasUrl);
  9.   return Request.create(request.method(), request.url(), traceHeaders, request.body(), request.charset());
  10. }

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

  1. private RequestKey(Request request) {
  2.   this.method = HttpMethod.valueOf(request.method());
  3.   this.url = buildUrl(request);
  4.   this.headers = request.headers();
  5.   this.charset = request.charset();
  6.   this.body = request.body();
  7. }

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

  1. Request toRequest() {
  2.  return new RequestTemplate()
  3.    .method(request.method())
  4.    .append(getUri().toASCIIString())
  5.    .headers(request.headers())
  6.    .body(request.body(), request.charset())
  7.    .request();
  8. }

代码示例来源：origin: bbilger/jrestless

  1. @Test
  2. public void execute_NullRequestHeadersGiven_ShouldRequestWithEmptyHeaders() throws IOException {
  3.   FeignLambdaClientImpl client = new FeignLambdaClientImpl(serviceResponse);
  4.   when(feignRequest.headers()).thenReturn(null);
  5.   client.execute(feignRequest, null);
  6.   assertEquals(Collections.emptyMap(), client.getServiceRequest().getHeaders());
  7. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

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