(Ffmpeg) 如何使用 Ffmpeg 从收到的 UDP 数据包中在浏览器中播放实时音频?

(Ffmpeg) How to play live audio in the browser from received UDP packets using Ffmpeg?

我有 .NET Core 控制台应用程序,它充当 UDP 服务器和 UDP 客户端

这是控制台应用程序的示例代码:

static UdpClient udpListener = new UdpClient();
    static IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse("192.168.1.230"), 6980);
    static IAudioSender audioSender = new UdpAudioSender(new IPEndPoint(IPAddress.Parse("192.168.1.230"), 65535));

    static void Main(string[] args)
    {
        udpListener.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
        udpListener.Client.Bind(endPoint);

        try
        {
            udpListener.BeginReceive(new AsyncCallback(recv), null);
        }
        catch (Exception e)
        {
            throw e;
        }

        Console.WriteLine("Press enter to dispose the running service");
        Console.ReadLine();
    }

    private async static void recv(IAsyncResult res)
    {
        byte[] received = udpListener.EndReceive(res, ref endPoint);
        OnAudioCaptured(received);
        udpListener.BeginReceive(new AsyncCallback(recv), null);
    }

另一方面,我有一个节点 js API 应用程序,它应该作为子进程执行 FFmpeg 命令并执行以下操作

最后,在客户端,我应该有一个源值等于 http://localhost:3000

的音频元素

目前,我只能执行这条 FFmpeg 命令:

ffmpeg -f  s16le  -ar 48000 -ac 2 -i 'udp://192.168.1.230:65535' output.wav

执行以下操作

我如何在接收 UDP 数据包的节点 js 服务器中执行一个子进程,并将结果作为 Webm 通过管道输出到响应中?

非常感谢 Brad,他指导我找到了解决方案。

在节点 js 服务器中,我必须执行以下操作

  • 将 Ffmpe 作为接收 UDP 数据包作为输入的子进程执行
  • 将子进程的每个结果输出到响应中。

这是节点js服务器的源代码:

var http = require("http");
var port = 8888;
var host = "localhost";
var children = require("child_process");

http
  .createServer(function (req, res) {
    //ffmpeg -f s16le -ar 48000 -ac 2 -i 'udp://192.168.1.230:65535' -b:a 128k -f webm -
    var ffm = children.spawn(
      "ffmpeg",
      "-f s16le -ar 48000 -ac 2 -i udp://192.168.1.230:65535 -b:a 128k -f webm -".split(
        " "
      )
    );

    res.writeHead(200, { "Content-Type": "audio/webm;codecs=vorbis" });
    ffm.stdout.on("data", (data) => {
      console.log(data);
      res.write(data);
    });
  })
  .listen(port, host);

console.log("Server running at http://" + host + ":" + port + "/");

客户端:

  <audio src="http://loclahost:8888" type='audio/webm; codecs="vorbis"' controls preload="none"></audio>