使用Flask-SocketIO和sounddevice实现实时音频流时出现周期性蜂鸣——是否为并发或部署问题？

这种周期性蜂鸣（每秒约2次）基本可以锁定是并发模型冲突或者音频捕获与SocketIO发射的时序不匹配导致的，结合你的代码和部署方式，我来拆解可能的原因和解决方案：

一、最可能的根源：Eventlet Monkey Patch与原生Threading的兼容性问题 #

你已经执行了eventlet.monkey_patch()，这会把Python原生的threading模块替换成Eventlet的协程实现，但sounddevice底层依赖的PortAudio是用操作系统原生线程处理音频捕获的。当你用threading.Thread（实际是Eventlet协程）运行_stream_audio时，Eventlet的协程调度器可能会抢占PortAudio的IO时间片，导致音频捕获不连续、出现丢包——反映到客户端就是周期性的蜂鸣（丢包间隙被填充为静音/失真）。

解决方案：用Eventlet原生协程替代Threading #

把threading.Thread换成Eventlet的spawn来创建音频流任务，Eventlet的调度器能更好地兼容自身的协程模型：

# 确保这两行是代码的最顶部
import eventlet
eventlet.monkey_patch()

# 修改AudioStreamer的start/stop方法
class AudioStreamer:
    def __init__(self, sample_rate=44100, channels=2, chunk_size=1024):
        self.sample_rate = sample_rate
        self.channels = channels
        self.chunk_size = chunk_size
        self.thread = None  # 现在存储Eventlet协程对象
        self.room = 'audio_listeners'
        self.is_running = False

    def start(self):
        if self.is_running:
            return
        self.is_running = True
        # 用eventlet.spawn替代threading.Thread
        self.thread = eventlet.spawn(self._stream_audio)
        print('[AudioStreamer] Audio coroutine started.')

    def stop(self):
        if not self.is_running:
            return
        self.is_running = False
        # 用Eventlet的kill方法终止协程
        if self.thread:
            self.thread.kill()
        print('[AudioStreamer] Audio coroutine stopped.')

你的工作示例能正常运行，是因为它在if __name__ == '__main__'里直接启动线程，此时SocketIO的服务器调度器还没完全接管所有上下文；但实际部署时，Gunicorn的Eventlet Worker全程掌控调度，原生Threading的兼容性问题就会暴露。

二、次要原因：阻塞式音频捕获卡住Eventlet Worker #

sd.InputStream.read()是阻塞调用，而PortAudio的IO属于C扩展，可能没被Eventlet的Monkey Patch覆盖，这个阻塞会卡住整个Eventlet Worker进程，导致SocketIO的消息发射、客户端连接处理被延迟，进而引发音频流时序混乱。

解决方案：用Flask-SocketIO的后台任务API #

Flask-SocketIO提供的sio.start_background_task会根据当前异步模型（Eventlet/Gevent/Threading）自动选择最兼容的任务创建方式，比手动创建线程/协程更可靠：

class AudioStreamer:
    def start(self):
        if self.is_running:
            return
        self.is_running = True
        # 用Flask-SocketIO的后台任务替代手动线程
        self.thread = sio.start_background_task(self._stream_audio)
        print('[AudioStreamer] Audio background task started.')

    def stop(self):
        if not self.is_running:
            return
        self.is_running = False
        # 等待后台任务结束
        if self.thread:
            self.thread.join(timeout=1)
        print('[AudioStreamer] Audio background task stopped.')

三、额外优化：对齐音频发射的时序 #

蜂鸣也可能是客户端播放时的缓冲区间隙导致的——每个音频chunk的播放时间是固定的（chunk_size / sample_rate），如果SocketIO发射的间隔不均匀，客户端就会填充间隙产生失真。可以在发射后加入对应时长的睡眠（用Eventlet的sleep，不要用原生time.sleep）：

def _stream_audio(self):
    try:
        # 计算每个chunk的播放时长（秒）
        chunk_duration = self.chunk_size / self.sample_rate
        with sd.InputStream(samplerate=self.sample_rate, channels=self.channels, dtype='int16') as stream:
            while self.is_running:
                data, _ = stream.read(self.chunk_size)
                sio.emit('audio_chunk', data.tobytes(), room=self.room)
                # 用eventlet.sleep对齐时序，替代sio.sleep(0)
                eventlet.sleep(chunk_duration)
    except Exception as e:
        print(f'[AudioStreamer] Error: {e}')

四、部署配置的小细节 #

你的Gunicorn命令gunicorn -k eventlet -w 1 -t 4 -b 0.0.0.0:5001 app:app基本没问题，但可以优化两点：

1. -t 4的超时时间偏短，建议改成-t 30，避免音频流的长连接被误杀；
2. 务必确保eventlet.monkey_patch()是代码的第一行，要在import sounddevice、import flask之前执行，否则PortAudio的IO函数不会被Eventlet替换，依然会阻塞Worker。

验证步骤 #

1. 先在开发环境用Gunicorn启动，复现蜂鸣问题，排除部署环境的特殊配置；
2. 优先尝试替换threading.Thread为eventlet.spawn或sio.start_background_task，观察蜂鸣是否消失；
3. 调整chunk_size（比如改成2048）和chunk_duration的sleep时间，看蜂鸣频率的变化。

内容来源于stack exchange