博爱老头的草屋

package com.util.log;

import java.util.Vector;
import java.sql.*;
import com.database.ConnectionManager;

/**
*
* <p>Title:日志处理类 </p>
* <p>Description: 将日志信息写入到数据库</p>
* <p>Copyright: Copyright (c) 2005</p>
* <p>Company: 自由鸟</p>
* @author XXX Programer
* @version 1.0
*/

public class LogUtil {
   /**
    * 用于缓存系统日志。当这个Vector对象的大小达到一定的值时，系统把这个缓存里的
    * 数据一次性写入数据库。这个集合对象里每个元素都是一个LogBean对象
    */
   private static Vector logCache = new Vector();

   /**
    * 缓存容量
    * 当缓存里面的数据条数(即logCache对象的大小)达到这个值时，系统把缓存里的数据
    * 写入数据库
    */
   private static final int CACHE_SIZE = 20;   //XX条记录写入一次


   /**
    * 把数据集里的数据写入到数据库
    * @param   datas    数据集合。里面每个元素都是一条数据(LogBean对象)
    */
   private static void writeToDB(Vector datas){
     Connection conn = null;
     PreparedStatement pstmt = null;

     try{
       conn = ConnectionManager.getConnection();
       String sql = "insert into lmzwap.WAP_MANAGE_LOG (USER_NAME, LOG_TIME, CLIENT_IP, OPERATE_TYPE, OPERATE_DESC) "
           +" values(?,NOW(),?,?,?)";
       pstmt = conn.prepareStatement(sql);
       LogBean logBean;

       //System.out.println("---------------writeToDB,datas.size(): "+datas.size());
       for(int i=0;i<datas.size();i++){
         logBean = (LogBean)datas.get(i);
           pstmt.setString(1,logBean.user_name);
           pstmt.setString(2,logBean.client_ip);
           pstmt.setString(3,String.valueOf(logBean.operateTypeID));
           pstmt.setString(4,logBean.operateTypeDesc);
           pstmt.addBatch();
       }//end for i
       pstmt.executeBatch();   //执行批处理
     }catch(Exception e){
       System.out.println("===============批处理写入日志失败，e: "+e);
     }finally{
       if(pstmt!=null)
         try{
           pstmt.close();
         }catch(Exception e1){}

       if(conn!=null)
         try{
           conn.close();
         }catch(Exception e1){}
     }
   }


   /**
    * 把系统日志缓存里的数据写入数据库，不论缓存里有多少条记录。这个方法一般用在
    * 用户从系统退出时时，把缓存里的数据写入数据库,而不管缓存里的数据条数是否达到
    * 缓存容量
    */
   public static void writeToDB(){
     Vector copied = null;

     synchronized(logCache){
         //从缓存取得数据:
         copied = new Vector(logCache.size());
         for(int i=0;i<logCache.size();i++){
           copied.addElement(logCache.get(i));
         }
         logCache.clear();   //清除缓存数据
     }//end synchronized

     writeToDB(copied);

   }


   /**
    * 记录系统日志。调用这个方法只是把日志内容写进缓存，并不一定立即写入数据库；
    * 当缓存里的日志数量达到一定程度时，再一次性写入数据库
    * @param   request    客户端发过来的request请求，里面包含了客户端端IP的信息，
    *                     通过这个请求可得到session,在session里可得到操作员工ID,
    *                     操作员工姓名等资料
    * @param   operateTypeID:   操作类型ID
    * @param   operateTypeDesc:   操作类型描述
    * @param   operateDetail:     操作的具体内容的描述
    */
   public static void writeLog(String user_name,String client_ip,
          char operateTypeID,String operateTypeDesc) {
     try{
       //Timestamp time = new Timestamp(System.currentTimeMillis()); //操作时间

       LogBean bean = new LogBean(user_name,client_ip,operateTypeID,operateTypeDesc);

       synchronized(logCache){
         logCache.addElement(bean);   //向缓存加入数据

         //如果缓存里的数据达到了缓存容量时，向数据库写入数据：
         if(logCache.size()>=CACHE_SIZE){
           //从缓存取得数据:
           Vector copied = new Vector(logCache.size());
           for(int i=0;i<logCache.size();i++){
             copied.addElement(logCache.get(i));
           }
           logCache.clear();   //清除缓存数据
           writeToDB(copied);
         }
       }//end synchronized

     }catch(Exception e){
       System.out.println("LogUtil,e: "+e);
     }
   }

