python 实现实时语音对讲

要实现实时语音对讲，可以使用 Python 的音频处理库 PyAudio 来录制和播放音频，同时使用 Socket 实现网络通信，实现音频的实时传输。

具体的实现步骤如下：

1. 导入 PyAudio 和 Socket 库。

import pyaudio
import socket

2. 创建 PyAudio 的输入流和输出流。

# 创建 PyAudio 的输入流和输出流
p = pyaudio.PyAudio()
input_stream = p.open(format=FORMAT, channels=CHANNELS, rate=RATE, input=True, frames_per_buffer=CHUNK)
output_stream = p.open(format=FORMAT, channels=CHANNELS, rate=RATE, output=True, frames_per_buffer=CHUNK)

其中，FORMAT、CHANNELS、RATE 和 CHUNK 都是常量，分别表示音频的格式、声道数、采样率和缓冲区大小，可以根据需要自行调整。

3. 创建 Socket 连接。

# 创建 Socket 连接
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(('127.0.0.1', 8000))
server_socket.listen(1)
print('等待连接...')
client_socket, client_address = server_socket.accept()
print('连接成功：', client_address)

注意要绑定本地 IP 和端口，等待客户端连接。

4. 不断循环，读取输入流的音频数据并发送给客户端，接收客户端发送的音频数据并写入输出流。

# 不断循环，读取输入流的音频数据并发送给客户端，接收客户端发送的音频数据并写入输出流
while True:
    # 读取输入流的音频数据并发送给客户端
    input_data = input_stream.read(CHUNK)
    client_socket.sendall(input_data)

    # 接收客户端发送的音频数据并写入输出流
    output_data = client_socket.recv(CHUNK)
    output_stream.write(output_data)

注意要使用 sendall() 和 recv() 函数来确保数据完整性。

完整代码如下：

import pyaudio
import socket

# 定义常量
FORMAT = pyaudio.paInt16
CHANNELS = 1
RATE = 16000
CHUNK = 1024

# 创建 PyAudio 的输入流和输出流
p = pyaudio.PyAudio()
input_stream = p.open(format=FORMAT, channels=CHANNELS, rate=RATE, input=True, frames_per_buffer=CHUNK)
output_stream = p.open(format=FORMAT, channels=CHANNELS, rate=RATE, output=True, frames_per_buffer=CHUNK)

# 创建 Socket 连接
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(('127.0.0.1', 8000))
server_socket.listen(1)
print('等待连接...')
client_socket, client_address = server_socket.accept()
print('连接成功：', client_address)

# 不断循环，读取输入流的音频数据并发送给客户端，接收客户端发送的音频数据并写入输出流
while True:
    # 读取输入流的音频数据并发送给客户端
    input_data = input_stream.read(CHUNK)
    client_socket.sendall(input_data)

    # 接收客户端发送的音频数据并写入输出流
    output_data = client_socket.recv(CHUNK)
    output_stream.write(output_data)