javax.servlet.http.HttpServletResponse#getHeader()源码实例Demo

下面列出了javax.servlet.http.HttpServletResponse#getHeader() 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： lemon 文件： CorsFilter.java

public void doFilter(ServletRequest req, ServletResponse res,
        FilterChain chain) throws IOException, ServletException {
    HttpServletRequest request = (HttpServletRequest) req;
    HttpServletResponse response = (HttpServletResponse) res;
    String url = request.getHeader("Origin");

    if (!StringUtils.isEmpty(url)) {
        String val = response.getHeader("Access-Control-Allow-Origin");

        if (StringUtils.isEmpty(val)) {
            response.addHeader("Access-Control-Allow-Origin", url);
            response.addHeader("Access-Control-Allow-Credentials", "true");
        }
    }

    chain.doFilter(req, res);
}

源代码2 项目： jvue-admin 文件： RestLogoutSuccessHandler.java

@Override
    public void onLogoutSuccess(HttpServletRequest request, HttpServletResponse response,
            Authentication authentication) throws IOException, ServletException {
        
        // 根据不同的Accept返回不同类型值
    	String accept = response.getHeader("accept");
    	if (MediaType.APPLICATION_JSON_UTF8_VALUE.equalsIgnoreCase(accept)
         		|| MediaType.APPLICATION_JSON_VALUE.equalsIgnoreCase(accept)) {
	        String result = objectMapper.writeValueAsString(BaseModel.ok(""));
	        response.setContentType(MediaType.APPLICATION_JSON_UTF8_VALUE);
			response.getWriter().write(result);
        } else {
        	// 画面跳转等处理 
        	super.handle(request, response, authentication);
        }
		
        //jwtTokenUtil.expireToken(token);
//        if (authorization != null) {
//            userService.logout(authorization);
//        }
    }

源代码3 项目： jvue-admin 文件： RestAuthenticationFailureHandler.java

@Override
public void onAuthenticationFailure(HttpServletRequest request, HttpServletResponse response,
		AuthenticationException exception) throws IOException, ServletException {
	// do nth.
	// TODO 处理登录失败N次后，账号锁定等

       // 根据不同的Accept返回不同类型值
	
   	String accept = response.getHeader("accept");
   	logger.info("accept {}",accept);
   	
       if (MediaType.APPLICATION_JSON_UTF8_VALUE.equalsIgnoreCase(accept)
       		|| MediaType.APPLICATION_JSON_VALUE.equalsIgnoreCase(accept)) {
		logger.info("login faild ");
		String result = objectMapper.writeValueAsString(BaseModel.error("1", exception.getMessage()));
		response.setContentType(MediaType.APPLICATION_JSON_UTF8_VALUE);
		response.getWriter().write(result);
       } else {
       	super.onAuthenticationFailure(request, response, exception);
       }
}

源代码4 项目： rebuild 文件： LanguagesControll.java

@RequestMapping(value = "bundle", method = RequestMethod.GET)
public void getLanguageBundle(HttpServletRequest request, HttpServletResponse response) throws IOException {
    response.setContentType(ServletUtils.CT_JS);
    final LanguageBundle bundle = getBundle(request);

    // whether the generated ETag should be weak
    // SPEC: length of W/ + " + 0 + 32bits md5 hash + "
    String responseETag = String.format("W/\"0%s\"", bundle.getBundleHash());
    response.setHeader(HEADER_ETAG, responseETag);

    // 无缓存
    String cacheControl = response.getHeader(HEADER_CACHE_CONTROL);
    if (cacheControl != null && cacheControl.contains(DIRECTIVE_NO_STORE)) {
        ServletUtils.write(response, "__LANGBUNDLE__ = " + bundle.toJSON().toJSONString());
        return;
    }

    String requestETag = request.getHeader(HEADER_IF_NONE_MATCH);
    if (requestETag != null && ("*".equals(requestETag) || responseETag.equals(requestETag) ||
            responseETag.replaceFirst("^W/", "").equals(requestETag.replaceFirst("^W/", "")))) {
        response.setStatus(HttpServletResponse.SC_NOT_MODIFIED);
    } else {
        ServletUtils.write(response, "__LANGBUNDLE__ = " + bundle.toJSON().toJSONString());
    }
}

源代码5 项目： lams 文件： ShallowEtagHeaderFilter.java

