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

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

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

Request.getUri介绍

暂无

代码示例

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

  1. @Override
  2. public URI getUri() {
  3.   return URI.create(req.getUri());
  4. }

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

  1. @Override
  2.   public boolean interceptRequest(Request request, Response response) throws Exception {
  3.     log.info("Logging HTTP request { HTTPMethod: " + request.getHttpMethod() + ", URI: " + request.getUri() + "}");
  4.     return true;
  5.   }
  6. }

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

  1. @Override
  2.   public boolean interceptRequest(Request request, Response response) throws Exception {
  3.     log.info("Logging HTTP request { HTTPMethod: {}, URI: {} }", request.getHttpMethod(), request.getUri());
  4.     return true;
  5.   }
  6. }

代码示例来源：origin: org.wso2.msf4j.samples/interceptor-common

  1. @Override
  2.   public boolean interceptRequest(Request request, Response response) throws Exception {
  3.     log.info("Logging HTTP request { HTTPMethod: {}, URI: {} }", request.getHttpMethod(), request.getUri());
  4.     return true;
  5.   }
  6. }

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

  1. private HTTPCarbonMessage getHttpCarbonMessage(Request request) throws HandlerException {
  2.   Class<?> clazz = request.getClass();
  3.   try {
  4.     Method retrieveCarbonMsg = clazz.getDeclaredMethod("getHttpCarbonMessage");
  5.     retrieveCarbonMsg.setAccessible(true);
  6.     return (HTTPCarbonMessage) retrieveCarbonMsg.invoke(request);
  7.   } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
  8.     throw new HandlerException(javax.ws.rs.core.Response.Status.INTERNAL_SERVER_ERROR,
  9.         String.format("Error in executing request: %s %s", request.getHttpMethod(),
  10.             request.getUri()), e);
  11.   }
  12. }

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

  1. private HTTPCarbonMessage getHttpCarbonMessage(Request request) throws HandlerException {
  2.   Class<?> clazz = request.getClass();
  3.   try {
  4.     Method retrieveCarbonMsg = clazz.getDeclaredMethod("getHttpCarbonMessage");
  5.     retrieveCarbonMsg.setAccessible(true);
  6.     return (HTTPCarbonMessage) retrieveCarbonMsg.invoke(request);
  7.   } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
  8.     throw new HandlerException(javax.ws.rs.core.Response.Status.INTERNAL_SERVER_ERROR,
  9.         String.format("Error in executing request: %s %s", request.getHttpMethod(),
  10.             request.getUri()), e);
  11.   }
  12. }

