树莓派使用Python Socket传输WAV文件偶发播放不完整及速率调整问题

你遇到的播放不全问题，核心和音频解码器关系不大，主要是Socket传输流程没有做完整性校验，导致传过去的WAV文件本身就存在内容截断、结构损坏的问题，叠加播放流程的资源释放缺陷，共同造成了偶发故障：

• TCP是面向字节流的协议，没有自带消息边界：你现在的逻辑靠conn.recv()返回空值判断传输结束，但网络临时闪断、客户端提前关连接、TCP缓冲区未排空，都会让recv提前返回空值，此时接收到的WAV内容只有部分片段，自然无法完整播放。同时客户端用的s.send()不会保证一次性把所有文件内容发送完毕，网络拥堵时单次调用仅能发送部分字节就返回，你没有校验实际发送长度就关socket，传出去的文件本身就是残缺的。
• 传输流程没有双向校验：客户端发完内容就直接关连接删本地文件，没有等服务端确认已经收完整份文件；服务端收到内容就直接关文件发确认，没有校验收到的内容长度是否和文件总大小匹配，只要网络流程有一点波动，文件就会缺头少尾。
• 播放时资源释放过早：pyaudio的输出流写完最后一块音频数据后，系统音频缓冲区（尤其是树莓派外接USB音箱的独立缓冲区）还存着未播放完的样本，你直接执行stop_stream、close、terminate流程，会强制把缓冲区里的剩余音频丢弃，树莓派系统负载高的时候，USB音箱的缓冲延迟会变大，这段被丢弃的内容占比就更高，也就出现了“只播文件四分之一、只播最后几秒”的现象。

传输层稳定性升级 #

彻底替代靠recv返回空判断结束的逻辑，采用“前置告知文件总大小+循环收满定长内容+双向校验确认”的模式，从根源上避免粘包、截断问题：

• 客户端不再使用单次s.send()，改用内置的s.sendall()方法，该方法会自动循环调用send直到所有内容发送完成，不会出现单次发送不完整的问题；传输前先把WAV文件的总长度以4字节大端序的格式发送到服务端，再发送完整文件内容，最后接收服务端的收包完成确认，再关闭连接、删除本地的临时WAV文件。
• 服务端收到连接后，先读取4字节的长度字段，循环累计接收内容直到收满约定的文件大小，再以覆盖模式（'wb'）写入本地文件，写完确认长度匹配后，再发送确认信号给客户端，最后关闭连接。

播放逻辑优化 #

在所有音频样本写入输出流后，增加0.1-0.3秒的延时，等USB音箱的音频缓冲区完全排空，再执行关流、释放PyAudio资源的流程，避免末尾音频被强制截断。

调低播放速率的实现 #

不需要引入额外的音频处理库，直接在打开PyAudio输出流时，对原WAV的采样率做比例缩放即可实现慢放：

• 想要放慢播放速度，就把实际输出的采样率按目标慢放比例降低，比如想实现原速80%的播放速度，就把流的rate参数设置为原WAV采样率*0.8；采样率越低，同样样本量的音频播放时长就越长。这种方法会同步降低音频音调，对语音类WAV文件来说实现成本最低，完全适配个人项目的需求。

客户端发送逻辑修正片段 #

# 完整读取WAV文件内容
with open("voice.wav", 'rb') as f:
    file_content = f.read()
file_total_size = len(file_content)

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.connect((HOST, PORT))
    # 先发送4字节的文件总长度，用大端序适配跨设备传输
    s.sendall(file_total_size.to_bytes(4, byteorder='big'))
    # sendall自动循环发完所有文件内容，不会出现发送不完整的问题
    s.sendall(file_content)
    # 等待服务端的接收完成确认
    confirm_msg = s.recv(1024)
    if confirm_msg == b'Audio_Recieved':
        print("文件传输完整性校验通过")

# 仅在校验通过后删除本地临时文件
os.remove('voice.wav')

服务端接收逻辑修正片段 #

s.bind((host, port))
s.listen()
while True:
    conn, addr = s.accept()
    # 先读取4字节的目标文件长度
    size_bytes = conn.recv(4)
    target_size = int.from_bytes(size_bytes, byteorder='big')
    received_size = 0
    # 每次以覆盖模式打开文件，清除旧文件的残留内容
    with open('voice.wav', 'wb') as f:
        while received_size < target_size:
            # 计算单次最大可接收的块大小，避免冗余读取
            chunk = conn.recv(min(1024, target_size - received_size))
            if not chunk:
                break
            f.write(chunk)
            received_size += len(chunk)
    # 收满约定大小的内容后，再发确认信号给客户端
    conn.send(b'Audio_Recieved')
    conn.close()

播放逻辑优化+慢放功能实现 #

def audio_player(play_speed=0.8): # play_speed为原速比例，小于1即为慢放，可根据需求调整
    chunk = 1024
    wf = wave.open('voice.wav', 'rb')
    p = pyaudio.PyAudio()
    # 按慢放比例调整实际输出的采样率
    output_rate = int(wf.getframerate() * play_speed)
    stream = p.open(
        format=p.get_format_from_width(wf.getsampwidth()),
        channels=wf.getnchannels(),
        rate=output_rate,
        output=True
    )
    data = wf.readframes(chunk)
    while data != b'':
        stream.write(data)
        data = wf.readframes(chunk)
    # 等待USB音箱的音频缓冲完全排空，避免截断末尾音频
    import time
    time.sleep(0.2)
    stream.stop_stream()
    stream.close()
    p.terminate()
    wf.close()
    return

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