优化UDP连接：跨系统光标控制程序卡顿问题优化建议咨询

问题背景 #

我正在开发一款可通过另一系统控制光标的程序，采用UDP Socket实现，但当前代码运行时存在明显卡顿现象。以下是当前使用的代码：

客户端代码 #

# client
import socket
import sys
import pyautogui
import time

IP_ADDRESS = socket.gethostbyname(socket.gethostname())
PORT = 65432


def main():
    with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as client:
        prev_x, prev_y = 0, 0
        while True:
            x, y = pyautogui.position()
            if prev_x == x and prev_y == y:
                continue

            client.sendto(f'{x} {y}'.encode(), (IP_ADDRESS, PORT))
            prev_x, prev_y = x, y
            time.sleep(0.0005)


if __name__ == '__main__':
    main()

服务端代码 #

# server
import socket
import sys
import pyautogui
import time


IP_ADDRESS = socket.gethostbyname(socket.gethostname())
PORT = 65432


def main():
    with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as server:
        server.bind((IP_ADDRESS, PORT))
        server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
        server.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 1)

        while True:
            data, sender = server.recvfrom(1024)
            x, y = [int(i) for i in data.split()]
            pyautogui.moveTo(x, y)
            time.sleep(0.0005)


if __name__ == '__main__':
    main()

具体优化建议 #

1. 移除无意义的睡眠延迟 #

客户端和服务端中的time.sleep(0.0005)会强制阻塞循环执行，直接拖慢光标响应速度，直接删除这两行代码即可。

2. 降低UDP发送频率，减少网络拥塞 #

当前客户端只要光标坐标有1像素变化就发送数据包，会产生大量冗余UDP包，引发网络拥塞和服务端处理积压。可以添加像素变化阈值，仅当坐标变化超过设定值时才发送：

# 客户端修改坐标判断逻辑
threshold = 3  # 超过3像素变化才发送
while True:
    x, y = pyautogui.position()
    if abs(x - prev_x) > threshold or abs(y - prev_y) > threshold:
        client.sendto(f'{x} {y}'.encode(), (IP_ADDRESS, PORT))
        prev_x, prev_y = x, y

也可以改为固定间隔采样发送（比如每10ms发送一次当前坐标），进一步控制发包频率。

3. 修复服务端接收缓冲区配置 #

服务端设置SO_RCVBUF=1会导致接收缓冲区极小，极易出现丢包问题，直接删除这行配置，使用系统默认的缓冲区大小即可：

# 服务端删除此行
server.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 1)

4. 优先处理最新的坐标数据包 #

UDP可能出现数据包乱序或堆积，服务端如果按顺序处理旧数据包，会导致光标滞后。修改接收逻辑，每次循环清空缓冲区，只保留最新的坐标：

# 服务端循环内修改
while True:
    server.setblocking(False)
    latest_data = None
    # 读取所有待处理的包，只保留最后一个
    while True:
        try:
            data, sender = server.recvfrom(1024)
            latest_data = data
        except BlockingIOError:
            break
    server.setblocking(True)
    
    if latest_data:
        x, y = [int(i) for i in latest_data.split()]
        pyautogui.moveTo(x, y)

5. 优化坐标传输的序列化方式 #

当前用字符串编码坐标，解析时需要split和类型转换，效率较低。改用struct模块二进制打包，减少数据体积和解析时间：

• 客户端发送修改：

import struct
# 替换原sendto行
data = struct.pack('ii', x, y)  # 将两个int打包为8字节二进制
client.sendto(data, (IP_ADDRESS, PORT))

• 服务端解析修改：

import struct
# 替换原解析行
x, y = struct.unpack('ii', data)

6. 采用异步/多线程提升响应性 #

单线程循环会导致轮询或接收操作阻塞，可改用asyncio实现异步UDP通信，或者拆分任务到多线程：比如客户端用单独线程监听光标位置，服务端用线程处理接收，避免主循环阻塞。

内容的提问来源于stack exchange，提问作者vSteppY