在 Python 中开始播放 URL 流的确切时刻的回调函数

问题描述

我目前正在使用 Python 为 RaspBerry Pi 开发网络广播播放器。功能很简单：在用户输入时，程序从预定义的列表中随机选择一个 URL 广播流，并作为子进程通过 omxplayer 开始播放。

这是我的代码：

import simpleaudio as sa
import random
import sys,termios,tty,os
import subprocess

radioList = ["https://edge126.rcs-rds.ro/profm/profm.mp3","https://live.guerrillaradio.ro:8443/guerrilla.aac","http://aska.ru-hoster.com:8053/autodj","https://live.rockfm.ro/rockfm.aacp","https://live.magicfm.ro/magicfm.aacp","http://zuicast.digitalag.ro:9420/zu"]

class AudioPlayer: # used only for playing noise.wav until radio stream starts 
    def __init__(self):
        self.play_obj = None

    def play(self,filename):
        if not self.is_done():
            self.play_obj.stop()

        wave_obj = sa.WaveObject.from_wave_file(filename)
        self.play_obj = wave_obj.play()
        
    def stop(self):
        self.play_obj.stop()

    def is_done(self):
        if self.play_obj:
            return not self.play_obj.is_playing()
        return True

def getRandomURL(radioList): # returns random URL from provided list
    r = random.randint(1,len(radioList)) - 1
    return radioList[r]

def getch(): # reads input character from stdin
    fd = sys.stdin.fileno()
    old_settings = termios.tcgetattr(fd)
    try:
        tty.setraw(sys.stdin.fileno())
        ch = sys.stdin.read(1)

    finally:
        termios.tcsetattr(fd,termios.TCSADRAIN,old_settings)
    return ch


noisePlayer = AudioPlayer() # create audio instance
omxprocess = ""


while True:
    char = getch()
        
    if(char == "p"):
        if omxprocess != "":
            omxprocess.kill()
        omxprocess = subprocess.Popen(['omxplayer',getRandomURL(radioList)],stdin=subprocess.PIPE) # you should change 'omxplayer' to 'cvlc' or 'mplayer' if you're not running this code on a raspi
        
        # noisePlayer.play("noise.wav") # this file should be played from the moment the above process is started until the radio stream is actually loaded and starts playing
        
    if(char == "x"):
        if omxprocess != "":
            omxprocess.kill()
        exit()

但是，我在 RaspBerry Pi Zero 上运行此代码，通常需要 3-4 秒（甚至更长）才能开始播放流。我想要做的是播放本地音频文件（本例中的 noise.wav，可以在：https://www.random.org/audio-noise/ 处生成）直到流开始播放的确切时刻，因此不会有静音-通勤广播电台之间的死角。我的问题是，我不知道如何完成这样的事情，因为当媒体流实际加载并开始播放时，我没有发现 omxplayer 触发的任何信号或事件，也没有发现 vlc 或 mplayer。>

然而，我确实发现 omxplayer 向标准输出发送了一些信息，这些信息在流开始播放时准确打印（vlc 和 mplayer 也是如此）。举个例子：

pi@raspi:~ $ omxplayer https://live.rockfm.ro/rockfm.aacp
Audio codec aac channels 2 samplerate 44100 bitspersample 16
Subtitle count: 0,state: off,index: 1,delay: 0
have a nice day ;)
pi@raspi:~ $

我很好奇是否有某种方法可以使用此输出作为触发器来阻止 noisePlayer 播放（使用 noisePlayer.stop()）开始玩？我尝试过的一种选择是使用线程模块中的 Timer 函数，但是它经常与可以更快开始播放的无线电流重叠：

        Timer(0.5,noisePlayer.play,["noise.wav"]).start()
        Timer(1.5,noisePlayer.stop).start()

我发现的唯一一篇关于我的问题的文章是：Python communicate with omxplayer 但是，它并没有完全解决我的问题。

如果有人可以对这个问题给出一个确切的实现或如何解决它的解决方案，我将非常非常感激，因为我根本无法理解它:)

解决方法

您只需要为标准输出包含一个 subprocess.PIPE。
如果您想对此进行测试，也可以包含一个用于 stderr 的内容。

import subprocess as sub

stdout,stderr  ##  forward declarations so that these exist within scope

while True:
    char = getch()

    if(char == "p"):
        if omxprocess != "":
            omxprocess.kill()
            command = ['omxplayer',getRandomURL(radioList)]
        omxprocess = sub.Popen(command,stdin=sub.PIPE,stdout=sub.PIPE,stderr=sub.PIPE)

        stdout,stderr = omxprocess.communicate()

        noisePlayer.play("noise.wav")

    if stdout or stderr: noisePlayer.stop()

    if(char == "x"):
        if omxprocess != "":
            omxprocess.kill()
        exit()