代码示例来源：origin: org.ballerinalang/composer-server-core

  1. @GET
  2. public Response handleGet(@Context Request request) {
  3.   String requestedPath = request.getUri();
  4.   String publicFolder = serverConfig.getPublicPath();
  5.   String targetFilePath = publicFolder + File.separator;
  6.   if (requestedPath.trim().length() == 0 || requestedPath.endsWith("/")) {
  7.     targetFilePath += "index.html";
  8.   } else if (requestedPath.indexOf('?') != -1) {
  9.     targetFilePath += requestedPath.substring(0, requestedPath.indexOf('?'));
  10.   } else {
  11.     targetFilePath += requestedPath;
  12.   }
  13.   File file = new File(targetFilePath);
  14.   if (file.exists()) {
  15.     return Response.ok(file).build();
  16.   }
  17.   return Response.status(Response.Status.NOT_FOUND).build();
  18. }

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.siddhi.editor.core

  1. @GET
  2. @Path("/**")
  3. public Response handleGet(@Context Request request) throws FileNotFoundException {
  4.   String rawUri = request.getUri().replaceFirst("^/editor", "");
  5.   String rawUriPath, mimeType;
  6.   if (rawUri == null || rawUri.trim().length() == 0 || "/".equals(rawUri)) {
  7.     rawUriPath = "/index.html";
  8.   } else {
  9.     int uriPathEndIndex = rawUri.indexOf('?');
  10.     if (uriPathEndIndex != -1) {
  11.       // handling query Params.
  12.       rawUriPath = rawUri.substring(0, uriPathEndIndex);
  13.     } else {
  14.       rawUriPath = rawUri;
  15.     }
  16.   }
  17.   try {
  18.     mimeType = MimeMapper.getMimeType(FilenameUtils.getExtension(rawUriPath));
  19.   } catch (Throwable ignored) {
  20.     mimeType = "text/plain";
  21.   }
  22.   File file = getResourceAsFile("/web" + rawUriPath);
  23.   if (file != null) {
  24.     return Response.ok(new FileInputStream(file)).type(mimeType).build();
  25.   }
  26.   log.error(" File not found [" + rawUriPath + "], Requesting path [" + rawUriPath + "] ");
  27.   return Response.status(Response.Status.NOT_FOUND).build();
  28. }

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.business.rules.templates.editor.core

  1. @GET
  2. @Path("/**")
  3. public Response handleGet(@Context Request request) throws FileNotFoundException {
  4.   String rawUri = request.getUri().replaceFirst("^/template-editor", "");
  5.   String rawUriPath, mimeType;
  6.   if (rawUri == null || rawUri.trim().length() == 0 || "/".equals(rawUri)) {
  7.     rawUriPath = "/index.html";
  8.   } else {
  9.     int uriPathEndIndex = rawUri.indexOf('?');
  10.     if (uriPathEndIndex != -1) {
  11.       // handling query Params.
  12.       rawUriPath = rawUri.substring(0, uriPathEndIndex);
  13.     } else {
  14.       rawUriPath = rawUri;
  15.     }
  16.   }
  17.   try {
  18.     mimeType = MimeMapper.getMimeType(FilenameUtils.getExtension(rawUriPath));
  19.   } catch (Throwable ignored) {
  20.     mimeType = "text/plain";
  21.   }
  22.   File file = getResourceAsFile("/web" + rawUriPath);
  23.   if (file != null) {
  24.     return Response.ok(new FileInputStream(file)).type(mimeType).build();
  25.   }
  26.   log.error(" File not found [" + rawUriPath + "], Requesting path [" + rawUriPath + "] ");
  27.   return Response.status(Response.Status.NOT_FOUND).build();
  28. }

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.msf4j.interceptor.common

  1. @Override
  2.   public boolean onRequestInterceptionError(Request request, Response response, Exception e) {
  4.     if (e instanceof LoginException) {
  5.       LOG.error("Authorization invalid for request : '" + request.getUri() + "'", e);
  6.       response.setEntity("Login credential is not valid in accessing the uri '" + request.getUri() + "'. " +
  7.           "Please check the credentials and try again.")
  8.           .setMediaType(MediaType.TEXT_PLAIN)
  9.           .setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode());
  10.       return false;
  11.     }
  13.     String message = "Exception while executing request interceptor '" + this.getClass() + "' for uri : '" +
  14.         request.getUri() + "'";
  15.     LOG.error(message, e);
  16.     response.setEntity(message)
  17.         .setMediaType(MediaType.TEXT_PLAIN)
  18.         .setStatus(javax.ws.rs.core.Response.Status.INTERNAL_SERVER_ERROR.getStatusCode());
  19.     return false;
  20.   }
  21. }

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.analytics.msf4j.interceptor.common

  1. @Override
  2. public boolean onRequestInterceptionError(Request request, Response response, Exception e) {
  3.   if (e instanceof AuthenticationException) {
  4.     LOGGER.debug("Authorization invalid for request '{}'.", request.getUri(), e);
  5.     response.setEntity(e.getMessage())
  6.         .setMediaType(MediaType.TEXT_PLAIN)
  7.         .setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode());
  8.     return false;
  9.   }
  10.   String message = "Exception while executing request interceptor '" + this.getClass() + "' for uri : '" +
  11.       request.getUri() + "'. Error: '" + e.getMessage() + "'";
  12.   LOGGER.debug(message, e);
  13.   response.setEntity(message)
  14.       .setMediaType(MediaType.TEXT_PLAIN)
  15.       .setStatus(javax.ws.rs.core.Response.Status.INTERNAL_SERVER_ERROR.getStatusCode());
  16.   return false;
  17. }

