如何保存图片从MJPEG流与Java

Question

如何在Java中保存MJPEG流中的图片?我想调用一个HTTP MJPEG地址，并将每一帧保存到一个单独的图片文件

Answer 1

VLCj应该能够播放该流。如果你只是想经常保存截图，你应该能够使用DirectMediaPlayer(它会给你一个BufferedImage)，然后使用ImageIO来保存它。

请注意，它不是世界上最容易使用的API，需要本地代码;如果你是一个初学者(从这个问题看来你可能是?)，那么这不是最简单的任务!

Answer 2

下面的代码可以帮到你:

http://www.walking-productions.com/notslop/2010/04/20/motion-jpeg-in-flash-and-java/

Answer 3

我的流服务器运行在linux上，我使用wget命令来读取

sudo wget -O ./outputfile.mjpg  XXX.XXX.XXX.XXX:port

然后转换输出文件。使用

将MJPG输出到file.mp4

ffmpeg -r 1/5 -i  outputfile.mjpg  outputfile.mp4.

Answer 4

参见几年前出版的http://wiki.bitplan.com/index.php/MJpegStreamer。

在该项目中有多个实现。下面是一个例子:

package com.bitplan.mjpegstreamer;
import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.util.logging.Level;
import com.bitplan.mjpegstreamer.ViewerSetting.DebugMode;
/**
 * Alternative MJpegRunner implementation
 * http://code.google.com/p/ipcapture/source/browse/IPCapture.java?r=0d
 * f4452208266f77fdc09b427682eaee09054fcb for an alternative implementation
 * Copyright (c) 2014 Wolfgang Fahl
 * 
 */
public class MJpegReaderRunner2 extends MJpegRunnerBase {
    private ByteArrayOutputStream jpgOut;
    public final static String VERSION = "0.1.1";
    /**
     * no args default constructor
     */
    public MJpegReaderRunner2() {
    }
    @Override
    public void init(InputStream inputStream) throws IOException {
        this.curFrame = new byte[0];
        this.frameAvailable = false;
        if (inputStream != null)
            this.inputStream = new BufferedInputStream(inputStream);
        // if (debug)
        // debugTrace("init called");
    }
    /**
     * stop reading
     */
    public synchronized void stop(String msg) {
        try {
            if (jpgOut != null)
                jpgOut.close();
            if (inputStream != null) {
                inputStream.close();
            }
        } catch (IOException e) {
            handle("Error closing streams: ", e);
        }
        DebugMode debugMode = DebugMode.None;
        if (viewer != null)
            debugMode = viewer.getViewerSetting().debugMode;
        if ((debugMode == DebugMode.Verbose) && (conn!=null))
            LOGGER
                    .log(Level.INFO, "stopping connection " + conn.getClass().getName());
        if (conn instanceof HttpURLConnection) {
            HttpURLConnection httpcon = (HttpURLConnection) conn;
            if (debugMode == DebugMode.Verbose)
                LOGGER.log(Level.INFO, "disconnecting " + this.getUrlString());
            httpcon.disconnect();
        }
        if (debugMode == DebugMode.Verbose)
            debugTrace("stop with msg: " + msg, this);
        super.stop(msg);
    }
    /**
     * run me
     */
    public void run() {
        connect();
        if (!connected)
            throw new IllegalStateException(
                    "connection lost immediately after connect");
        int prev = 0;
        int cur = 0;
        try {
            // EOF is -1
            readloop: while (connected && (inputStream != null)
                    && ((cur = inputStream.read()) >= 0)) {
                if (prev == 0xFF && cur == 0xD8) {
                    jpgOut = new ByteArrayOutputStream(INPUT_BUFFER_SIZE);
                    jpgOut.write((byte) prev);
                }
                if (jpgOut != null) {
                    jpgOut.write((byte) cur);
                    if (prev == 0xFF && cur == 0xD9) {
                        synchronized (curFrame) {
                            curFrame = jpgOut.toByteArray();
                        }
                        frameAvailable = true;
                        jpgOut.close();
                        // the image is now available - read it and check if we reached the
                        // limit
                        // e.g. maxFrameCount
                        connected = read();
                        // LOGGER.log(Level.INFO,this.getTimeMsg());
                        if (!connected) {
                            break readloop;
                        }
                    }
                }
                prev = cur;
            }
            // end of input stream reached
            String msg = "end of inputstream " + this.getTimeMsg();
            if (viewer!=null)
                msg+=" read time out is set at "+viewer.getViewerSetting().readTimeOut+" msecs";
            stop(msg);
        } catch (IOException e) {
            handle("I/O Error " + this.getTimeMsg() + ":", e);
        }
    }
}

Answer 5

您可以解析出Jpeg字节并将其保存到文件中。