# 背景
使用实时输入法：[sonic输入法 ](https://soniccloudorg.github.io/saa/saa-keyboard.html)时，提示java.lang.SecurityException提示



# 分析

```sh
lixuefu@lixuefu-virtual-machine:~$ adb shell ime enable org.cloud.sonic.android/.keyboard.SonicKeyboard

Exception occurred while executing 'ime':
java.lang.SecurityException: uid 2000 does not have android.permission.WRITE_SECURE_SETTINGS.
	at android.app.ContextImpl.enforce(ContextImpl.java:2189)
	at android.app.ContextImpl.enforceCallingPermission(ContextImpl.java:2207)
	at com.android.server.inputmethod.InputMethodManagerService$ShellCommandImpl.lambda$onCommand$0$InputMethodManagerService$ShellCommandImpl(InputMethodManagerService.java:5590)
	at com.android.server.inputmethod.InputMethodManagerService$ShellCommandImpl$$ExternalSyntheticLambda0.accept(Unknown Source:4)
	at java.util.Arrays$ArrayList.forEach(Arrays.java:3805)
	at com.android.server.inputmethod.InputMethodManagerService$ShellCommandImpl.onCommand(InputMethodManagerService.java:5590)
	at com.android.modules.utils.BasicShellCommandHandler.exec(BasicShellCommandHandler.java:97)
	at android.os.ShellCommand.exec(ShellCommand.java:38)
	at com.android.server.inputmethod.InputMethodManagerService.onShellCommand(InputMethodManagerService.java:5564)
	at android.os.Binder.shellCommand(Binder.java:971)
	at android.os.Binder.onTransact(Binder.java:855)
	at com.android.internal.view.IInputMethodManager$Stub.onTransact(IInputMethodManager.java:535)
	at com.android.server.inputmethod.InputMethodManagerService.onTransact(InputMethodManagerService.java:1819)
	at com.android.server.inputmethod.OplusInputMethodManagerService.onTransact(OplusInputMethodManagerService.java:186)
	at android.os.Binder.execTransactInternal(Binder.java:1227)
	at android.os.Binder.execTransact(Binder.java:1164)
lixuefu@lixuefu-virtual-machine:~$ adb shell ime set org.cloud.sonic.android/.keyboard.SonicKeyboard

Exception occurred while executing 'ime':
java.lang.SecurityException: uid 2000 does not have android.permission.WRITE_SECURE_SETTINGS.
	at android.app.ContextImpl.enforce(ContextImpl.java:2189)
	at android.app.ContextImpl.enforceCallingPermission(ContextImpl.java:2207)
	at com.android.server.inputmethod.InputMethodManagerService$ShellCommandImpl.lambda$onCommand$0$InputMethodManagerService$ShellCommandImpl(InputMethodManagerService.java:5590)
	at com.android.server.inputmethod.InputMethodManagerService$ShellCommandImpl$$ExternalSyntheticLambda0.accept(Unknown Source:4)
	at java.util.Arrays$ArrayList.forEach(Arrays.java:3805)
	at com.android.server.inputmethod.InputMethodManagerService$ShellCommandImpl.onCommand(InputMethodManagerService.java:5590)
	at com.android.modules.utils.BasicShellCommandHandler.exec(BasicShellCommandHandler.java:97)
	at android.os.ShellCommand.exec(ShellCommand.java:38)
	at com.android.server.inputmethod.InputMethodManagerService.onShellCommand(InputMethodManagerService.java:5564)
	at android.os.Binder.shellCommand(Binder.java:971)
	at android.os.Binder.onTransact(Binder.java:855)
	at com.android.internal.view.IInputMethodManager$Stub.onTransact(IInputMethodManager.java:535)
	at com.android.server.inputmethod.InputMethodManagerService.onTransact(InputMethodManagerService.java:1819)
	at com.android.server.inputmethod.OplusInputMethodManagerService.onTransact(OplusInputMethodManagerService.java:186)
	at android.os.Binder.execTransactInternal(Binder.java:1227)
	at android.os.Binder.execTransact(Binder.java:1164)
lixuefu@lixuefu-virtual-machine:~$ adb shell pm grant org.cloud.sonic.android android.permission.WRITE_SECURE_SETTINGS

Exception occurred while executing 'grant':
java.lang.SecurityException: grantRuntimePermission: Neither user 2000 nor current process has android.permission.GRANT_RUNTIME_PERMISSIONS.
	at android.app.ContextImpl.enforce(ContextImpl.java:2189)
	at android.app.ContextImpl.enforceCallingOrSelfPermission(ContextImpl.java:2217)
	at com.android.server.pm.permission.PermissionManagerService.grantRuntimePermissionInternal(PermissionManagerService.java:1497)
	at com.android.server.pm.permission.PermissionManagerService.grantRuntimePermission(PermissionManagerService.java:1479)
	at android.permission.PermissionManager.grantRuntimePermission(PermissionManager.java:378)
	at com.android.server.pm.PackageManagerShellCommand.runGrantRevokePermission(PackageManagerShellCommand.java:2419)
	at com.android.server.pm.PackageManagerShellCommand.onCommand(PackageManagerShellCommand.java:260)
	at com.android.modules.utils.BasicShellCommandHandler.exec(BasicShellCommandHandler.java:97)
	at android.os.ShellCommand.exec(ShellCommand.java:38)
	at com.android.server.pm.PackageManagerService.onShellCommand(PackageManagerService.java:25926)
	at android.os.Binder.shellCommand(Binder.java:971)
	at android.os.Binder.onTransact(Binder.java:855)
	at android.content.pm.IPackageManager$Stub.onTransact(IPackageManager.java:4818)
	at com.android.server.pm.PackageManagerService.onTransact(PackageManagerService.java:9006)
	at android.os.Binder.execTransactInternal(Binder.java:1227)
	at android.os.Binder.execTransact(Binder.java:1164)
lixuefu@lixuefu-virtual-machine:~$ adb shell ime enable org.cloud.sonic.android/.keyboard.SonicKeyboard
Input method org.cloud.sonic.android/.keyboard.SonicKeyboard: now enabled for user #0
lixuefu@lixuefu-virtual-machine:~$ adb shell pm grant org.cloud.sonic.android android.permission.WRITE_SECURE_SETTINGS

Exception occurred while executing 'grant':
java.lang.SecurityException: Package org.cloud.sonic.android has not requested permission android.permission.WRITE_SECURE_SETTINGS
	at com.android.server.pm.permission.PermissionManagerService.grantRuntimePermissionInternal(PermissionManagerService.java:1563)
	at com.android.server.pm.permission.PermissionManagerService.grantRuntimePermission(PermissionManagerService.java:1479)
	at android.permission.PermissionManager.grantRuntimePermission(PermissionManager.java:378)
	at com.android.server.pm.PackageManagerShellCommand.runGrantRevokePermission(PackageManagerShellCommand.java:2419)
	at com.android.server.pm.PackageManagerShellCommand.onCommand(PackageManagerShellCommand.java:260)
	at com.android.modules.utils.BasicShellCommandHandler.exec(BasicShellCommandHandler.java:97)
	at android.os.ShellCommand.exec(ShellCommand.java:38)
	at com.android.server.pm.PackageManagerService.onShellCommand(PackageManagerService.java:25926)
	at android.os.Binder.shellCommand(Binder.java:971)
	at android.os.Binder.onTransact(Binder.java:855)
	at android.content.pm.IPackageManager$Stub.onTransact(IPackageManager.java:4818)
	at com.android.server.pm.PackageManagerService.onTransact(PackageManagerService.java:9006)
	at android.os.Binder.execTransactInternal(Binder.java:1227)
	at android.os.Binder.execTransact(Binder.java:1164)

```

经对比分析，是OV类开发者中开关：禁止权限监控，没打开，打开后,可以发现能正常设置

```sh
lixuefu@lixuefu-virtual-machine:~$ adb shell ime set org.cloud.sonic.android/.keyboard.SonicKeyboard
Input method org.cloud.sonic.android/.keyboard.SonicKeyboard selected for user #0
lixuefu@lixuefu-virtual-machine:~$ adb shell ime set org.cloud.sonic.android/.keyboard.SonicKeyboard
Input method org.cloud.sonic.android/.keyboard.SonicKeyboard selected for user #0
```

实时输入法使用

# 背景
性能测试时，日常需要对视频分成多帧标定启动启动时间(ms)

# 实现
核心后端实现：
```python
import cv2
import os
import logging


class VideoProcessor:
    def __init__(self, video_path: str):
        """
        初始化视频处理器
        Args:
            video_path (str): 视频文件路径
        """
        self.video_path = video_path
        self.file_name = os.path.basename(video_path).split('.')[0]
        self.dir_path = os.path.join(os.path.dirname(video_path), self.file_name)
        self.dir_path_th = None
        self.v = None

    def initialize_directories(self, mk_black_white=False):
        """
        初始化保存帧的目录
        Args:
            mk_black_white (bool): 是否创建黑白帧保存目录
        """
        os.makedirs(self.dir_path, exist_ok=True)
        if mk_black_white:
            self.dir_path_th = os.path.join(os.path.dirname(self.video_path), self.file_name + '_th')
            os.makedirs(self.dir_path_th, exist_ok=True)

    def open_video(self):
        """
        打开视频文件
        Raises:
            Exception: 如果视频文件无法打开
        """
        self.v = cv2.VideoCapture(self.video_path)
        if not self.v.isOpened():
            raise Exception(f'Video[{self.video_path}] open failed!')

    def get_video_info(self) -> (float, int):
        """
        获取视频的帧率和总帧数
        Returns:
            fps (float): 视频帧率
            total_frame (int): 视频总帧数
        """
        total_frame = int(self.v.get(cv2.CAP_PROP_FRAME_COUNT))  # 获取总帧数
        fps = self.v.get(cv2.CAP_PROP_FPS)  # 获取帧率
        return fps, total_frame

    def cv2black_white(self, frame, gray_threshold=None):
        """
        将图像转换为黑白图像
        Args:
            frame: 图像帧
            gray_threshold: 灰度阈值
        Returns:
            th_frame: 黑白图像帧
        """
        gray = cv2.cvtColor(frame, cv2.COLOR_BGR2GRAY)
        if gray_threshold is not None:
            _, th_frame = cv2.threshold(gray, gray_threshold, 255, cv2.THRESH_BINARY)
        else:
            _, th_frame = cv2.threshold(gray, 127, 255, cv2.THRESH_BINARY)
        return th_frame

    def split_video_frame(self, mk_black_white=False, gray_threshold=None) -> (float, int, str):
        """
        将视频分解为帧并保存
        Args:
            mk_black_white (bool): 是否保存黑白帧
            gray_threshold: 黑白图像的灰度阈值
        Returns:
            fps (float): 视频帧率
            total_frame (int): 视频总帧数
            dir_path (str): 保存帧的目录路径
        """
        logging.info(f'即将对视频【{self.video_path}】进行分帧处理...')
        self.initialize_directories(mk_black_white=mk_black_white)
        self.open_video()

        fps, total_frame = self.get_video_info()

        idx = 0
        while True:
            ok, frame = self.v.read()
            if ok:
                idx += 1
                # 保存原始帧
                cv2.imwrite(os.path.join(self.dir_path, f'{idx}.jpg'), frame)
                cv2.waitKey(1)
                # 保存黑白帧
                if mk_black_white:
                    th_frame = self.cv2black_white(frame, gray_threshold=gray_threshold)
                    cv2.imwrite(os.path.join(self.dir_path_th, f'{idx}.jpg'), th_frame)
                    cv2.waitKey(1)
            else:
                break
        self.v.release()
        return fps, total_frame, self.dir_path


# 使用示例
if __name__ == "__main__":
    logging.basicConfig(level=logging.INFO)
    video_path = "/home/aab/android-10.1.10.671-open-plugin_163745_1.mp4"
    processor = VideoProcessor(video_path)
    fps, total_frame, dir_path = processor.split_video_frame(mk_black_white=False, gray_threshold=128)
    logging.info(f'视频帧率: {fps}, 总帧数: {total_frame}, 帧保存目录: {dir_path}')

```

核心前端展示实现：

```vue
methods: {
    async showImgList (item, field) {
      console.log('item: ', item)
      const currSelected = [item.start_idx, item.end_idx].filter(idx => idx !== null)

      // 检查 img_list 是否存在并且是数组
      if (!item.img_list || !Array.isArray(item.img_list)) {
        console.error('img_list is undefined or not an array:', item.img_list)
        alert('图片列表未加载或为空，请检查数据！')
        return;
      }

      const vm = this
      const dl = vm.openDialog({
        title: '分帧图片',
        width: '80%',
        render: (h) => {
          return h(SelectableImg, {
            props: {
              imgList: item.img_list, // 确保 imgList 是一个数组
              currSelected: currSelected,
              onItemSelected: async (e, idx) => {
                if (e.target.checked) {
                  currSelected.push(idx + 1)
                } else {
                  currSelected.splice(currSelected.indexOf(idx + 1), 1)
                }
                await vm.change_select_idx(item.id, currSelected).then(async data => {
                  item.result = data.result
                  item.start_idx = data.start_idx
                  item.end_idx = data.end_idx
                  dl.close();
                  await field.$view.reload()
                }).catch(_ => {})
              }
            }
          })
        }
      })
    },
    async change_select_idx (itemID, selected = []) {
      const vm = this;
      return new Promise(async (resolve, reject) => {
        if (selected.length < 2) {
          return;
        }
        if (selected.length !== 2) {
          alert(`请选择2个图片，当前选择[${selected.length}]个`)
          return;
        }
        let resp = await vm.serviceApi('app-perf', 'test_term_simple_video_result_item').post({
          action: 'update_idx'
        }, {id: itemID, 'idx_list': selected.join(',')})
        if (resp.data.ok) {
          await vm.$confirm(`耗时计算成功: [${resp.data.data.result}]！需要关闭并刷新数据吗？`).then(
            _ => resolve(resp.data.data)
          ).catch(reject);
        }
      })
    },
    async bindVideoToPerfMetrics(metrics, item) {
      const vm = this
      try {

        await vm.api('perf_metrics').patch({
          id: metrics.id
        }, {
          perf_id: item.id
        })
        vm.$Message.success('绑定成功')
      } catch (error) {
        vm.$Message.success('绑定失败')
        console.error('绑定过程中发生错误:', error)
      }
    }
  }
```

视频分帧实现

# 稳定性
常规Android稳定性的执行，可以靠monkey来触发，但其基本跑不出什么异常崩溃，所以常常需要用到fastbot，其支持常规Android 5～14稳定性执行

基于 Model-based Testing 结合机器学习、强化学习的APP 稳定性测试工具：
[fastbot-Android](https://github.com/bytedance/Fastbot_Android/blob/main/handbook-cn.md)



# 安卓15支持
支持参考[：A15](https://github.com/bytedance/Fastbot_Android/issues/281)

解决思路：

目前来看，Android 15 开发者预览版会报这个错，不确定后续正式版会不会好
我这边的临时方案是把MonkeyRotationEvent.java 里的injectEvent 方法内容给注释掉，先屏蔽转屏事件，直接返回MonkeyEvent.INJECT_SUCCESS，重新打包monkeyq.jar推送至Android 15设备，目前来看可以跑

安卓15/16稳定性执行

# 背景
pip内部库需要内部圈子自行使用，需要搭建内部库



# 操作

```sh
mkdir /var/docker/pypi
cd /var/docker /pypi
mkdir -p auth       //认证文件存放目录
mkdir -p packages   //pypi安装包存放目录

# 注意当前目录为/var/docker/
pip install htpasswd
htpasswd -sc htpasswd.txt <username>
cp ./htpasswd.txt ./auth

```

docker-compose.yml启动

```yml
version: "3"

services:
  pypiserver:
    image: pypiserver/pypiserver:latest
    restart: always
    volumes:
      - type: bind
        source: /var/docker/pypi/packages
        target: /data/packages
      - type: bind
        source: /var/docker/pypi/auth
        target: /data/auth
    command: -P /data/auth/htpasswd.txt -a update,download,list /data/packages
    ports:
      - "8888:8080"
```
启动后：

```sh
(myenv) root@abc:/var/docker# docker ps -a
CONTAINER ID   IMAGE                          COMMAND                  CREATED          STATUS          PORTS                                       NAMES
5be7a28e3637   pypiserver/pypiserver:latest   "/entrypoint.sh -P /…"   55 seconds ago   Up 54 seconds   0.0.0.0:8888->8080/tcp, :::8888->8080/tcp   docker_pypiserver_1
```

访问（阿里云安全组得开放对应端口）：http://www.lixf6.com:8888/simple/
 或 http://www.lixf6.com:8888
 
 出现：（说明搭建成功）
```sh
Welcome to pypiserver!
This is a PyPI compatible package index serving 0 packages.

To use this server with pip, run the following command:

        pip install --index-url http://www.lixf6.com:8888/simple/ PACKAGE [PACKAGE2...]
      
To use this server with easy_install, run the following command:

        easy_install --index-url http://www.lixf6.com:8888/simple/ PACKAGE [PACKAGE2...]
      
The complete list of all packages can be found here or via the simple index.

This instance is running version 1.4.2 of the pypiserver software.
```
 
# 使用
1、项目sdk化

2、增加setup.py文件设置

3、MANIFEST.in文件设置

4、打包并推送到服务中

```sh
# pip install twine
# python setup.py check
# python setup.py sdist  //打包sdk,并在当前目录下生成一个dist打包文件
# twine upload --repository-url http://www.lixf6.com:8888 dist/*  //把dist内的打包文件推到服务器，需要输入账号密码
```
5、从pypi下载并安装

```sh
pip install --trusted-host www.lixf6.com:8888 --extra-index-url http://lixf6:密码@www.lixf6.com:8888 core==0.1.23
注意：
没有给服务器配置 https 的情况下，需要 --trusted-host 参数，否则 pip 会 ignore 这个仓库
如果你没有设置 Auth 的话，url 中就不需要 youruser:yourpass@ 这部分了;
如果你的 package 奇葩地和公共库中的某个包（和我们一样）重名了，你应该用 --index-url 来代替 --extra-index-url，这样它就会优先找你的包了。
```

pypi私有库搭建

# 背景

内部开发者Java版本官方SDK[：java版鸿蒙远控底层OS对应SDK](https://gitcode.com/OpenHarmonyToolkitsPlaza/HOScrcpy/tree/main)

可以通过此，获取稳定的h264流及远控up down move实现


协议底层：设备跟pc的协议是通过grpc协议





```Java
待实现
```

hypium版本
参考官方源码实现（可以投屏，但没法实现丝滑的up down move[：华为官方hypium文档](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides-V5/hypium-python-guidelines-V5)

```python3
import logging
import os
import socket
import json
import asyncio

import websockets
from threading import Thread
from datetime import datetime

from hypium import UiDriver, KeyCode, BY
from hmdriver2.driver import Driver

# 配置 logging
logging.basicConfig(
    level=logging.INFO,
    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
)

# 设置 root logger 的级别
logging.getLogger().setLevel(logging.INFO)


class HmScrcpyServer:
    """录制屏幕并通过 WebSocket 提供实时投屏流"""

    def __init__(self, driver):
        self.driver = driver
        # self.client = driver._client
        self.clients = set()
        self.loop = asyncio.new_event_loop()
        asyncio.set_event_loop(self.loop)
        # self.ws_port = None

        self.gesture = driver.gesture

    def start(self, free_port, timeout=3600):

        self.is_running = True
        self.timeout = timeout
        self.stop_capture_if_running()
        msg_json = {'api': "startCaptureScreen", 'args': []}
        full_msg = {"module": "com.ohos.devicetest.hypiumApiHelper",
                    "method": "Captures", "params": msg_json,
                    "request_id": datetime.now().strftime("%Y%m%d%H%M%S%f")}
        self.driver._client._send_msg(full_msg)
        reply = self.driver._client._recv_msg(1024)
        logging.info(f'reply: {reply}')
        if b"true" in reply:
            thread_ws = Thread(target=self.run_loop, args=(self._start_websocket_server(free_port),))
            thread_ws.start()
            thread_record = Thread(target=self._record_worker)
            thread_record.start()
        else:
            raise RuntimeError("Fail to start screen capture")

    def run_loop(self, coro):
        asyncio.set_event_loop(self.loop)
        self.loop.run_until_complete(coro)
        self.loop.run_forever()

    def stop_capture_if_running(self):
        msg_json = {
            'api': "stopCaptureScreen", 'args': []
        }
        full_msg = {"module": "com.ohos.devicetest.hypiumApiHelper",
                    "method": "Captures", "params": msg_json,
                    "request_id": datetime.now().strftime("%Y%m%d%H%M%S%f")}
        self.driver._client._send_msg(full_msg)
        reply = self.driver._client._recv_msg(1024)
        logging.info(f'stop reply: {reply}')

    async def _start_websocket_server(self, free_port=8765):
        # 动态选择一个可用端口
        self.ws_port = free_port
        while True:
            try:
                server = await websockets.serve(self._handler, "0.0.0.0", self.ws_port)
                logging.info(f"WebSocket server started at ws://0.0.0.0:{self.ws_port}")
                await server.wait_closed()
                break
            except OSError as e:
                if e.errno == 10048:
                    self.ws_port += 1
                else:
                    raise e

    async def _handler(self, websocket, path):
        self.clients.add(websocket)
        logging.info(f"New WebSocket connection from {websocket.remote_address}")
        try:
            async for message in websocket:
                logging.info(f"Received message from {websocket.remote_address}: {message}")
                try:
                    data = json.loads(message)
                    if data.get('type') == 'touch':
                        action = data.get('action')
                        x = data.get('x')
                        y = data.get('y')

                        if action == 'down':
                            logging.info(f'down {x} {y}')
                            self.gesture.start(x, y, 0.1).action()
                        elif action == 'up':
                            logging.info(f'up {x} {y}')
                            self.gesture.pause(0.1).action()
                        elif action == 'move':
                            logging.info(f'move {x} {y}')
                            self.gesture.move(x, y, 0.1).action()
                        elif action == 'normal':
                            # 调用触摸操作函数，传递 x 和 y 坐标
                            self.driver.touch((x, y))
                        elif action == 'long':
                            # 处理长按操作
                            self.driver.touch(target=(x, y), mode='long')
                        elif action == 'double':
                            # 处理双击操作
                            self.driver.touch(target=(x, y), mode='double')
                        elif action == 'move':
                            x1 = data.get('x1')
                            y1 = data.get('y1')
                            x2 = data.get('x2')
                            y2 = data.get('y2')
                            self.driver.slide(start=(x1, y1), end=(x2, y2), slide_time=0.1)
                        else:
                            logging.info(f'not support action {action}')
                    elif data.get('type') == 'keyEvent':
                        # {"type":"keyEvent","eventNumber":3}
                        # 使用 adbutils 提供的 shell 方法执行按键事件命令
                        event_number = data['eventNumber']
                        # tudo 这里应该要把这些数字抽象出来为一个类，这里先跑通再优化
                        if event_number == 187:
                            # self. driver.press_key(KeyCode.MENU)
                            self.driver.swipe_to_recent_task()
                        elif event_number == 3:
                            # home
                            self.driver.go_home()
                        elif event_number == 4:
                            # home
                            self.driver.go_back()  # press_back 也可以用
                        elif event_number == 224:
                            # wake up display
                            self.driver.wake_up_display()
                    elif data.get('type') == 'text':
                        # input: {"type":"text","detail":"hello"}
                        # 1-借助hdc/shell命令执行输入文本操作 但是执行太慢了
                        # exam: hdc shell uitest uiInput inputText point_x point_y text
                        # self.driver.hdc(f"shell uitest uiInput inputText {data.get('x')} {data.get('y')} {data.get('detail')}")
                        if data.get('detail') == 'CODE_AC_BACK':
                            self.driver.press_key(KeyCode.DEL)
                        elif data.get('detail') == 'CODE_AC_ENTER':
                            self.driver.press_key(KeyCode.ENTER)
                        else:
                            # 常规字符输入
                            self.driver.shell(
                                f"uitest uiInput inputText {data.get('x')} {data.get('y')} {data.get('detail')}")
                        # 2-使用input_text方法
                        # self.driver.input_text(BY.type("TextInput"), data.get('detail'))
                except json.JSONDecodeError as e:
                    logging.info(f"Error decoding JSON: {e}")
                except Exception as e:
                    logging.info(f"Error processing message: {e}")
        except websockets.exceptions.ConnectionClosedError:
            pass
        finally:
            self.clients.remove(websocket)

    def _record_worker(self):
        tmp_data = b''
        start_flag = b'\xff\xd8'
        end_flag = b'\xff\xd9'
        while self.is_running:
            try:
                result = self.driver._client._recv_msg(4096 * 1024, print=False)
                # logging.info(f'len: {len(result)}')
                tmp_data += result

                while start_flag in tmp_data and end_flag in tmp_data:
                    start_index = tmp_data.index(start_flag)
                    end_index = tmp_data.index(end_flag) + 2
                    frame = tmp_data[start_index:end_index]
                    tmp_data = tmp_data[end_index:]

                    # 发送完整的JPEG图像帧给所有客户端
                    asyncio.run_coroutine_threadsafe(self._broadcast(frame), self.loop)

            except socket.timeout:
                logging.info("timeout")
                continue
            except Exception as e:
                logging.info("connection closed", e)
                self.is_running = False
                self.driver._client._connect_sock = None
                break

    async def _broadcast(self, data):
        for client in self.clients:
            try:
                await client.send(data)
            except websockets.exceptions.ConnectionClosedError:
                logging.info("WebSocket connection closed")
                self.clients.remove(client)
            except Exception as e:
                logging.info(f"Error sending data to client: {e}")

    def stop(self):
        self.is_running = False
        if self.driver._client._connect_sock is None:
            return
        msg_json = {'api': "stopCaptureScreen", 'args': []}
        full_msg = {"module": "com.ohos.devicetest.hypiumApiHelper",
                    "method": "Captures", "params": msg_json,
                    "request_id": datetime.now().strftime("%Y%m%d%H%M%S%f")}
        self.driver._client.sendall(full_msg)
        reply = self.driver._client._recv_msg(1024)
        if b"true" not in reply:
            logging.info("Fail to stop capture")
        self.driver._client.release()
        self.driver._client._connect_sock = None
        self.loop.stop()
        for client in self.clients:
            asyncio.run_coroutine_threadsafe(client.close(), self.loop)


def main():
    # 从环境变量中读取空闲端口
    free_port = int(os.environ.get('FREE_PORT'))
    logging.info(f'free_port: {free_port}')
    # 从环境变量中读取UDID
    udid = os.environ.get('UDID')
    logging.info(f'udid: {udid}')
    driver = Driver(udid)
    recorder = HmScrcpyServer(driver)
    recorder.start(free_port)


if __name__ == "__main__":
    main()
    # result = input("press to stop:")
    # recorder.stop()

```

基于官方python版本SDK实现

```python3.11
待补充
```

其他相关：
已开源贡献mjpeg方式的实现：
[uiautodev](https://github.com/codeskyblue/uiautodev)