${log_path}/api.ln.log
             
                 
      
       ${log_path}/api.%d{yyyy-MM-dd_HH}.log
                  
                  
      
       10
                  
      
       8GB
              
             
                 
      
       %d{MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n
              
         
    

// ch.qos.logback.core.joran.spi.EventPlayer    public void play(List
    
      aSaxEventList) {        eventList = aSaxEventList;        SaxEvent se;        for (currentIndex = 0; currentIndex < eventList.size(); currentIndex++) {            se = eventList.get(currentIndex);            if (se instanceof StartEvent) {                interpreter.startElement((StartEvent) se);                // invoke fireInPlay after startElement processing                interpreter.getInterpretationContext().fireInPlay(se);            }            if (se instanceof BodyEvent) {                // invoke fireInPlay before characters processing                interpreter.getInterpretationContext().fireInPlay(se);                interpreter.characters((BodyEvent) se);            }            // rollingPollicy 在此处调唤醒            if (se instanceof EndEvent) {                // invoke fireInPlay before endElement processing                interpreter.getInterpretationContext().fireInPlay(se);                interpreter.endElement((EndEvent) se);            }        }    }
    

// ch.qos.logback.core.joran.spi.Interpreter    private void callEndAction(List
    
      applicableActionList, String tagName) {        if (applicableActionList == null) {            return;        }        // logger.debug("About to call end actions on node: [" + localName + "]");        Iterator
     
       i = applicableActionList.iterator();        while (i.hasNext()) {            Action action = i.next();            // now let us invoke the end method of the action. We catch and report            // any eventual exceptions            try {                action.end(interpretationContext, tagName);            } catch (ActionException ae) {                // at this point endAction, there is no point in skipping children as                // they have been already processed                cai.addError("ActionException in Action for tag [" + tagName + "]", ae);            } catch (RuntimeException e) {                // no point in setting skip                cai.addError("RuntimeException in Action for tag [" + tagName + "]", e);            }        }    }
     
    

// ch.qos.logback.core.rolling.TimeBasedRollingPolicy    public void start() {        // set the LR for our utility object        renameUtil.setContext(this.context);        // find out period from the filename pattern        if (fileNamePatternStr != null) {            fileNamePattern = new FileNamePattern(fileNamePatternStr, this.context);            determineCompressionMode();        } else {            addWarn(FNP_NOT_SET);            addWarn(CoreConstants.SEE_FNP_NOT_SET);            throw new IllegalStateException(FNP_NOT_SET + CoreConstants.SEE_FNP_NOT_SET);        }        compressor = new Compressor(compressionMode);        compressor.setContext(context);        // wcs : without compression suffix        fileNamePatternWithoutCompSuffix = new FileNamePattern(Compressor.computeFileNameStrWithoutCompSuffix(fileNamePatternStr, compressionMode), this.context);        addInfo("Will use the pattern " + fileNamePatternWithoutCompSuffix + " for the active file");        if (compressionMode == CompressionMode.ZIP) {            String zipEntryFileNamePatternStr = transformFileNamePattern2ZipEntry(fileNamePatternStr);            zipEntryFileNamePattern = new FileNamePattern(zipEntryFileNamePatternStr, context);        }        // 默认会使用 DefaultTimeBasedFileNamingAndTriggeringPolicy 进行滚动        if (timeBasedFileNamingAndTriggeringPolicy == null) {            timeBasedFileNamingAndTriggeringPolicy = new DefaultTimeBasedFileNamingAndTriggeringPolicy
    
     ();        }        timeBasedFileNamingAndTriggeringPolicy.setContext(context);        timeBasedFileNamingAndTriggeringPolicy.setTimeBasedRollingPolicy(this);        timeBasedFileNamingAndTriggeringPolicy.start();        if (!timeBasedFileNamingAndTriggeringPolicy.isStarted()) {            addWarn("Subcomponent did not start. TimeBasedRollingPolicy will not start.");            return;        }        // the maxHistory property is given to TimeBasedRollingPolicy instead of to        // the TimeBasedFileNamingAndTriggeringPolicy. This makes it more convenient        // for the user at the cost of inconsistency here.        if (maxHistory != UNBOUND_HISTORY) {            archiveRemover = timeBasedFileNamingAndTriggeringPolicy.getArchiveRemover();            archiveRemover.setMaxHistory(maxHistory);            archiveRemover.setTotalSizeCap(totalSizeCap.getSize());            if (cleanHistoryOnStart) {                addInfo("Cleaning on start up");                Date now = new Date(timeBasedFileNamingAndTriggeringPolicy.getCurrentTime());                cleanUpFuture = archiveRemover.cleanAsynchronously(now);            }        } else if (!isUnboundedTotalSizeCap()) {            addWarn("'maxHistory' is not set, ignoring 'totalSizeCap' option with value ["+totalSizeCap+"]");        }        // 调用父类start(), 设置启动标识，不允许多次调用初始化        super.start();    }    // DefaultTimeBasedFileNamingAndTriggeringPolicy 的实现，设置类功能主要还是调用 TimeBasedFileNamingAndTriggeringPolicy 的方法，而其自身，则是处理一些异常情况,以及开启一个 Remover, 供具体的实现调用    @Override    public void start() {        super.start();        if (!super.isErrorFree())            return;        if(tbrp.fileNamePattern.hasIntegerTokenCOnverter()) {            addError("Filename pattern ["+tbrp.fileNamePattern+"] contains an integer token converter, i.e. %i, INCOMPATIBLE with this configuration. Remove it.");            return;        }                archiveRemover = new TimeBasedArchiveRemover(tbrp.fileNamePattern, rc);        archiveRemover.setContext(context);        started = true;    }    // TimeBasedFileNamingAndTriggeringPolicy, 则实际处理日志的滚动逻辑了    public void start() {        DateTokenConverter
     
    

// ch.qos.logback.core.ch.qos.logback.core.rolling.RollingFileAppender, 其接入口为: UnsynchronizedAppenderBase.doAppend()   // ch.qos.logback.core.OutputStreamAppender    @Override    protected void append(E eventObject) {        if (!isStarted()) {            return;        }        // 调用 RollingFileAppender 实现        subAppend(eventObject);    }   // ch.qos.logback.core.ch.qos.logback.core.rolling.RollingFileAppender    @Override    protected void subAppend(E event) {        // The roll-over check must precede actual writing. This is the        // only correct behavior for time driven triggers.        // We need to synchronize on triggeringPolicy so that only one rollover        // occurs at a time        synchronized (triggeringPolicy) {            if (triggeringPolicy.isTriggeringEvent(currentlyActiveFile, event)) {                rollover();            }        }        super.subAppend(event);    }

// ch.qos.logback.core.rolling.DefaultTimeBasedFileNamingAndTriggeringPolicy    public boolean isTriggeringEvent(File activeFile, final E event) {        long time = getCurrentTime();        if (time >= nextCheck) {            Date dateOfElapsedPeriod = dateInCurrentPeriod;            addInfo("Elapsed period: " + dateOfElapsedPeriod);            elapsedPeriodsFileName = tbrp.fileNamePatternWithoutCompSuffix.convert(dateOfElapsedPeriod);            setDateInCurrentPeriod(time);            computeNextCheck();            return true;        } else {            return false;        }    }

/**     * Implemented by delegating most of the rollover work to a rolling policy.     */    public void rollover() {        // 此处lock为 ReentrantLock, 即是互斥锁，只能一个线程可访问！        lock.lock();        try {            // Note: This method needs to be synchronized because it needs exclusive            // access while it closes and then re-opens the target file.            //            // make sure to close the hereto active log file! Renaming under windows            // does not work for open files.            this.closeOutputStream();            attemptRollover();            attemptOpenFile();        } finally {            lock.unlock();        }    }    // 滚动文件逻辑，调用设置的 policy 实现进行滚动，此处我设置的是 TimeBasedRollingPolicy    private void attemptRollover() {        try {            rollingPolicy.rollover();        } catch (RolloverFailure rf) {            addWarn("RolloverFailure occurred. Deferring roll-over.");            // we failed to roll-over, let us not truncate and risk data loss            this.append = true;        }    }    // ch.qos.logback.core.rolling.TimeBasedRollingPolicy rollover    public void rollover() throws RolloverFailure {        // when rollover is called the elapsed period's file has        // been already closed. This is a working assumption of this method.        String elapsedPeriodsFileName = timeBasedFileNamingAndTriggeringPolicy.getElapsedPeriodsFileName();        String elapsedPeriodStem = FileFilterUtil.afterLastSlash(elapsedPeriodsFileName);        if (compressionMode == CompressionMode.NONE) {            if (getParentsRawFileProperty() != null) {                renameUtil.rename(getParentsRawFileProperty(), elapsedPeriodsFileName);            } // else { nothing to do if CompressionMode == NONE and parentsRawFileProperty == null }        } else {            if (getParentsRawFileProperty() == null) {                compressionFuture = compressor.asyncCompress(elapsedPeriodsFileName, elapsedPeriodsFileName, elapsedPeriodStem);            } else {                compressionFuture = renameRawAndAsyncCompress(elapsedPeriodsFileName, elapsedPeriodStem);            }        }        if (archiveRemover != null) {            Date now = new Date(timeBasedFileNamingAndTriggeringPolicy.getCurrentTime());            this.cleanUpFuture = archiveRemover.cleanAsynchronously(now);        }    }

// ch.qos.logback.core.rolling.helper.RenameUtil    /**     * A relatively robust file renaming method which in case of failure due to     * src and target being on different volumes, falls back onto     * renaming by copying.     *     * @param src     * @param target     * @throws RolloverFailure     */    public void rename(String src, String target) throws RolloverFailure {        if (src.equals(target)) {            addWarn("Source and target files are the same [" + src + "]. Skipping.");            return;        }        File srcFile = new File(src);        if (srcFile.exists()) {            // 如果目录不存在，会先去创建目录，所以你可以滚动到其他地方，而目录位置则不用管（权限除外）            File targetFile = new File(target);            createMissingTargetDirsIfNecessary(targetFile);            addInfo("Renaming file [" + srcFile + "] to [" + targetFile + "]");            boolean result = srcFile.renameTo(targetFile);            // 对于直接重命名失败，则会再次尝试，如果在不同的分区，则会使用一次文件复制的方式进行一次重命名,具体做法是，先把文件copy到新地址，然后再将当前文件删除            if (!result) {                addWarn("Failed to rename file [" + srcFile + "] as [" + targetFile + "].");                Boolean areOnDifferentVolumes = areOnDifferentVolumes(srcFile, targetFile);                if (Boolean.TRUE.equals(areOnDifferentVolumes)) {                    addWarn("Detected different file systems for source [" + src + "] and target [" + target + "]. Attempting rename by copying.");                    renameByCopying(src, target);                    return;                } else {                    addWarn("Please consider leaving the [file] option of " + RollingFileAppender.class.getSimpleName() + " empty.");                    addWarn("See also " + RENAMING_ERROR_URL);                }            }        } else {            throw new RolloverFailure("File [" + src + "] does not exist.");        }    }

public Future
     cleanAsynchronously(Date now) {        ArhiveRemoverRunnable runnable = new ArhiveRemoverRunnable(now);        ExecutorService executorService = context.getScheduledExecutorService();        Future
     future = executorService.submit(runnable);        return future;    }

public class ArhiveRemoverRunnable implements Runnable {        Date now;        ArhiveRemoverRunnable(Date now) {            this.now = now;        }        @Override        public void run() {            // 先清除当前文件，再根据设置的最大值，删除列表            clean(now);            if (totalSizeCap != UNBOUNDED_TOTAL_SIZE_CAP && totalSizeCap > 0) {                capTotalSize(now);            }        }    }    public void clean(Date now) {         long nowInMillis = now.getTime();        // for a live appender periodsElapsed is expected to be 1        int periodsElapsed = computeElapsedPeriodsSinceLastClean(nowInMillis);        lastHeartBeat = nowInMillis;        if (periodsElapsed > 1) {            addInfo("Multiple periods, i.e. " + periodsElapsed + " periods, seem to have elapsed. This is expected at application start.");        }        for (int i = 0; i < periodsElapsed; i++) {            // 此处会根据 maxHistory 进行 -1 后清除文件，即: 只会清理 periodsElapsed 次历史日志            int offset = getPeriodOffsetForDeletionTarget() - i;            Date dateOfPeriodToClean = rc.getEndOfNextNthPeriod(now, offset);            cleanPeriod(dateOfPeriodToClean);        }    }    public void cleanPeriod(Date dateOfPeriodToClean) {        // 获取需要删除的文件列表，然后依次删除，如果文件夹内的文件全部被删除，则将文件夹删除        File[] matchingFileArray = getFilesInPeriod(dateOfPeriodToClean);        for (File f : matchingFileArray) {            addInfo("deleting " + f);            f.delete();        }        if (parentClean && matchingFileArray.length > 0) {            File parentDir = getParentDir(matchingFileArray[0]);            removeFolderIfEmpty(parentDir);        }    }    // 按规则匹配需要删除的文件    protected File[] getFilesInPeriod(Date dateOfPeriodToClean) {        String filenameToDelete = fileNamePattern.convert(dateOfPeriodToClean);        File file2Delete = new File(filenameToDelete);        if (fileExistsAndIsFile(file2Delete)) {            return new File[] { file2Delete };        } else {            return new File[0];        }    }    // 清理历史文件逻辑，注意要想清理历史文件，就一定要设置好 totalSizeCap, 否则，不会进行自动清理！    void capTotalSize(Date now) {        long totalSize = 0;        long totalRemoved = 0;        for (int offset = 0; offset < maxHistory; offset++) {            Date date = rc.getEndOfNextNthPeriod(now, -offset);            File[] matchingFileArray = getFilesInPeriod(date);            descendingSortByLastModified(matchingFileArray);            for (File f : matchingFileArray) {                long size = f.length();                if (totalSize + size > totalSizeCap) {                    addInfo("Deleting [" + f + "]" + " of size " + new FileSize(size));                    totalRemoved += size;                    f.delete();                }                totalSize += size;            }        }        addInfo("Removed  " + new FileSize(totalRemoved) + " of files");    }

// 滚动时机判定    // ch.qos.logback.core.rolling.helper.RollingCalendar    public Date getEndOfNextNthPeriod(Date now, int periods) {        return innerGetEndOfNextNthPeriod(this, this.periodicityType, now, periods);    }    static private Date innerGetEndOfNextNthPeriod(Calendar cal, PeriodicityType periodicityType, Date now, int numPeriods) {        cal.setTime(now);        switch (periodicityType) {        case TOP_OF_MILLISECOND:            cal.add(Calendar.MILLISECOND, numPeriods);            break;        case TOP_OF_SECOND:            cal.set(Calendar.MILLISECOND, 0);            cal.add(Calendar.SECOND, numPeriods);            break;        case TOP_OF_MINUTE:            cal.set(Calendar.SECOND, 0);            cal.set(Calendar.MILLISECOND, 0);            cal.add(Calendar.MINUTE, numPeriods);            break;        case TOP_OF_HOUR:            cal.set(Calendar.MINUTE, 0);            cal.set(Calendar.SECOND, 0);            cal.set(Calendar.MILLISECOND, 0);            cal.add(Calendar.HOUR_OF_DAY, numPeriods);            break;        case TOP_OF_DAY:            cal.set(Calendar.HOUR_OF_DAY, 0);            cal.set(Calendar.MINUTE, 0);            cal.set(Calendar.SECOND, 0);            cal.set(Calendar.MILLISECOND, 0);            cal.add(Calendar.DATE, numPeriods);            break;        case TOP_OF_WEEK:            cal.set(Calendar.DAY_OF_WEEK, cal.getFirstDayOfWeek());            cal.set(Calendar.HOUR_OF_DAY, 0);            cal.set(Calendar.MINUTE, 0);            cal.set(Calendar.SECOND, 0);            cal.set(Calendar.MILLISECOND, 0);            cal.add(Calendar.WEEK_OF_YEAR, numPeriods);            break;        case TOP_OF_MONTH:            cal.set(Calendar.DATE, 1);            cal.set(Calendar.HOUR_OF_DAY, 0);            cal.set(Calendar.MINUTE, 0);            cal.set(Calendar.SECOND, 0);            cal.set(Calendar.MILLISECOND, 0);            cal.add(Calendar.MONTH, numPeriods);            break;        default:            throw new IllegalStateException("Unknown periodicity type.");        }        return cal.getTime();    }

yum install cronolog -y

tar -zxvf cronolog-bin.tar.gz -C /

hehe...

$> | /usr/local/sbin/cronolog -S /var/logs/ai_ln.out /var/logs/ai.%Y-%m-%d-%H.out

exec nohup java -jar /www/aproj\.jar 2>&1 | /usr/local/sbin/cronolog -S /var/logs/ai_ln.out /var/logs/ai.%Y-%m-%d-%H.out >> /dev/null &

exec nohup java -jar /www/aproj\.jar 2>&1 | /usr/local/sbin/cronolog -S /var/logs/ai_ln.out /var/logs/ai.%Y-%m-%d-%H.out >> /dev/null 2>&1 &

/* Loop, waiting for data on standard input */    for (;;)    {        /**          * Read a buffer's worth of log file data, exiting on errors         * or end of file.         */        n_bytes_read = read(0, read_buf, sizeof read_buf);        if (n_bytes_read == 0)        {            exit(3);        }        if (errno == EINTR)        {            continue;        }        else if (n_bytes_read < 0)        {            exit(4);        }        time_now = time(NULL) + time_offset;                /**         * If the current period has finished and there is a log file         * open, close the log file         */        if ((time_now >= next_period) && (log_fd >= 0))        {            close(log_fd);            log_fd = -1;        }                /**          * If there is no log file open then open a new one.         */        if (log_fd < 0)        {            log_fd = new_log_file(template, linkname, linktype, prevlinkname,                      periodicity, period_multiple, period_delay,                      filename, sizeof (filename), time_now, &next_period);        }        DEBUG(("%s (%d): wrote message; next period starts at %s (%d) in %d secs\n",               timestamp(time_now), time_now,                timestamp(next_period), next_period,               next_period - time_now));        /**         * Write out the log data to the current log file.         */        if (write(log_fd, read_buf, n_bytes_read) != n_bytes_read)        {            perror(filename);            exit(5);        }    }

# vim clean_log.sh        find /var/logs/ai -mtime +8 -name "ai.*out" -exec rm -rf {} \;    # 然后在 crontab 中加入执行时机即可，一般一天一次！        0 0  * * * sh clean_log.sh

#!/bin/bashlog_path_prefix=/opt/springboot/logsexpire_hours=3;expire_minutes=$[ expire_hours * 60 ];now_time=`date "+%Y-%m-%d %H:%M:%S"`echo "-At $now_time";# del functionfunction del_expire_logs() {    find_cmd="find $1 -mmin +${2} -type f "    if [ "$3" != "" ]; then        find_cmd="$find_cmd -name '$3'";    fi;    echo " -Cmd: $find_cmd";    f_expired_files=`eval $find_cmd`;    echo " -Find result: $f_expired_files";    if [ "$f_expired_files" != "" ]; then        file_list=($f_expired_files);        for item in ${file_list[@]};        do            echo " -Del file: $item";            rm -rf $item;                done;    fi;}del_expire_logs $log_path_prefix $expire_minutes "*.out";log_path_prefix2=/opt/logs$expire_minutes2=2880;        # for 2 daydel_expire_logs $log_path_prefix2 $expire_minutes2;