JAVA + LR如何實(shí)現(xiàn)apache流媒體的性能測(cè)試

這篇文章給大家分享的是有關(guān)JAVA + LR如何實(shí)現(xiàn)apache流媒體的性能測(cè)試的內(nèi)容。小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，一起跟隨小編過(guò)來(lái)看看吧。

多客戶端的模擬無(wú)外乎3種方法：
1.全公司總動(dòng)員，一起看。
2.一臺(tái)機(jī)器開(kāi)多個(gè)播放頁(yè)面（或者是一個(gè)頁(yè)面上嵌入多個(gè)播放器），調(diào)用多臺(tái)機(jī)器。
3.拋棄客戶端的解碼播放過(guò)程，直接想法下載視頻文件。

第一種方法不用說(shuō)，雖然最真實(shí)，但太原始沒(méi)有技術(shù)含量，如果是小公司人還不一定夠。
第二種方法在需要測(cè)試的用戶數(shù)不大時(shí)還可以，否則會(huì)占用較多資源，而且技術(shù)含量也較低。這種方式，一臺(tái)機(jī)器上能模擬的用戶數(shù)很有限，因?yàn)镃PU會(huì)很快成為瓶頸。
第三種方法最高效，在千兆網(wǎng)環(huán)境下，一臺(tái)機(jī)器可以模擬很多路用戶，此時(shí)網(wǎng)絡(luò)帶寬是瓶頸（如果帶寬更大，估計(jì)硬盤IO就是瓶頸了）。但是沒(méi)有解碼和播放，如何判斷客戶端的效果呢？?jī)煞N方式，一是對(duì)比下載速度和碼率，理論上只要下載速度足夠就可以了；二是測(cè)試過(guò)程中也可以打開(kāi)幾個(gè)真實(shí)的播放窗口來(lái)驗(yàn)證播放效果，因?yàn)閴毫υ诜?wù)端，可以認(rèn)為每個(gè)客戶端都是等價(jià)的。

本文要講的就是第三種測(cè)試方法。
以前還測(cè)過(guò)FMS的流媒體，網(wǎng)上可以找到現(xiàn)成的工具來(lái)實(shí)現(xiàn)本方法，只要調(diào)用就可以了。但HTTP的這次也搜了兩天，好像還真沒(méi)有，只好自己動(dòng)手了。看來(lái)最高效的方法，實(shí)現(xiàn)起來(lái)卻是最麻煩的?；舅悸肥荍AVA實(shí)現(xiàn)下載功能，用LR的JAVA Vuser實(shí)現(xiàn)多用戶的控制。動(dòng)手前先給自己整理了一個(gè)需求

功能：
模擬下載√
播放列表√
下載速度記錄：總平均速度、每秒速度√
*偽裝成播放器進(jìn)行連接
*客戶端限速

測(cè)試結(jié)果：
apache限速
下載速度
文件完整

功能擴(kuò)展
jar包或者exe文件傳參（播放列表）

打?qū)︺^的是已經(jīng)實(shí)現(xiàn)了，帶星號(hào)的是未實(shí)現(xiàn)、也不一定需要實(shí)現(xiàn)的高級(jí)功能。通過(guò)測(cè)試程序，需要得到的結(jié)果是下載是否正確完成？下載速度是否足夠？apache的限速模塊是否起作用（如果開(kāi)啟）？這里可能會(huì)有個(gè)問(wèn)題，如果下載程序突破了apache的限速，那有可能是測(cè)試程序的問(wèn)題，這就引出了上面的高級(jí)功能“偽裝成播放器”。

下面直接貼代碼，說(shuō)明盡量放到注釋里。

下載類，提供靜態(tài)方法。

