在上篇文章中有提到在获取完成配置后，调用runcase()方法，如下：

//执行monitorcase
    function runcase(){     
        url="runcases";
        $.post(
                url,
                {   //传入参数：lineName 业务线名称；frequency 监控频率； smsValue 是否发送短信。
                    "lineName" : document.getElementById("dropDownToggleName").text,
                    "frequency" : document.getElementById("monitorFreq").value,
                    "smsValue" : document.getElementById("smsValue").checked
                },
                function(data){
                    removeElementById("accordion");
                    removeElementById("summary");
                    var total = data.total;
                    var itemContent = "<h5 class=summary id=summary> 共找到" + total + "条数据</h5>"
                    var json_array = data.data;
                    itemContent += "<div class=panel-group id=accordion>"
                    for (var i = 0; i < json_array.length; i++) {
                        if (json_array[i].success == "false") {
                            itemContent += "<div class='panel panel-danger'>"   
                        } else {
                            itemContent += "<div class='panel panel-success'>"
                        }
                        itemContent += "<div class=panel-heading>"
                        itemContent += "<h4 class=panel-title style=float:left>"
                        itemContent += "<a data-toggle=collapse data-parent=#accordion href=#collapse" + json_array[i].id + ">"
                        itemContent += "用例名称: " + json_array[i].fileName
                        itemContent += "</a></h4>"
                        itemContent += "<a style=float:right; href=javascript:copy('" + json_array[i].id + "');>前往接口测试平台</a>"
                        itemContent += "<div style=clear:both></div>"
                        itemContent += "</div>"
                        itemContent += "<div id=collapse" + json_array[i].id + " class='panel-collapse collapse'>"
                        itemContent += "<div class=panel-body>"
                            if (json_array[i].success == "false") {
                                
                                itemContent += " Event: "+ JSON.stringify(json_array[i].failureMessage)
                            } else {
                                itemContent += " Event: 测试通过"
                            }
                        
                        itemContent += "</div></div></div>"
                    }
                    itemContent += "</div>"
                    removeElementById("accordion");
                    removeElementById("summary");
                    $(".seperator1").after(itemContent);;
                },"json") 
    }

web.xml配置

<servlet>
        <servlet-name>runcases</servlet-name>
        <servlet-class>com.xxx.servlet.RunMonitorCasesServlet</servlet-class>
        <init-param>
            <param-name>monitorCaseRootPath</param-name>
            <param-value>此处配置jmx文件存储路径</param-value>
        </init-param>
        <init-param>
            <param-name>jmeterCommand</param-name>
            <param-value>此处配置jmeter执行文件路径</param-value>
        </init-param>
        <!-- 设置结果文件存储路径 -->
        <init-param>
            <param-name>caseResultPath</param-name>
            <param-value>此处配置结果文件存储路径</param-value>
        </init-param>
        <!--设置各个业务线邮箱接收人 支持多个邮箱，英文逗号分隔即可 -->
        <init-param>
            <param-name>serverline1</param-name>
            <param-value>xxx@xxx.com</param-value>
        </init-param>
        <init-param>
            <param-name>serverline2</param-name>
            <param-value>xxx@xxx.com</param-value>
        </init-param>
        ……
            <init-param>
            <param-name>testmail</param-name>
            <param-value>xxx@xxx.com</param-value>
        </init-param>
        <!-- 设置各个业务线短信接收人 支持多个手机号，英文逗号分隔即可-->
        <init-param>
            <param-name>serverline_sms1</param-name>
            <param-value>1xxxxxxxxxx</param-value>
        </init-param>
        <init-param>
            <param-name>serverline_sms2</param-name>
            <param-value>1xxxxxxxxxx</param-value>
        </init-param>
        ……
</servlet>
<servlet-mapping>
        <servlet-name>runcases</servlet-name>
        <url-pattern>/runcases</url-pattern>
</servlet-mapping>

RunMonitorCasesServlet中实现了2个功能，
1.执行jmx文件并返回结果
2.将执行结果进行分析
3.发送邮件以及短信
由于发送短信是直接调用公司同事开发的接口，再次就不说明了，本篇值介绍执行jmx文件并返回结果，并分析，下一篇会单独介绍发送邮件~

