ATX ATX 学习 (三)-atxserver2-android-provider

阿凯 · May 13, 2019 · Last by 阿凯 replied at May 14, 2019 · 622 hits

服务端代码

代码clone到本地,搭好相应环境(怎么搭的这里就不介绍了,很好搭的哈)
一般库首先查看main.py文件,debug模式开始运行

一开始就是没接触过的tornado.ioloop,有点偏底层,头疼,还是加油干吧

为了理解的更深入些,先了解下ioloop的一些知识吧,在这之前先了解点预备知识

一、epoll

ioloop 的实现基于epoll,那么什么是epoll?epoll是Linux内核为处理大批量文件描述
符而作了改进的 poll。那什么是poll呢?首先,我们了解一下, socket 通信时的服务端,当它接受( accept )一个连接并建立通信后( connection )就进行通信,而此时我们并不知道连接的客户端有没有信息发完。 这时候有两种选择:

  • 一直在这里等着直到收发数据结束;
  • 每隔一定时间来看看这里有没有数据;

    第二种办法要比第一种好一些,多个连接可以统一在一定时间内轮流看一遍里面有没
    有数据要读写,看上去可以处理多个连接了,这个方式就是 poll / select 的解决方案。 看起来似乎解决了问题,但实际上,随着连接越来越多,轮询所花费的
    时间将越来越长,而服务器连接的 socket大多不是活跃的,所以轮询所花费的大部分
    时间将是无用的。为了解决这个问题, epoll 被创造出来,它的概念和 poll 类似,不过每次轮询时,他只会把有数据活跃的socket挑出来轮询,这样在有大量连接时轮询就节省了大量时间。

而对于epoll的操作,其实也很简单,只要 4 个 API 就可以完全操作它。

epoll_create

用来创建一个 epoll 描述符( 就是创建了一个 epoll )

epoll_ctl

操作 epoll 中的 event;可用参数有:

参数 含义
EPOLL_CTL_ADD 添加一个新的epoll事件
EPOLL_CTL_DEL 删除一个epoll事件
EPOLL_CTL_MOD 改变一个事件的监听方式

而事件的监听方式有七种,而我们只需要关心其中的三种:

宏定义 含义
EPOLLIN 缓冲区满,有数据可读
EPOLLOUT 缓冲区空,可写数据
EPOLLERR 发生错误

epoll_wait

就是让 epoll 开始工作,里面有个参数 timeout,当设置为非 0 正整数时,会监听(阻塞) timeout 秒;设置为 0 时立即返回,设置为 -1 时一直监听。

在监听时有数据活跃的连接时其返回活跃的文件句柄列表(此处为 socket 文件句柄)

close

关闭 epoll

现在简单了解了 epoll 后,我们就可以来了解ioloop代码

二 ioloop.py文件

ioloop是tornado的关键,是他的最底层。
ioloop就是对I/O多路复用的封装,它实现了一个单例,将这个单例保存在IOLoop._instance中
主要有两个要点。一个是configurable机制,一个就是epoll循环

2.1 创建IOLoop实例

来看IOLoop,它的父类是Configurable类,也就是说:IOLoop是一个直属配置子类
class IOLoop(Configurable):
......
这里就要结合Configurable类进行讲解:
Configurable中的new方法
1.首先实例化一个该直属配置子类的'执行类对象',也就是调用该类的configurable_default方法并返回赋值给impl:

2.2 epoll

从start()开始,啥都不说,上代码

asyncio.get_event_loop()方法,在一个coroutine内部获取loop他不需要将loop作为参数传递给协程函数

注意get_event_loop()方法仅在同样的线程中生效,如果在一个新线程中,应该用new_event_loop()来获取新的loop,并通过set_event_loop(loop)来将其设为该线程下的loop。
(暂时深入到这里吧,跑偏题了,尴尬)
继续
main.py文件中运行开始 IOLoop.current().run_sync(async_main)是干什么的

IOLoop中的run_sync方法中调用的函数添加参数,这个好理解。
(这里暂时不在深入,怕又跑偏了,记录yi有时间的话继续)

