使用pyalsaaudio实现音频流传输时出现杂音问题求助

你的代码出现杂音的核心问题有几个，对照bash命令的工作逻辑，我们逐一解决：

1. 非阻塞模式导致空数据写入 #

你用了alsaaudio.PCM_NONBLOCK模式，这意味着read()会立即返回，哪怕没捕获到足够音频数据。当没有数据时，read()返回(0, b'')，直接写入空数据到播放设备就会产生杂音。而bash命令里的arecord和aplay默认用阻塞模式，会等数据足够才处理，所以正常工作。

2. 未正确处理read()返回值 #

capture.read()返回(num_frames, data)，其中num_frames是实际读取到的帧数。忽略这个值直接写入空/不完整数据，播放设备就会输出杂音。

3. 缓冲区（periodsize）设置过小 #

你设置的buffer_size=128太小，和bash命令默认参数不匹配。arecord -f cd对应16位、44100Hz、双声道，默认periodsize远大于128，过小的缓冲区会导致数据碎片化，引发卡顿和杂音。

4. 多进程访问PCM对象的风险 #

alsaaudio的PCM对象并非进程安全，子进程直接访问父进程创建的self.capture和self.playback可能引发资源冲突，导致异常。

修复后的代码 #

import alsaaudio
import multiprocessing
import time


class AudioProcessor:
    def __init__(
        self,
        playback_device="bluealsa",
        capture_device="hw:0,0",
        channels=2,
        rate=44100,
        format=alsaaudio.PCM_FORMAT_S16_LE,
        buffer_size=1024,  # 增大缓冲区，匹配bash默认参数
    ):
        # 使用默认阻塞模式，无需显式指定PCM_BLOCK
        self.capture = alsaaudio.PCM(
            type=alsaaudio.PCM_CAPTURE,
            device=capture_device,
            format=format,
            rate=rate,
            channels=channels,
            periodsize=buffer_size,
        )

        self.playback = alsaaudio.PCM(
            type=alsaaudio.PCM_PLAYBACK,
            device=playback_device,
            format=format,
            rate=rate,
            channels=channels,
            periodsize=buffer_size,
        )

        self.terminate_flag = multiprocessing.Event()
        # 保存设备参数，供子进程初始化使用
        self.capture_params = (capture_device, format, rate, channels, buffer_size)
        self.playback_params = (playback_device, format, rate, channels, buffer_size)

    def _process_audio(self):
        # 子进程内重新初始化设备，避免进程间资源冲突
        capture = alsaaudio.PCM(
            type=alsaaudio.PCM_CAPTURE,
            device=self.capture_params[0],
            format=self.capture_params[1],
            rate=self.capture_params[2],
            channels=self.capture_params[3],
            periodsize=self.capture_params[4],
        )
        playback = alsaaudio.PCM(
            type=alsaaudio.PCM_PLAYBACK,
            device=self.playback_params[0],
            format=self.playback_params[1],
            rate=self.playback_params[2],
            channels=self.playback_params[3],
            periodsize=self.playback_params[4],
        )

        while not self.terminate_flag.is_set():
            try:
                # 阻塞读取，确保获取完整周期数据
                num_frames, input_data = capture.read()
                if num_frames > 0:
                    # 仅写入有效音频数据
                    playback.write(input_data)
            except alsaaudio.ALSAAudioError as e:
                print(f"音频处理错误: {e}")
                time.sleep(0.1)
        # 子进程内关闭设备
        capture.close()
        playback.close()

    def start_playback(self):
        self.playback_process = multiprocessing.Process(target=self._process_audio, name="playback_process")
        self.playback_process.start()

    def close_streams(self):
        self.terminate_flag.set()
        self.playback_process.join()
        # 关闭父进程中的设备实例
        self.capture.close()
        self.playback.close()

关键改进点说明 #

• 移除NONBLOCK模式，改用默认阻塞模式，确保每次读取都能获取完整音频数据
• 增大buffer_size到1024，匹配bash命令默认缓冲区大小，减少数据碎片化
• 增加num_frames判断，仅在读取到有效数据时才写入播放设备
• 调整多进程实现，在子进程内重新初始化PCM对象，避免进程间资源冲突
• 显式调用close()方法关闭音频设备，确保资源正确释放

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