使用python代码socket传音频

在Python中，可以使用socket模块来实现实时音频传输，通常我们会利用`socketio`库（基于WebSocket协议的实时通信库）配合`pyaudio`（处理音频数据）来完成音频的发送和接收。下面是一个简单的示例：

首先安装必要的库：

pip install socketio pyaudio

然后创建服务器端代码（server.py）:

import socketio
import threading

sio = socketio.Server()
app = socketio.WSGIApp(sio)

@sio.on('connect')
def connect(sid, environ):
    print('Client connected')

@sio.on('disconnect')
def disconnect(sid):
    print('Client disconnected')

@sio.on('audio_data')
def handle_audio(sid, data):
    # 数据应该是二进制音频流，这里只是简单打印
    print(f"Received audio data: {data}")
    # 在实际应用中，你可以将数据保存到文件或者进一步处理

if __name__ == '__main__':
    sio.run(app, host='0.0.0.0', port=8000)

创建客户端代码（client.py）:

from pyaudio import PyAudio
import numpy as np
import socketio

# 初始化socketIO连接
sio = socketio.Client()

def callback(in_data, frame_count, time_info, status_flags):
    # 音频处理部分，例如从录音设备获取数据
    # 这里我们假设in_data是numpy数组，实际应用中可能需要转换
    audio_data = np.frombuffer(in_data, dtype=np.int16)
    
    # 发送音频数据给服务器
    sio.emit('audio_data', audio_data.tobytes())
    return (in_data, pyaudio.paContinue)  # 返回原样继续录音

p = PyAudio()
stream = p.open(format=pyaudio.paInt16,
                channels=1,
                rate=44100,
                input=True,
                frames_per_buffer=1024,
                stream_callback=callback)

try:
    sio.connect('http://localhost:8000')  # 连接到服务器地址
    sio.wait()  # 开始监听服务器消息
finally:
    stream.stop_stream()
    stream.close()
    p.terminate()

在这个例子中，服务器等待客户端发送音频数据，而客户端通过`PyAudio`持续录音并将其作为二进制数据发送给服务器。注意这只是一个基础演示，实际应用可能需要添加错误处理、编码解码、音视频同步等复杂功能。