/**
 * Indicates whether the given request and response are eligible for ETag generation.
 * <p>The default implementation returns {@code true} if all conditions match:
 * <ul>
 * <li>response status codes in the {@code 2xx} series</li>
 * <li>request method is a GET</li>
 * <li>response Cache-Control header is not set or does not contain a "no-store" directive</li>
 * </ul>
 * @param request the HTTP request
 * @param response the HTTP response
 * @param responseStatusCode the HTTP response status code
 * @param inputStream the response body
 * @return {@code true} if eligible for ETag generation; {@code false} otherwise
 */
protected boolean isEligibleForEtag(HttpServletRequest request, HttpServletResponse response,
		int responseStatusCode, InputStream inputStream) {

	String method = request.getMethod();
	if (responseStatusCode >= 200 && responseStatusCode < 300
			&& HttpMethod.GET.matches(method)) {

		String cacheControl = null;
		if (servlet3Present) {
			cacheControl = response.getHeader(HEADER_CACHE_CONTROL);
		}
		if (cacheControl == null || !cacheControl.contains(DIRECTIVE_NO_STORE)) {
			return true;
		}
	}
	return false;
}

源代码6 项目： spectator 文件： IpcServletFilter.java

private void addIfNotPresent(HttpServletResponse httpRes, String name, String value) {
  if (httpRes.getHeader(name) == null) {
    httpRes.addHeader(name, value);
  }
}

源代码7 项目： cf-java-logging-support 文件： HttpHeaderUtilities.java

private static String getHeaderValueInternal(HttpServletResponse httpResponse, HttpHeader header) {
	if (httpResponse == null) {
		return null;
	}
	String headerName = header.getName();
	return httpResponse.getHeader(headerName);
}

源代码8 项目： spring-analysis-note 文件： ServletWebRequest.java

@Override
public boolean checkNotModified(@Nullable String etag, long lastModifiedTimestamp) {
	HttpServletResponse response = getResponse();
	if (this.notModified || (response != null && HttpStatus.OK.value() != response.getStatus())) {
		return this.notModified;
	}

	// Evaluate conditions in order of precedence.
	// See https://tools.ietf.org/html/rfc7232#section-6

	if (validateIfUnmodifiedSince(lastModifiedTimestamp)) {
		if (this.notModified && response != null) {
			response.setStatus(HttpStatus.PRECONDITION_FAILED.value());
		}
		return this.notModified;
	}

	boolean validated = validateIfNoneMatch(etag);
	if (!validated) {
		validateIfModifiedSince(lastModifiedTimestamp);
	}

	// Update response
	if (response != null) {
		boolean isHttpGetOrHead = SAFE_METHODS.contains(getRequest().getMethod());
		if (this.notModified) {
			response.setStatus(isHttpGetOrHead ?
					HttpStatus.NOT_MODIFIED.value() : HttpStatus.PRECONDITION_FAILED.value());
		}
		if (isHttpGetOrHead) {
			if (lastModifiedTimestamp > 0 && parseDateValue(response.getHeader(HttpHeaders.LAST_MODIFIED)) == -1) {
				response.setDateHeader(HttpHeaders.LAST_MODIFIED, lastModifiedTimestamp);
			}
			if (StringUtils.hasLength(etag) && response.getHeader(HttpHeaders.ETAG) == null) {
				response.setHeader(HttpHeaders.ETAG, padEtagIfNecessary(etag));
			}
		}
	}

	return this.notModified;
}

源代码9 项目： spring-analysis-note 文件： DefaultCorsProcessor.java

@Override
@SuppressWarnings("resource")
public boolean processRequest(@Nullable CorsConfiguration config, HttpServletRequest request,
		HttpServletResponse response) throws IOException {

	response.addHeader(HttpHeaders.VARY, HttpHeaders.ORIGIN);
	response.addHeader(HttpHeaders.VARY, HttpHeaders.ACCESS_CONTROL_REQUEST_METHOD);
	response.addHeader(HttpHeaders.VARY, HttpHeaders.ACCESS_CONTROL_REQUEST_HEADERS);

	if (!CorsUtils.isCorsRequest(request)) {
		return true;
	}

	if (response.getHeader(HttpHeaders.ACCESS_CONTROL_ALLOW_ORIGIN) != null) {
		logger.trace("Skip: response already contains \"Access-Control-Allow-Origin\"");
		return true;
	}

	boolean preFlightRequest = CorsUtils.isPreFlightRequest(request);
	if (config == null) {
		if (preFlightRequest) {
			rejectRequest(new ServletServerHttpResponse(response));
			return false;
		}
		else {
			return true;
		}
	}

	return handleInternal(new ServletServerHttpRequest(request), new ServletServerHttpResponse(response), config, preFlightRequest);
}