   /**
    * <pre>
    * 类名： LogBean
    * 描述： 用来缓存日志数据的类。一个对象代表一条日志记录
    * </pre>
    */
   private static class LogBean{
     String user_name;
     String client_ip;
     char operateTypeID;
     String operateTypeDesc;

     public LogBean(String user_name,String client_ip,
          char operateTypeID,String operateTypeDesc){
       this.user_name = user_name;
       this.client_ip = client_ip;
       this.operateTypeID = operateTypeID;
       this.operateTypeDesc = operateTypeDesc;
     }//
   }
 }

import java.io.*;
import java.util.zip.*;
import java.util.*;

public class UnZip {
 static final int BUFFER = 2048;     //设置缓冲流
 public static String[] unZip(String path) {
     String[] list = null;
     String patht = new String("文件路径");
   try {
     BufferedOutputStream dest = null;
     FileInputStream fis = new FileInputStream(path);   //获得输入流
     ZipInputStream zis = new ZipInputStream(new BufferedInputStream(fis));
     ZipEntry entry;
     while ( (entry = zis.getNextEntry()) != null) {
       int count;
       byte data[] = new byte[BUFFER];    //开始读入
       // 分文件写到磁盘
       FileOutputStream fos = new FileOutputStream(patht+entry.getName());
       dest = new BufferedOutputStream(fos, BUFFER);
       while ( (count = zis.read(data, 0, BUFFER))
              != -1) {
         dest.write(data, 0, count);  
       }
       //关闭流
       dest.flush();
       dest.close();
     }
     zis.close();
     File f = new File(patht);
     list = f.list(); //返回由path指定路径里的所有文件名和目录名
   }
   catch (Exception e) {
     e.printStackTrace();
   }
   return list;
 }
}

import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFCell;
import java.io.FileInputStream;
public class ReadXL {
　//
　public static String fileToBeRead="yourfile_dir";
　public static void main(String argv[]){
　try{
　　// 创建对Excel工作簿文件的引用
　　HSSFWorkbook workbook = new HSSFWorkbook(new FileInputStream(fileToBeRead));
　　HSSFSheet sheet = workbook.getSheet("Sheet");
　　HSSFRow row = sheet.getRow(0);
　　HSSFCell cell = row.getCell((short)0);
　　System.out.println("left_upon"+ cell.getStringCellValue());
　}catch(Exception e) {
　　......................|
　}
}
}

import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFCell;
import java.io.FileOutputStream;
public class CreateXL {

　//
　public static String outputFile="yourfile_dir";

　public static void main(String argv[]){

　try{

　　// 创建新的Excel
　　HSSFWorkbook workbook = new HSSFWorkbook();

　　HSSFSheet sheet = workbook.createSheet();
　　HSSFRow row = sheet.createRow((short)0);

　　//在索引0的位置创建单元格
　　HSSFCell cell = row.createCell((short) 0);
　　cell.setCellType(HSSFCell.CELL_TYPE_STRING);
　　cell.setCellValue("增加值");
　　FileOutputStream fOut = new FileOutputStream(outputFile);
　　workbook.write(fOut);
　　fOut.flush();
　　// 操作结束，关闭文件
　　fOut.close();
　　System.out.println("execute success...");

　}catch(Exception e) {
　　...................
　}
}
}

class CommentAutoMata{
   final int start=0;
   final int one=1;
   final int two=2;
   final int three=3;
   final int finalState=4;
   final int five=5;
   final int six=6;
   public List getCommentList(String s){
       ArrayList ret=new ArrayList();
       int begin=-1;      
       int curState=start;
       for(int i=0;i<s.length();i++){
           char c=s.charAt(i);
           switch(curState){
           case(start):
               if(c=='/'){
                   begin=i;
                   curState=one;
               }
               else if(c=='"'){
                   //识别字符出
                   curState=5;
               }
               break;
           case(one):
               if(c=='*') curState=two;
               else curState=start;            
               break;
           case(two):
               if(c=='*') curState=three;
               break;
           case(three):
               if(c=='/'){
                   curState=finalState;
                    //eat
                   ret.add(s.substring(begin,i+1));
                   //reset;
                   curState=start;
                   begin=-1;
               }
               else curState=two;
               break;
           case(five):
               if(c=='"') curState=start;
               else if(c=='\\')curState=six;
               break;
           case(six):
               curState=five;
               break;
             
           }
       }
       
       return ret;
   }
}