定义变量

    private static final long serialVersionUID = 1L;
     // 定义一个ServletConfig对象
    private ServletConfig config = null;
    //定义case存储路径
    private String monitorCaseRootPath = "";
    //定义Jmeter执行文件路径
    private String jmeterCommand = "";
    //定义结果文件存放路径（总路径）
    private String caseResultPath = "";
    // 获取csv解析结果列表
    private ArrayList<String[]> csvList = new ArrayList<String[]>();
    //定义时间戳结果差
    private Long timejmx = (long) 0;
    int csvindex=0;
    private static Logger loginfo=Logger.getLogger(RunMonitorCasesServlet.class);

获取文件配置信息

    //获取配置文件信息
    public void init(ServletConfig config) throws ServletException {
        super.init(config); // 继承父类的init()方法
        this.config = config; // 获取配置信息

        monitorCaseRootPath = config.getInitParameter("monitorCaseRootPath");
        jmeterCommand = config.getInitParameter("jmeterCommand");
        caseResultPath = config.getInitParameter("caseResultPath");
        //配置email信息
        serverLine_Mail1 = config.getInitParameter("serverline1");
        serverLine_Mail2 = config.getInitParameter("serverline2");
                testMail = config.getInitParameter("testmail");
        mailMap.put("serverline1",serverLine_Mail1);
        mailMap.put("serverline2", serverLine_Mail2);
        mailMap.put("test", testMail);
        //省略短信配置
    }

编写post方法(执行jmx文件)