源代码10 项目： odo 文件： PluginHelper.java

public static void writeResponseContent(HttpServletResponse response, String content) throws IOException {
    // check to see if this is chunked
    boolean chunked = false;
    if (response.containsHeader(PluginHelper.STRING_TRANSFER_ENCODING)
            && response.getHeader(PluginHelper.STRING_TRANSFER_ENCODING).compareTo("chunked") == 0) {
        response.setHeader(PluginHelper.STRING_CONNECTION, PluginHelper.STRING_CHUNKED);
        chunked = true;
    }

    // check to see if this content is supposed to be compressed
    // if so recompress it
    boolean isEncoded = false;
    ByteArrayOutputStream out = new ByteArrayOutputStream();
    if (response.getHeader("content-encoding") != null &&
            response.getHeader("content-encoding").equals("gzip")) {
        // GZIP the data
        isEncoded = true;
        GZIPOutputStream gzip = new GZIPOutputStream(out);
        gzip.write(content.getBytes());
        gzip.close();
        out.close();
    } else if (response.getHeader("content-encoding") != null &&
            response.getHeader("content-encoding").equals("deflate")) {
        // Deflate the data
        isEncoded = true;
        Deflater compressor = new Deflater();
        compressor.setInput(content.getBytes());
        compressor.finish();

        byte[] buffer = new byte[1024];
        while (!compressor.finished()) {
            int count = compressor.deflate(buffer);
            out.write(buffer, 0, count);
        }
        out.close();
        compressor.end();
    }


    // don't do this if we got a HTTP 304 since there is no data to send back
    if (response.getStatus() != HttpServletResponse.SC_NOT_MODIFIED) {
        if (!chunked) {
            // change the content length header to the new length
            if (content != null && !isEncoded) {
                response.setContentLength(content.getBytes().length);
            } else if (isEncoded) {
                response.setContentLength(out.toByteArray().length);
            }
        }

        OutputStream outputStreamClientResponse = response.getOutputStream();
        response.resetBuffer();

        if (content != null && !isEncoded) {
            outputStreamClientResponse.write(content.getBytes());
        } else if (isEncoded) {
            outputStreamClientResponse.write(out.toByteArray());
        }
    }
}

源代码11 项目： java-technology-stack 文件： ServletWebRequest.java

@Override
public boolean checkNotModified(@Nullable String etag, long lastModifiedTimestamp) {
	HttpServletResponse response = getResponse();
	if (this.notModified || (response != null && HttpStatus.OK.value() != response.getStatus())) {
		return this.notModified;
	}

	// Evaluate conditions in order of precedence.
	// See https://tools.ietf.org/html/rfc7232#section-6

	if (validateIfUnmodifiedSince(lastModifiedTimestamp)) {
		if (this.notModified && response != null) {
			response.setStatus(HttpStatus.PRECONDITION_FAILED.value());
		}
		return this.notModified;
	}

	boolean validated = validateIfNoneMatch(etag);
	if (!validated) {
		validateIfModifiedSince(lastModifiedTimestamp);
	}

	// Update response
	if (response != null) {
		boolean isHttpGetOrHead = SAFE_METHODS.contains(getRequest().getMethod());
		if (this.notModified) {
			response.setStatus(isHttpGetOrHead ?
					HttpStatus.NOT_MODIFIED.value() : HttpStatus.PRECONDITION_FAILED.value());
		}
		if (isHttpGetOrHead) {
			if (lastModifiedTimestamp > 0 && parseDateValue(response.getHeader(LAST_MODIFIED)) == -1) {
				response.setDateHeader(LAST_MODIFIED, lastModifiedTimestamp);
			}
			if (StringUtils.hasLength(etag) && response.getHeader(ETAG) == null) {
				response.setHeader(ETAG, padEtagIfNecessary(etag));
			}
		}
	}

	return this.notModified;
}

