SoloX之安卓logcat

@socketio.on('connect', namespace='/logcat')

def connect():

    socketio.emit('start connect', {'data': 'Connected'}, namespace='/logcat')

    logDir = os.path.join(os.getcwd(),'adblog')

    if not os.path.exists(logDir):

        os.mkdir(logDir)

    global thread

    thread = True

    with thread_lock:

        if thread:

            thread = socketio.start_background_task(target=backgroundThread)

def backgroundThread():

    global thread

    try:

        # logger.info('Initializing adb environment ...')

        # os.system('adb kill-server')

        # os.system('adb start-server')

        current_time = time.strftime("%Y%m%d%H", time.localtime())

        logPath = os.path.join(os.getcwd(),'adblog',f'{current_time}.log')

        logcat = subprocess.Popen(f'adb logcat *:E > {logPath}', stdout=subprocess.PIPE,

                                  shell=True)

        with open(logPath, "r") as f:

            while thread:

                socketio.sleep(1)

                for line in f.readlines():

                    socketio.emit('message', {'data': line}, namespace='/logcat')

        if logcat.poll() == 0:

            thread = False

    except Exception:

        pass