多台设备并行运行monkey

比如有10 台设备，要在这10台设备上运行monkey 脚本们可以通过命令行的方式来进行。如果手动执行会比较麻烦；

运行单个手机 monkey

adb 命令

  1. adb shell monkey 500

monkey ：https://developer.android.google.cn/studio/test/monkey?hl=zh-cn

subprocss 子进程方式执行命令

python 脚本, 执行一台设备的脚本

  1. import  subprocess
  3. monkey_cmd = "adb -s 127.0.0.1:62001 shell monkey -p org.cnodejs.android.md -v --throttle 500 500"
  4. with open('./monkey_run.log',mode='w',encoding='utf8') as file:
  5.     subprocess.Popen(monkey_cmd,stdout=file)

命令解释

  1. "adb -s 127.0.0.1:62001 shell monkey -p org.cnodejs.android.md -v --throttle 500 500"
  3. -s 127.0.0.1:62001   # 执行的手机设备串号
  4. -p org.cnodejs.android.md   # 执行运行的app
  5. -v  # 显示详细日志 日志级别分为三个基本  -vv  表示最详细的日志级别
  6. --throttle 500    # 每个事件之间的 间隔时间 为500 毫秒
  7. 500 # 执行500个事件

如果现在是两台设备

  1. C:\Users\zengy>adb devices
  2. List of devices attached
  3. 127.0.0.1:62001 device
  4. emulator-5554   device

写个for循环 启动子进程的方式运行多台设备

  1. import  subprocess
  3. def run(device_id):
  4.     monkey_cmd = f"adb -s {device_id} shell monkey -p org.cnodejs.android.md -v --throttle 500 500"
  5.     with open('./monkey_run.log',mode='w',encoding='utf8') as file:
  6.         subprocess.Popen(monkey_cmd,stdout=file,shell=True)
  8. if __name__ == '__main__':
  9.     devices = ['127.0.0.1:62001',"emulator-5554"]
  10.     for device in devices:
  11.         run(device)

两台设备运行的时候都会把把日志写入到一个文件中。这样肯定是不行的
下面要求：

  1. 自动获取device的设备串号，比如设备连接 三台， 自动获取这三台手机的串号
  2. 自动执行monkey ，运行monkey的时候，每台设备产生的日志信息应该保存到对应的设备的日志中。日志文件名以设备串号命名。

使用代码的方式获取已经连接成功的设备

  1. C:\Users\zengy>adb devices
  2. List of devices attached
  3. emulator-5554   device
  4. emulator-5556   unauthorized

获取所有连接的设备

  1. import subprocess
  2. # 创建子进程
  3. devices = []
  5. proc = subprocess.Popen('adb devices',stdout=subprocess.PIPE,shell=True)
  6. for line in proc.stdout.readlines():
  7.     # print(type(line),line)
  8.     # 将字节类型转换为字符串
  9.     linestr = line.decode(encoding='utf8')
  10.     if '\tdevice' in linestr:
  11.         # 字符串分割 提取 deviceid值
  12.         device_id = linestr.strip().split('\tdevice')[0]
  13.         devices.append(device_id)
  15. print(devices)

实现自动执行多台设备

  1. import  subprocess
  3. def get_connect_devices():
  4.     """
  5.     获取已经成功连接的设备
  6.     :return: list
  7.     """
  8.     devices = []
  10.     proc = subprocess.Popen('adb devices', stdout=subprocess.PIPE,shell=True)
  11.     for line in proc.stdout.readlines():
  12.         # print(type(line),line)
  13.         # 将字节类型转换为字符串
  14.         linestr = line.decode(encoding='utf8')
  15.         if '\tdevice' in linestr:
  16.             # 字符串分割 提取 deviceid值
  17.             device_id = linestr.strip().split('\tdevice')[0]
  18.             devices.append(device_id)
  20.     return devices
  23. def run(device_id:str):
  24.     # 字符串名字去掉特殊字符
  25.     devicename = device_id.replace(':','_')
  26.     devicefile = devicename.replace('.',"_")
  27.     monkey_cmd = f"adb -s {device_id} shell monkey -p org.cnodejs.android.md -vv --throttle 500 500"
  28.     with open(f'./{devicefile}.log',mode='w',encoding='utf8') as file:
  29.         subprocess.Popen(monkey_cmd,stdout=file,shell=True)
  31. if __name__ == '__main__':
  32.     devices = get_connect_devices()
  33.     for device in devices:
  34.         run(device)

multiprocessing 并行运行

