Go语言视频零基础入门到精通

javalearner

问题：写出这个工具的意义在于我运行一个需要长时间执行的程序，如单线程爬虫。在网络出现中断的或网站丢包情况下，
程序会抛出socketexception 和sockettimeoutexception。程序会中断。 解决方案：    java 并不能像C#一样对windows的进程进行监控（资料说这是跨平台原因）。因此没有api 提供对其他进程的监控
（如果在此您有其他办法，希望您给出宝贵建议）。所以很多人都是通过对文件的加锁，来判断程序是否在运行。 一、判断当前程序是否正在运行 在此我参考了： java 对文件的加锁。 http://www.examda.com/Java/jichu/20070411/140527453.HTML   
  
   
   
     
   

     
   
  
这里的思路是： 1、 在要监视的程序中（这里假设为爬虫）对一个用来判断程序是否运行的文件（自定义，无实际意义。只是一个空文件）
对文件进行加锁。 2、 在守护程序中写个简单的循环来实现按时探测。这里面比如说20秒。 3、 如果程序确实在运行（即文件不能再被加锁，因为已被锁），那么证明程序确实在运行，否则， 如果程序出现了网络异常而中断，那么runtime重新调用该程序。 (演示代码如下：注意不要忘了在爬虫程序中需要对文件进行加锁)。这样才有效。

1. import java.io.File;
   
2. import java.io.FileNotFoundException;
   
3. import java.io.IOException;
   
4. import java.io.RandomAccessFile;
   
5. import java.nio.channels.FileChannel;
   
6. import java.nio.channels.FileLock;
   
7. import data.BaseDataofConfiguration;
   
8. public class ThreadKeepTools {
   
9.     /**
   
10.     * 通过文件锁来判断程序是否正在运行
    
11.     * @return 如果正在运行返回true，否则返回false
    
12.     */
    
13.     private static boolean isRunning(String fileLockPath)
    
14.     {
    
15.         boolean rv=false;
    
16.         try {
    
17.                        
    
18.             RandomAccessFile fis = new RandomAccessFile(fileLockPath,"rw");
    
19.             FileChannel lockfc = fis.getChannel();
    
20.             FileLock flock = lockfc.tryLock();
    
21.             if(flock == null) {
    
22.                 System.out.println("程序正在运行.");
    
23.                 rv=true;
    
24.                
    
25.             }else {
    
26.                 flock.release();
    
27.             }
    
28.             
    
29.          
    
30.         } catch (FileNotFoundException e1) {
    
31.             e1.printStackTrace();
    
32.         }
    
33.         catch (IOException e) {
    
34.             e.printStackTrace();
    
35.         }
    
36.         return rv;
    
37.     }
    
38.    
    
39.     public static void ExcuteThread() throws InterruptedException{
    
40.         String strFilePath=BaseDataofConfiguration.baseUrlOfPro+"testThread.txt";//空文件
    
41.         String strBatPath=BaseDataofConfiguration.baseUrlOfPro+"run.bat";
    
42.         strBatPath=strBatPath.replaceFirst("/", "");
    
43.         while(true){
    
44.             System.out.println("strFilePath:"+strFilePath);
    
45.         boolean RunOrNOT=isRunning(strFilePath);
    
46.         System.out.println("RunOrNot:"+RunOrNOT);
    
47.         
    
48.         if(!RunOrNOT){
    
49.             try {
    
50.                 System.out.println("开始执行程序！");
    
51.             
    
52.                 Runtime.getRuntime().exec("cmd /k start "+strBatPath);
    
53.                 System.out.println("strbatpath:"+strBatPath);
    
54.             } catch (IOException e) {
    
55.                 // TODO Auto-generated catch block
    
56.                 e.printStackTrace();
    
57.             }
    
58.             
    
59.         }else {
    
60.             Thread.sleep(6000);
    
61.         }
    
62.         Thread.sleep(10000);
    
63.         
    
64.         }
    
65.     }
    
66.     public static void main(String[] args) {
    
67.         try {
    
68.             ExcuteThread();
    
69.         } catch (InterruptedException e) {
    
70.             // TODO Auto-generated catch block
    
71.             e.printStackTrace();
    
72.         }
    
73.     }
    
74. }
    

复制代码

  
  
   
   

     
   

     
   
  

复制代码