代码示例来源：origin: org.wso2.carbon.analytics-common/org.wso2.carbon.analytics.msf4j.interceptor.common

  1. @Override
  2.   public boolean onRequestInterceptionError(Request request, Response response, Exception e) {
  3.     if (e instanceof AuthenticationException) {
  4.       LOGGER.debug("Authorization invalid for request '{}'.", request.getUri(), e);
  5.       response.setEntity(e.getMessage())
  6.           .setMediaType(MediaType.TEXT_PLAIN)
  7.           .setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode());
  8.       return false;
  9.     }
  10.     String message = "Exception while executing request interceptor '" + this.getClass() + "' for uri : '" +
  11.         request.getUri() + "'. Error: '" + e.getMessage() + "'";
  12.     LOGGER.debug(message, e);
  13.     response.setEntity(message)
  14.         .setMediaType(MediaType.TEXT_PLAIN)
  15.         .setStatus(javax.ws.rs.core.Response.Status.INTERNAL_SERVER_ERROR.getStatusCode());
  16.     return false;
  17.   }
  18. }

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.msf4j.interceptor.common

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   String authorizationHeader = request.getHeader(HEADER_AUTHORIZATION);
  4.   if (authorizationHeader != null) {
  5.     byte[] decodedAuthHeader = Base64.getDecoder().decode(authorizationHeader.split(" ")[1]);
  6.     String authHeader = new String(decodedAuthHeader);
  7.     String userName = authHeader.split(":")[0];
  8.     String password = authHeader.split(":")[1];
  9.     CarbonMessage carbonMessage = new DefaultCarbonMessage();
  10.     carbonMessage.setHeader(HEADER_AUTHORIZATION, "Basic " + Base64.getEncoder()
  11.         .encodeToString((userName + ":" + password).getBytes())
  12.     );
  13.     /*
  14.     ProxyCallbackHandler callbackHandler = new ProxyCallbackHandler(carbonMessage);
  15.     LoginContext loginContext;
  16.     loginContext = new LoginContext("CarbonSecurityConfig", callbackHandler);
  17.     loginContext.login();
  18.     */
  19.     return true;
  20.   }
  21.   LOG.error("Authorization header not found for request : '" + request.getUri() + "'");
  22.   response.setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode())
  23.       .setEntity("Authorization is required to access uri '" + request.getUri() + "'. Please set " +
  24.           "the authentication header and try again.")
  25.       .setMediaType(MediaType.TEXT_PLAIN);
  26.   return false;
  27. }

