启动多个Appium服务 (2)

多进程中,同一个变量,各自有一份拷贝存在于每个进程中,互不影响。
而多线程中,所有变量都由所有线程共享,所以,任何一个变量都可以被任何一个线程修改,因此,线程之间共享数据最大的危险在于多个线程同时改一个变量,容易把内容给改乱了。
知识点补充:

线程与进程
Python多进程
python多线程
代码实现

multi_devices_sync.py

from appium import webdriver

import yaml

from  time import  ctime

import multiprocessing

with open(\'desired_caps.yaml\',\'r\') as file:

data=yaml.load(file)

devices_list=[\'127.0.0.1:62001\',\'127.0.0.1:62025\']

def appium_desired(udid,port):

desired_caps={}

desired_caps[\'platformName\']=data[\'platformName\']

desired_caps[\'platformVersion\']=data[\'platformVersion\']

desired_caps[\'deviceName\']=data[\'deviceName\']

desired_caps[\'udid\']=udid

desired_caps[\'app\']=data[\'app\']

desired_caps[\'appPackage\']=data[\'appPackage\']

desired_caps[\'appActivity\']=data[\'appActivity\']

desired_caps[\'noReset\']=data[\'noReset\']

print(\'appium port:%s start run %s at %s\' %(port,udid,ctime()))

driver=webdriver.Remote(\'http://\'+str(data[\'ip\'])+\':\'+str(port)+\'/wd/hub\',desired_caps)

driver.implicitly_wait(5)

return driver

#构建desired进程租

desired_process=[]

#加载desied进程

for i in range(len(devices_list)):

port = 4723 + 2 * i

desired=multiprocessing.Process(target=appium_desired,args=(devices_list[i],port))

desired_process.append(desired)

if __name__ == \'__main__\':

# 启动多设备执行测试

for desired in desired_process:

desired.start()

for desired in desired_process:

desired.join()

Python启动Appium 服务
目前我们已经实现了并发启动设备,但是我们的Appium服务启动还是手动档,比如使用Dos命令或者bat批处理来手动启动appium服务,启动效率低下。如何将启动Appium服务也实现自动化呢?

方案分析

我们可以使用python启动appium服务,这里需要使用subprocess模块,该模块可以创建新的进程,并且连接到进程的输入、输出、错误等管道信息,并且可以获取进程的返回值。

subprocess模块官方文档

测试场景

使用Python启动2台appium服务,端口配置如下:

Appium服务器端口:4723,bp端口为4724
Appium服务器端口:4725,bp端口为4726
说明:bp端口( --bootstrap-port)是appium和设备之间通信的端口,如果不指定到时无法操作多台设备运行脚本。

代码实现

首先我们使用Python脚本启动单个appium服务:

host:127.0.0.1
port:4723
multi_appium.py

import subprocess

from time import ctime

def appium_start(host,port):

\'\'\'启动appium server\'\'\'

bootstrap_port = str(port + 1)

cmd = \'start /b appium -a \' + host + \' -p \' + str(port) + \' -bp \' + str(bootstrap_port)

print(\'%s at %s\' %(cmd,ctime()))

subprocess.Popen(cmd, shell=True,stdout=open(\'./appium_log/\'+str(port)+\'.log\',\'a\'),stderr=subprocess.STDOUT)

if __name__ == \'__main__\':

host = \'127.0.0.1\'

port=4723

appium_start(host,port)

启动校验

启动后我们需要校验服务是否启动成功,校验方法如下:

首先查看有没有生成对应的log文件,查看log里面的内容。
使用如下命令来查看
netstat -ano |findstr 端口号

netstat 命令解释

netstat命令是一个监控TCP/IP网络的非常有用的工具,它可以显示路由表、实际的网络连接以及每一个网络接口设备的状态信息。输入 netstat -ano 回车.可以查看本机开放的全部端口;输入命令 netstat -h可以查看全部参数含义。

C:\Users\Shuqing>netstat -ano |findstr "4723"

TCP    127.0.0.1:4723         0.0.0.0:0              LISTENING       8224

关闭Appium服务

关闭进程有2种方式,具体如下:

通过netstat命令找到对应的Appium进程pid然后可以在系统任务管理器去关闭进程;
win7系统任务管理器PID显示

使用如下命令来关闭:
taskkill -f -pid appium进程id

多个appium服务启动

多个appium服务启动非常简单,只需在执行环境使用循环调用即可。

if __name__ == \'__main__\':

host = \'127.0.0.1\'

for i in range(2):

port=4723+2*i

appium_start(host,port)

多进程并发启动appium服务
上面的案例还不是并发执行启动appium,因此我们需要使用多进程来实现并发启动。 同样需要引入multiprocessing多进程模块。

muti_appium_sync.py

import multiprocessing

import subprocess

from  time import  ctime

def appium_start(host,port):

\'\'\'启动appium server\'\'\'

bootstrap_port = str(port + 1)

cmd = \'start /b appium -a \' + host + \' -p \' + str(port) + \' --bootstrap-port \' + str(bootstrap_port)

print(\'%s at %s\' %(cmd,ctime()))

subprocess.Popen(cmd, shell=True,stdout=open(\'./appium_log/\'+str(port)+\'.log\',\'a\'),stderr=subprocess.STDOUT)

#构建appium进程组

appium_process=[]

#加载appium进程

for i in range(2):

host=\'127.0.0.1\'

port = 4723 + 2 * i

appium=multiprocessing.Process(target=appium_start,args=(host,port))

appium_process.append(appium)

if __name__ == \'__main__\':

#并发启动appium服务

for appium in appium_process:

appium.start()

for appium in appium_process:

appium.join()

Appium端口检测
问题思考

经过前面学习,我们已经能够使用python启动appium服务,但是启动Appium服务之前必须保证对应的端口没有被占用,否则会出现如下报错:

C:\Users\Shuqing>appium -a 127.0.0.1 -p 4723

[Appium] Welcome to Appium v1.7.2

[Appium] Non-default server args:

[Appium]   address: 127.0.0.1

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zwzggd.html