logo标签列表

使用套接字fd从手机向手机实时传输视频流

androidvideo-streamingmedia-playerlive-streamingfile-descriptor
24

我刚接触安卓编程，发现自己陷入了困境。我一直在研究各种方法将手机上的实时视频流传输到另一个手机，似乎大部分功能都已经实现了，除了最重要的一部分：播放视频流。它似乎可以从一个手机发送视频流，但第二个手机无法播放视频流。

这里是播放端的代码：

public class VideoPlayback extends Activity implements Callback {
MediaPlayer mp;
private SurfaceView mPreview;
private SurfaceHolder holder;
private TextView mTextview;
public static final int SERVERPORT = 6775;
public static String SERVERIP="192.168.1.126";
Socket clientSocket;
private Handler handler = new Handler();
/** Called when the activity is first created. */
@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.main);
    mPreview = (SurfaceView) findViewById(R.id.surfaceView1);
    mTextview = (TextView) findViewById(R.id.textView1);
    holder = mPreview.getHolder();
    holder.addCallback(this);
    holder.setType(SurfaceHolder.SURFACE_TYPE_PUSH_BUFFERS);
    mTextview.setText("Attempting to connect");
    mp = new MediaPlayer();
    Thread t = new Thread(){
        public void run(){
            try {
                    clientSocket = new Socket(SERVERIP,SERVERPORT);
                handler.post(new Runnable() {
                    @Override
                    public void run() {
                        mTextview.setText("Connected to server");
                    }
                });
                handler.post(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(clientSocket);
                            pfd.getFileDescriptor().sync();
                            mp.setDataSource(pfd.getFileDescriptor());
                            pfd.close();
                            mp.setDisplay(holder);
                            mp.prepareAsync();
                            mp.start();
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }

                    }
                });

            } catch (UnknownHostException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    };
    t.start();
}

这里是流媒体端的代码：

public class VideoStreaming extends Activity{
// User Interface Elements
VideoView mView;
TextView connectionStatus;
SurfaceHolder mHolder;
// Video variable
MediaRecorder recorder; 
// Networking variables
public static String SERVERIP="";
public static final int SERVERPORT = 6775;
private Handler handler = new Handler();
private ServerSocket serverSocket;  
/** Called when the activity is first created. */
@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.main);
    // Define UI elements
    mView = (VideoView) findViewById(R.id.video_preview);
    connectionStatus = (TextView) findViewById(R.id.connection_status_textview);
    mHolder = mView.getHolder();
    mHolder.setType(SurfaceHolder.SURFACE_TYPE_PUSH_BUFFERS);
    SERVERIP = "192.168.1.126";
    // Run new thread to handle socket communications
    Thread sendVideo = new Thread(new SendVideoThread());
    sendVideo.start();
}
 public class SendVideoThread implements Runnable{
    public void run(){
        // From Server.java
        try {
            if(SERVERIP!=null){
                handler.post(new Runnable() {
                    @Override
                    public void run() {
                        connectionStatus.setText("Listening on IP: " + SERVERIP);
                    }
                });
                serverSocket = new ServerSocket(SERVERPORT);
                while(true) {
                    //listen for incoming clients
                    Socket client = serverSocket.accept();
                    handler.post(new Runnable(){
                        @Override
                        public void run(){
                            connectionStatus.setText("Connected.");
                        }
                    });
                    try{
                            // Begin video communication
                            final ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(client);
                            handler.post(new Runnable(){
                                @Override
                                public void run(){
                                    recorder = new MediaRecorder();
                                    recorder.setVideoSource(MediaRecorder.VideoSource.CAMERA);
                                    recorder.setOutputFormat(MediaRecorder.OutputFormat.THREE_GPP);                 
                                    recorder.setOutputFile(pfd.getFileDescriptor());
                                    recorder.setVideoFrameRate(20);
                                    recorder.setVideoSize(176,144);
                                    recorder.setVideoEncoder(MediaRecorder.VideoEncoder.H263);
                                    recorder.setPreviewDisplay(mHolder.getSurface());
                                    try {
                                        recorder.prepare();
                                    } catch (IllegalStateException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                    } catch (IOException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                    }
                                    recorder.start();
                                }
                            });
                    } catch (Exception e) {
                        handler.post(new Runnable(){
                            @Override
                            public void run(){
                                connectionStatus.setText("Oops.Connection interrupted. Please reconnect your phones.");
                            }
                        });
                        e.printStackTrace();
                    }
                }
            } else {
                handler.post(new Runnable() {
                    @Override
                    public void run(){
                        connectionStatus.setText("Couldn't detect internet connection.");
                    }
                });
            }
        } catch (Exception e){
            handler.post(new Runnable() {
                @Override
                public void run() {
                    connectionStatus.setText("Error");
                }
            });
            e.printStackTrace();
        }
        // End from server.java
    }
}