package com.test;
import java.io.*;
import java.net.*;
import java.util.*;
public class DownloadFile {
    /*
     *下載指定URL的文件
     *userid是用于保存本地文件的標(biāo)識(shí)
     **/
    public static int getHttpFileByUrl(String address, String userid) {
        int bufferSize = 1024;
        int size = 0;
        byte[] buf = new byte[bufferSize];
        
        /*
         *下載時(shí)間字符串
         *用于文件標(biāo)識(shí)
         *格式201210260130
         **/        
        Date date = new Date();
        SimpleDateFormat formatDate = new SimpleDateFormat("yyyyMMddHHmmss");
        String downloadTime = formatDate.format(date);
        
         /*
          *計(jì)算下載速度相關(guān)
          */
        int totalDownloadSize = 0;
        int lastDownloadSize = 0;
        long lastCheckTime = 0;
        long startDownloadTime = 0;
        int sec = 0;
        
        /*
         *下載和計(jì)算過(guò)程
         */
        try {
            URL url = new URL(address);
            URLConnection conn = url.openConnection();
            BufferedInputStream bis = new BufferedInputStream(conn.getInputStream());
            FileOutputStream fos = new FileOutputStream("e:\test\testvideo" + "_" + downloadTime + "_" + userid); 
            
            System.out.println("File Size：" + conn.getContentLength()/1024 + "KB");
            
            startDownloadTime = System.currentTimeMillis();
            lastCheckTime = startDownloadTime;
            
            while ((size = bis.read(buf)) != -1)
            {
                fos.write(buf,0,size);
                totalDownloadSize += size;
                
                /*
                 *計(jì)算每秒下載速度
                 */
                if (System.currentTimeMillis() - lastCheckTime > 1000) {
                    System.out.println(sec + ": " + (totalDownloadSize - lastDownloadSize)/1024 + "KB");
                    lastCheckTime = System.currentTimeMillis();
                    lastDownloadSize = totalDownloadSize;
                    sec++;
                }
            }
            
            System.out.println("Vuser " + userid + " Download Completed!");
            System.out.println("Average Download Speed: " + (totalDownloadSize/1024)/((System.currentTimeMillis() - startDownloadTime)/1000) + "KB/s");
            
            fos.close();
            bis.close();
            
        }catch (MalformedURLException e) {
            e.printStackTrace();
        }catch (IOException e) {
            e.printStackTrace();
        }
        
        return totalDownloadSize/1024;
    }    
}

測(cè)試驅(qū)動(dòng)。

import com.test.*;
import java.util.*;
import java.io.*;
public class DownloadDrive {
    public static void main (String[] args) {
        
        //System.out.println("test");
        //DownloadFile.test();
        
        /*
         *調(diào)用者測(cè)量
         *自行實(shí)現(xiàn)
         */
        int DownLoadSize = 0;
        double DownLoadTime = 0;
        int Speed = 0;
                
        String url;
        ArrayList urlList = new ArrayList();
        /*
         *讀取待下載的URL地址
         *保存到list中
         */
        try{
            BufferedReader br = new BufferedReader(new FileReader("url.txt"));
            while((url = br.readLine()) != null){
                urlList.add(url);
            }    
        }catch(IOException ie){
            ie.printStackTrace();
        }
        
        System.out.println("Total URLs: " + urlList.size());
        
        /*
         *依次下載list中的文件
         */
        for(int i = 0; i < urlList.size(); i++){
            url = (String)urlList.get(i);
            System.out.println(url);            
            //傳入url和每個(gè)調(diào)用者的標(biāo)識(shí)
            DownloadFile.getHttpFileByUrl(url, "1");
        }
    }    
    
}

將待下載的URL保存到url.txt中，每行一個(gè)地址。文件放到DownloadDrive.class同目錄中。

到這，主要代碼已經(jīng)實(shí)現(xiàn)了。下一步需要做的是和LR整合，用LR的Java Vuser對(duì)下載功能進(jìn)行控制，模擬多用戶。其實(shí)也就是重寫(xiě)一個(gè)測(cè)試驅(qū)動(dòng)，只不過(guò)這個(gè)驅(qū)動(dòng)是需要LR內(nèi)部方法了，應(yīng)該沒(méi)有什么技術(shù)上的難點(diǎn)了。

接下來(lái)，通過(guò)LoadRunner來(lái)實(shí)現(xiàn)多線程的模擬和控制。