/**
* @author    李国庆
* @company   leemenz (C) copyright
* @time      Dec 18, 2006  2:08:18 PM
* @version   1.0.0.0
* @package   com
*/
package com;

import java.io.IOException;
import java.io.PrintWriter;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;

/**
* @author Administrator
*
* 这个过滤器用来过滤黑名单中的用户不能留言
*
*/
public class NoteFilter implements Filter {

private FilterConfig config = null;

private String blackList = null;

/*
 * (non-Javadoc)
 *
 * @see javax.servlet.Filter#destroy()
 */
public void destroy() {
 // TODO Auto-generated method stub
 config = null;
}

/*
 * (non-Javadoc)
 *
 * @see javax.servlet.Filter#doFilter(javax.servlet.ServletRequest,
 *      javax.servlet.ServletResponse, javax.servlet.FilterChain)
 */
public void doFilter(ServletRequest request, ServletResponse response,
  FilterChain chain) throws IOException, ServletException {
 // TODO Auto-generated method stub
 String username = request.getParameter("username");
 if (username != null)
  username = new String(request.getParameter("username").getBytes(
    "ISO8859-1"), "GB2312");
 if (username != null && username.indexOf(blackList) != -1) {
  response.setContentType("text/html;charset=GB2312");
  PrintWriter out = response.getWriter();
  out.println("<html><head></head><body>");
  out.println("<h1>对不起，" + username + ",您没有留言的权限！");
  out.println("</h1></body></html>");
  out.flush();
  return;
 }

 long before = System.currentTimeMillis();
 config.getServletContext()
   .log("NoteFilter:before call chain.Filter();");
 chain.doFilter(request, response);
 config.getServletContext().log("NoteFilter:after call chain.Filter();");
 long end = System.currentTimeMillis();
 String name = "";
 if (request instanceof javax.servlet.http.HttpServletRequest) {
  name = ((HttpServletRequest) request).getRequestURI();
 }
 config.getServletContext().log(
   "NoteFilter " + name + " : " + (end - before) + " ms");
}

/*
 * (non-Javadoc)
 *
 * @see javax.servlet.Filter#init(javax.servlet.FilterConfig)
 */
public void init(FilterConfig arg0) throws ServletException {
 // TODO Auto-generated method stub
 this.config = arg0;
 this.blackList = config.getInitParameter("blackList");
}

}


/**
* @author    李国庆
* @company   leemenz (C) copyright
* @time      Dec 18, 2006  2:08:18 PM
* @version   1.0.0.0
* @package   com
*/
package com;

import java.io.IOException;