async(协程的语法)

作者很给力,不断的使用新的东西,这是python3.5后为asyncio提供了async和await的新语法
想要了解协程的可以看下这篇,通过实例来了解更好些https://zhuanlan.zhihu.com/p/25228075
注意:通过async关键字定义一个协程(coroutine),协程也是一种对象。协程不能直接运行,需要把协程加入到事件循环(loop),由后者在适当的时候调用协程。
定义异步函数async def async_main()

三 继续看代码吧

# 定义异步函数

async def async_main():
# 建立解析对象ArgumentParser formatter_class 重置 help 信息输出的格式
parser = argparse.ArgumentParser(
formatter_class=argparse.ArgumentDefaultsHelpFormatter)
# 为应用程序添加参数选项 -的为可选参数,default默认参数值
parser.add_argument(
'-s', '--server', default='localhost:4000', help='server address')
# action参数的处理方法
parser.add_argument(
"--allow-remote", action="store_true", help="allow remote connect device")
parser.add_argument(
'-t', '--test', action="store_true", help="run test code")
# type参数的数据类型
parser.add_argument(
'-p', '--port', type=int, default=3500, help='listen port')
parser.add_argument("--owner", type=str, help="provider owner email")
parser.add_argument(
"--owner-file", type=argparse.FileType("r"), help="provider owner email from file")

3.1调用parse_args()

来解析ArgumentParser对象中保存的命令行参数:将命令行参数解析成相应的数据类型并采取相应的动作,它返回一个Namespace对象。

args = parser.parse_args()

3.2 heartbeat_connect 等待连接

这里直接运行会出现

什么原因,应该很容易看到,需要连接localhost:4000,没有起服务,好吧,先运行rethinkdb数据库,然后启动atx-server2

好了,然后运行

3.3 进入make_app()

使用tornado.web.Application进行路由控制

3.4 heartbeat_connect去连接设备,这里可以看到过程中基本都是异步方法aysc,运行到_connect这个方法时:

async def _connect(self):
ws = await websocket.websocket_connect(self._server_ws_url)
ws.__class__ = SafeWebSocket

await ws.write_message({
"command": "handshake",
"name": self._name,
"owner": self._owner,
"secret": self._secret,
"url": self._provider_url,
"priority": self._priority, # the large the importanter
})

发现通过websockt 服务来连接

3.5 hbc.open()

IOLoop.current().spawn_callback(coroutine_visit) #开始调用协程

3.6 device_watch()

開始使用adb進行監控 127.0.0.1:5037 这里就不再说name多了
_init_binaries() 这里刚开始获取了设备信息] [设备名] [sdk: 28, abi: arm64-v8a, abis: ['arm64-v8a', 'armeabi-v7a', 'armeabi']
根据设备选择要使用的atx 代理use atx-agent: atx-agent-armv7

3.7 _install_apk()安装whatsInput 和ATX这里只看这两个,另一个属于测试包

这里手机初始化准备好后会向前端页面发送
websocket send: {'udid': '2d869e6', 'platform': 'android', 'colding': False, 'provider': {'atxAgentAddress': '127.0.0.1:20001', 'remoteConnectAddress': 'Ip:20004',

'whatsInputAddress': '127.0.0.1:20003'}, 'properties': {'serial': '设备名', 'brand': 'Xiaomi', 'version': '9', 'model': 'MI 9', 'name': 'MI 9'}, 'command': 'update'}

暂时写到这里吧,明天有时间看下atx-server2的部分代码,觉得结合着看更方便去了解

目前还在学习中,希望会对大家有所帮助,觉得不错,就点赞支持一下。 另外,有什么错误的地方需要大家指正。谢谢!

共收到 2 条回复 时间 点赞

看的真仔细

阿凯 #2 · May 14, 2019 作者
codeskyblue 回复

大佬好,非常感谢项目的开源,感谢可以让我有进一步提升的学习机会😀

需要 Sign In 后方可回复, 如果你还没有账号请点击这里 Sign Up