org.wso2.msf4j.Request.getHeader()方法的使用及代码示例

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

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

Request.getHeader介绍

[英]Get an HTTP header of the HTTP request.
[中]获取HTTP请求的HTTP头。

代码示例

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

  1. @Override
  2. public String getHttpHeaderValue(String headerName) {
  3.   return req.getHeader(headerName);
  4. }

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. /**
  2.  * Get the request's content type.
  3.  *
  4.  * @return String request's content type
  5.  */
  6. public String getContentType() {
  7.   return this.request.getHeader("Content-Type");
  8. }

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

  1. /**
  2.  * Get the request's content type.
  3.  *
  4.  * @return String request's content type
  5.  */
  6. public String getContentType() {
  7.   return this.request.getHeader("Content-Type");
  8. }

代码示例来源：origin: org.wso2.carbon.auth/org.wso2.carbon.auth.rest.api.authenticators

  1. private String getAuthenticationType(Request request) {
  2.   String header = request.getHeader(RestAPIConstants.AUTHORIZATION);
  3.   if (StringUtils.isNotEmpty(header)) {
  4.     if (header.contains("Basic")) {
  5.       return RestAPIConstants.AUTH_TYPE_BASIC;
  6.     } else if (header.contains("Bearer")) {
  7.       return RestAPIConstants.AUTH_TYPE_OAUTH2;
  8.     }
  9.   }
  10.   return null;
  11. }

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. private void setBaseUri(Request request) {
  2.   StringBuilder builder = new StringBuilder();
  3.   builder.append(request.getProperty(Constants.PROTOCOL).toString().toLowerCase(Locale.US)).append("://")
  4.       .append(request.getHeader(HttpHeaderNames.HOST.toString()));
  5.   if (builder.charAt(builder.length() - 1) != '/') {
  6.     builder.append("/");
  7.   }
  8.   try {
  9.     MSF4JResponse.setBaseUri(new URI(builder.toString()));
  10.   } catch (URISyntaxException e) {
  11.     log.error("Error while setting the Base URI. " + e.getMessage(), e);
  12.   }
  13. }

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

  1. private void setBaseUri(Request request) {
  2.   StringBuilder builder = new StringBuilder();
  3.   builder.append(request.getProperty(Constants.PROTOCOL).toString().toLowerCase(Locale.US)).append("://")
  4.       .append(request.getHeader(HttpHeaderNames.HOST.toString()));
  5.   if (builder.charAt(builder.length() - 1) != '/') {
  6.     builder.append("/");
  7.   }
  8.   try {
  9.     MSF4JResponse.setBaseUri(new URI(builder.toString()));
  10.   } catch (URISyntaxException e) {
  11.     log.error("Error while setting the Base URI. " + e.getMessage(), e);
  12.   }
  13. }

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. @SuppressWarnings("unchecked")
  2. private Object getCookieParamValue(HttpResourceModel.ParameterInfo<String> info, Request request) {
  3.   CookieParam cookieParam = info.getAnnotation();
  4.   String cookieName = cookieParam.value();
  5.   String cookieHeader = request.getHeader("Cookie");
  6.   if (cookieHeader != null) {
  7.     String cookieValue = Arrays.stream(cookieHeader.split(";"))
  8.         .filter(cookie -> cookie.startsWith(cookieName + "="))
  9.         .findFirst()
  10.         .map(cookie -> cookie.substring((cookieName + "=").length()))
  11.         .orElseGet(info::getDefaultVal);
  12.     return info.convert(cookieValue);
  13.   }
  14.   return null;
  15. }

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

  1. @SuppressWarnings("unchecked")
  2. private Object getCookieParamValue(HttpResourceModel.ParameterInfo<String> info, Request request) {
  3.   CookieParam cookieParam = info.getAnnotation();
  4.   String cookieName = cookieParam.value();
  5.   String cookieHeader = request.getHeader("Cookie");
  6.   if (cookieHeader != null) {
  7.     String cookieValue = Arrays.stream(cookieHeader.split(";"))
  8.         .filter(cookie -> cookie.startsWith(cookieName + "="))
  9.         .findFirst()
  10.         .map(cookie -> cookie.substring((cookieName + "=").length()))
  11.         .orElseGet(info::getDefaultVal);
  12.     return info.convert(cookieValue);
  13.   }
  14.   return null;
  15. }

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

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   String authHeader = request.getHeader(javax.ws.rs.core.HttpHeaders.AUTHORIZATION);
  4.   if (authHeader != null) {
  5.     String authType = authHeader.substring(0, AUTH_TYPE_BASIC_LENGTH);
  6.     String authEncoded = authHeader.substring(AUTH_TYPE_BASIC_LENGTH).trim();
  7.     if (AUTH_TYPE_BASIC.equals(authType) && !authEncoded.isEmpty()) {
  8.       byte[] decodedByte = authEncoded.getBytes(Charset.forName(CHARSET_UTF_8));
  9.       String authDecoded = new String(Base64.getDecoder().decode(decodedByte),
  10.           Charset.forName(CHARSET_UTF_8));
  11.       String[] authParts = authDecoded.split(":");
  12.       String username = authParts[0];
  13.       String password = authParts[1];
  14.       if (authenticate(username, password)) {
  15.         return true;
  16.       }
  17.     }
  18.   }
  19.   response.setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode());
  20.   response.setHeader(javax.ws.rs.core.HttpHeaders.WWW_AUTHENTICATE, AUTH_TYPE_BASIC);
  21.   return false;
  22. }

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   String authHeader = request.getHeader(javax.ws.rs.core.HttpHeaders.AUTHORIZATION);
  4.   if (authHeader != null) {
  5.     String authType = authHeader.substring(0, AUTH_TYPE_BASIC_LENGTH);
  6.     String authEncoded = authHeader.substring(AUTH_TYPE_BASIC_LENGTH).trim();
  7.     if (AUTH_TYPE_BASIC.equals(authType) && !authEncoded.isEmpty()) {
  8.       byte[] decodedByte = authEncoded.getBytes(Charset.forName(CHARSET_UTF_8));
  9.       String authDecoded = new String(Base64.getDecoder().decode(decodedByte),
  10.           Charset.forName(CHARSET_UTF_8));
  11.       String[] authParts = authDecoded.split(":");
  12.       String username = authParts[0];
  13.       String password = authParts[1];
  14.       if (authenticate(username, password)) {
  15.         return true;
  16.       }
  17.     }
  18.   }
  19.   response.setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode());
  20.   response.setHeader(javax.ws.rs.core.HttpHeaders.WWW_AUTHENTICATE, AUTH_TYPE_BASIC);
  21.   return false;
  22. }

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

  1. @Override
  2.   public void postCall(Request request, int status, ServiceMethodInfo serviceMethodInfo) {
  3.     numPostCalls.incrementAndGet();
  4.     String header = request.getHeader("X-Request-Type");
  5.     if (header != null && header.equals("PostException")) {
  6.       throw new IllegalArgumentException("PostException");
  7.     }
  8.   }
  9. }

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

  1. /**
  2.  * Returns the current session associated with this request, or if the request does not have a session,
  3.  * creates one.
  4.  *
  5.  * @return Session
  6.  */
  7. public Session getSession() {
  8.   if (sessionManager == null) {
  9.     throw new IllegalStateException("SessionManager has not been set");
  10.   }
  11.   if (session != null) {
  12.     return session.setAccessed();
  13.   }
  14.   String cookieHeader = getHeader("Cookie");
  15.   if (cookieHeader != null) {
  16.     session = Arrays.stream(cookieHeader.split(";")).map(String::trim)
  17.         .filter(cookie -> cookie.startsWith(MSF4JConstants.SESSION_ID))
  18.         .findFirst()
  19.         .map(jsession -> sessionManager.getSession(jsession.substring(MSF4JConstants.SESSION_ID.length())))
  20.         .orElseGet(sessionManager::createSession);
  21.     return session.setAccessed();
  22.   }
  23.   return session = sessionManager.createSession();
  24. }

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   log.info("Authentication precall");
  4.   boolean isValidSignature;
  5.   String jwtHeader = request.getHeader(JWT_HEADER);
  6.   if (jwtHeader != null) {
  7.     isValidSignature = verifySignature(jwtHeader);
  8.     if (isValidSignature) {
  9.       return true;
  10.     }
  11.   }
  12.   response.setHeader(javax.ws.rs.core.HttpHeaders.WWW_AUTHENTICATE, AUTH_TYPE_JWT);
  13.   response.setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode());
  14.   return false;
  15. }

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

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   log.info("Authentication precall");
  4.   boolean isValidSignature;
  5.   String jwtHeader = request.getHeader(JWT_HEADER);
  6.   if (jwtHeader != null) {
  7.     isValidSignature = verifySignature(jwtHeader);
  8.     if (isValidSignature) {
  9.       return true;
  10.     }
  11.   }
  12.   response.setHeader(javax.ws.rs.core.HttpHeaders.WWW_AUTHENTICATE, AUTH_TYPE_JWT);
  13.   response.setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode());
  14.   return false;
  15. }

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

  1. private void handleTracing(Request request, HTTPMonitoringEvent httpMonitoringEvent) {
  2.   String traceId, parentRequest;
  3.   if (this.isTracing()) {
  4.     traceId = request.getHeader(ACTIVITY_ID);
  5.     if (traceId == null) {
  6.       traceId = this.generateTraceId();
  7.     }
  8.     parentRequest = request.getHeader(PARENT_REQUEST);
  9.   } else {
  10.     traceId = DEFAULT_TRACE_ID;
  11.     parentRequest = DEFAULT_PARENT_REQUEST;
  12.   }
  13.   httpMonitoringEvent.setActivityId(traceId);
  14.   httpMonitoringEvent.setParentRequest(parentRequest);
  15. }

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. @SuppressWarnings("unchecked")
  2. private Object getHeaderParamValue(HttpResourceModel.ParameterInfo<List<String>> info, Request request) {
  3.   HeaderParam headerParam = info.getAnnotation();
  4.   String headerName = headerParam.value();
  5.   String header = request.getHeader(headerName);
  6.   if (header == null || header.isEmpty()) {
  7.     String defaultVal = info.getDefaultVal();
  8.     if (defaultVal != null) {
  9.       header = defaultVal;
  10.     }
  11.   }
  12.   return info.convert(Collections.singletonList(header));
  13. }

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

  1. @SuppressWarnings("unchecked")
  2. private Object getHeaderParamValue(HttpResourceModel.ParameterInfo<List<String>> info, Request request) {
  3.   HeaderParam headerParam = info.getAnnotation();
  4.   String headerName = headerParam.value();
  5.   String header = request.getHeader(headerName);
  6.   if (header == null || header.isEmpty()) {
  7.     String defaultVal = info.getDefaultVal();
  8.     if (defaultVal != null) {
  9.       header = defaultVal;
  10.     }
  11.   }
  12.   return info.convert(Collections.singletonList(header));
  13. }

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

  1. @Override
  2. public boolean preCall(Request request, Response responder, ServiceMethodInfo serviceMethodInfo)
  3.     throws Exception {
  4.   numPreCalls.incrementAndGet();
  5.   String header = request.getHeader("X-Request-Type");
  6.   if (header != null && header.equals("Reject")) {
  7.     responder.setStatus(javax.ws.rs.core.Response.Status.NOT_ACCEPTABLE.getStatusCode());
  8.     responder.send();
  9.     return false;
  10.   }
  11.   if (header != null && header.equals("PreException")) {
  12.     throw new IllegalArgumentException("PreException");
  13.   }
  14.   return true;
  15. }

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

  1. /**
  2.    * Set connection header of the response object according to the
  3.    * connection header of the request.
  4.    *
  5.    * @param request  HTTP request object
  6.    * @param response HTTP response object
  7.    */
  8.   public static void setConnectionHeader(Request request, Response response) {
  9.     String connection = request.getHeader(HttpHeaderNames.CONNECTION.toString());
  10.     if (connection != null && CLOSE.equalsIgnoreCase(connection)) {
  11.       response.setHeader(HttpHeaderNames.CONNECTION.toString(), CLOSE);
  12.     } else {
  13.       response.setHeader(HttpHeaderNames.CONNECTION.toString(), KEEP_ALIVE);
  14.     }
  15.   }
  16. }

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. /**
  2.    * Set connection header of the response object according to the
  3.    * connection header of the request.
  4.    *
  5.    * @param request  HTTP request object
  6.    * @param response HTTP response object
  7.    */
  8.   public static void setConnectionHeader(Request request, Response response) {
  9.     String connection = request.getHeader(HttpHeaderNames.CONNECTION.toString());
  10.     if (connection != null && CLOSE.equalsIgnoreCase(connection)) {
  11.       response.setHeader(HttpHeaderNames.CONNECTION.toString(), CLOSE);
  12.     } else {
  13.       response.setHeader(HttpHeaderNames.CONNECTION.toString(), KEEP_ALIVE);
  14.     }
  15.   }
  16. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

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