登录
当前位置： 首页 > 知识库问答 >
问题：

如何并行运行testng测试方法？

苗盛
2023-03-14 
  package com.sonata.tests;

import java.util.Map;
import java.util.Properties;

import org.testng.SkipException;
import org.testng.annotations.AfterMethod;
import org.testng.annotations.BeforeMethod;
import org.testng.annotations.BeforeTest;
import org.testng.annotations.Parameters;
import org.testng.annotations.Test;

import com.sonata.utility.DataReader;
import com.sonata.utility.DriverCreation;
import com.sonata.pages.ComplaintPage;
import com.sonata.pages.HomePage;
import com.sonata.pages.LoginPage;

public class ComplainTest extends DriverCreation {

    private String browser;
    private String url;

    HomePage homeObject;
    LoginPage loginObject;
    ComplaintPage compObject;
    DataReader dataReader = new DataReader();

    @Parameters({ "url", "browser" })
    @BeforeMethod
    public void readProperties(String url, String browser) {
        /*
         * Properties prop = PropertiesReader.getProperty(); browser =
         * prop.getProperty("browser.name"); url = prop.getProperty("app.url");
         */
        this.browser = browser;
        this.url = url;
    }

    @Test
    public void createComplaintCaseWithDefault() {

        setTestCaseName("TC-10672");
        initExtent(testCaseName);

        if (!dataReader.isTestCaseExecute(xlsReader, testCaseName)) {
            logger.info("Test Case not executed as its run mode is NO");
            throw new SkipException("");
        }
        Object[][] testData = dataReader.getTestData(xlsReader, testCaseName);
        for (int t = 0; t < testData.length; t++) {
            initDriver(browser);
            homeObject = new HomePage(driver, report, wait, logger);
            homeObject.goToHomepge(url);

            @SuppressWarnings("unchecked")
            Map<String, String> testDataMap = (Map<String, String>) testData[t][0];
            loginObject = new LoginPage(driver, report, wait, logger);
            loginObject.login(testDataMap.get("UserName"),
                    testDataMap.get("Password"));

            compObject = new ComplaintPage(driver, report, wait, logger);
            compObject.createCase(testDataMap.get("ComplaintType"),
                    testDataMap.get("CustomerName"),
                    testDataMap.get("ComplaintCategory"));
            compObject.complaintPageVerification();
        }
    }

    @Test
    public void createComplaintCaseWithSensitive() {

        setTestCaseName("TC-10692");
        initExtent(testCaseName);

        if (!dataReader.isTestCaseExecute(xlsReader, testCaseName)) {
            logger.info("Test Case not executed as its run mode is NO");
            throw new SkipException("");
        }

        Object[][] testData = dataReader.getTestData(xlsReader, testCaseName);
        for (int t = 0; t < testData.length; t++) {
            initDriver(browser);
            homeObject = new HomePage(driver, report, wait, logger);
            homeObject.goToHomepge(url);

            @SuppressWarnings("unchecked")
            Map<String, String> testDataMap = (Map<String, String>) testData[t][0];

            loginObject = new LoginPage(driver, report, wait, logger);
            loginObject.login(testDataMap.get("UserName"),
                    testDataMap.get("Password"));

            compObject = new ComplaintPage(driver, report, wait, logger);
            compObject.createCase(testDataMap.get("ComplaintType"),
                    testDataMap.get("CustomerName"),
                    testDataMap.get("ComplaintCategory"));
            compObject.complaintPageVerification();
        }
    }

    @Test
    public void reopenComplaintFieldVerfication() {

        setTestCaseName("TC-10958");
        initExtent(testCaseName);

        if (!dataReader.isTestCaseExecute(xlsReader, testCaseName)) {
            logger.info("Test Case not executed as its run mode is NO");
            throw new SkipException("");
        }
        Object[][] testData = dataReader.getTestData(xlsReader, testCaseName);
        for (int t = 0; t < testData.length; t++) {
            initDriver(browser);
            homeObject = new HomePage(driver, report, wait, logger);
            homeObject.goToHomepge(url);

            @SuppressWarnings("unchecked")
            Map<String, String> testDataMap = (Map<String, String>) testData[t][0];
            loginObject = new LoginPage(driver, report, wait, logger);
            loginObject.login(testDataMap.get("UserName"),
                    testDataMap.get("Password"));

            compObject = new ComplaintPage(driver, report, wait, logger);
            compObject.reopenReasonFieldVerification(testDataMap
                    .get("ComplaintID"));
        }
    }

