Я понятия не имею, как решить эту проблему. Помогите пожалуйста мне :)
Я хотел бы отправить звуковые данные, записанные одним компьютером, на другой компьютер и воспроизвести их. (по УДП)
Программа может работать корректно, но звук содержит(?) неприятный шум. когда я пытался записать и воспроизвести звук в одной программной последовательности, он работал правильно. Шума не было. В случае использования UDP даже на одном ПК, используйте IP 127.0.0.1, появился шум. Сначала я подумал, что причина в том, что воспроизводимый звук отсутствует на другом ПК, и я исправил это, создав буфер. Это устранило небольшой шум, но почти весь шум все еще остается.
следующий код это
Клиент
import pyaudio
import socket
from threading import Thread
frames = []
def udpStream():
udp = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
while True:
if len(frames) > 0:
udp.sendto(frames.pop(0), ("127.0.0.1", 12345))
udp.close()
def record(stream, CHUNK):
while True:
frames.append(stream.read(CHUNK))
if __name__ == "__main__":
CHUNK = 1024
FORMAT = pyaudio.paInt16
CHANNELS = 2
RATE = 44100
p = pyaudio.PyAudio()
stream = p.open(format = FORMAT,
channels = CHANNELS,
rate = RATE,
input = True,
frames_per_buffer = CHUNK,
)
Tr = Thread(target = record, args = (stream, CHUNK,))
Ts = Thread(target = udpStream)
Tr.setDaemon(True)
Ts.setDaemon(True)
Tr.start()
Ts.start()
Tr.join()
Ts.join()
Сервер
import pyaudio
import socket
from threading import Thread
frames = []
def udpStream(CHUNK):
udp = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
udp.bind(("127.0.0.1", 12345))
while True:
soundData, addr = udp.recvfrom(CHUNK)
frames.append(soundData)
udp.close()
def play(stream, CHUNK):
BUFFER = 10
while True:
if len(frames) == BUFFER:
while True:
stream.write(frames.pop(0), CHUNK)
if __name__ == "__main__":
FORMAT = pyaudio.paInt16
CHUNK = 1024
CHANNELS = 2
RATE = 44100
p = pyaudio.PyAudio()
stream = p.open(format=FORMAT,
channels = CHANNELS,
rate = RATE,
output = True,
frames_per_buffer = CHUNK,
)
Ts = Thread(target = udpStream, args=(CHUNK,))
Tp = Thread(target = play, args=(stream, CHUNK,))
Ts.setDaemon(True)
Tp.setDaemon(True)
Ts.start()
Tp.start()
Ts.join()
Tp.join()
извините за длинный исходный код. Не стесняйтесь играть в эту программу.
threading
— правильный выбор для разделения извлечения потока и воспроизведения потока). - person Dr. Jan-Philip Gehrcke   schedule 16.01.2014