创建我自己的 MJPEG 流

Question

我正在尝试创建一个 MJPEG 流，我有一系列 jpeg，我想将它们组合成一个流，这样用户就可以点击一个 URL 并获得一个 mjpeg 流。 在过去的几天里，我一直在努力让它发挥作用，但这可能是不可能的。我提出了 ethereal 并听取了来自网络某处轴摄像头的数据包，并试图模仿它。我最初尝试使用 WCF，并返回一个“流”，但后来发现我需要在该流上设置内容类型，所以我尝试了 WCF REST api，但遇到了同样的问题。所以我现在只是使用一个简单的 HTTPListener，并处理事件。我非常喜欢使用 WCF，但我不确定它是否允许我返回具有正确内容类型的流。 这就是我为 httpListener 准备的内容。

在侦听器回调的处理程序中，我放了以下内容。

        HttpListenerResponse response = context.Response;
        response.ProtocolVersion = new System.Version(1, 0);
        response.StatusCode = 200;
        response.StatusDescription = "OK";
        response.ContentType = "multipart/x-mixed-replace;boundary=" + BOUNDARY + "\r\n";
        System.IO.Stream output = response.OutputStream;
        Render(output);

Render 方法如下所示

        var writer = new StreamWriter(st);
        writer.Write("--" + BOUNDARY + "\r\n");
        while (true)
        {
            for (int i = 0; i < imageset.Length; i++)
            {
                var resource = Properties.Resources.ResourceManager.GetObject(imageset[i]) as Bitmap;
                var memStream = new MemoryStream();
                resource.Save(memStream,ImageFormat.Jpeg);
                byte[] imgBinaryData = memStream.ToArray();
                string s = Convert.ToBase64String(imgBinaryData);
                writer.Write("Content-type: image/jpeg\r\n");
                foreach (var s1 in imgBinaryData)
                {
                    writer.Write((char)s1);
                }
                writer.Write("\n--" + BOUNDARY + "\n");
                writer.Flush();
                Thread.Sleep(500);
            }
        }

此时，我刚刚在 dll 上添加了一些 jpeg 图像作为属性，并且正在对其进行迭代，最终这些将是动态图像，但现在我只想让它工作。

根据我对 MJPEG（规范）的了解，内容必须设置为 multipart/x-mixed-replace 和边界集。然后您只需按边界划分流内的 jpeg。

这似乎应该比我做的更简单，但我想知道我哪里出错了。如果我在 IE 或 Firefox 中加载此 URL，它就会挂起。如果我尝试使用 img 标签制作一个存根 html 页面，其来源是 URL，那么我会得到一个损坏的图像。

任何想法，谢谢

乔什

Answer 1

好吧，据我所知，这是您的问题：

1. StreamWriter 不是正确的选择。使用常规的流写入功能就可以了。意思是，您应该将数据写入字节数组而不是字符串。

2. 你把图片的Binary数据转成String64，浏览器不知道，还以为是32bit数据。

3. 您的 jpeg 帧格式不正确。您还应该将Content-Length 添加到帧头，以便接收流的应用程序知道何时停止读取，而不必在每次读取时检查下一个边界字符串。这将导致读取数据的速度提高约 4-5 倍。而且你的换行符也有不一致的地方，有些是“\r\n”，有些是“\n”。

4. while循环是一个无限循环。

所以，这就是解决方案。

注意：可能存在一些语法错误，但您可能已经大致了解。

private byte[] CreateHeader(int length)
{
    string header = 
        "--" + BOUDARY + "\r\n" +
        "Content-Type:image/jpeg\r\n" +
        "Content-Length:" + length + "\r\n" +
        + "\r\n"; // there are always 2 new line character before the actual data

    // using ascii encoder is fine since there is no international character used in this string.
    return ASCIIEncoding.ASCII.GetBytes(header); 
}

public byte[] CreateFooter()
{
    return ASCIIEncoding.ASCII.GetBytes("\r\n");
}

private void WriteFrame(Stream st, Bitmap image)
{
    // prepare image data
    byte[] imageData = null;

    // this is to make sure memory stream is disposed after using
    using (MemoryStream ms = new MemoryStream())
    {
        image.Save(ms, ImageFormat.Jpeg);

        imageData = ms.ToArray();
    }

    // prepare header
    byte[] header = CreateHeader(imageData.Length);
    // prepare footer
    byte[] footer = CreateFooter();

    // Start writing data
    st.Write(header, 0, header.Length);
    st.Write(imageData, 0, imageData.Length);
    st.Write(footer, 0, footer.Length);
}

private void Render(Stream st)
{
    for (int i = 0; i < imageset.Length; i++)
    {
        var resource = Properties.Resources.ResourceManager.GetObject(imageset[i]) as Bitmap;
        WriteFrame(st, resource);
        Thread.Sleep(500);
    }
}

Answer 2

还有一个实现@https://net7mma.codeplex.com/SourceControl/latest那里的库可以动态地将Http转码为兼容的Rtp！