监控系统内存

netcome

public CollectorThread(int second,String path,String pid,String name)    {        this.second = second;        this.pid = pid;        this.name = name;        String osname = System.getProperty("os.name");        System.setProperty("PERFMON_PATH",path);        if("SunOS".equals(osname))        {            os = "solaris";            command = "ps -p "+pid+" -o pid,pcpu,pmem,osz,rss";        }        if("AIX".equals(osname))        {            os = "aix";            command = "ps v "+pid;        }        if("Linux".equals(osname))        {            os = "linux";            command = "ps u "+pid;        }        if(osname.indexOf("Window")>=0)        {            os = "window";            command = "java";        }        setPriority(Thread.MIN_PRIORITY);    }public void execute()    {        try        {            Process p = rt.exec(command);            InputStream is = p.getInputStream();            InputStreamReader isr = new InputStreamReader(is);            BufferedReader br = new BufferedReader(isr);            String line = br.readLine();            line = br.readLine();            if(line == null || "".equals(line))                return;            StringTokenizer st = new StringTokenizer(line);            String ts = null;            String cpu = null;            String mem = null;            String vmem = null;            if("solaris".equals(os))            {                ts = formatDate(new Date());                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    cpu = st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    vmem = st.nextToken();                if(st.hasMoreTokens())                    mem = st.nextToken();            }            if("aix".equals(os))            {                ts = formatDate(new Date());                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    vmem = st.nextToken();                if(st.hasMoreTokens())                    mem = st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    cpu = st.nextToken();            }            if("linux".equals(os))            {                ts = formatDate(new Date());                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    cpu = st.nextToken();                if(st.hasMoreTokens())                    st.nextToken();                if(st.hasMoreTokens())                    vmem = st.nextToken();                if(st.hasMoreTokens())                    mem = st.nextToken();            }            if(mem != null && !"".equals(mem))                mem = ""+Long.parseLong(mem)*1024;            if(vmem != null && !"".equals(vmem))                vmem = ""+Long.parseLong(vmem)*1024;            if(name != null && !"".equals(name))            {                String file = path+"/perfmon_cpu_"+name+".tsv";                FileOutputStream fos = new FileOutputStream(file,true);                fos.write(("\""+ts+"\"\t"+"\""+cpu+"\"\r\n").getBytes());                fos.close();                file = path+"/perfmon_mem_"+name+".tsv";                fos = new FileOutputStream(file,true);                fos.write(("\""+ts+"\"\t"+"\""+mem+"\"\r\n").getBytes());                fos.close();                file = path+"/perfmon_vmem_"+name+".tsv";                fos = new FileOutputStream(file,true);                fos.write(("\""+ts+"\"\t"+"\""+vmem+"\"\r\n").getBytes());                fos.close();            }            else            {                String file = path+"/perfmon_cpu_"+pid+".tsv";                FileOutputStream fos = new FileOutputStream(file,true);                fos.write(("\""+ts+"\"\t"+"\""+cpu+"\"\r\n").getBytes());                fos.close();                file = path+"/perfmon_mem_"+pid+".tsv";                fos = new FileOutputStream(file,true);                fos.write(("\""+ts+"\"\t"+"\""+mem+"\"\r\n").getBytes());                fos.close();                file = path+"/perfmon_vmem_"+pid+".tsv";                fos = new FileOutputStream(file,true);                fos.write(("\""+ts+"\"\t"+"\""+vmem+"\"\r\n").getBytes());                fos.close();            }            is.close();            p = null;         }        catch(Exception e)        {            e.printStackTrace();        }    }