使用 Java 日志过滤器解析 HTTP

使用 Java 日志过滤器分析 HTTP 请求。

javax.servlet.Filter.来实现解析 HTTP 请求内容和输出日志的便捷方法。过滤器班级

此日志过滤器使用 "java.util.logging.Logger "进行日志输出，可通过更改日志级别来改变信息输出。

什么是 javax.servlet.Filter？

在构建Web应用时，除了主要业务处理之外，还需要在主要业务处理前后进行常见的二次处理。
例如，客户端认证、权限检查、日志记录等。
在每个资源中对这种副处理进行编码成为阻碍软件可维护性的主要原因，导致应用程序难以维护。

通过实施 javax.servlet.Filter，可以在请求传递给 servlet 类之前共同执行这种子处理。
还可以在 web.xml 中配置过滤器，这样就可以灵活地添加和删除过滤器，而无需更改源代码。

尝试使用日志过滤器。

让我们将日志过滤器付诸实践，通过过滤器来分析 HTTP 请求。
这一次汤姆猫从一开始，EXAMPLES 应用程序就可以在
该过滤器可通过以下设置立即执行。

  < 过滤器
   LogFilter 过滤器名
   LogFilter（日志过滤器
   <init-param
    logging.Level</参数名称
    FINE 参数值
   </init-param
   </filter
  < 过滤器映射
   日志过滤器</过滤器名称
   /* </filter
   过滤器映射

*使用 Struts 框架时，URL 模式如下。

   *.do。

检查运行会话示例屏幕的日志输出结果。

输出日志信息和日志级别。

日志输出内容

应在以下情况下使用日志级别

• 精细...... 输出最详细的日志，如果您想详细分析 HTTP 请求，可进行设置。
• CONFIG - 输出更详细的日志。建议在开发过程中保持这一水平。
• INFO・・・・ 只输出屏幕过渡信息。

如何更改日志级别。
日志输出级别可通过设置初始化参数 logging.Level.
例如

   <init-param
    logging.Level</参数名称
    INFO。

源代码

import java.io.IOException;<br /> import java.io.UnsupportedEncodingException;<br /> import java.sql.Time;<br /> import java.text.DecimalFormat;<br /> import java.text.SimpleDateFormat;<br /> import java.util.Date;<br /> import java.util.Enumeration;<br /> import java.util.Hashtable;<br /> import java.util.Iterator;<br /> import java.util.Map;<br /> import java.util.TreeMap;<br /> import java.util.logging.Formatter;<br /> import java.util.logging.Handler;<br /> import java.util.logging.Level;<br /> import java.util.logging.LogManager;<br /> import java.util.logging.LogRecord;<br /> import java.util.logging.Logger;<br /> import java.util.logging.StreamHandler;</p> <p>导入 javax.servlet.Filter;<br /> 导入 javax.servlet.FilterChain;<br /> 导入 javax.servlet.FilterConfig;<br /> 导入 javax.servlet.ServletException;<br /> 导入 javax.servlet.ServletRequest;<br /> 导入 javax.servlet.ServletResponse;<br /> 导入javax.servlet.http.Cookie；<br /> 导入 javax.servlet.http.HttpServletRequest;<br /> 导入 javax.servlet.http.HttpServletResponse;<br /> 导入 javax.servlet.http.HttpSession;</p> <p>/**<br /> * 实现javax.servlet.Filter来分析HTTP请求内容并输出日志<br /> * 过滤器类。<br /> */<br /> 公共类 LogFilter 实现 Filter {</p> <p> 私有静态记录器记录器=<br /> Logger.getLogger(LogFilter.class.getName());<br /> 私有静态最终字符串 LINE_SEPA =<br /> System.getProperty(“line.separator”);<br /> 私有静态最终字符串NEXT_PAGE =“LogFilter.NEXT_PAGE”;</p> <p> /**<br /> * 初始化该日志过滤器。<br /> * @参数映射<br /> */<br /> 公共无效初始化（FilterConfig映射）{<br /> String str = mapping.getInitParameter(“logging.Level”);<br /> System.out.println(“设置日志级别为“+str+”。”);<br /> 级别 level = null;<br /> 尝试 {<br /> 级别 = Level.parse(str);<br /> } catch (异常 e) {<br /> e.printStackTrace();<br /> 级别 = 级别.INFO;<br /> }<br /> LogManager.getLogManager().reset();<br /> 处理程序 handler = new CustomConsoleHandler();<br /> handler.setFormatter(new CustomFormatter());<br /> handler.setLevel(级别);<br /> logger.setLevel(级别);<br /> logger.getParent().addHandler(处理程序);<br /> }</p> <p> /**<br /> * 这是一个输出日志的过滤器。<br /> * @param request 正在处理的HTTP请求<br /> * @param response 正在生成 HTTP 响应<br /> * @参数链<br /> */<br /> 公共无效 doFilter(ServletRequest _request, ServletResponse _response,<br /> FilterChain 链）抛出 IOException、ServletException {</p> <p> // --------------------“预处理”<br /> HttpServletRequest 请求 = (HttpServletRequest)_request;<br /> HttpServletResponse 响应 = (HttpServletResponse) _response;<br /> 如果（logger.isLoggable（Level.CONFIG））{<br /> 记录器.config(<br /> “============请求开始！！”<br /> +“线程ID：”<br /> + Thread.currentThread().hashCode()<br /> + ” ========================================================”);<br /> }<br /> // 内存使用情况<br /> 字符串actionMemory = null;<br /> 如果（logger.isLoggable（Level.CONFIG））{<br /> 动作内存 = getMemoryInfo(” ”<br /> + new Time(System.currentTimeMillis()) + ”Request[上一个]”);<br /> }<br /> 如果 (logger.isLoggable(Level.FINE)) {<br /> logger.fine(“Cookie 信息” + getCookieInfo(request));<br /> }<br /> 如果 (logger.isLoggable(Level.FINE)) {<br /> logger.fine(“HTTP头信息” + getHeadersInfo(request));<br /> }<br /> 如果 (logger.isLoggable(Level.FINE)) {<br /> 记录器<br /> .fine(“HTTP其他信息” + getRequestOtherInfo(request));<br /> }<br /> 如果（logger.isLoggable（Level.CONFIG））{<br /> 字符串 reqlog = getRequestParametersInfo(request);<br /> logger.config(“HTTP请求参数” + reqlog);<br /> }<br /> 如果（logger.isLoggable（Level.CONFIG））{<br /> logger.config(“请求范围对象”<br /> + getRequestAttributeInfo(请求));<br /> }<br /> 如果（logger.isLoggable（Level.CONFIG））{<br /> 字符串 sessionlog = getSessionInfo(request,true);<br /> logger.config(“会话范围对象（请求处理之前）”<br /> + 会话日志）；<br /> }</p> <p> // 调用下一个过滤器<br /> chain.doFilter(请求，响应);</p> <p> // - - - - - - - - - - “后期处理”<br /> 如果（logger.isLoggable（Level.CONFIG））{<br /> 字符串 sessionlog = getSessionInfo(request,false);<br /> logger.config(“会话范围对象（请求处理后）”<br /> + 会话日志）；<br /> }<br /> // 内存使用情况<br /> 如果（logger.isLoggable（Level.CONFIG））{<br /> actionMemory = ”请求前后的内存使用情况”+LINE_SEPA<br /> + 动作内存 + LINE_SEPA<br /> + getMemoryInfo(” ” + new Time(System.currentTimeMillis())<br /> +“请求[之后]”）；<br /> logger.config(actionMemory+LINE_SEPA);</p> <p> }<br /> // 屏幕转换信息<br /> 如果 (logger.isLoggable(Level.INFO)) {<br /> String nextPage = (String) request.getAttribute(NEXT_PAGE);<br /> if (nextPage == null || nextPage.length() == 0) {<br /> 下一页 = request.getRequestURI();<br /> }<br /> logger.info(“NEXT_PAGE=[” + nextPage + “], ”<br /> + “IP_ADDRESS=[” + request.getRemoteAddr() + “], ”<br /> + “SESSION_ID=[” + request.getSession().getId() + “], ”<br /> + “USER-AGENT=[” + request.getHeader(“用户代理”) + “]”);<br /> }<br /> 如果（logger.isLoggable（Level.CONFIG））{<br /> 记录器.config(<br /> “============请求结束！！”<br /> +”线程ID:”+ Thread.currentThread().hashCode()<br /> + ” =========================================================”<br /> +LINE_SEPA+LINE_SEPA);<br /> }<br /> }</p> <p> /**<br /> *<br /> */<br /> 公共无效销毁（）{<br /> }</p> <p> // －－－－－－－－－－ 下面的私有方法 －－－－－－－－－－－－<br /> 私有静态 String getMemoryInfo(String message) {<br /> DecimalFormat dFromat = new DecimalFormat(“#,###KB”);<br /> 长空闲 = Runtime.getRuntime().freeMemory() / 1024;<br /> 长总计 = Runtime.getRuntime().totalMemory() / 1024;<br /> 长最大值 = Runtime.getRuntime().maxMemory() / 1024;<br /> 使用时间长=总计-免费；<br /> String msg = 消息 + ” : ” + “total=” + dFromat.format(total) + “, ”<br /> + “已使用量=” + dFromat.format(已使用) + ” (” + (已使用 * 100 / 总计)<br /> + “%), 最大可用=” + dFromat.format(max);<br /> 返回消息；<br /> }<br /> /**<br /> * 将所有请求头输出到日志中。<br /> */<br /> 私有静态字符串 getHeadersInfo(HttpServletRequest 请求) {<br /> StringBuffer buff = new StringBuffer(LINE_SEPA);<br /> 枚举 headerNames = request.getHeaderNames();<br /> while (headerNames.hasMoreElements()) {<br /> String headerName = (String) headerNames.nextElement();<br /> buff.append(“”);<br /> buff.append(headerName);<br /> buff.append(“=”);<br /> buff.append(request.getHeader(headerName));<br /> buff.append(LINE_SEPA);<br /> }<br /> 返回 buff.toString();<br /> }<br /> 私有静态字符串 getCookieInfo(HttpServletRequest 请求) {<br /> StringBuffer buff = new StringBuffer();<br /> Cookie[] cookies = request.getCookies();<br /> if (cookies == null) {<br /> 返回 ””;<br /> }<br /> for (int i = 0; i < cookies.length; i++) {<br /> buff.append(“\n — Cookie[” + i + “] —\n”);<br /> buff.append(“”);<br /> buff.append(cookies[i].getName());<br /> buff.append(“=”);<br /> buff.append(cookies[i].getValue());<br /> buff.append(LINE_SEPA);<br /> buff.append(“”);<br /> buff.append(“getVersion()”);<br /> buff.append(“=”);<br /> buff.append(cookies[i].getVersion());<br /> buff.append(LINE_SEPA);<br /> buff.append(“”);<br /> buff.append(“getComment()”);<br /> buff.append(“=”);<br /> buff.append(cookies[i].getComment());<br /> buff.append(LINE_SEPA);<br /> buff.append(“”);<br /> buff.append(“getDomain()”);<br /> buff.append(“=”);<br /> buff.append(cookies[i].getDomain());<br /> buff.append(LINE_SEPA);<br /> buff.append(“”);<br /> buff.append(“getMaxAge()”);<br /> buff.append(“=”);<br /> buff.append(cookies[i].getMaxAge());<br /> buff.append(LINE_SEPA);<br /> buff.append(“”);<br /> buff.append(“getPath()”);<br /> buff.append(“=”);<br /> buff.append(cookies[i].getPath());<br /> buff.append(LINE_SEPA);<br /> buff.append(“”);<br /> buff.append(“getSecure()”);<br /> buff.append(“=”);<br /> buff.append(cookies[i].getSecure());<br /> buff.append(LINE_SEPA);<br /> }<br /> 返回 buff.toString();<br /> }<br /> 私有静态字符串 getRequestParametersInfo(HttpServletRequest 请求) {<br /> StringBuffer buff = new StringBuffer(LINE_SEPA);<br /> 地图map=convertRequest(request);<br /> TreeMap trr = new TreeMap(map);<br /> 迭代器 itr = trr.keySet().iterator();<br /> while (itr.hasNext()) {<br /> 字符串键 = (字符串) itr.next();<br /> buff.append(“”);<br /> buff.append(key);<br /> buff.append(“=”);<br /> 对象值=map.get(key);<br /> String[]值=(String[])值；<br /> if (values.length == 1) {<br /> buff.append(值[0]);<br /> } 别的 {<br /> // 字符串数组转换<br /> 字符串 strValue = 层（值）；<br /> buff.append(strValue);<br /> }<br /> buff.append(LINE_SEPA);<br /> }<br /> 返回 buff.toString();<br /> }<br /> 私有静态字符串 getRequestAttributeInfo(HttpServletRequest 请求) {<br /> StringBuffer buff = new StringBuffer(LINE_SEPA);<br /> 枚举 e = request.getAttributeNames();<br /> while (e.hasMoreElements()) {<br /> 字符串名称 = (String) e.nextElement();<br /> buff.append(” 名称=” + 名称 + “, attributeClass= ”<br /> + request.getAttribute(name).getClass().getName()<br /> + “, toString() = ” + request.getAttribute(name)<br /> + LINE_SEPA);<br /> }<br /> 返回 buff.toString();<br /> }<br /> 私有静态字符串 getRequestOtherInfo(HttpServletRequest 请求) {<br /> StringBuffer buff = new StringBuffer();<br /> buff.append(LINE_SEPA);<br /> buff.append(”getCharacterEncoding()=”);<br /> buff.append(request.getCharacterEncoding());<br /> buff.append(LINE_SEPA);<br /> buff.append(“getContentLength()=”);<br /> buff.append(request.getContentLength());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getContentType()=”);<br /> buff.append(request.getContentType());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getLocale()=”);<br /> buff.append(request.getLocale());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getProtocol()=”);<br /> buff.append(request.getProtocol());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getRemoteAddr()=”);<br /> buff.append(request.getRemoteAddr());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getRemoteHost()=”);<br /> buff.append(request.getRemoteHost());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getScheme()=”);<br /> buff.append(request.getScheme());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getServerName()=”);<br /> buff.append(request.getServerName());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getServerPort()=”);<br /> buff.append(request.getServerPort());<br /> buff.append(LINE_SEPA);<br /> buff.append(”isSecure()=”);<br /> buff.append(request.isSecure());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getAuthType()=”);<br /> buff.append(request.getAuthType());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getContextPath()=”);<br /> buff.append(request.getContextPath());<br /> buff.append(LINE_SEPA);<br /> buff.append(“getMethod()=”);<br /> buff.append(request.getMethod());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getPathInfo()=”);<br /> buff.append(request.getPathInfo());<br /> buff.append(LINE_SEPA);<br /> buff.append(“getPathTranslated()=”);<br /> buff.append(request.getPathTranslated());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getQueryString()=”);<br /> buff.append(request.getQueryString());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getRemoteUser()=”);<br /> buff.append(request.getRemoteUser());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getRequestedSessionId()=”);<br /> buff.append(request.getRequestedSessionId());<br /> buff.append(LINE_SEPA);<br /> buff.append(“getRequestURI()=”);<br /> buff.append(request.getRequestURI());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getServletPath()=”);<br /> buff.append(request.getServletPath());<br /> buff.append(LINE_SEPA);<br /> buff.append(”getUserPrincipal()=”);<br /> buff.append(request.getUserPrincipal());<br /> buff.append(LINE_SEPA);<br /> buff.append(”isRequestedSessionIdFromCookie()=”);<br /> buff.append(request.isRequestedSessionIdFromCookie());<br /> buff.append(LINE_SEPA);<br /> buff.append(”isRequestedSessionIdFromURL()=”);<br /> buff.append(request.isRequestedSessionIdFromURL());<br /> buff.append(LINE_SEPA);<br /> buff.append(”isRequestedSessionIdValid()=”);<br /> buff.append(request.isRequestedSessionIdValid());<br /> buff.append(LINE_SEPA);<br /> 返回 buff.toString();<br /> }</p> <p> private static String getSessionInfo(HttpServletRequest request,boolean before) {<br /> HttpSession 会话 = request.getSession();<br /> StringBuffer buff = new StringBuffer();<br /> buff.append(LINE_SEPA);<br /> 如果（之前）{<br /> buff.append(” session.isNew() = ” + session.isNew());<br /> buff.append(LINE_SEPA);<br /> buff.append(” session.getId() = ” + session.getId());<br /> buff.append(LINE_SEPA);<br /> }<br /> 枚举 e = session.getAttributeNames();<br /> while (e.hasMoreElements()) {<br /> String sessionName = (String) e.nextElement();<br /> String sessionClassName = session.getAttribute(sessionName)<br /> .getClass().getName();<br /> buff.append(” name =” + sessionName + “, value =”<br /> + session.getAttribute(sessionName) + “, attributeClass = ”<br /> + 会话类名称+LINE_SEPA);<br /> }<br /> 返回 buff.toString();<br /> }</p> <p> 私有静态Hashtable ConvertRequest（HttpServletRequest请求）{<br /> Hashtable tempHash = new Hashtable();<br /> 枚举 e = request.getParameterNames();<br /> while (e.hasMoreElements()) {<br /> String key = (String) e.nextElement();<br /> String[]values=request.getParameterValues(key);<br /> String[]参数值=new String[values.length];<br /> for (int i = 0; i < 值.length; i++) {<br /> 参数值[i] = convUnicode(值[i]);<br /> }<br /> tempHash.put(key, 参数值);<br /> }<br /> 返回临时哈希值；</p> <p> }<br /> 私有静态字符串层（对象值）{<br /> 如果（值==空）{<br /> 返回“空”；<br /> } else if (value instanceof String[]) {<br /> 返回 convString((String[]) 值);<br /> } 别的 {<br /> 返回值.toString();<br /> }<br /> }</p> <p> /**<br /> * 将字符串数组 [strArray] 的内容作为字符串返回，如下所示。<br /> *“[温度1，温度2，温度3]”<br /> * @param strArray 要计算的字符串数组<br /> * @return 转换后的字符串<br /> */<br /> 私有静态字符串 convString(String[] strArray) {<br /> if (strArray == null)<br /> 返回空值；<br /> StringBuffer buff = new StringBuffer(“[”);<br /> for (int i = 0; i < strArray.length; i++) {<br /> buff.append(strArray[i] + “, “);<br /> }<br /> buff.delete(buff.length() – 2, buff.length());<br /> buff.append(“]”);<br /> 返回 buff.toString();<br /> }</p> <p> /**<br /> * 将 [str] 转换为 Unicode。<br /> * @参数str<br /> * @返回<br /> */<br /> 私有静态字符串 convUnicode(字符串 str) {<br /> if (str == null)<br /> 返回空值；<br /> 尝试 {<br /> 返回新字符串（str.getBytes（“8859_1”），“JISAutoDetect”）；<br /> } catch (UnsupportedEncodingException e) {<br /> 抛出新的运行时异常（e）；<br /> }<br /> }<br /> // ———————————————————————–<br /> 静态类 CustomFormatter 扩展 Formatter {<br /> 静态最终字符串模式=“yyyy/MM/dd HH:mm:ss”；<br /> 公共同步字符串格式（LogRecord记录）{<br /> StringBuffer buf = new StringBuffer();<br /> // 设置日期和时间<br /> 日期日期 = 新日期();<br /> date.setTime(record.getMillis());<br /> SimpleDateFormat 格式化程序 = new SimpleDateFormat(pattern);<br /> buf.append(formatter.format(日期));<br /> buf.append(“:”);<br /> // 设置级别<br /> buf.append(“[” + record.getLevel().getName() + “]”);<br /> buf.append(“:”);<br /> buf.append(record.getMessage());<br /> buf.append(LINE_SEPA);<br /> 返回 buf.toString();<br /> }<br /> }<br /> 静态类 CustomConsoleHandler 扩展 StreamHandler {<br /> 公共 CustomConsoleHandler() {<br /> 极好的（）;<br /> setOutputStream(System.out);<br /> }<br /> /**<br /> * 发出日志记录。<br /> * 最初，记录请求被发送到 Logger 对象。<br /> * 该对象初始化 LogRecord 并<br /> *重定向至此处。<br /> *<br /> * @param record 日志事件的描述。空记录被简单地忽略<br /> * 并且不会发送任何通知。<br /> */<br /> 公共无效发布（LogRecord记录）{<br /> 超级.发布(记录);<br /> 冲洗（）；<br /> }<br /> /**<br /> * 重写 StreamHandler.close 来刷新，但是<br /> * 输出流未关闭。换句话说，System.err 没有关闭。<br /> */<br /> 公共无效关闭（）{<br /> 冲洗（）；<br /> }<br /> }<br /> }<br />