源代码12 项目： openwebbeans-meecrowave 文件： ProxyServlet.java

protected void forwardResponse(final Routes.Route route, final Response response,
                               final HttpServletRequest request, final HttpServletResponse resp,
                               final Function<InputStream, InputStream> responseRewriter) throws IOException {
    final int status = response.getStatus();
    resp.setStatus(status);
    forwardHeaders(route, response, resp);
    if (status == HttpServletResponse.SC_NOT_MODIFIED && resp.getHeader(HttpHeaders.CONTENT_LENGTH) == null) {
        resp.setIntHeader(HttpHeaders.CONTENT_LENGTH, 0);
    }
    forwardCookies(route, response, resp);
    writeOutput(resp, responseRewriter.apply(response.readEntity(InputStream.class)));
}

源代码13 项目： jvue-admin 文件： RestAuthenticationSuccessHandler.java

@Override
public void onAuthenticationSuccess(HttpServletRequest request, HttpServletResponse response,
		Authentication authentication) throws IOException, ServletException {

       // 根据不同的Accept返回不同类型值
   	String accept = response.getHeader("accept");
   	if (MediaType.APPLICATION_JSON_UTF8_VALUE.equalsIgnoreCase(accept)
        		|| MediaType.APPLICATION_JSON_VALUE.equalsIgnoreCase(accept)) {
   		Object principal = authentication.getPrincipal();
   		
   		// TODO 异步写登录日志等
		if (principal != null) {
			if (principal instanceof JwtUserDetails) {

				JwtUserDetails userDetail = (JwtUserDetails)principal;

				JvueUserInfo userInfo = new JvueUserInfo();
				userInfo.setUsername(userDetail.getUsername());
				userInfo.setEmail(userDetail.getEmail());
				userInfo.setNickname(userDetail.getNickname());
				String result = objectMapper.writeValueAsString(BaseModel.ok(userInfo));
				response.setContentType(MediaType.APPLICATION_JSON_UTF8_VALUE);
				response.getWriter().write(result);
			}
		}
        clearAuthenticationAttributes(request);
	} else {
		super.onAuthenticationSuccess(request, response, authentication);
	}
       
}

源代码14 项目： spring-cloud-sleuth 文件： ServletUtils.java

static String getHeader(HttpServletRequest request, HttpServletResponse response,
		String name) {
	String value = request.getHeader(name);
	return value != null ? value : response.getHeader(name);
}

源代码15 项目： lams 文件： ServletWebRequest.java

private boolean isHeaderAbsent(HttpServletResponse response, String header) {
	if (response == null || !servlet3Present) {
		// Can't check response.getHeader(header) - let's assume it's not set
		return true;
	}
	return (response.getHeader(header) == null);
}

源代码16 项目： spring4-understanding 文件： ServletWebRequest.java

private boolean isHeaderAbsent(HttpServletResponse response, String header) {
	if (response == null || !servlet3Present) {
		// Can't check response.getHeader(header) - let's assume it's not set
		return true;
	}
	return (response.getHeader(header) == null);
}

源代码17 项目： joynr 文件： TestRequestDispatcher.java

@Override
public void doHandle(String target,
                     Request baseRequest,
                     HttpServletRequest request,
                     HttpServletResponse response) throws IOException, ServletException {

    String sessionId = request.getRequestedSessionId();

    if (sessionId == null) {
        String contextPath = forwardRoundRobin(baseRequest, response);

        // check if a session has been created in this request
        String location = response.getHeader("Location");
        if (location != null && Utilities.isSessionEncodedInUrl(location, "jsessionid")) {
            String createdSessionId = Utilities.getSessionId(location, "jsessionid");

            ClusterNode sessionCreatingInstance = getSessionCreatingServerInstance(createdSessionId);

            if (sessionCreatingInstance != null) {
                sessionStore.put(createdSessionId, sessionCreatingInstance.getContextPath());
                logger.debug("Request created a session encoded url that was created at server instance {}. Stored session ID {} for that instance",
                             sessionCreatingInstance.getContextPath(),
                             createdSessionId);
            } else {
                sessionStore.put(createdSessionId, contextPath);
                logger.debug("Request created a session encoded url. Stored session ID {} for that context {}",
                             createdSessionId,
                             contextPath);
            }
        }

    } else {

        String targetPath = sessionStore.get(sessionId);

        if (targetPath == null) {
            targetPath = forwardRoundRobin(baseRequest, response);
            sessionStore.put(sessionId, targetPath);
            logger.debug("Created new target path {} for session {}", targetPath, sessionId);
        } else {
            logger.debug("Applying sticky session pattern for target path {} and session {}",
                         targetPath,
                         sessionId);
            forwardToUrl(targetPath, baseRequest, response);
        }

    }

}

