PHP Lame Stream Filter

Question

У меня есть задача сделать встроенный в страницу mp3-плеер, который будет воспроизводить некоторые голосовые сообщения, хранящиеся в базе данных. Некоторые сообщения хранятся в WAV-формате, поэтому их необходимо конвертировать в mp3. Преобразование должно быть сделано "на лету". Поскольку не все сообщения должны быть преобразованы, я решил, что было бы неплохо использовать потоковый фильтр, который будет использоваться при необходимости.

class LameFilter extends php_user_filter
{
  protected $process;
  protected $pipes = array();

  public function onCreate() {
    $descriptorspec = array(
       0 => array("pipe", "r"),
       1 => array("pipe", "w"),
       //2 => array("pipe", "w"),
    );

    $this->process = proc_open('lame --cbr -b 128 - -', $descriptorspec, $this->pipes);
  }

  public function filter($in, $out, &$consumed, $closing) {
    while ($bucket = stream_bucket_make_writeable($in)) {

      fwrite($this->pipes[0], $bucket->data);

      $data = '';
      while (true) {
        $line = fread($this->pipes[1], 8192);
        if (strlen($line) == 0) {
            /* EOF */
            break;
        }
        $data .= $line;
      }

      $bucket->data = $data;
      $consumed += $bucket->datalen;
      stream_bucket_append($out, $bucket);
    }
    return PSFS_PASS_ON;
  }

  public function onClose() {
    //$error = stream_get_contents($this->pipes[2]);
    fclose($this->pipes[0]);
    fclose($this->pipes[1]);
    //fclose($this->pipes[2]);
    proc_close($this->process);
  }
}

/* Register our filter with PHP */
stream_filter_register("lame", "LameFilter")
  or die("Failed to register filter");

$mp3 = fopen("result.mp3", "wb");

/* Attach the registered filter to the stream just opened */
stream_filter_append($mp3, "lame");

$wav = fopen('ir_end.wav', 'rb');
while (!feof($wav)) {
  fwrite($mp3, fread($wav, 8192));
}

fclose($wav);
fclose($mp3);

В примере я использовал чтение из одного файла и запись в другой. Но на самом деле данные читаются из OCI-lob и должны быть записаны в STDOUT.

Проблема в том, что строка "$ line = fread ($ this-> pipe [1], 8192);" фактически блокирует скрипт независимо от ожидаемой длины данных.

Есть ли правильный способ чтения из процесса, не закрывая свой STDIN?

Answer 1

В качестве альтернативы этому решению вы рассматривали сохранение BLOB во временный файл и использование lame для преобразования временного файла, чтобы вы могли просто использовать popen () для потоковой передачи результатов обратно?