通过多进程的方式执行自动化脚本
https://docs.python.org/zh-cn/3/library/multiprocessing.html

  1. import time
  3. def run():
  4.     time.sleep(1)
  5.     print('helloworld')
  6.     time.sleep(1)
  7.     print('end')
  9. if __name__ == '__main__':
  10.     start= time.perf_counter()
  11.     for i in range(4):
  12.         run()
  13.     end = time.perf_counter()
  14.     print(f'执行用时: {end-start}s')

image.png

下面使用多进程的方式执行

  1. import time
  2. import multiprocessing
  3. import random
  5. def run(name):
  6.     time.sleep(1)
  7.     print(f'helloworld-{name}')
  8.     time.sleep(1)
  9.     print('end')
  11. if __name__ == '__main__':
  12.     start= time.perf_counter()
  13.     processes = []
  14.     # 启动8个进程
  15.     for i in range(8):
  16.         p = multiprocessing.Process(target=run,args=(random.random(),)) # 注意参数
  17.         processes.append(p)
  18.         p.start()  # 启动
  20.     # 执行进程中的脚本
  21.     for proce in processes:
  22.         proce.join() # 加入队列
  24.     end = time.perf_counter()
  25.     print(f'执行用时: {end-start}s')

使用多进程的方式之后，代码执行需要2s

使用多进程的方式改进自动化monkey代码

  1. import  subprocess
  2. import multiprocessing
  4. def get_connect_devices():
  5.     """
  6.     获取已经成功连接的设备
  7.     :return: list
  8.     """
  9.     devices = []
  11.     proc = subprocess.Popen('adb devices', stdout=subprocess.PIPE,shell=True)
  12.     for line in proc.stdout.readlines():
  13.         # print(type(line),line)
  14.         # 将字节类型转换为字符串
  15.         linestr = line.decode(encoding='utf8')
  16.         if '\tdevice' in linestr:
  17.             # 字符串分割 提取 deviceid值
  18.             device_id = linestr.strip().split('\tdevice')[0]
  19.             devices.append(device_id)
  21.     return devices
  24. def run(device_id:str):
  25.     # 字符串名字去掉特殊字符
  26.     devicename = device_id.replace(':','_')
  27.     devicefile = devicename.replace('.',"_")
  28.     monkey_cmd = f"adb -s {device_id} shell monkey -p org.cnodejs.android.md -s 1625569785406 -vv --throttle 500 500"
  29.     with open(f'./{devicefile}.log',mode='w',encoding='utf8') as file:
  30.         subprocess.Popen(monkey_cmd,stdout=file,shell=True)
  32. if __name__ == '__main__':
  33.     devices = get_connect_devices()
  34.     process = []
  35.     for device_id in devices:
  36.         p = multiprocessing.Process(target=run,args=(device_id,))
  37.         process.append(p)
  38.         p.start()
  40.     for proc in process:
  41.         proc.join()
  43.     # for device in devices:
  44.     #     run(device)

appium 多台设备并行执行

现在有两台手机设备

  1. C:\Users\zengy>adb devices
  2. List of devices attached
  3. 127.0.0.1:62001 device
  4. 127.0.0.1:62025 device

分别启动两个appium 服务

  1. appium -p 4723
  1. appium -p 4725

image.png
同时使用appium 连接两台设备

  2. def start_driver(device_id, port):
  3.     desired_caps = {
  4.         'platformName': 'Android',  # 测试Android系统
  5.         'udid': device_id,  # adb devices 命令查看  设置为自己的设备
  6.         'automationName': 'UiAutomator2',  # 自动化引擎
  7.         'noReset': False,  # 不要重置app的状态
  8.         'fullReset': False,  # 不要清理app的缓存数据
  9.         # 'chromedriverExecutable': chromedriver,  # chromedriver 对应的绝对路径
  10.         'appPackage': "org.cnodejs.android.md",  # 应用的包名
  11.         'appActivity': ".ui.activity.LaunchActivity"  # 应用的活动页名称
  12.     }
  13.     driver = webdriver.Remote(f'http://127.0.0.1:{port}/wd/hub', desired_capabilities=desired_caps)
  14.     driver.implicitly_wait(5)  # 全局的隐式等待时间
  18. if __name__ == '__main__':
  19.     deivces = [('127.0.0.1:62001', 4723),('127.0.0.1:62025',4725)]
  20.     processes = []
  21.     for device in deivces:
  22.         p= multiprocessing.Process(target=start_driver,args=(device[0],device[1],))
  23.         p.start()
  24.         processes.append(p)
  26.     for proc in processes:
  27.         proc.join()