尝试创建MediaPlayer时，我收到了以下错误。
05-24 16:25:39.360: ERROR/MediaPlayerService(88): offset error
05-24 16:25:39.360: ERROR/MediaPlayer(11895): Unable to to create media player
05-24 16:25:39.360: WARN/System.err(11895): java.io.IOException: setDataSourceFD failed.: status=0x80000000
05-24 16:25:39.360: WARN/System.err(11895):     at android.media.MediaPlayer.setDataSource(Native Method)
05-24 16:25:39.360: WARN/System.err(11895):     at android.media.MediaPlayer.setDataSource(MediaPlayer.java:811)
05-24 16:25:39.360: WARN/System.err(11895):     at com.conti.VideoPlayBack.VideoPlayback$1$2.run(VideoPlayback.java:63)
05-24 16:25:39.360: WARN/System.err(11895):     at android.os.Handler.handleCallback(Handler.java:587)
05-24 16:25:39.360: WARN/System.err(11895):     at android.os.Handler.dispatchMessage(Handler.java:92)
05-24 16:25:39.360: WARN/System.err(11895):     at android.os.Looper.loop(Looper.java:132)
05-24 16:25:39.360: WARN/System.err(11895):     at android.app.ActivityThread.main(ActivityThread.java:4025)
05-24 16:25:39.360: WARN/System.err(11895):     at java.lang.reflect.Method.invokeNative(Native Method)
05-24 16:25:39.360: WARN/System.err(11895):     at java.lang.reflect.Method.invoke(Method.java:491)
05-24 16:25:39.360: WARN/System.err(11895):     at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:841)
05-24 16:25:39.360: WARN/System.err(11895):     at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:599)
05-24 16:25:39.360: WARN/System.err(11895):     at dalvik.system.NativeStart.main(Native Method)

有人有解决这个问题的方法吗？提前感谢！
这个对你有用吗？如果它能正常工作，请告诉我如何解决这个问题。 - Aravi
这个主题有几个问题，最终都以相同的方式结束，即有人说应该是可能的，但没有真正的答案，也没有可行的代码示例，这非常令人沮丧。 - steveh
我找到了一个使用MediaCodec从文件中实际工作的项目。它比MediaPlayer复杂得多，但可能值得一看。您需要用来自套接字的ParcelFileDescriptor替换extractor.setDataSource(fname);，所以我不知道它是否会起作用，但至少您有机会对其进行调试并与本地文件解码进行比较。我计划尝试它，如果它有效，我会发布源代码。 - steveh
抱歉，忘记发布该示例项目的链接了 https://github.com/vecio - steveh
1
我知道这个有点晚了，你解决了吗？@udm_coder - Parth Anjaria
4个回答
6
我找到了一个开源项目，可以实现我想要的功能。通过 IP 摄像头处理带元数据的视频。虽然它无法直接将视频发送到电话，但是它可以广播视频供其他设备观看。该源代码可以在以下项目页面找到：http://code.google.com/p/ipcamera-for-android/。
在 Android 4.4 中，还有一种播放实时 MJPEG 流的方法。您正在播放的流应该由其他设备通过 UDP 端口进行广播。假设我们正在广播 192.168.0.101:8080 上的流。我们可以在布局中添加 WebView 来播放该流。然后在我们的活动中执行以下操作：
@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.mjpeg_activity);
    // Grab instance of WebView
    WebView webView = (WebView)findViewById(R.id.webViewStream);
    // Set page content for webview
    webView.loadData("<html><head><meta name='viewport' content='target-densitydpi=device-dpi,initial-scale=1,minimum-scale=1,user-scalable=yes'/></head><body><center><img src=\"http://192.168.0.101:8080/\" alt=\"Stream\" align=\"middle\"></center></body></html>", "text/html", null);
    webView.getSettings().setBuiltInZoomControls(true);
}

在这段内容中，我们告诉网页使用设备的dpi。为了支持用户在网页上进行捏合缩放，我添加了以下initial-scale=1、minimum-scale=1、user-scalable=yes。最初图像是其原始尺寸，不能缩小。现在用户可以通过缩放来放大或缩小图像至其原始大小。删除最小比例将使用户完全控制缩放，但可能导致图像变得太小而无法找到它。
1
无法运行此项目。您能否写下步骤？ - Biraj Zalavadia
那么你最终没有使用MediaPlayer了。 - Fanglin
4
您需要设置录制输出格式为8（MPEG-2TS，仅适用于Android版本3.0+）。在这种情况下，以此格式记录视频并将流发送到其他手机并保存在文件中。在写入一些数据后播放文件，然后您就可以看到实时流。
注意：您无法直接通过套接字文件描述符播放，因为套接字fd不可寻址。如果您使用套接字fd，将会出现“偏移错误”。录制是可能的，但播放受到限制。
0

请查看流媒体到Android MediaPlayer，其中可能有一些有用的提示，可以帮助您进行流媒体传输。我怀疑问题在于Android试图在文件中寻找，但作为网络套接字-它无法这样做。也许一些支持寻址的磁盘/内存缓冲区可以帮助解决问题？

看起来我确实需要像建议的那样处理缓冲区。我明天早上会尝试一下，看看会发生什么。感谢您的帖子。 - udm_coder
似乎正在流式传输的文件格式不适合媒体播放器播放。我不确定如何解决这个问题。 - udm_coder
1
媒体播放器在处理流媒体时可能会遇到的一个问题是如果元数据没有首先发送。通常，您可以使用像ffmpeg的qt-faststart这样的工具将元数据放在内容之前，但我不确定在实时生成流时该如何操作。 - Steve Pomeroy
0
网页内容由stack overflow 提供, 点击上面的
可以查看英文原文，
原文链接