import org.testng.IRetryAnalyzer;
import org.testng.ITestResult;/*** 用例失败自动重跑逻辑* @author Charlie.chen**/
public class TestNGRetry implements IRetryAnalyzer {public LogUtil log = new LogUtil(this.getClass());private int retryCount = 0;private int maxRetryCount=2;public boolean retry(ITestResult result) {if (retryCount <= maxRetryCount) {String message = "running retry for  '" + result.getName() + "' on class " + this.getClass().getName() + " Retrying " + retryCount + " times";log.info(message);retryCount++;return true;}return false;}
}

import java.lang.reflect.Constructor;
import java.lang.reflect.Method;
import org.testng.IAnnotationTransformer;
import org.testng.IRetryAnalyzer;
import org.testng.annotations.ITestAnnotation;/*** 添加用例重跑监听器，用例失败自动重跑功能* * @author Charlie.chen**/public class RetryListener implements IAnnotationTransformer {public void transform(ITestAnnotation annotation, Class testClass, Constructor testConstructor, Method testMethod) {IRetryAnalyzer retry = annotation.getRetryAnalyzer();if (retry == null) {annotation.setRetryAnalyzer(TestNGRetry.class);}}
}

  <listeners><listener class-name="com.dji.utils.RetryListener"/></listeners>

@Overridepublic void onFinish(ITestContext testContext) {log.info("Test Finish");Iterator<ITestResult> listOfFailedTests = testContext.getFailedTests().getAllResults().iterator();while (listOfFailedTests.hasNext()) {ITestResult failedTest = listOfFailedTests.next();ITestNGMethod method = failedTest.getMethod();if (testContext.getFailedTests().getResults(method).size() > 1) {listOfFailedTests.remove();} else {if (testContext.getPassedTests().getResults(method).size() > 0) {listOfFailedTests.remove();}}}}