新建LR的JAVA Vuser腳本，這里可以直接進(jìn)行JAVA編碼，又可以調(diào)用LR的內(nèi)部方法，如事務(wù)、思考時(shí)間、集合點(diǎn)等等。到了這步已經(jīng)沒(méi)有任何難點(diǎn)了，開(kāi)發(fā)人員只要花1個(gè)小時(shí)了解下LR的基本使用和常用方法即可，測(cè)試人員如果不會(huì)JAVA……那還是算了吧。

Action.java內(nèi)容如下：

import lrapi.lr;
import com.test.*;
import java.util.*;
import java.io.*;
public class Actions
{
    public int init() throws Throwable {
        return 0;
    }//end of init
    public int action() throws Throwable {
        
        /*
        調(diào)用者測(cè)量
        */
        int downloadSize = 0;
        int downloadTime = 0;
        long startTime = 0;
        long endTime = 0;
        int speed = 0;
        int vid;
        vid = lr.get_vuser_id();
        /*
        從url文件生成arraylist
            */
        String url;
        ArrayList urlList = new ArrayList();
        try{        
                BufferedReader br = new BufferedReader(new FileReader("url.txt"));
        　　　　　while((url = br.readLine()) != null){
            　　 urlList.add(url);
        }
        }catch(IOException ie){
        　　ie.printStackTrace();
        }
        lr.enable_redirection(true);
        lr.set_debug_message(lr.MSG_CLASS_JIT_LOG_ON_ERROR, lr.SWITCH_OFF);
        System.out.println("Total URLs: " + urlList.size());
        for(int i = 0; i < urlList.size(); i++){
        　　url = (String)urlList.get(i);
        　　System.out.println(url);
        　　//事務(wù)名稱
        　　String trxName = "URL" + (i+1);
        　　startTime = System.currentTimeMillis();
        　　lr.start_transaction(trxName);
        　　//傳入url和每個(gè)調(diào)用者的標(biāo)識(shí)
        　　downloadSize = DownloadFile.getHttpFileByUrl(url, Integer.toString(vid));
        　　lr.end_transaction(trxName, lr.AUTO);
        　　endTime = System.currentTimeMillis();
        　　downloadTime = (int)(endTime - startTime)/1000;
        　　speed = downloadSize / downloadTime;
        　　lr.output_message(trxName + ": completed");
        　　lr.output_message("time cost: " + downloadTime + "s");
        　　lr.output_message("average speed: " + speed + "KB/s");
        　　lr.output_message("");
        }
        lr.set_debug_message(lr.MSG_CLASS_JIT_LOG_ON_ERROR, lr.SWITCH_ON);
        return 0;
    }//end of action
    public int end() throws Throwable {
        return 0;
    }//end of end
}

所有以lr開(kāi)頭的方法都是LR內(nèi)部方法，這里只用到了事務(wù)、日志等幾個(gè)。

編譯之前我們的JAVA下載代碼，將包（com.test）放入LR腳本的目錄中，如圖：

打開(kāi)LR腳本，運(yùn)行試一下。

可以看到正常輸出了日志，再驗(yàn)證一下下載到的文件是否完整，找到輸出路徑，如“h:testtestvideo_20121106194419_-1”，用播放器打開(kāi)這個(gè)文件，正常播放。說(shuō)明我們的腳本已經(jīng)OK了，下面就要做多用戶的測(cè)試了。

打開(kāi)controller，設(shè)置同時(shí)運(yùn)行2個(gè)VUSER（為了保證負(fù)載機(jī)的網(wǎng)絡(luò)不成為瓶頸），運(yùn)行場(chǎng)景。

可以看到，2個(gè)VUSER都按預(yù)期正常完成了。

從幾個(gè)方面驗(yàn)證測(cè)試的有效性：
1是負(fù)載機(jī)的網(wǎng)絡(luò)利用，上面單用戶執(zhí)行腳本時(shí)下載速度是5M/s（apache服務(wù)器做了限速），這次兩個(gè)用戶同時(shí)下載達(dá)到了10M。

2是每個(gè)VUSER的輸出日志。
3是下載文件的完整性。

感謝各位的閱讀！關(guān)于“JAVA + LR如何實(shí)現(xiàn)apache流媒體的性能測(cè)試”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！