package net.sjava.logging;

import java.util.Map;
import java.util.HashMap;

/**
 *
 * @author mcsong@gmail.com
 * @since 2009. 7. 1.
 */
public class LevelFactory {   
    /** map of levels     */
    private Map<String, Level> levelMap;

    /** singleton instance */
    private static LevelFactory instance = new LevelFactory();
   
    /** constructor */
    private LevelFactory() {
        this.levelMap = new HashMap<String, Level>();
       
        this.levelMap.put("all", new Level(0, "all"));
        this.levelMap.put("fatal", new Level(1, "fatal"));
        this.levelMap.put("error", new Level(2, "error"));
        this.levelMap.put("warn", new Level(3, "warn"));
        this.levelMap.put("info", new Level(4, "info"));
        this.levelMap.put("debug", new Level(5, "debug"));
        this.levelMap.put("trace", new Level(6, "trace"));
        this.levelMap.put("system", new Level(7, "system"));
    }
   
    /**
     *
     * @return
     */
    public static LevelFactory getInstance() {
        return instance;
    }
   
    /**
     *
     * @param level
     * @return
     */
    public Level getLevel(int level) {
        switch (level) {
        case 1:
            return this.getLevel("fatal");
        case 2:
            return this.getLevel("error");
        case 3:
            return this.getLevel("warn");
        case 4:
            return this.getLevel("info");
        case 5:
            return this.getLevel("debug");
        case 6:
            return this.getLevel("trace");
        case 7:
            return this.getLevel("system");
           
        default:
            return this.getLevel("all");
        }
    }
   
    /**
     *
     * @param name
     * @return
     */
    public Level getLevel(String name) {
        if (name == null)
            return null;
       
        if(!this.levelMap.containsKey(name.toLowerCase()))
            return (Level)this.levelMap.get("all");
       
        return (Level)this.levelMap.get(name.toLowerCase());
    }
}

package net.sjava.logging;

/**
 *
 * @author mcsong@gmail.com
 * @since 2009. 6. 19.
 */

public class Level {

    /** level number */
    public int level;
   
    /** level name */
    public String name;

    /**
     * Constructor
     *
     * @param level
     * @param name
     */
    public Level(int level, String name) {
        this.level = level;
        this.name = name;
    }
   
    /**
     * @return the level
     */
    public int getLevel() {
        return level;
    }

    /**
     * @param level the level to set
     */
    public void setLevel(int level) {
        this.level = level;
    }

    /**
     * @return the name
     */
    public String getName() {
        return name;
    }

    /**
     * @param name the name to set
     */
    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "name is " + this.name + ", level is " + this.level;
    }
}

package net.sjava.logging.test;

import net.sjava.logging.Logger;

import java.util.Date;
import java.text.SimpleDateFormat;

public class LoggingTest {

    private static SimpleDateFormat format = new SimpleDateFormat("yyyy.MM.dd HH:mm:ss SSS");
   
    /**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        //load();

        // add shutdown hook
        Runtime.getRuntime().addShutdownHook(new Thread() {
            public void run() {
                net.sjava.logging.util.BufferedWriterCacheUtility.shutdown();
            }
        });
       
        System.out.println("s - " + format.format(new Date()));
       
        for(int i=0; i < 1000000; i++) {
            Logger.getInstance().log("aaaaaaaaaaaaaaa");
            Logger.getInstance().log("aaaaaaaaaaaaccccccccccccccccccaaa");
           
            Logger.getInstance().log("metoo", "푸푸푸푸푸박.. ");
           
            Logger.getInstance().log("abcded", "abcde", "aaaa b aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa");
        }
   
        System.out.println("e - " + format.format(new Date()));
    }
}

<?xml version="1.0" encoding="utf-8"?>
<sjava-logging>
    <!-- array variable delimeter is "," -->
    <!-- do not delete  -->
    <sjava-service name="config">
        <key name="watch" value="false" /> <!-- true, false -->
        <key name="period" value="60" /> <!-- 60 seconds -->
    </sjava-service>
   
    <!-- 로그서버 설정 -->
    <sjava-service name="logging">
        <key name="baseDir" value="d:\sjava-logging" />
        <key name="serviceDir" value="default" />
        <key name="fileName" value="default" />
        <key name="fileExt" value="log" />
        <key name="bufferSize" value="1024" />
        <!-- dayily(1), hourly(2), minutes(3) -->
        <key name="strategy" value="2" />
    </sjava-service>
   
</sjava-logging>

package net.sjava.io.test;

import java.util.Map;
import java.util.LinkedHashMap;
import java.io.FileWriter;
import java.io.BufferedWriter;
import java.util.Iterator;

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class BufferedWriterCacheUtility {
   
    /** max cache size */
    private static final int size = 10;
    /** lock */
    private static Lock lock = new ReentrantLock();
   