    @AfterMethod
    public void closeBrowser() {
        if (driver != null) {
            homeObject.tearDownTest();
        }
        if (report != null) {
            report.endTest();
        }
    }
}

这是驱动程序类，它将为每个测试方法创建驱动程序实例。

package com.sonata.utility;

import java.io.File;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.concurrent.TimeUnit;

import org.apache.log4j.Logger;
import org.openqa.selenium.Dimension;
import org.openqa.selenium.Platform;
import org.openqa.selenium.WebDriver;
import org.openqa.selenium.chrome.ChromeDriver;
import org.openqa.selenium.firefox.FirefoxDriver;
import org.openqa.selenium.ie.InternetExplorerDriver;
import org.openqa.selenium.phantomjs.PhantomJSDriver;
import org.openqa.selenium.phantomjs.PhantomJSDriverService;
import org.openqa.selenium.remote.DesiredCapabilities;
import org.openqa.selenium.remote.RemoteWebDriver;
import org.openqa.selenium.support.ui.WebDriverWait;
import org.testng.Assert;

import com.relevantcodes.extentreports.ExtentReports;
import com.relevantcodes.extentreports.LogStatus;
import com.sonata.constants.Constants;

public class DriverCreation {

    public ExtentReports report;
    public WebDriver driver;
    public DesiredCapabilities cap1;
    public WebDriverWait wait;
    protected String testCaseName;

    ExtentReport extent;
    public Logger logger = Logger.getLogger(this.getClass().toString());
    public ExcelReader xlsReader = new ExcelReader(getProjectPath()
            + Constants.XLS_FILE_PATH);

    /*
     * public DriverCreation(String browser,ExtentReports report,Logger logger){
     * this.browser = browser; this.report = report; this.logger = logger; }
     */

    public void initExtent(String reportName) {
        extent = new ExtentReport();
        report = extent.getExtentReportInstance(reportName);
    }

    public void setTestCaseName(String testCaseName){
        this.testCaseName = testCaseName;
    }