自动获取连接的设备，并自动启动appium

  1. # 并行 运行两台设备
  3. from appium import webdriver
  4. import subprocess,os,sys
  5. import multiprocessing
  7. def get_connect_devices():
  8.     """
  9.     获取已经成功连接的设备
  10.     :return: list
  11.     """
  12.     devices = []
  13.     port = 4723
  15.     proc = subprocess.Popen('adb devices', stdout=subprocess.PIPE,shell=True)
  17.     for line in proc.stdout.readlines():
  18.         # print(type(line),line)
  19.         # 将字节类型转换为字符串
  20.         linestr = line.decode(encoding='utf8')
  21.         if '\tdevice' in linestr:
  22.             # 字符串分割 提取 deviceid值
  23.             device_id = linestr.strip().split('\tdevice')[0]
  24.             devices.append((device_id,port))
  25.             port += 2 # 端口递增2
  27.     return devices
  29. def start_appium(port):
  30.     """
  31.     使用命令行的方式启动appium
  32.     :return:
  33.     """
  34.     start_cmd=f'appium -p {port}'
  35.     with open(f'./{port}.log',mode='w',encoding='utf8') as file:
  36.         subprocess.Popen(start_cmd,shell=True,stdout=file)
  39. def kill_appium(port):
  40.     """
  41.     通过端口号结束appium 进程
  42.     Windows 执行命令 netstat -anp | finstr port
  43.     通过 taskkill -f -pid   pid  结束进程
  44.     Mac 系统 执行名 lsof -p  port
  45.     执行 kill -9 pid  结束进程
  46.     :param port:
  47.     :return:
  48.     """
  49.     # 执行根据端口号 查找进程
  50.     # windows 系统：
  52.     # print(sys.platform)
  53.     if sys.platform == 'win32':
  54.         find_pid = f'netstat -ano | findstr {port}'
  55.         proc = subprocess.Popen(find_pid,shell=True,stdout=subprocess.PIPE)
  56.         for line in proc.stdout.readlines():
  57.             print("line",line)
  58.             if line:
  59.                 strline= line.decode(encoding='utf8')
  60.                 if "LISTENING" in strline:
  61.                     print('strline',strline)
  62.                     pid = strline.strip().split('LISTENING')[-1].strip()
  63.                     # 有了pid 之后 再执行 taskkill -f -pid pid
  64.                     os.system(f'taskkill -f -pid {pid}')
  65.     # mac 系统
  66.     else:
  67.         mac_cmd = f"lsof -i tcp:{port}"
  68.         p = subprocess.Popen(mac_cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  69.         for line in p.stdout.readlines():
  70.             line = line.decode('utf8')
  71.             # print("line",line)
  72.             if "node" in line:
  73.                 stdoutline = line.split(" ")
  74.                 print(stdoutline)
  75.                 pid = stdoutline[4]
  76.                 os.system(f"kill {pid}")
  78. def start_driver(device_id, port):
  79.     # 先开启appium 再连接, 启动之前 先结束之前启动的apppium
  80.     kill_appium(port)
  81.     start_appium(port)
  83.     desired_caps = {
  84.         'platformName': 'Android',  # 测试Android系统
  85.         'udid': device_id,  # adb devices 命令查看  设置为自己的设备
  86.         'automationName': 'UiAutomator2',  # 自动化引擎
  87.         'noReset': False,  # 不要重置app的状态
  88.         'fullReset': False,  # 不要清理app的缓存数据
  89.         # 'chromedriverExecutable': chromedriver,  # chromedriver 对应的绝对路径
  90.         'appPackage': "org.cnodejs.android.md",  # 应用的包名
  91.         'appActivity': ".ui.activity.LaunchActivity"  # 应用的活动页名称
  92.     }
  93.     driver = webdriver.Remote(f'http://127.0.0.1:{port}/wd/hub', desired_capabilities=desired_caps)
  94.     driver.implicitly_wait(5)  # 全局的隐式等待时间
  98. if __name__ == '__main__':
  99.     devices = get_connect_devices()
  100.     # print(devices)
  101.     # deivces = [('127.0.0.1:62001', 4723),('127.0.0.1:62025',4725)]
  102.     processes = []
  103.     for device in devices:
  104.         p= multiprocessing.Process(target=start_driver,args=(device[0],device[1],))
  105.         p.start()
  106.         processes.append(p)
  108.     for proc in processes:
  109.         proc.join()

Windows 搭建JenKins自动化测试集成环境

自动化操作多台设备