[原创]Appium集成openSTF实现多设备并发执行用例 - 51Testing软件测试论坛

public class AppiumServer {
private static AppiumServiceBuilder appiumServicebuilder;
private static AppiumDriverLocalService appiumService;
public static URL getAppiumUrl (){
logger.info("获取Ip:"+appiumService.getUrl().toString());
return appiumService.getUrl();
}
public static void startServer(){
//启动appium服务
appiumServicebuilder = new AppiumServiceBuilder();
appiumServicebuilder.withIPAddress("127.0.0.1");//此处ip无法动态，手机必须连接在服务启动的电脑
int port = Integer.parseInt("47"+ RandomUtil.nextInt(89));
logger.info("Random appium server port is:"+port);
if (!checkAppiumServerIsRunning(port)){
appiumServicebuilder.usingPort(port);//需要改成动态的
}
appiumServicebuilder.withArgument(GeneralServerFlag.SESSION_OVERRIDE);
appiumServicebuilder.withArgument(GeneralServerFlag.LOG_LEVEL,"error");//暂时不知道是哪里的日志级别
//appiumService = AppiumDriverLocalService.buildDefaultService();
appiumService = AppiumDriverLocalService.buildService(appiumServicebuilder);
appiumService.start();
}
}

复制代码

public class MyAndroidKeyMobileDriver{
/*
* 启动driver
*/
public static WebDriver getDriver(ITestContext context) {
WebDriver driver = null;
DesiredCapabilities desiredCapabilities = null;
try {
desiredCapabilities = BaseDriven.setAndroidCapabilities(context);
//新增的代码
driver = new AndroidDriver<>(AppiumServer.getAppiumUrl(), desiredCapabilities);
DriverCache.set(driver);
driver.manage().timeouts().implicitlyWait(30, TimeUnit.SECONDS);
logger.info("appium android 成功启动 APP Package [ " +
desiredCapabilities.getCapability(AndroidMobileCapabilityType.APP_PACKAGE) + " ]。");
}catch ( WebDriverException e ) {
if (e.getMessage().contains("Connection refused: ")) {
logger.error("Appium Desktop 服务器未启动，请检查，谢谢。");
}
if (e.getMessage().contains("not find app package")) {
assert desiredCapabilities != null;
logger.error("Android app【 " + desiredCapabilities.getCapability
(AndroidMobileCapabilityType.APP_PACKAGE) + " ] 不存在。");
}
logger.error("App启动异常：", e);
}
return driver;
}
}

复制代码