import javax.servlet.ServletException;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/*
*测试页面
*/
public class NoteServlet extends HttpServlet {

public static final String CONTENT_TYPE = "text/html;charset=GB2312";

/**
 * Constructor of the object.
 */
public NoteServlet() {
 super();
}

/**
 * Destruction of the servlet. <br>
 */
public void destroy() {
 super.destroy(); // Just puts "destroy" string in log
 // Put your code here
}

/**
 * The doDelete method of the servlet. <br>
 *
 * This method is called when a HTTP delete request is received.
 *
 * @param request
 *            the request send by the client to the server
 * @param response
 *            the response send by the server to the client
 * @throws ServletException
 *             if an error occurred
 * @throws IOException
 *             if an error occurred
 */
public void doDelete(HttpServletRequest request,
  HttpServletResponse response) throws ServletException, IOException {

 // Put your code here
}

/**
 * The doGet method of the servlet. <br>
 *
 * This method is called when a form has its tag value method equals to get.
 *
 * @param request
 *            the request send by the client to the server
 * @param response
 *            the response send by the server to the client
 * @throws ServletException
 *             if an error occurred
 * @throws IOException
 *             if an error occurred
 */
public void doGet(HttpServletRequest request, HttpServletResponse response)
  throws ServletException, IOException {

 response.setContentType(CONTENT_TYPE);
 ServletOutputStream out = response.getOutputStream();
 out
   .println("<!DOCTYPE HTML PUBLIC \"-//W3C//DTD HTML 4.01 Transitional//EN\">");
 out.println("<HTML>");
 out.println("  <HEAD><TITLE>留言簿</TITLE></HEAD>");
 out.println("  <BODY>");

 String name = request.getParameter("username");
 String content = request.getParameter("content");

 if (name != null)
  name = new String(name.getBytes("ISO-8859-1"), "GB2312");
 if (content != null)
  content = new String(content.getBytes("ISO-8859-1"), "GB2312");

 if (content != null)
  out.println("<p> " + name + "的留言为：" + content);

 out.println("<form method=\"post\" action=\""
   + request.getContextPath() + "/servlet/NoteServlet\">");
 out.println("<b>姓名：</b><input type=\"text\" name=\"username\"></br>");
 out
   .println("<b>内容：</b><textArea name=\"content\" row=\"5\" cols=\"20\"　wrap></textArea></br>");
 out.println("<input type=\"submit\" name=\"提交\" value=\"提交\">");
 out.println("<input type=\"reset\" name=\"重填\" value=\"重填\"></br>");
 out.println("  </BODY>");
 out.println("</HTML>");
 out.flush();
 out.close();
}

/**
 * The doPost method of the servlet. <br>
 *
 * This method is called when a form has its tag value method equals to
 * post.
 *
 * @param request
 *            the request send by the client to the server
 * @param response
 *            the response send by the server to the client
 * @throws ServletException
 *             if an error occurred
 * @throws IOException
 *             if an error occurred
 */
public void doPost(HttpServletRequest request, HttpServletResponse response)
  throws ServletException, IOException {

 this.doGet(request, response);
}

/**
 * Initialization of the servlet. <br>
 *
 * @throws ServletException
 *             if an error occure
 */
public void init() throws ServletException {
 // Put your code here
}

}


/**
* @author    李国庆
* @company   leemenz (C) copyright
* @time      Dec 18, 2006  3:58:53 PM
* @version   1.0.0.0
* @package   com
*/
package com;

import java.io.IOException;

import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpServletResponseWrapper;

/**
* @author Administrator
* 　这个类继承HttpServletResponseWrapper ，并重写相应的方法
*/
public class ReplaceServletWapper extends HttpServletResponseWrapper {

private ReplaceTextStream tpStream;

/**
 * @param arg0
 */
public ReplaceServletWapper(HttpServletResponse arg0, String searchText,
  String replaceText) throws IOException {
 // TODO Auto-generated constructor stub
 super((HttpServletResponse)arg0);
 tpStream = new ReplaceTextStream(arg0.getOutputStream(),searchText,replaceText);
}

public ServletOutputStream getOutputStream() throws IOException {
 return tpStream;
}

}


/**
* @author    李国庆
* @company   leemenz (C) copyright
* @time      Dec 18, 2006  2:08:18 PM
* @version   1.0.0.0
* @package   com
*/
package com;

import java.io.IOException;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletResponse;

/**
* @author Administrator
*
* 这个类用来过滤留言或者是用户名中的非法内容
*
*/
public class ReplaceTextFilter implements Filter {

private FilterConfig config;

private String searchStr;

private String replaceStr;

/*
 * (non-Javadoc)
 *
 * @see javax.servlet.Filter#destroy()
 */
public void destroy() {
 // TODO Auto-generated method stub
 config = null;
}

/*
 * (non-Javadoc)
 *
 * @see javax.servlet.Filter#doFilter(javax.servlet.ServletRequest,
 *      javax.servlet.ServletResponse, javax.servlet.FilterChain)
 */
public void doFilter(ServletRequest request, ServletResponse response,
  FilterChain chain) throws IOException, ServletException {
 // TODO Auto-generated method stub
 ReplaceServletWapper myWrappered = new ReplaceServletWapper(
   (HttpServletResponse) response, searchStr, replaceStr);
 config.getServletContext().log(
   "ReplaceTextFilter : before called doFilter");
 chain.doFilter(request, myWrappered);
 config.getServletContext().log(
   "ReplaceTextFilter : after called doFilter");
 myWrappered.getOutputStream().close();
}

/*
 * (non-Javadoc)
 *
 * @see javax.servlet.Filter#init(javax.servlet.FilterConfig)
 */
public void init(FilterConfig arg0) throws ServletException {
 // TODO Auto-generated method stub
 this.config = arg0;
 this.searchStr = config.getInitParameter("search");
 this.replaceStr = config.getInitParameter("replace");
}

}


