Merge branch 'master' of code.gitlink.org.cn:mahaotian/DeviceShare

Author: qy-liuhuo

.gitignore

@@ -0,0 +1,10 @@
+/.idea/
+**/__pycache__
+./devices.json
+/dist/
+/build/
+*.spec
+**/*.key
+**/*.pyc
+**/*.db
+.DS_Store

cliptest.py

@@ -0,0 +1,4 @@
+import pyperclip
+
+pyperclip.copy("123")
+print(pyperclip.paste())

deviceShare.py

@@ -0,0 +1,56 @@
+import sys
+
+
+from PyQt5.QtWidgets import QApplication, QDialog, QVBoxLayout, QPushButton, QLabel
+import qt_material
+from src.sharer.client import Client
+from src.sharer.server import Server
+
+
+class RoleSelectionDialog(QDialog):
+    def __init__(self):
+        super().__init__()
+
+        self.setFixedSize(400, 200)
+
+        self.setWindowTitle("身份选择")
+        self.layout = QVBoxLayout()
+
+        self.server_button = QPushButton("主控机")
+        self.client_button = QPushButton("被控机")
+
+        self.layout.addWidget(self.server_button)
+        self.layout.addWidget(self.client_button)
+
+        self.setLayout(self.layout)
+
+        self.server_button.clicked.connect(self.select_server)
+        self.client_button.clicked.connect(self.select_client)
+
+        self.selected_role = None
+
+    def select_server(self):
+        self.selected_role = "server"
+        self.accept()
+
+    def select_client(self):
+        self.selected_role = "client"
+        self.accept()
+
+
+def main():
+    app = QApplication(sys.argv)
+    qt_material.apply_stylesheet(app, theme='dark_blue.xml')
+    selected_role = 'client'
+    # 显示身份选择弹窗
+    role_dialog = RoleSelectionDialog()
+    if role_dialog.exec_() == QDialog.Accepted:
+        selected_role = role_dialog.selected_role
+    if selected_role == 'server':
+        Server(app)
+    elif selected_role == 'client':
+        Client(app)
+    app.exec_()
+
+if __name__ == "__main__":
+    main()

keyboard_controller.py

@@ -0,0 +1,98 @@
+import threading
+import time
+
+from evdev import InputDevice, categorize, ecodes, list_devices, UInput
+import os
+
+
+class KeyboardController:
+    def __init__(self):
+        devices = [InputDevice(path) for path in list_devices()]
+        # 打印所有设备以便调试
+        # for device in devices:
+        #     print(f"设备名: {device.name}, 设备路径: {device.path}")
+        # 找到在线的键盘设备
+        self.stop_event = threading.Event()
+
+        self.keyboard_devices = []
+        for device in devices:
+            if not os.path.exists(device.path):
+                continue
+            capabilities = device.capabilities()
+            if ecodes.EV_KEY in capabilities and ecodes.EV_SYN in capabilities:
+                if ecodes.KEY_A in capabilities[ecodes.EV_KEY]:  # 检查是否有键盘按键
+                    self.keyboard_devices.append(device)
+        capabilities = {ecodes.EV_KEY: list(ecodes.keys.keys())}
+        self.ui = UInput(capabilities, name="virtual_keyboard")
+
+    def press(self, key):
+        self.ui.write(ecodes.EV_KEY, key, 1)
+        self.ui.syn()
+
+    def release(self, key):
+        self.ui.write(ecodes.EV_KEY, ecodes.KEY_A, 0)
+        self.ui.syn()
+
+    def click(self, click_type, keyData):
+        key = self.keyFactory.outPut(keyData)
+        if click_type == 'press':
+            self.press(key)
+        elif click_type == 'release':
+            self.release(key)
+
+    def run_keyboard_listener(self, keyboard, on_press, on_release, suppress=False):
+        if suppress:
+            keyboard.grab()
+        try:
+            while not self.stop_event.is_set():
+                event = keyboard.read_one()  # 非阻塞读取事件
+                if event:
+                    if event.type == ecodes.EV_KEY:
+                        key_event = categorize(event)
+                        if key_event.keystate == key_event.key_down:
+                            on_press(key_event.keycode)
+                        elif key_event.keystate == key_event.key_up:
+                            on_release(key_event.keycode)
+                else:
+                    time.sleep(0.01)  # 如果没有事件，休眠一段时间，减少 CPU 使用率
+        except KeyboardInterrupt:
+            print("Stopped listening for events.")
+        except Exception as e:
+            print(f"发生错误: {e}")
+        finally:
+            if suppress:
+                keyboard.ungrab()
+
+    def keyboard_listener(self, on_press, on_release, suppress=False):
+        self.listener = []
+        for keyboard in self.keyboard_devices:
+            print(f"监听设备: {keyboard.name} at {keyboard.path}")
+            self.listener.append(
+                threading.Thread(target=self.run_keyboard_listener, args=(keyboard, on_press, on_release, suppress)))
+        for i in self.listener:
+            i.start()
+        return self.listener
+
+    def stop_listener(self):
+        self.stop_event.set()
+        self.listener.clear()
+
+    def __del__(self):
+        self.ui.close()
+
+
+if __name__ == '__main__':
+    def on_press(key):
+        print(f"按下: {key}")
+
+    def on_release(key):
+        print(f"释放: {key}")
+
+    keyboardController = KeyboardController()
+    keyboardController.keyboard_listener(on_press, on_release, suppress=False)
+    for i in range(10):
+        keyboardController.press(ecodes.KEY_A)
+        time.sleep(0.01)
+        keyboardController.release(ecodes.KEY_A)
+        time.sleep(1)
+    keyboardController.stop_listener()

mouse_controller.py

@@ -0,0 +1,124 @@
+import threading
+import time
+
+from evdev import InputDevice, categorize, ecodes, list_devices, UInput
+import subprocess
+
+
+class MouseController:
+
+    def __init__(self):
+        devices = [InputDevice(path) for path in list_devices()]
+        self.stop_event = threading.Event()
+        self.mouse_devices = []
+        for device in devices:
+            capabilities = device.capabilities()
+            if ecodes.EV_REL in capabilities and ecodes.EV_KEY in capabilities:
+                if ecodes.REL_X in capabilities[ecodes.EV_REL] and ecodes.REL_Y in capabilities[ecodes.EV_REL]:
+                    if ecodes.BTN_LEFT in capabilities[ecodes.EV_KEY] or ecodes.BTN_RIGHT in capabilities[
+                        ecodes.EV_KEY]:
+                        self.mouse_devices.append(device)
+        capabilities = {ecodes.EV_REL: [ecodes.REL_X, ecodes.REL_Y, ecodes.REL_WHEEL],
+                        ecodes.EV_KEY: [ecodes.BTN_LEFT, ecodes.BTN_RIGHT, ecodes.BTN_MIDDLE]}
+        self.ui = UInput(capabilities, name="virtual_mouse")
+
+    def update_last_position(self):
+        pass
+
+    def get_last_position(self):
+        pass
+
+    def get_position(self):
+        result = subprocess.run(['xdotool', 'getmouselocation'], stdout=subprocess.PIPE, stderr=subprocess.PIPE,
+                                text=True)
+        output = result.stdout
+        # 解析输出
+        location = {}
+        for item in output.split():
+            key, value = item.split(':')
+            location[key] = int(value)
+        return location['x'], location['y']
+
+    def move_to(self, position: tuple):
+        pass
+
+    def move(self, dx, dy):
+        pass
+
+    def scroll(self, dx, dy):
+        pass
+
+    def click(self, button, pressed):
+        pass
+
+    def run_mouse_listener(self, mouse, on_click, on_move, on_scroll, suppress=False):
+        if suppress:
+            mouse.grab()
+        try:
+            while not self.stop_event.is_set():
+                event = mouse.read_one()  # 非阻塞读取事件
+                if event:
+                    if event.type == ecodes.EV_REL:
+                        # if event.code == ecodes.REL_X:
+                        #     on_move(event.value, 0)
+                        # elif event.code == ecodes.REL_Y:
+                        #     on_move(0, event.value)
+                        # elif event.code == ecodes.REL_WHEEL:
+                        #     on_scroll(0, event.value)
+                        print(f"REL: {event}")
+                    elif event.type == ecodes.EV_KEY:
+                        if event.code == ecodes.BTN_LEFT:
+                            if event.value == 1:
+                                on_click('Button.left', 'press')
+                            elif event.value == 0:
+                                on_click('Button.left', 'release')
+                        elif event.code == ecodes.BTN_RIGHT:
+                            if event.value == 1:
+                                on_click('Button.right', 'press')
+                            elif event.value == 0:
+                                on_click('Button.right', 'release')
+                else:
+                    time.sleep(0.01)
+        except KeyboardInterrupt:
+            print("Stopped listening for events.")
+        except Exception as e:
+            print(f"发生错误: {e}")
+        finally:
+            if suppress:
+                mouse.ungrab()
+
+    def mouse_listener(self, on_click, on_move, on_scroll, suppress=False):
+        self.listener = []
+        for mouse in self.mouse_devices:
+            print(f"监听设备: {mouse.name} at {mouse.path}")
+            self.listener.append(threading.Thread(target=self.run_mouse_listener,args=(mouse, on_click, on_move, on_scroll, suppress)))
+        for i in self.listener:
+            i.start()
+        return self.listener
+
+    def stop_listener(self):
+        self.stop_event.set()
+        self.listener.clear()
+
+    def __del__(self):
+        self.ui.close()
+
+
+if __name__ == '__main__':
+
+    # mouseController = MouseController()
+    # mouseController.mouse_listener(None, None, None, suppress=True)
+    # for i in range(10):
+    #     mouseController.click('Button.left', 'press')
+    #     time.sleep(0.01)
+    #     mouseController.click('Button.left', 'release')
+    #     time.sleep(1)
+    # mouseController.stop_listener()
+    ui = UInput()
+    def move_mouse(dx,dy):
+        ui.write(ecodes.EV_REL, ecodes.REL_X, dx)
+        ui.write(ecodes.EV_REL, ecodes.REL_Y, dy)
+        ui.syn()
+    
+    move_mouse(100, 100)
+    ui.close()

readme.md

@@ -0,0 +1,73 @@
+# DeviceShare —— 跨平台多主机输入设备共享
+
+## 项目介绍
+
+DeviceShare 是一款跨平台的多主机输入设备共享工具，支持 Windows、Linux、MacOS 等操作系统。通过 DeviceShare，您可以在多台主机之间共享鼠标、键盘、剪贴板等输入设备，实现多台主机之间的输入设备共享。
+
+
+## 功能特性
+
+1. **跨平台支持**：支持 Windows、Linux、MacOS 等操作系统。
+2. **多主机支持**：支持多台主机之间的输入设备共享。
+3. **鼠标共享**：支持鼠标在多台主机之间的共享。
+4. **键盘共享**：支持键盘在多台主机之间的共享。
+5. **剪贴板共享**：支持剪贴板在多台主机之间的共享。
+6. **屏幕位置配置**：支持配置屏幕位置，方便多台主机之间的切换。
+
+**演示环境**
+![1719817611466.png](https://img.qylh.xyz/blog/1719817611466.png)
+
+**双机演示**
+
+https://github.com/qy-liuhuo/deviceShare/assets/60374114/6e126292-22e0-4d91-bab9-272470689ecd
+
+
+**三机演示**
+
+https://github.com/qy-liuhuo/deviceShare/assets/60374114/1b911b8a-976f-4128-9518-9c64c73a7a39
+
+
+
+## 使用说明
+针对x86架构的Windows、Kylin、Debian操作系统以及MacOS系统，我们打包构建了可执行程序，可在Github Release界面下载合适的版本。 
+
+若构建的版本无法支持目标机器，可选择源码运行或自行打包。该方案需具备Python3 环境，具体步骤如下：
+1. 获取项目代码
+2. 使用pip install -r requirements.txt命令安装依赖
+3. 选择执行run_server.py 或 run_client.py
+4. 安装pyinstaller
+5. 使用pyinstaller打包目标程序
+
+6. 注意Kylin操作系统在安装python的evdev依赖时可能出现错误，请选择安装预编译版本evdev-binary，参考 https://python-evdev.readthedocs.io/en/latest/install.html
+
+
+## 系统架构
+
+![1718631831164.png](https://img.qylh.xyz/blog/1718631831164.png)
+
+项目的整体设计框架如上图所示，整体由四个部分构成：
+- 服务端为Hid Input设备的拥有者，可向其他客户端主机共享其拥有的输入设备。
+- 客户端可使用主机共享的输入设备。
+- 网络通信模块用于服务端和客户端的数据传输。
+- 设备控制模块用于读取Hid Input设备信息及控制Hid Input设备。
+
+软件的运行流程如下图所示，客户端与服务端作为两个独立模块单独启动，客户端启动后会向局域网中广播自身信息，
+服务端收到广播信息后将其加入主机列表，并配置屏幕间的相对位置信息。当服务端主机的光标移出屏幕范围后，会自动判断接下来被控的主机，
+并将本机输入设备产生的输入拦截，通过网络模块转发给客户端，客户端收到输入信息后响应相应的控制信号。当客户端的光标移出范围后向服务端主机发送事件标志，
+服务端主机停止控制信号的转发，并恢复输入事件的响应。
+![1718631845356.png](https://img.qylh.xyz/blog/1718631845356.png)
+
+
+## TODO
+- [x] 主机发现机制
+- [x] 屏幕位置配置
+- [x] 鼠标共享功能
+- [x] 键盘共享功能
+- [x] 剪切板共享功能
+- [ ] 文件拖拽共享功能
+- [ ] 剪切板内容加密传输
+- [ ] 解耦各设备共享模块，支持用户自定义开关相关功能
+- [ ] 优化屏幕管理功能
+- [ ] 优化代码质量，提升代码可读性，提升软件性能和稳定性
+- [ ] 测试更多类型操作系统
+- [ ] 优化文档