//定义返回类型和字符集
        res.setContentType("application/json; charset=utf-8");
        //输出流对象
        PrintWriter out = res.getWriter();

        //获取请求中传输的业务线名称&监控时长
        String lineName = req.getParameter("lineName");
        String frequency = req.getParameter("frequency");
        String smsValue=req.getParameter("smsValue");

        //将监控时长转换为int类型，便于后面进行处理
        int frequencyValue = 0;
        try {
            frequencyValue = Integer.parseInt(frequency);
        } catch (NumberFormatException e) {
            e.printStackTrace();
        }
        
        try {
            
            //定义返回值json
            JSONObject jsonObject = new JSONObject();
            //定义json包含的数组
            JSONArray arraycase = new JSONArray();
            
            //处理case存放路径
            File rootFolder = new File(monitorCaseRootPath + lineName);
            File[] caseFileList = rootFolder.listFiles();
            
            //定义caseName&当日时间_用于定义结果文件名
            String caseName = "";
            String caseDate = formatTodayDate();
            
            //创建当日结果文件存放文件夹
            File caseResultPathFile=new File(caseResultPath+lineName+File.separator+caseDate+File.separator);
            if(!caseResultPathFile.exists()){
                caseResultPathFile.mkdirs();
            }

            //执行case&输出结果
            for (int i = 0; i < caseFileList.length; i++) {
                // 仅处理文件
                if (caseFileList[i].isFile() && caseFileList[i].toString().endsWith(".jmx") ) {
                    //获取caseName的值
                    caseName = caseFileList[i].getName();
                    //创建结果存放文件
                    File resultFile = new File(
                            caseResultPath+lineName+File.separator+caseDate+File.separator + caseName.substring(0, caseName.lastIndexOf(".")) +"_"+ caseDate + ".csv");
                    if(!resultFile.exists()){
                        resultFile.createNewFile();
                    }
                    //执行case并输出csv结果文件
                    Process process = Runtime.getRuntime()
                            .exec(jmeterCommand + " -n -t " + caseFileList[i].toString() + " -l " + caseResultPath+lineName+File.separator+caseDate+File.separator
                                    + caseName.substring(0, caseName.lastIndexOf("."))  +"_"+ caseDate + ".csv");
                    process.waitFor(4, TimeUnit.SECONDS);            
                }
            }

分析结果文件

//结果处理
            //创建失败计数文件,并将每条case计数设置为0
            File countFile=new File(caseResultPath+lineName+"countFile.txt");
            //定义执行case总数total
            int total = 0;
            for (int i = 0; i < caseFileList.length; i++) {
                if (caseFileList[i].isFile() && caseFileList[i].toString().endsWith(".jmx")) {
                    total++;
                    //遍历将id，fileName存入json中
                    JSONObject jsonObjectcase = new JSONObject();
                    jsonObjectcase.put("id", total);
                    jsonObjectcase.put("fileName", caseFileList[i].getName().toString());
                    caseName = caseFileList[i].getName();
                    
                    //读取结果文件
                    int readCount=0;
                    while(readCount<3) {
                        //等待2s后读取结果文件
                        TimeUnit.SECONDS.sleep(2);
                        csvList = read(
                                caseResultPath+lineName+File.separator+caseDate+File.separator + caseName.substring(0, caseName.lastIndexOf(".")) +"_"+ caseDate + ".csv");
                        File file=new File(caseResultPath+lineName+File.separator+caseDate+File.separator + caseName.substring(0, caseName.lastIndexOf("."))  +"_"+ caseDate + ".csv");
                        long time=file.lastModified();
                        Date nowTime = new Date(System.currentTimeMillis());
                        timejmx = nowTime.getTime() - time;
                        if(csvList.size()==0) {
                            readCount++;
                            if(readCount==3) {
                                jsonObjectcase.put("timedate", time);
                                jsonObjectcase.put("success", "false");
                                jsonObjectcase.put("failureMessage", "当日首次写入文件失败");
                            }
                        }else if(timejmx / 1000 > frequencyValue) {
                            readCount++;
                            if(readCount==3) {
                                jsonObjectcase.put("timedate", time);
                                jsonObjectcase.put("success", "false");
                                jsonObjectcase.put("failureMessage", "无法读取到最近一次执行结果");
                            }
                        }else {
                            int csvindex=csvList.size() - 1;
                             //读取结果文件的最后一条，将时间戳，结果，错误信息存入json中
                            jsonObjectcase.put("timedate", csvList.get(csvindex)[0]);
                            jsonObjectcase.put("success", csvList.get(csvindex)[7]);
                            jsonObjectcase.put("failureMessage", csvList.get(csvindex)[8]);
                            readCount=3;
                        }                       
                    }
                    

                    FileReader fr = new FileReader(countFile);
                        //创建集合对象
                    Properties pro = new Properties();              
                    pro.load(fr);
                    fr.close();
                    String caseFailValue =pro.getProperty(lineName+"_countnum_caseFail"+total);
                    String readFailValue =pro.getProperty(lineName+"_countnum_caseFail"+total);
                    jsonObjectcase.put("caseFailCount",caseFailValue );
                    jsonObjectcase.put("readFailCount",readFailValue);
                    
                    //将当前case的所有信息存入到json数组中
                    arraycase.add(jsonObjectcase);
                    jsonObject.put("data", arraycase);
                }
            }
            
            //将执行case的计数存入数组中
            jsonObject.put("total", total);
                    
            //报警逻辑，根据json+计数文件 操作发送邮件
            int caseFailFlag=0;
            int readFailFlag=0;
            for(int i=0;i<jsonObject.getJSONArray("data").size();i++) {
                //文件已经存在
                //输入流读取文件
                FileReader fr = new FileReader(countFile);
                //创建集合对象
                Properties pro = new Properties();
                pro.load(fr);
                fr.close();
                //获取count值
                String caseid= jsonObject.getJSONArray("data").getJSONObject(i).get("id")+"";
                String caseFailValue = pro.getProperty(lineName+"_countnum_caseFail"+caseid);
                String readFailValue =pro.getProperty(lineName+"_countnum_readFail"+caseid);
                int caseFailCount = Integer.parseInt(caseFailValue);
                int readFailCount = Integer.parseInt(readFailValue);
                
                //首先判断本次执行case是否fail，若fail，再进行判断
                if(jsonObject.getJSONArray("data").getJSONObject(i).get("failureMessage")!="") {
                    if(!jsonObject.getJSONArray("data").getJSONObject(i).get("failureMessage").equals("当日首次写入文件失败") || 
                            !jsonObject.getJSONArray("data").getJSONObject(i).get("failureMessage").equals("无法读取到最近一次执行结果") ) {
                        //fail计数增加1，
                        caseFailCount++;
                            //fail计数为3时，发送邮件
                            if(caseFailCount==3) {
                                pro.setProperty(lineName+"_countnum_caseFail"+caseid, caseFailCount+"");
                                FileWriter fw = new FileWriter(countFile);
                                pro.store(fw, "");
                                fw.close();
                                jsonObject.getJSONArray("data").getJSONObject(i).put("caseFailCount",caseFailCount+"");
                                caseFailFlag=1;
                            //fail计数为15时，清空计数
                            }else if(caseFailCount==15){
                                caseFailCount=0;
                                pro.setProperty(lineName+"_countnum_caseFail"+caseid, caseFailCount+"");
                                FileWriter fw = new FileWriter(countFile);
                                pro.store(fw, "");
                                fw.close();
                                jsonObject.getJSONArray("data").getJSONObject(i).put("caseFailCount",caseFailCount+"");
                            }else {
                                pro.setProperty(lineName+"_countnum_caseFail"+caseid, caseFailCount+"");
                                FileWriter fw = new FileWriter(countFile);
                                pro.store(fw, "");
                                fw.close();
                                jsonObject.getJSONArray("data").getJSONObject(i).put("caseFailCount",caseFailCount+"");
                            }
                    }else {
                        if(jsonObject.getJSONArray("data").getJSONObject(i).get("failureMessage").equals("当日首次写入文件失败") &&
                            jsonObject.getJSONArray("data").getJSONObject(i).get("failureMessage").equals("无法读取到最近一次执行结果") ) {
                            
                            readFailCount++;
            
                             if(readFailCount==3) {
                                pro.setProperty(lineName+"_countnum_readFail"+caseid, readFailCount+"");
                                    FileWriter fw = new FileWriter(countFile);
                                    pro.store(fw, "");
                                    fw.close();
                                    jsonObject.getJSONArray("data").getJSONObject(i).put("readFailCount",readFailCount+"");
                                    readFailFlag=1;
                                    //fail计数为15时，清空计数
                             }else if(readFailCount==15) {
                                 readFailCount=0;
                                    pro.setProperty(lineName+"_countnum_readFail"+caseid, readFailCount+"");
                                    FileWriter fw = new FileWriter(countFile);
                                    pro.store(fw, "");
                                    fw.close();
                                    jsonObject.getJSONArray("data").getJSONObject(i).put("readFailCount",readFailCount+"");
                             }else {
                                pro.setProperty(lineName+"_countnum_readFail"+caseid, readFailCount+"");
                                    FileWriter fw = new FileWriter(countFile);
                                    pro.store(fw, "");
                                    fw.close();
                                    jsonObject.getJSONArray("data").getJSONObject(i).put("readFailCount",readFailCount+"");
                             }                               
                        }
                                            
                    }
                    
                //本次执行case，结果为成功，将计数清零存储至计数文件
            }else {
                    caseFailCount=0;
                    readFailCount=0;
                    pro.setProperty(lineName+"_countnum_caseFail"+caseid, caseFailCount+"");
                    pro.setProperty(lineName+"_countnum_readFail"+caseid, readFailCount+"");
                FileWriter fw = new FileWriter(countFile);
                pro.store(fw, "");
                fw.close();
                jsonObject.getJSONArray("data").getJSONObject(i).put("caseFailCount",caseFailCount+"");
                jsonObject.getJSONArray("data").getJSONObject(i).put("readFailCount",readFailCount+"");
                };          
            }
            if(caseFailFlag==1) {
                send("caseFail",lineName,jsonObject,mailMap);
                if(smsValue.equals("true")) {
                                // 发送短信
                }
            }
            if(readFailFlag==1) {
                send("readFail",lineName,jsonObject,mailMap);
            }
            out.write(jsonObject.toString());
        } catch (Exception e) {
            e.printStackTrace();
            out.println(e.toString());
        }
        out.close();