    public WebDriver initDriver(String browser) {
        try {
            cap1 = new DesiredCapabilities();
            if (!Constants.CONSTANTS_GRIDEXECUTION) {
                if (browser.equalsIgnoreCase("Firefox")) {
                    System.setProperty("webdriver.gecko.driver",
                            Constants.CONSTANTS_GECKO_DRIVER_PATH);
                    cap1.setCapability("marionette", true);
                /*  ThreadLocal<WebDriver> driver1 = new ThreadLocal<WebDriver>(){
                        @Override
                        protected WebDriver initialValue(){
                            return new FirefoxDriver(cap1);
                        }
                    };*/
                    //driver = driver1.get();*/
                    driver= new FirefoxDriver(cap1);
                    driver.manage().timeouts()
                            .implicitlyWait(2, TimeUnit.SECONDS);
                    wait = new WebDriverWait(driver, 50);
                    report.log(LogStatus.INFO, "Firefox driver has started");
                    logger.info("Firefox driver has started");

                } else if (browser.equalsIgnoreCase("Chrome")) {
                    System.setProperty(Constants.CONSTANTS_CHROME_PROPERTY,
                            Constants.CONSTANTS_CHROME_DRIVER_PATH);
                    /*driver1 = new ThreadLocal<WebDriver>(){
                        @Override
                        protected WebDriver initialValue(){
                            return new ChromeDriver();
                        }
                    };
                    driver = driver1.get();*/
                    driver = new ChromeDriver();
                    driver.manage().timeouts()
                            .implicitlyWait(2, TimeUnit.SECONDS);
                    wait = new WebDriverWait(driver, 50);
                    report.log(LogStatus.INFO, "Chrome driver has started");
                    logger.info("Chrome driver has started");
                } else if (browser.equalsIgnoreCase("PhantomJS")) {
                    System.setProperty(Constants.CONSTANTS_PHANTOM_PROPERTY,
                            Constants.CONSTANTS_PHANTOM_DRIVER_PATH);
                    cap1.setJavascriptEnabled(true);
                    cap1.setCapability("takesScreenshot", true);
                    cap1.setCapability(
                            PhantomJSDriverService.PHANTOMJS_EXECUTABLE_PATH_PROPERTY,
                            Constants.CONSTANTS_PHANTOM_DRIVER_PATH);
                    /*ThreadLocal<WebDriver> driver1 = new ThreadLocal<WebDriver>(){
                        @Override
                        protected WebDriver initialValue(){
                            return new PhantomJSDriver(cap1);
                        }
                    };
                    driver = driver1.get();*/
                    driver = new PhantomJSDriver(cap1);
                    driver.manage().window().setSize(new Dimension(1920, 1200));
                    wait = new WebDriverWait(driver, 50);
                    report.log(LogStatus.INFO,
                            "PhantomJS/Ghost driver has started");
                    logger.info("PhantomJS/Ghost driver has started");
                } else if (browser.equalsIgnoreCase("IE")) {
                    System.setProperty(Constants.CONSTANTS_IE_PROPERTY,
                            Constants.CONSTANTS_IE_DRIVER_PATH);
                    // cap1.internetExplorer();
                    cap1.setCapability(
                            InternetExplorerDriver.IE_ENSURE_CLEAN_SESSION,
                            true);
                    /*ThreadLocal<WebDriver> driver1 = new ThreadLocal<WebDriver>(){
                        @Override
                        protected WebDriver initialValue(){
                            return new InternetExplorerDriver(cap1);
                        }
                    };
                    driver = driver1.get();*/
                    driver = new InternetExplorerDriver(cap1);
                    driver.manage().timeouts()
                            .implicitlyWait(2, TimeUnit.SECONDS);
                    wait = new WebDriverWait(driver, 50);
                    report.log(LogStatus.INFO,
                            "Internet Explorer driver has started");
                    logger.info("Internet Explorer driver has started");
                }
            } else {
                String nodeUrl = Constants.CONSTANTS_IPDETAILS;
                if (browser.equalsIgnoreCase("Firefox")) {
                    System.setProperty("webdriver.gecko.driver",
                            Constants.CONSTANTS_GECKO_DRIVER_PATH);
                    cap1.setCapability("marionette", true);
                    cap1 = DesiredCapabilities.firefox();
                    cap1.setBrowserName("firefox");
                    cap1.setPlatform(Platform.WINDOWS);
                } else if (browser.equalsIgnoreCase("Chrome")) {
                    System.setProperty(Constants.CONSTANTS_CHROME_PROPERTY,
                            Constants.CONSTANTS_CHROME_DRIVER_PATH);
                    cap1 = DesiredCapabilities.chrome();
                    cap1.setBrowserName("chrome");
                    cap1.setPlatform(Platform.WINDOWS);
                } else if (browser.equalsIgnoreCase("IE")) {
                    System.setProperty(Constants.CONSTANTS_IE_PROPERTY,
                            Constants.CONSTANTS_IE_DRIVER_PATH);
                    // cap1.internetExplorer();
                    cap1 = DesiredCapabilities.internetExplorer();
                    cap1.setBrowserName("internet explorer");
                    cap1.setPlatform(Platform.WINDOWS);
                    cap1.setCapability(
                            InternetExplorerDriver.INTRODUCE_FLAKINESS_BY_IGNORING_SECURITY_DOMAINS,
                            true);
                    cap1.setCapability(
                            InternetExplorerDriver.IE_ENSURE_CLEAN_SESSION,
                            true);
                }
                ThreadLocal<WebDriver> driver1 = new ThreadLocal<WebDriver>(){
                    @Override
                    protected WebDriver initialValue(){
                            try {
                                return new RemoteWebDriver(new URL(nodeUrl), cap1);
                            } catch (MalformedURLException e) {
                                e.printStackTrace();
                            }
                            return null;
                    }
                };
                driver = driver1.get();
                driver.manage().timeouts().implicitlyWait(2, TimeUnit.SECONDS);
                wait = new WebDriverWait(driver, 50);
                report.log(LogStatus.INFO, browser + " driver has started");
                logger.info(browser + " driver has started");
            }

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                Assert.assertTrue(true, "Set up Test");
            } catch (Exception e) {
                logger.error("Try and catch block while assert " + e);
            }
        }
        return driver;
    }

    private String getProjectPath() {
        File currentDirFile = new File("");
        String path = currentDirFile.getAbsolutePath();
        return path;
    }

}