代码示例来源：origin: org.wso2.carbon.uiserver/org.wso2.carbon.uiserver

  1. String rawUri = request.getUri();
  2. int uriPathEndIndex = rawUri.indexOf('?');
  3. String rawUriPath, rawQueryString;

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

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   SecurityErrorCode errorCode;
  4.   try {
  5.     HttpHeaders headers = request.getHeaders();
  6.     String authHeader = headers.getHeaderString(AUTHORIZATION_HTTP_HEADER);
  7.     if (authHeader != null && !authHeader.isEmpty()) {
  8.       return validateToken(authHeader);
  9.     } else {
  10.       throw new MSF4JSecurityException(SecurityErrorCode.AUTHENTICATION_FAILURE,
  11.           "Missing Authorization header is the request.`");
  12.     }
  13.   } catch (MSF4JSecurityException e) {
  14.     errorCode = e.getErrorCode();
  15.     log.error(e.getMessage() + " Requested Path: " + request.getUri());
  16.   }
  17.   handleSecurityError(errorCode, response);
  18.   return false;
  19. }

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

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   SecurityErrorCode errorCode;
  4.   try {
  5.     HttpHeaders headers = request.getHeaders();
  6.     String authHeader = headers.getHeaderString(AUTHORIZATION_HTTP_HEADER);
  7.     if (authHeader != null && !authHeader.isEmpty()) {
  8.       return validateToken(authHeader);
  9.     } else {
  10.       throw new MSF4JSecurityException(SecurityErrorCode.AUTHENTICATION_FAILURE,
  11.           "Missing Authorization header is the request.`");
  12.     }
  13.   } catch (MSF4JSecurityException e) {
  14.     errorCode = e.getErrorCode();
  15.     log.error(e.getMessage() + " Requested Path: " + request.getUri());
  16.   }
  17.   handleSecurityError(errorCode, response);
  18.   return false;
  19. }

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

  1. /**
  2.  * Get defined HTTP methods in the swagger definition as a comma separated string
  3.  *
  4.  * @param request Request
  5.  * @return Http Methods as a comma separated string
  6.  */
  7. public static RestAPIInfo getElectedRestApiInfo(Request request) {
  8.   if (request.getProperty(RestAPIConstants.ELECTED_BASE_PATH) != null) {
  9.     return ServiceReferenceHolder.getInstance().getSwaggerDefinitionMap().get(request.getProperty
  10.         (RestAPIConstants.ELECTED_BASE_PATH));
  11.   }
  12.   String requestURI = request.getUri().toLowerCase(Locale.ENGLISH);
  13.   RestAPIInfo electedSwagger = null;
  14.   for (String basePath : ServiceReferenceHolder.getInstance().getSwaggerDefinitionMap().keySet()) {
  15.     if (requestURI.contains(basePath)) {
  16.       electedSwagger = ServiceReferenceHolder.getInstance().getSwaggerDefinitionMap().get(basePath);
  17.       break;
  18.     }
  19.   }
  20.   if (electedSwagger != null) {
  21.     request.setProperty(RestAPIConstants.ELECTED_BASE_PATH, electedSwagger.getBasePath());
  22.   }
  23.   return electedSwagger;
  24. }

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

  1. httpMonitoringEvent.setServiceName(serviceName);
  2. httpMonitoringEvent.setServiceMethod(serviceMethod);
  3. httpMonitoringEvent.setRequestUri(request.getUri());
  4. httpMonitoringEvent.setServiceContext(servicePath);

代码示例来源：origin: org.wso2.carbon.identity.gateway/org.wso2.carbon.identity.gateway.api

  1. /**
  2.  * Update GatewayRequestBuilder.
  3.  *
  4.  * @param builder Builder.
  5.  * @param request MS4J request
  6.  * @throws GatewayClientException GatewayClientException
  7.  */
  8. protected void create(T builder, Request request)
  9.     throws GatewayClientException {
  10.   request.getHeaders().getAll().forEach(header -> {
  11.     builder.addHeader(header.getName(), header.getValue());
  12.   });
  13.   builder.setMethod(request.getHttpMethod());
  14.   builder.setContentType(request.getContentType());
  15.   builder.setRequestURI(request.getUri());
  16.   builder.setMethod(request.getHttpMethod());
  17.   builder.setAttributes((Map) request.getProperties());
  18.   builder.addParameter(Constants.QUERY_PARAMETERS,
  19.       (Serializable) request.getProperty(Constants.QUERY_PARAMETERS));
  20.   builder.addParameter(Constants.BODY_PARAMETERS, (Serializable) request.getProperty(Constants.BODY_PARAMETERS));
  21.   String[] queryStringParams = request.getUri().split("\\?");
  22.   if (queryStringParams.length > 1) {
  23.     builder.setQueryString(queryStringParams[1]);
  24.   } else {
  25.     builder.setQueryString(queryStringParams[0]);
  26.   }
  27.   if (logger.isDebugEnabled()) {
  28.     logger.debug("Successfully Updated the request builder in GatewayRequestBuilderFactory.");
  29.   }
  30. }

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

  1. serverTraceEvent.setParentId(traceParentId);
  2. serverTraceEvent.setHttpMethod(request.getHttpMethod());
  3. serverTraceEvent.setUrl(request.getUri());
  4. TracingEventTracker.setTraceEvent(serverTraceEvent);
  5. serviceMethodInfo.setAttribute(TRACE_EVENT_ATTRIBUTE, serverTraceEvent);

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

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