/*
* 获取所有设备
*/
public static List<DeviceEntity> getAllDevices(){
Map stfHeaderMap = new HashMap();
Map paramMap = new HashMap();
stfHeaderMap.put("Authorization","Bearer "+ACCESS_TOKEN);
String response = httpClientAdaptor.doGet(STF_SERVICE_URL + "devices",stfHeaderMap,paramMap);//查询所有的设备
Map maps = JsonUtil.toObject(response, Map.class); // json转换为Map
String devices = String.valueOf(maps.get("devices")); // 获取设备列表，是一个json数组
System.out.println("所有的设备信息："+devices);
//将json数组转化为
List<DeviceEntity> deviceList = new ArrayList<>();
JSONArray array = JsonUtil.toJSONArray(devices);
for (int i = 0;i<array.size();i++){
DeviceEntity deviceEntity = new DeviceEntity();
JSONObject obj = (JSONObject) array.get(i);
deviceEntity.setSerial(obj.getString("serial"));
deviceEntity.setPlatform(obj.getString("platform"));
deviceEntity.setVersion(obj.getString("version"));
deviceEntity.setRemoteConnectUrl(obj.getString("remoteConnectUrl"));
deviceEntity.setUsing(Boolean.parseBoolean(obj.getString("using")));
deviceEntity.setReady(Boolean.parseBoolean(obj.getString("ready")));
deviceEntity.setPresent(Boolean.parseBoolean(obj.getString("present")));
String providerJson = obj.getString("provider");
Map providerMaps = JsonUtil.toObject(providerJson, Map.class);
String providerName = (String) providerMaps.get("name");
deviceEntity.setProvider(providerName);
deviceList.add(deviceEntity);
}
System.out.println("设备个数："+deviceList.size());
return deviceList;
}
/*
* 查找空闲设备并锁定
*/
public static String connectFreeDevice(String slaveMachine){
String currentConnectedDevice = null;
List<DeviceEntity> deviceList = getAllDevices();
for (Iterator itr = deviceList.iterator(); itr.hasNext();) {
DeviceEntity device = (DeviceEntity) itr.next();
//获取对应编译机上挂载的手机设备
if (device.getProvider().contains(slaveMachine)){
if (!device.isPresent() || !device.isReady() || device.isUsing()){
//logger.error("device is in use!");
continue;
}
//找到空闲即申请使用
currentConnectedDevice = device.getSerial();
addDeviceToUser(currentConnectedDevice);
logger.info("Find free device："+currentConnectedDevice);
break;
}
}
return currentConnectedDevice;
}
/*
* 锁定设备，标识被某个stf的账户占用
*/
private static boolean addDeviceToUser(String serial){
String reqJson = "{\"serial\": \""+serial+"\"}";
Map stfHeaderMap = new HashMap();
Map paramMap = new HashMap();
stfHeaderMap.put("Authorization","Bearer "+ACCESS_TOKEN);
stfHeaderMap.put("Content-Type","application/json; charset=utf-8");
String response = httpClientAdaptor.doPost(STF_SERVICE_URL + "user/devices",stfHeaderMap,reqJson);
logger.info("mq 端锁定设备响应消息:"+response);
Map maps = JsonUtil.toObject(response, Map.class); // json转换为Map
if (!Boolean.parseBoolean(String.valueOf(maps.get("success")))) {
logger.error("Device not found");
return false;
}
logger.info("The device ["+serial+"]is locked successfully");
return true;
}
/*
* 释放设备(用例用完以后，将该设备重新置为空闲)
*/
public static void releaseDevice(String serial) {
Map paramMap = new HashMap();
Map stfHeaderMap = new HashMap();
stfHeaderMap.put("Authorization","Bearer "+stfService.getAuthToken());
String response = httpClientAdaptor.doDelete(stfService.getStfUrl() + "user/devices/"+serial,stfHeaderMap,"");
logger.info("释放设备接口返回信息："+response);
}

复制代码

package cn.study.testapi.base.support;
import cn.study.testapi.base.enums.DrivenEnum;
import cn.study.testapi.base.load.InitLoadNew;
import cn.study.testapi.core.appium.server.AppiumServer;
import cn.study.testapi.core.driver.driven.factory.KeyDriverFactory;
import cn.study.testapi.core.driver.keydriver.AndroidKeyDriver;
import cn.study.testapi.core.openstf.DeviceApi;
import cn.study.testapi.utils.*;
import cn.study.testapi.core.keyaction.AndroidKeyAction;
import cn.study.testapi.core.entity.ComponentStep;
import org.apache.log4j.Logger;
import org.testng.ITestContext;
import org.testng.annotations.*;
import java.util.List;
public class AndroidKeywordTest extends BaseKeyTest {
protected static Logger logger = Logger.getLogger(AndroidKeywordTest.class);
protected AndroidKeyDriver driver = null;
//在testng suit之前启动appium server
@Parameters({"deviceSerial"})
@BeforeSuite(alwaysRun = true)
public void setUp(@Optional("deviceSerial") String deviceSerial, ITestContext context) {
InitLoadNew initLoadNew = new InitLoadNew(odinEnv, taskId);
// 初始化接口返回result
setCaseStepList(initLoadNew.getCaseStepList());
AppiumServer.startServer();//启动appium server
driver = MyAndroidKeyMobileDriver.getDriver(context); // 启动android app，根据自己的项目结构去设计此处获取driver的方式
}
@Test(alwaysRun = true, dataProvider = "keyword")
public void testCaseStep(List<ComponentStep> data) {
//执行你的用例
}
//aftersuit执行的动作，此处传一个【设备序列】参数，指明要释放的设备
@Parameters({"deviceSerial"})
@AfterSuite(alwaysRun = true)
public void tearDown(@Optional("deviceSerial") String deviceSerial) {
logger.info("========= tearDown ========");
DeviceApi.releaseDevice(deviceSerial);//释放移动设备
AppiumServer.stopAppiumServer();//用例执行完后停掉服务
JdbcUtil.close();
TempFileUtil.deleteOnExit();
driver.quit();
}
}

复制代码