源代码18 项目： cf-java-logging-support 文件： RequestLoggingFilter.java

private void doFilterRequest(HttpServletRequest httpRequest, HttpServletResponse httpResponse, FilterChain chain)
		throws IOException, ServletException {
	if (httpRequest.getHeader(dynLogEnvironment.getDynLogHeaderKey()) != null && dynamicLogLevelProcessor != null) {
		dynamicLogLevelProcessor.copyDynamicLogLevelToMDC(httpRequest);
	}
	/*
	 * -- make sure correlation id is read from headers
	 */
	LogContext.initializeContext(HttpHeaderUtilities.getHeaderValue(httpRequest, HttpHeaders.CORRELATION_ID));

	try {

		RequestRecord rr = requestRecordFactory.create(httpRequest);
		httpRequest.setAttribute(MDC.class.getName(), MDC.getCopyOfContextMap());
		
		if (!httpResponse.isCommitted() && httpResponse.getHeader(HttpHeaders.CORRELATION_ID.getName()) == null) {
			httpResponse.setHeader(HttpHeaders.CORRELATION_ID.getName(), LogContext.getCorrelationId());
		}

		/*
		 * If request logging is disabled skip request instrumentation and continue the
		 * filter chain immediately.
		 */
		if (!RequestLogger.isRequestLoggingEnabled()) {
			doFilter(chain, httpRequest, httpResponse);
			return;
		}

		/*
		 * -- we essentially do three things here: -- a) we create a log
		 * record using our library and log it via STDOUT -- b) keep track
		 * of certain header fields so that they are available in later
		 * processing steps -- b) inject a response wrapper to keep track of
		 * content length (hopefully)
		 */
		if (wrapResponse) {
			httpResponse = new ContentLengthTrackingResponseWrapper(httpResponse);
		}

		if (wrapRequest) {
			httpRequest = new ContentLengthTrackingRequestWrapper(httpRequest);
		}

		RequestLogger loggingVisitor = new RequestLogger(rr, httpRequest, httpResponse);
		httpRequest = new LoggingContextRequestWrapper(httpRequest, loggingVisitor);



		/* -- start measuring right before calling up the filter chain -- */
		rr.start();
		doFilter(chain, httpRequest, httpResponse);

		if (!httpRequest.isAsyncStarted()) {
			loggingVisitor.logRequest();
		}
		/*
		 * -- close this
		 */
	} finally {
		if (dynamicLogLevelProcessor != null) {
			dynamicLogLevelProcessor.removeDynamicLogLevelFromMDC();
		}
		LogContext.resetContextFields();
	}
}

源代码19 项目： spring-analysis-note 文件： ShallowEtagHeaderFilter.java

/**
 * Indicates whether the given request and response are eligible for ETag generation.
 * <p>The default implementation returns {@code true} if all conditions match:
 * <ul>
 * <li>response status codes in the {@code 2xx} series</li>
 * <li>request method is a GET</li>
 * <li>response Cache-Control header is not set or does not contain a "no-store" directive</li>
 * </ul>
 * @param request the HTTP request
 * @param response the HTTP response
 * @param responseStatusCode the HTTP response status code
 * @param inputStream the response body
 * @return {@code true} if eligible for ETag generation, {@code false} otherwise
 */
protected boolean isEligibleForEtag(HttpServletRequest request, HttpServletResponse response,
		int responseStatusCode, InputStream inputStream) {

	String method = request.getMethod();
	if (responseStatusCode >= 200 && responseStatusCode < 300 && HttpMethod.GET.matches(method)) {
		String cacheControl = response.getHeader(HttpHeaders.CACHE_CONTROL);
		return (cacheControl == null || !cacheControl.contains(DIRECTIVE_NO_STORE));
	}
	return false;
}

源代码20 项目： heimdall 文件： CallImpl.java

@Override
public String get(String name) {
     
     HttpServletResponse r = context.getResponse();
     
     return r.getHeader(name);
}