我想将我的手机用作实时MJPEG视频源。到目前为止，捕获帧并将它们转换为JPEG格式很简单。我的真正问题是正确地发送多部分响应。有许多关于发送多部分响应的文档，但它们的问题在于它们都期望所有图像在HTTP请求到达时都可用（例如用于多图像上传的情况）。当然，为了实时流式传输，我需要能够开始发送多部分响应并持续向主体添加JPEG。我肯定不是HTTP专家，因此不希望被要求自己编写HTTP响应并直接写入套接字。是否有库支持这种行为？我已在互联网上搜寻了解决方案，但我确实没有看到任何有用的东西。
你有什么想法吗？最糟糕的情况是，我愿意查看如何手动编写多部分响应的可读性文件，但如果可能的话，我真的只想使用库。
提前致谢。
编辑：根据sigmavirus的建议，使用orielly servlet库使其工作。请注意，MJPEG流或多或少是从我发送一个仅包含图像/ JPEG的multipart / x-mixed-replace中推断出来的。在我的代码注释中，可以查看教程以查看您需要获取此运行的jetty库。当然，您还需要cos.jar，Orielly servlet库。以下是代码：
你有什么想法吗？最糟糕的情况是，我愿意查看如何手动编写多部分响应的可读性文件，但如果可能的话，我真的只想使用库。
提前致谢。
编辑：根据sigmavirus的建议，使用orielly servlet库使其工作。请注意，MJPEG流或多或少是从我发送一个仅包含图像/ JPEG的multipart / x-mixed-replace中推断出来的。在我的代码注释中，可以查看教程以查看您需要获取此运行的jetty库。当然，您还需要cos.jar，Orielly servlet库。以下是代码：
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()
{
}
}