    /** initialized lru cache */
    private static Map<String, BufferedWriter> cache = new LinkedHashMap<String, BufferedWriter> (size, .75F, true) {
        private static final long serialVersionUID = 1L;
        protected boolean removeEldestEntry(Map.Entry<String, BufferedWriter> eldest) {
            if(size() > size) {
                try {
                    // flush and close before deleted
                    eldest.getValue().close();
                } catch(java.io.IOException e) {
                    // ignore
                }
            }
           
            return size() > size;  
        }
    };

   
    /**
     *
     * @param fileName
     * @return
     */
    public static BufferedWriter createBufferedWriter(String fileName) {
        lock.lock();
        try{
            if(cache.containsKey(fileName))
                return cache.get(fileName);
       
            return new BufferedWriter(new FileWriter(fileName, true), 1024);
        } catch(java.io.IOException e) {
            e.printStackTrace();
            return null;
        } finally {
            lock.unlock();
        }
    }
   
    /**
     *
     * @param fileName
     * @param writer
     */
    public static void close(String fileName, BufferedWriter writer) {
        lock.lock();
        try {
            cache.put(fileName, writer);
        } finally {
            lock.unlock();
        }
    }
   
    /** shutdown hooking thread call */
    public static void shutdown() {
        // 아래의 코드를 통해서 종료가 되더라도 다 flush 하고 종료한다.     
        Iterator<BufferedWriter> iter = null;
        try {
            iter = cache.values().iterator();
            while (iter.hasNext()){
                iter.next().close();
                //iter.next().close();
            }
           
        }catch(java.io.IOException e) {
            e.printStackTrace();
        }
    }
}

package net.sjava.io.test;

import java.io.BufferedWriter;
import java.io.FileWriter;
import java.text.SimpleDateFormat;
import java.util.Date;

public class BufferedWriterTest {

    private static SimpleDateFormat format = new SimpleDateFormat("yyyy.MM.dd HH:mm:ss SSS");

    /**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        //load();
               
        System.out.println("s - " + format.format(new Date()));
       
        BufferedWriter bwriter01 = null;
        try {
            for(int i=0; i < 100000; i++) {
                bwriter01 = new BufferedWriter(new FileWriter("c:\\test01.txt", true), 1024);
                bwriter01.write("aaaaaaaaaaaaccccccccccccccccccaaa");
                bwriter01.newLine();
                bwriter01.flush();
                bwriter01.close();
            }
        } catch(java.io.IOException e) {
            e.printStackTrace();
        }
        System.out.println("e - " + format.format(new Date()));
        
        System.out.println("s - " + format.format(new Date()));
        BufferedWriter bwriter02 = null;
        try {
            bwriter02 = new BufferedWriter(new FileWriter("c:\\test02.txt", true), 1024);
            for(int i=0; i < 100000; i++) {
                bwriter02.write("aaaaaaaaaaaaccccccccccccccccccaaa");
                bwriter02.newLine();
            }
            bwriter02.flush();
            bwriter02.close();
        } catch(java.io.IOException e) {
            e.printStackTrace();
        }
        System.out.println("e - " + format.format(new Date()));        
        
        // 날짜별 혹은 서비스별로 로깅을 해야 될경우
        System.out.println("s - " + format.format(new Date()));
        BufferedWriter bwriter03 = null;
        try {
            for(int i=0; i < 100000; i++) {
                bwriter03 = BufferedWriterCacheUtility.createBufferedWriter("c:\\test03.txt");   
                bwriter03.write("aaaaaaaaaaaaccccccccccccccccccaaa");
                bwriter03.newLine();
                BufferedWriterCacheUtility.close("c:\\test03.txt", bwriter03);
            }
        } catch(java.io.IOException e) {
            e.printStackTrace();
        }
       
        System.out.println("e - " + format.format(new Date()));
    }

}

import java.util.Timer;
import java.util.TimerTask;

public class TimerTest {

    /**
     * @param args
     */
    public static void main(String[] args) throws Exception {
        Timer timer = new Timer("test");
        timer.schedule(new TimerTask() {
            public void run(){
                try {
                        Thread.sleep(2000);
                        System.out.println("- schedule job run at " + new java.util.Date());
                    } catch(Exception e) {
                        e.printStackTrace();
                    }
                }
            }, 0, 1000 * 1); // 10 초
       
       
        timer.scheduleAtFixedRate(new TimerTask() {
            public void run(){
                try {
                        Thread.sleep(2000);
                        System.out.println("- scheduleatfixedrate run at " + new java.util.Date());
                    } catch(Exception e) {
                        e.printStackTrace();
                    }
                }
            }, 0, 1000 * 1); // 10 초
    }
}