最近开发一个进程监控的服务，由于对windows api不熟，所以折腾了小两周才完全跑通，特记录一下

 
 

  1
   由于需求需要根据进程名来进行监控，所以首先要根据进程名来获取进程句柄（同名进程可能有多个，比如，起了多个notepad.exe）
 
 

   
 
 

  

   //通过进程名获取进程句柄集
  
  

   //
    返回值为 同名进程个数（不超过20个）
  
  

   int getProcessHandle(LPCWSTR lpName, HANDLE pH[20])  
  
  

   {
  
  

    int num = 0;
  
  

       HANDLE hSnapshot = CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0);  
  
  

       if (INVALID_HANDLE_VALUE == hSnapshot)
  
  

       {  
  
  

           return 0;
  
  

       }  
  
  

       PROCESSENTRY32 pe = { sizeof(pe) };
  
  

       BOOL fOk;  
  
  

       for (fOk = Process32First(hSnapshot, &pe); fOk; fOk = Process32Next(hSnapshot, &pe))  
  
  

       {
  
  

   

  
  

    if (!_tcsicmp(pe.szExeFile, lpName))
  
  

           {
  
  

    pH[num++] = OpenProcess(PROCESS_ALL_ACCESS, FALSE, pe.th32ProcessID);
  
  

           }
  
  

    //
    同名进程超过20个，返回20个
  
  

    if (num > 20)
  
  

    {
  
  

    num = 20;
  
  

    break;
  
  

    }
  
  

       }
  
  

    CloseHandle(hSnapshot);
  
  

       return num;  
  
  

   }
  
 
 


2    根据进程句柄来获取程序开始运行的时间（多个同名进程里最早的一个）
               earliesttime = COleDateTime::GetCurrentTime();
 for (i = 0; i < number; i++)
 {
 GetProcessTimes(hProcess[i], &ftCreation, &ftExit, &ftKernel, &ftUser);
 if ((earliesttime - (COleDateTime(ftCreation))).GetTotalSeconds() > 0){
 earliesttime = ftCreation;
 }

 }
3     创建子线程，来监听该程序名的所有进程句柄的结束事件，将结束时间写入redis
 for (int j = 0; j < number; j++){
 pDataArray[ncount]->hProcess[j] = hProcess[j];
}
pDataArray[ncount]->procname = _strdup(name);
pDataArray[ncount]->num = number;

hThreadArray[ncount] = (HANDLE)_beginthreadex(NULL, 0, &MyThreadFunction, pDataArray[ncount], 0, NULL);
unsigned int _stdcall MyThreadFunction(LPVOID lpParam)
{
 char endtime[BUFFERSIZE] = "";
 char buffer[BUFFERSIZE] = "";
 char buff[BUFFERSIZE] = "";
 HANDLE hProcess[20];
 int number = 0;
 int flag = 1;
 DWORD nret;
 redisContext* c;
 COleDateTime timeCreation, timeNow;

 PMYDATA  pDataArray = (PMYDATA)lpParam;
// printf("thread--------------name=[%s]-----tid=[%ld]\n", pDataArray->procname, GetCurrentThreadId());

 if (pDataArray->num > 1)
 {
 nret = WaitForMultipleObjects(pDataArray->num, pDataArray->hProcess, TRUE, TIMEOUT);
 }
 else if (pDataArray->num == 1)
 {
 nret = WaitForSingleObject(pDataArray->hProcess[0], TIMEOUT);
 }

 switch (nret)
 {
 case WAIT_OBJECT_0:
 // 所有同名进程都结束，则写endtime
 number = getProcessHandle(T2W((LPTSTR)CString(pDataArray->procname).GetBuffer(NULL)), hProcess);
 if (!number)
 {
 sprintf_s(buff, BUFFERSIZE, "%s", removeSuffix(pDataArray->procname, ".exe"));
 _strlwr_s(buff, BUFFERSIZE);
 timeNow = COleDateTime::GetCurrentTime();
 sprintf_s(endtime, "%02d:%02d:%02d", timeNow.GetHour(), timeNow.GetMinute(), timeNow.GetSecond(), BUFFERSIZE);
 sprintf_s(buffer, "rpush %s|%s|%04d-%02d-%02d endtime|%s", mac, buff, timeNow.GetYear(), timeNow.GetMonth(), timeNow.GetDay(), endtime);
                        //    将进程结束时间写入 redis
 c = redisConnect(redisip, redisport);
 if (c->err)
 {
 printf("Connect to redisServer failed:%s\n", c->errstr);
 redisFree(c);
 return -1;
 }
 if (rpushString(c, buffer))
 {
 printf("setString error [%s]\n", buffer);
 }
 redisFree(c);
 } 
 break;
 case WAIT_TIMEOUT:
 // 超时，退出
 ;;
 break;
 case WAIT_ABANDONED_0:
 ;;
 break;
 case WAIT_FAILED:
 // 函数调用失败，比如传递了一个无效的句柄
 ;;
 break;
 }
 return 0;

}
4    将监控事件做成定时事件，30秒跑一次
    timer_id = timeSetEvent(TIMEOUT+1000, 1, (LPTIMECALLBACK)onTimeFunc, DWORD(1), TIME_PERIODIC);