/**
* @author    李国庆
* @company   leemenz (C) copyright
* @time      Dec 18, 2006  3:33:51 PM
* @version   1.0.0.0
* @package   com
*/
package com;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.OutputStream;

import javax.servlet.ServletOutputStream;

/**
* @author Administrator
*  这个类继承ServletOutputStream ，并重写相应的方法
*/
public class ReplaceTextStream extends ServletOutputStream {

private OutputStream intStream;

private ByteArrayOutputStream baStream;

private boolean closed = false;

private String newStr;

private String oldStr;

/**
 *
 */
public ReplaceTextStream(OutputStream outStream, String strSearch,
  String strReplace) {
 // TODO Auto-generated constructor stub
 intStream = outStream;
 baStream = new ByteArrayOutputStream();
 oldStr = strSearch;
 newStr = strReplace;
}

/*
 * (non-Javadoc)
 *
 * @see java.io.OutputStream#write(int)
 */
public void write(int b) throws IOException {
 // TODO Auto-generated method stub
 baStream.write(b);
}

/**
 * 重写方法
 */
public void println(String s) throws IOException {
 s = s + "\n";
 byte[] bs = s.getBytes();
 baStream.write(bs);
}

/**
 * 重写方法
 */
public void close() throws IOException {
 if (!closed) {
  processStream();
  intStream.close();
  closed = true;
 }
}

/**
 * 重写方法
 */
public void flush() throws IOException {
 if (baStream.size() != 0) {
  processStream();
  baStream = new ByteArrayOutputStream();
 }
}

/**
 * 重写 processStream 方法
 *
 * @throws IOException
 */
public void processStream() throws IOException {
 intStream.write(replaceContent(baStream.toByteArray()));
}

/**
 * 替换所有的目的词语
 *
 * @param inBytes
 * @return
 */
public byte[] replaceContent(byte[] inBytes) {
 String retVal = "";
 String tpString = new String(inBytes);
 String srchString = (new String(inBytes)).toLowerCase();
 int endBody = srchString.indexOf(oldStr);
 if (endBody != -1) {
  retVal = tpString.replaceAll(oldStr, newStr);
 } else
  retVal = tpString;
 return retVal.getBytes();
}

}


<?xml version="1.0" encoding="GB2312"?>
<web-app version="2.4"
xmlns="http://java.sun.com/xml/ns/j2ee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">

<!--  -->

<filter>
 <filter-name>NoteFilter</filter-name>
 <filter-class>com.NoteFilter</filter-class>
 <init-param>
  <param-name>blackList</param-name>
  <param-value>毛泽东</param-value>
 </init-param>
</filter>

<filter-mapping>
 <filter-name>NoteFilter</filter-name>
 <url-pattern>/servlet/NoteServlet</url-pattern>
</filter-mapping>

<filter>
 <filter-name>ReplaceTextFilter</filter-name>
 <filter-class>com.ReplaceTextFilter</filter-class>
 <init-param>
  <param-name>search</param-name>
  <param-value>法轮功</param-value>
 </init-param>
 <init-param>
  <param-name>replace</param-name>
  <param-value>邪教</param-value>
 </init-param>
</filter>

<filter-mapping>
 <filter-name>ReplaceTextFilter</filter-name>
 <url-pattern>/servlet/NoteServlet</url-pattern>
</filter-mapping>

 <servlet>
   <servlet-name>NoteServlet</servlet-name>
   <servlet-class>com.NoteServlet</servlet-class>
 </servlet>

 <servlet-mapping>
   <servlet-name>NoteServlet</servlet-name>
   <url-pattern>/servlet/NoteServlet</url-pattern>
 </servlet-mapping>
</web-app>

<Logger className="org.apache.catalina.logger.FileLogger"
             prefix="catalina_log." suffix=".txt"
             timestamp="true"/>

enjoy it!!!   :)