Explication détaillée d'exemples de méthodes pour la surveillance en temps réel et la sortie de fichiers journaux en Java

Cet article vous présente principalement la méthode de surveillance en temps réel et de sortie des fichiers journaux en Java. L'article la présente en détail à travers un exemple de code, qui a une certaine valeur de référence et d'apprentissage pour tous les amis qui en ont besoin. l'éditeur. Étudier et étudier.

Avant-propos

Récemment, il existe un système de blanchiment des données bancaires qui oblige l'opérateur à appeler le shell du serveur Linux distant sur la page et afficher le shell Les informations sont enregistrées dans un fichier journal et la page frontale doit afficher le contenu du fichier journal en temps réel. La difficulté de ce problème est de savoir quelles données sont nouvellement ajoutées. . En consultant le document d'aide du JDK,

java.io.RandomAccessFileCe problème peut être résolu. Afin de simuler ce problème, écrivez les classes LogSvr et LogSvr en continu pour écrire des données dans le fichier journal mock.log. LogView génère les données de la partie modifiée du journal en temps réel.

Code 1 : Classe de génération de journaux

package com.bill99.seashell.domain.svr; 
 
import java.io.File; 
import java.io.FileWriter; 
import java.io.IOException; 
import java.io.Writer; 
import java.text.SimpleDateFormat; 
import java.util.Date; 
import java.util.concurrent.Executors; 
import java.util.concurrent.ScheduledExecutorService; 
import java.util.concurrent.TimeUnit; 
/** 
 *<p>title: 日志服务器</p> 
 *<p>Description: 模拟日志服务器</p> 
 *<p>CopyRight: CopyRight (c) 2010</p> 
 *<p>Company: 99bill.com</p> 
 *<p>Create date: 2010-6-18</P> 
 *@author Tank Zhang<tank.zhang@99bill.com> 
 *@version v0.1 2010-6-18 
 */ 
public class LogSvr { 
  
 private SimpleDateFormat dateFormat = 
  new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
 
 /** 
  * 将信息记录到日志文件 
  * @param logFile 日志文件 
  * @param mesInfo 信息 
  * @throws IOException 
  */ 
 public void logMsg(File logFile,String mesInfo) throws IOException{ 
  if(logFile == null) { 
   throw new IllegalStateException("logFile can not be null!"); 
  } 
  Writer txtWriter = new FileWriter(logFile,true); 
  txtWriter.write(dateFormat.format(new Date()) +"\t"+mesInfo+"\n"); 
  txtWriter.flush(); 
 } 
  
 public static void main(String[] args) throws Exception{ 
   
  final LogSvr logSvr = new LogSvr(); 
  final File tmpLogFile = new File("mock.log"); 
  if(!tmpLogFile.exists()) { 
   tmpLogFile.createNewFile(); 
  } 
  //启动一个线程每5秒钟向日志文件写一次数据 
  ScheduledExecutorService exec = 
   Executors.newScheduledThreadPool(1); 
  exec.scheduleWithFixedDelay(new Runnable(){ 
   public void run() { 
    try { 
     logSvr.logMsg(tmpLogFile, " 99bill test !"); 
    } catch (IOException e) { 
     throw new RuntimeException(e); 
    } 
   } 
  }, 0, 5, TimeUnit.SECONDS); 
 } 
}

Code 2 : Classe d'affichage du journal

package com.bill99.seashell.domain.client;  
 
import java.io.File;  
import java.io.IOException;  
import java.io.RandomAccessFile;  
import java.util.concurrent.Executors;  
import java.util.concurrent.ScheduledExecutorService;  
import java.util.concurrent.TimeUnit;  
 
public class LogView {  
 private long lastTimeFileSize = 0; //上次文件大小  
 /** 
  * 实时输出日志信息 
  * @param logFile 日志文件 
  * @throws IOException 
  */ 
 public void realtimeShowLog(File logFile) throws IOException{  
  //指定文件可读可写  
  final RandomAccessFile randomFile = new RandomAccessFile(logFile,"rw");  
  //启动一个线程每10秒钟读取新增的日志信息  
  ScheduledExecutorService exec =  
   Executors.newScheduledThreadPool(1);  
  exec.scheduleWithFixedDelay(new Runnable(){  
   public void run() {  
    try {  
     //获得变化部分的  
     randomFile.seek(lastTimeFileSize);  
     String tmp = "";  
     while( (tmp = randomFile.readLine())!= null) {  
      System.out.println(new String(tmp.getBytes("ISO8859-1")));  
     }  
     lastTimeFileSize = randomFile.length();  
    } catch (IOException e) {  
     throw new RuntimeException(e);  
    }  
   }  
  }, 0, 1, TimeUnit.SECONDS);  
 }  
   
 public static void main(String[] args) throws Exception {  
  LogView view = new LogView();  
  final File tmpLogFile = new File("mock.log");  
  view.realtimeShowLog(tmpLogFile);  
 }  
 
}

Exécuter la classe LogSvr La classe LogSvr démarrera un thread et écrira des données dans le fichier journal mock.log. toutes les 5 secondes. Exécutez ensuite la classe LogView. LogView la lira toutes les 1 secondes si les données changent.

Le résultat est :

.

2010-06-19 17:25:54 99bill test !
2010-06-19 17:25:59 99bill test !
2010-06-19 17:26:04 99bill test !
2010-06-19 17:26:09 99bill test !
2010-06-19 17:26:14 99bill test !
2010-06-19 17:26:19 99bill test !

PS :

Le code a été modifié. Un ami a téléchargé mon code et a dit que s'il est chinois, il sera tronqué si vous le changez. le code sur la ligne 30 de la classe de sortie du journal System.out.println(tmp) à System.out.println(new String(tmp.getBytes("ISO8859-1"))), le chinois s'affichera normalement

.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!