5    套上SCManager框架，将程序做成服务，把状态传入SCManager

 
 
该监控工具，可以监控所有注册表/文件/进程的所有操作
 
 
转载于:https://my.oschina.net/tomlin/blog/3064550

 java调用bat:如果要和Runtime创建的进程交互，必须自己写交互的代码，例如通过socket，两个java进程互相通信。
 
import java.io.IOException;

public class Main {

public static void main(String[] args){
try {
Runtime rt = Runtime.getRuntime();
rt.exec("cmd.exe /c start c:\\1.bat");
} catch (IOException e) {
e.printStackTrace();
}
}
/* 1.bat的内容
* @echo off
* echo lsd>>c:\lsd.txt
*
* */
}
   


 java监控windows下的某一进程是否关闭：应为这里直接调用的操作系统带的命令，所以可以直接用getInputStream()来获得操作系统的反馈信息。如果调用命令启动另一个java应用，两个java应用互相交互，则getInputStream()就没用了。
 
ProcessBuilder pb = new ProcessBuilder("tasklist");
try {
Process p = pb.start();
BufferedReader rb = new BufferedReader(new InputStreamReader(p.getInputStream()));
String line;
String storeLine="";
while((line=rb.readLine())!=null){
if(line.indexOf("eclipse.exe")!=-1)//过滤进程eclipse.exe的信息
storeLine = line;
System.out.println(line);
}
//获取进程的pid号
if(storeLine!=""){
int beginIndex = storeLine.indexOf("exe");
int endIndex = storeLine.indexOf("Console");
String pid = storeLine.substring(beginIndex+3, endIndex).trim();
System.out.println("this process id is "+pid);
}else{
System.out.println("this process is not exist");
} 
   
 
 
 

 
 
相信大家都有这样的需求，某程序（进程）在运行的时候可能挂掉，需要去监控该程序，并在它挂掉的时候重启之，确保该程序能一直运行。比如土net就经常挂，需要监控程序去监控。Linux下面似乎有守护进程的概念，Windows下面其实也很简单，dos批处理就可以搞定:-)

 需要了解如下几个命令，tasklist +find，ping。tasklist是列出所有进程，可以指定只列出某用户的进程，用/FI参数过滤。find/C可以去tasklist的结果中查找指定进程名，并输出个数。

 还有个问题是如何设置每隔一段时间去检测进程是否在运行，我用的是ping命令自带的延迟参数-w，将IP地址设置成一个空地址，比如0.0.0.1，这样该命令会一直ping，直到一定n*w毫秒后才返回（n和w分别是参数-n和-w指定的值）。

 示例程序如下，红色部分需要根据需求进行替换，enjoy it！
 
 

 :RESTART
 tasklist /FI "username eq bigtree" |find /C "java" >temp.txt
 set /p num= < temp.txt
 del /F temp.txt
 echo %num%

 if "%num%" == "0" 
 
 

         start /D"E:Userbigtreeprogramcomparison"pos
  

  
 ping -n 10 -w 2000 0.0.0.1> temp.txt
  
 del /F temp.txt
  
 goto RESTART
 
 
 

  注意1：goto语句是将监控程序设置成死循环，哇咔咔。
  
 注意2：可以用start /D pathprogram去异步调用program程序，也就是不等program指定完毕就执行下面的语句，因此可以设置固定间隔（n*w毫秒）去监测。
  
        如果用callprogram则是同步调用，会等待program执行完毕，这样延迟就用不着了。
 
 
 
转载于:https://www.cnblogs.com/sunyllove/p/11225860.html