TESTNG SUITE XML:

    <?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE suite SYSTEM "http://testng.org/testng-1.0.dtd" >
    <suite name="C4C" thread-count="3" parallel="methods">
        <parameter name="url" value="https://abc.xyz.ondemand.com/"/>
        <parameter name="browser" value="Chrome"/>
        <test name="Case" allow-return-values="true" group-by-instances="true">
            <classes>
                <class name="com.sonata.tests.ComplainTest" >
                </class>
            </classes>
        </test>
    </suite>

共有1个答案

吕利
2023-03-14

您正在类级别存储驱动程序。但您基于方法进行并行化。在这种情况下，将有一个驱动程序对象。我看到线程局部的线都被评论了。

有两种方法可以解决这个问题，

第一：当您在方法级别运行并在每个方法中导航主页时，您可以在方法级别维护驱动程序对象，

        Webdriver driver = initDriver(browser);
        homeObject = new HomePage(driver, report, wait, logger);
        homeObject.goToHomepge(url);

 public class DriverCreation {
    private static ThreadLocal<WebDriver> WEBDRIVER = new ThreadLocal<WebDriver>();

   public WebDriver getWebDriver(String browser){
      WebDriver driver= WEBDRIVER.get();
      if (driver== null) {
        driver = initDriver(browser);
        WEBDRIVER.set(driver);
      }
      return driver;
   }

}

        Webdriver driver = getWebDriver(browser);
        homeObject = new HomePage(driver, report, wait, logger);
        homeObject.goToHomepge(url);
 类似资料：
  • TestNG并行测试运行

    我试图用TestNG并行运行一个示例测试项目。但它是在一个线程中顺序执行的。我漏掉什么了吗？ 谢了。

  • 如何使用testng并行运行我的selenium测试方法

    问题内容： 我正在尝试使用testng并行运行自动化测试（Selenium webdriver）。这是我正在运行的节点： 这是我的测试课： } 这是我的xml： 当我运行XML时，我希望我的测试一次在两个线程中的两个浏览器上运行，但是，当我运行XML时，我使两个浏览器实例第一次运行，然后它们分别递增，并且50％测试失败了，您可以看到我正在尝试在每个方法中实例化驱动程序，尽管这不是我的框架如何工作，

  • 并行运行TestNG QAF BDD测试

  • 如何并行运行cucumber测试_Junit/TestNg[重复]

    我正在使用cucumber测试和testng，我计划并行运行测试。我以前有使用testng框架和并行执行的经验，如果不使用mavensurfire插件（pom.xml），我如何实现相同的效果 我的配置， Cucumber JVM，TestNGCucumberRunner。用于触发特性文件的java文件

  • 如何在TestNG中运行并行测试套件

    请让我知道是否可以通过TestNG运行并行套件？

  • 与surefire和testng并行运行测试

    我正在试验如何与maven surefire和testng并行运行测试。然而，配置似乎不是很简单，我无法让它工作。下面是我的虚拟测试。 这是我的surefire配置： 测试基本上是按顺序运行的。以下是日志作为证据： 我的意图是并行运行所有测试（直到方法级别）。那么，我该如何实现呢？

相关问答

与surefire和testng并行运行测试TestNG类并行运行，但方法不并行。如何配置testng.xml文件和测试类，使方法也并行运行？TestNG不运行并行方法如何并行运行Spock测试？如何并行运行testNG en，但用于不同的测试

相关文章

与TestNG并行进行参数化硒测试如何使用TestNG框架和Jenkins运行Selenium测试Gradle编译但不运行TestNG测试如何获得在testng拆卸方法中运行的测试方法的名称？特定测试方法的执行如何依赖于TestNG中的其他测试方法？

相关阅读

TestNG忽略测试TestNG + Spring集成测试TestNG + Selenium负载测试TestNG参数化测试TestNG参数测试实例

相关工具

uengine 运行器TestNGTestNG Data Bindingitest(爱测试)活性测试

相关文档

lemp PHP 集成运行环境测试手册Android 测试教程TestNG 中文教程OWASP 测试指南 v4.0
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.