Mercurial Hosting > nabble
view src/cachingfilter/CachingRequestWrapper.java @ 43:4d90d48a19ec
fix init example
author | Vadim Filimonov <fffilimonov@yandex.ru> |
---|---|
date | Fri, 11 Jun 2021 15:28:26 +0300 |
parents | 7ecd1a4ef557 |
children |
line wrap: on
line source
package cachingfilter; import java.io.IOException; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Enumeration; import java.util.TimeZone; import java.util.Date; import java.util.Locale; import java.util.Map; import java.util.HashMap; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequestWrapper; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.eclipse.jetty.server.AbstractHttpConnection; final class CachingRequestWrapper extends HttpServletRequestWrapper { private static final Logger logger = LoggerFactory.getLogger(CachingRequestWrapper.class); static final String IF_MODIFIED_SINCE = "If-Modified-Since".toLowerCase(); static final String IF_NONE_MATCH = "If-None-Match".toLowerCase(); static final String ACCEPT_ENCODING = "Accept-Encoding".toLowerCase(); final Map<String,Object> headerMap = new HashMap<String,Object>(); CachingRequestWrapper(HttpServletRequest request) throws IOException { super(request); checkRequest(request); } private static void checkRequest(HttpServletRequest request) throws IOException { AbstractHttpConnection c = ((org.eclipse.jetty.server.Request) request).getConnection(); if (c.getRequestFields().containsKey("Host")) { for (Enumeration<String> e2 = c.getRequestFields().getValues("Host"); e2.hasMoreElements();) { if (e2.nextElement().trim().endsWith(":")) { throw new IOException("Bad 'Host' request header (ends with colon)"); } } } } public String getHeader(String name) { /* String v = getHeader2(name); logger.trace("getHeader "+name+" = "+v); return v; } public String getHeader2(String name) { */ String key = name.toLowerCase(); if( headerMap.containsKey(key) ) { Object val = headerMap.get(key); if( val instanceof Long ) { long date = (Long)val; if( date == -1 ) return null; return formatDate(date); } return (String)val; } return super.getHeader(name); } public long getDateHeader(String name) { /* long v = getDateHeader2(name); logger.trace("getDateHeader "+name+" = "+v); return v; } public long getDateHeader2(String name) { */ String key = name.toLowerCase(); if( headerMap.containsKey(key) ) return (Long)headerMap.get(key); return super.getDateHeader(name); } boolean isCacheable() { boolean isCacheable = false; Long val = (Long)headerMap.get(IF_MODIFIED_SINCE); if( val!=null ) { try { long cachedLastModified = val; if( cachedLastModified != -1 ) { long ifModifiedSince = super.getDateHeader(IF_MODIFIED_SINCE); //logger.trace("cachedLastModified = "+cachedLastModified+" ifModifiedSince = "+ifModifiedSince); if( cachedLastModified > ifModifiedSince ) return false; isCacheable = true; } } catch(IllegalArgumentException e) { logger.warn("bad date, user-agent="+getHeader("user-agent"),e); } } String etag = (String)headerMap.get(IF_NONE_MATCH); if( etag != null ) { String ifNoneMatch = super.getHeader(IF_NONE_MATCH); if( !etag.equals(ifNoneMatch) ) return false; isCacheable = true; } return isCacheable; } private static ThreadLocal<DateFormat> dateFormat = new ThreadLocal<DateFormat>() { protected synchronized DateFormat initialValue() { DateFormat httpDateFormat = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss z", Locale.US); httpDateFormat.setTimeZone(TimeZone.getTimeZone("GMT")); return httpDateFormat; } }; private String formatDate(long date) { return dateFormat.get().format(new Date(date)); } }