如何通过网络套接字同步多台树莓派的Adafruit LED灯效，解决动画漂移问题？

问题根因 #

• 灯效循环无固定帧率控制：slow_circles循环的每轮执行耗时受当前Pi Zero的CPU占用、IO负载影响，两台设备每轮循环的耗时差不断累积，就会出现明显不同步
• 无周期性同步校准：仅在触发时同步一次启动信号，没有后续的进度校准机制，加上单板硬件时钟本身存在漂移，运行时间越长偏差越大
• 线程调度差异：不同设备的系统线程调度优先级、资源占用情况不同，会进一步放大循环耗时的差值

修复方案 #

1. 给灯效循环加固定帧率控制 #

在slow_circles的每轮循环末尾添加固定间隔等待，用目标帧率反推每轮最大耗时，抵消每轮循环的耗时差：

def slow_circles(event):
    global thread_running
    thread_running = True
    # 设定目标帧率，比如30帧/秒，每帧耗时约33ms，可根据实际灯效调整
    FRAME_DURATION = 1 / 30
    while not event.isSet():
        # 记录本轮循环开始时间
        loop_start = time.time()
        if not thread_running:
            event.set()
            break
        for i in range(num_of_pixels):
            # 原有像素渲染逻辑保持不变
            if not thread_running:
                event.set()
                break
            pixels.show()
        # 计算本轮实际耗时，补足剩余时间保证每轮总耗时固定
        loop_cost = time.time() - loop_start
        if loop_cost < FRAME_DURATION:
            time.sleep(FRAME_DURATION - loop_cost)

2. 添加周期性同步机制 #

用作为主控的树莓派3，每隔1-2秒给所有从设备发送一次同步帧，内容包含当前灯效的进度，从设备收到后立刻对齐自己的灯效进度，抵消累计偏差：

• 主控端（接收MIDI信号的树莓派3）新增进度计数逻辑：

# 新增全局变量记录当前运行的灯效和累计进度
current_effect = None
effect_progress = 0
NUM_PIXELS = 24 # 替换为你实际的LED灯珠数量

# 启动独立线程按固定帧率累加进度
def progress_counter():
    global effect_progress
    FRAME_DURATION = 1 /30
    while True:
        if current_effect is not None:
            effect_progress +=1
            # 到循环总帧数就重置，和从设备的灯效循环逻辑对齐
            if effect_progress >= NUM_PIXELS:
                effect_progress =0
        time.sleep(FRAME_DURATION)

在原有15秒心跳发送逻辑中，追加同步指令发送：

s1.sendall(f'sync:{effect_progress}'.encode('utf8'))
s2.sendall(f'sync:{effect_progress}'.encode('utf8'))

• 从设备（Pi Zero端）在handle_client的接收逻辑中添加同步指令处理：

data=client.recv(1024).decode()
if not data:
    # 原有断链处理逻辑保持不变
if data.startswith('sync:'):
    # 对齐灯效进度，把slow_circles里的循环计数变量改为同步过来的进度值即可
    current_progress = int(data.split(':')[1])

3. 优化线程调度优先级 #

把灯效线程的优先级调高，避免系统其他进程抢占资源导致灯效循环卡慢：

import os
# 在灯效线程启动后设置高优先级，需要用root权限运行程序生效
p = Thread(target=slow_circles, args=(thread,))
p.daemon = True
p.start()
os.system(f"renice -20 -p {p.ident}")

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