Android-телефон как видеосервер MJPEG в реальном времени

Question

Я пытаюсь использовать мой телефон в качестве источника видео MJPEG в реальном времени. Пока что захват кадров и преобразование их в JPEG не представляет особой проблемы. Моя настоящая проблема - правильно отправить ответ из нескольких частей. Существует множество документов об отправке многочастных ответов, но проблема в том, что все они ожидают, что все изображения будут доступны в момент поступления HTTP-запроса (например, который будет использоваться для загрузки нескольких изображений). Конечно, для потоковой передачи в реальном времени мне нужно иметь возможность начать посылать многочастный ответ, постоянно добавляя jpegs в тело. Я ни в коем случае не любитель HTTP, поэтому мне нежелательно бросать свой собственный ответ HTTP и писать прямо в сокет. Есть ли библиотека, которая поддерживает такое поведение? Я искал Интернет для решений, но я действительно не вижу ничего полезного там.

Есть идеи? В худшем случае я хотел бы взглянуть на удобочитаемую документацию о том, как написать многочастный ответ вручную, но я бы действительно предпочел использовать библиотеку, если это возможно.

Заранее спасибо.

редактировать: заставить работать, используя библиотеку orielly servlet согласно предложению sigmavirus. Обратите внимание, что поток MJPEG более или менее неявно выводится из того факта, что я отправляю multipart/x-mixed-replace, в котором есть только изображения /jpeg. Посмотрите комментарий в моем коде для учебника, который показывает, какие библиотеки Jetty вам понадобятся, чтобы запустить его. Конечно, вам также понадобится cos.jar, библиотека сервлетов Orielly. Код следует:

package edu.stevens.arpac.webclient;

import java.io.IOException;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.util.Collections;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpServletRequest;

import org.apache.http.conn.util.InetAddressUtils;
import org.eclipse.jetty.server.Handler;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.handler.AbstractHandler;
import org.eclipse.jetty.server.Request;

import com.oreilly.servlet.MultipartResponse;
import com.oreilly.servlet.ServletUtils;


import android.os.Environment;
import android.util.Log;
// holla at http://puregeekjoy.blogspot.com/2011/06/running-embedded-jetty-in-android-app.html
public class JettyServer extends Thread 
{
private static final String TAG = "JettyServer";
private Server webServer;
private Boolean isStarted = false;

public JettyServer()
{
    super();
    Log.i(TAG, "Initializing server to port 8080");
    webServer = new Server(8080);

    Handler handler = new AbstractHandler() {
        public void handle(String target, Request request, HttpServletRequest servletRequest,
                HttpServletResponse servletResponse) throws IOException, ServletException {

            ServletOutputStream out = servletResponse.getOutputStream();

             MultipartResponse multi = new MultipartResponse(servletResponse);


             Boolean go = true;
             while( go )
             {

                 try
                 {
                     multi.startResponse("image/jpeg");
                     ServletUtils.returnFile(Environment.getExternalStorageDirectory().getPath() + "/ARPac/twi.jpg", out);
                     multi.endResponse();
                 }
                 catch(IOException ex)
                 {
                    go = false;
                    Log.i(TAG, "IO Failed with exception " + ex.getMessage());
                 }
             }
             request.setHandled(true);
        }
    };
    webServer.setHandler(handler);

    try {
        webServer.start();
        Log.d(TAG, "started Web server @ " + getIPAddress());
        isStarted = true;

    }
    catch (Exception e) {
        Log.d(TAG, "unexpected exception starting Web server: " + e);
    }
}

/**
 * Get IP address from first non-localhost interface
 * @return  address or empty string
 */
private String getIPAddress() 
{
    try 
    {
        List<NetworkInterface> interfaces = Collections.list(NetworkInterface.getNetworkInterfaces());
        for (NetworkInterface intf : interfaces) 
        {
            List<InetAddress> addrs = Collections.list(intf.getInetAddresses());
            for (InetAddress addr : addrs) 
            {
                if (!addr.isLoopbackAddress())
                {
                    String sAddr = addr.getHostAddress().toUpperCase(); 
                    if (InetAddressUtils.isIPv4Address(sAddr))
                    {
                        //Log.d(TAG, "IP address is: " + sAddr);
                        return sAddr;
                    } 
                }
            }
        }
    } 
    catch (Exception ex) 
    { 
        Log.e(TAG, "could not get IP address: " + ex.getMessage());
    } // for now eat exceptions
    Log.e(TAG, "Could not find a non-loopback IPv4 address!");
    return "";
}

public void teardown()
{
    if( isStarted )
    {
        try {
            webServer.stop();
            isStarted = false;
        } catch (Exception e) {
            Log.e(TAG, "Couldn't stop server. Probably was called when server already stopped.");
        }
    }
}

public void run() 
 {

 }

}

Answer 1

Вы видели это? http://www.servlets.com/cos/javadoc/com/oreilly/servlet/MultipartResponse.html Похоже, что пример отправляет каждую часть в отдельности и ожидает заданный лимит времени перед отправкой следующего или получением прерывания.