JMF ，RTP流的录音保存问题？

chen106106

浏览: 407602 次
性别:
来自: 深圳

最近访客更多访客>>

linsonlmy

feiyue81

Kira_喵

kt-zhang

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

jmf学习笔记

package gov.nist.applet.phone.media.messaging;

import java.awt.FileDialog;
import java.awt.Frame;
import java.io.IOException;

import javax.media.CannotRealizeException;
import javax.media.ConfigureCompleteEvent;
import javax.media.ControllerEvent;
import javax.media.ControllerListener;
import javax.media.DataSink;
import javax.media.Format;
import javax.media.Manager;
import javax.media.MediaLocator;
import javax.media.NoDataSinkException;
import javax.media.NoProcessorException;
import javax.media.NotConfiguredError;
import javax.media.Player;
import javax.media.Processor;
import javax.media.ProcessorModel;
import javax.media.RealizeCompleteEvent;
import javax.media.control.TrackControl;
import javax.media.format.AudioFormat;
import javax.media.format.VideoFormat;
import javax.media.protocol.DataSource;
import javax.media.protocol.FileTypeDescriptor;

//import jmapps.util.StateHelper;

public class SaveAudioVideo2File {

    /**
     * @param args
     */
    Processor processor;
    DataSource dataSource;
    DataSink dataSink;
    StateHelper state;
    MediaLocator mediaLocator;
    boolean encodingOK = false;

    public boolean record(DataSource ds)
    {

        try {

            this.processor = Manager.createProcessor(ds);

        } catch (Exception e1)
        {
            System.err.println("no such processor exception");
            e1.printStackTrace();
            return false;
        }
        this.state = new StateHelper(processor);
             if(!state.configure(1000))
        {
            System.out.println("configure error :");
            return false;
        }

//      // 设置存储录像文件的格式为 .QUICKTIME
      processor.setContentDescriptor(new FileTypeDescriptor(FileTypeDescriptor.QUICKTIME));

        // realize the processor，让 processor 进入 realized 状态
      if (!state.realize(1000)) {
          System.out.println("realize error!");
          return false;
      }

        boolean encodingOK = false;

        encodingOK = setTracks(processor, encodingOK);
        if(!encodingOK)
        {
            System.err.println("encoding error!");
            return false;
        }

        try
        {
            this.dataSink = Manager.createDataSink(processor.getDataOutput(), getMediaLocator());
        } catch (NoDataSinkException e1)
        {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }

        try
        {
            dataSink.open();
            dataSink.start();
        } catch (SecurityException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return false;
        } catch (IOException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return false;
        }

        processor.start();
        return true;
    }

    private MediaLocator getMediaLocator()
    {

         Frame saveVideoFrame = new Frame("保存视频文件");
         FileDialog saveVideoFileDialog = new FileDialog(saveVideoFrame, "保存视频文件", FileDialog.SAVE);
         saveVideoFileDialog.setFile(".mov");
         saveVideoFileDialog.setVisible(true);
         String videoFileSavePath = saveVideoFileDialog.getDirectory();
         String videoFileSaveName = saveVideoFileDialog.getFile();
                 if (videoFileSaveName != null) {
             videoFileSavePath = videoFileSavePath.replace("\\", "/");
             String destinationString = "file:///" + videoFileSavePath + videoFileSaveName;
             MediaLocator mediaLocator = new MediaLocator(destinationString);
             return mediaLocator;
         }
         //if a user not choose a file path,then
         return new MediaLocator("file://d:/media.mov");
    }
    public void stopRecord()
    {

            dataSink.close();
            processor.close();
            processor.deallocate();//回收内存
            processor = null;



    }
    public void setDataSource(DataSource ds)
    {
        this.dataSource = ds;
    }
    /**
     * save the position you wanted to save this file
     * @param ml
     */
    public void setMediaLocator(MediaLocator ml)
    {
        this.mediaLocator = ml;
    }
    private static boolean setTracks(Processor p, boolean encodingOK)
            throws NotConfiguredError
    {
        TrackControl tracks[] = p.getTrackControls();
        for(int i=0;i<tracks.length;i++)
        {
            if(tracks[i].getFormat() instanceof AudioFormat)
            {
                tracks[i].setFormat(new AudioFormat(AudioFormat.IMA4));
                encodingOK = true;
            }
            else if(tracks[i].getFormat() instanceof VideoFormat)
            {
                tracks[i].setFormat(new VideoFormat(VideoFormat.H263));
                encodingOK = true;
            }
            else
                tracks[i].setEnabled(false);
        }
        return encodingOK;
    }

      public class StateHelper implements ControllerListener {
            Player xplayer = null;
            boolean configured = false;
            boolean realized = false;
            // boolean prefetched = false;
            // boolean eom = false;// End of media.

            boolean failed = false;
            boolean closed = false;

            public StateHelper(Player p) {
                xplayer = p;
                p.addControllerListener(this);
            }

            public boolean configure(int timeOutMillis) {
                // RealizeCompleteEvent 发生了的话使 ce 事件与之比较，若相等，那么 realized 为 true。
                /*
                 * 监听 ConfigureCompleteEvent 和 ConfigureCompleteEvent 事件的发生。
                 * 如 ConfigureCompleteEvent 事件发生，那么就会赋给 configured 为 ture，使得 public
                 * boolean configure 方法中的 while (!configured && !failed){} 这个循环退出。
                 */
                long startTime = System.currentTimeMillis();
                synchronized (this) {
                    if (xplayer instanceof Processor) {
                        ((Processor) xplayer).configure();
                    } else {
                        return false;
                    }
                    while (!configured && !failed) {
                        try {
                            wait(timeOutMillis);
                        } catch (InterruptedException ex) {
                            ex.printStackTrace();
                        }
                        if (System.currentTimeMillis() - startTime > timeOutMillis) {
                            break;
                        }
                    }
                }
                return configured;
            }

            public boolean realize(int timeOutMillis) {
                long startTime = System.currentTimeMillis();
                synchronized (this) {
                    xplayer.realize();
                    while (!realized && !failed) {
                        try {
                            wait(timeOutMillis);
                        } catch (InterruptedException ie) {
                            ie.printStackTrace();
                        }
                        if (System.currentTimeMillis() - startTime > timeOutMillis) {
                            break;
                        }
                    }
                }
                return realized;
            }

            public synchronized void controllerUpdate(ControllerEvent ce) {
                if (ce instanceof RealizeCompleteEvent) {
                    realized = true;
                } else if (ce instanceof ConfigureCompleteEvent) {
                    configured = true;
                } else {
                    return;
                }
                notifyAll();
            }
        }

}

调用这个类的时候，我传过来的参数是通过RTPManager 管理接收的RTP流，通过update()方法中监听NewReceiverStream事件，当收到一个NewStream的时候，stream=（（NewStreamEvent）event）.getReceiveStream().DataSource ds = stream.getDataSource();

我建立了2个RTP流，一个是视频，一个是音频的。

                if (ctl.getFormat() instanceof VideoFormat)
                {
                    PlayerWindow pw = new PlayerWindow(p, stream);
                    playerWindows.addElement(pw);
                    videoDataSource = ((SourceCloneable)clonedSource).createClone();
                }

                else if(ctl.getFormat() instanceof AudioFormat)
                {
                    DataSource clonedDataSource3 = ((SourceCloneable)clonedSource).createClone();
                    audioDataSource = clonedDataSource3;
                }

    saveMedia = new SaveAudioVideo2File();
             if(videoDataSource!=null&&audioDataSource!=null)
                {
                    try
                    {
                        mergeDataSource = Manager.createMergingDataSource(
                                new DataSource[]{audioDataSource,videoDataSource,});
                        saveMedia.record(mergeDataSource);
                    } catch (IncompatibleSourceException e)
                    {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                else if(videoDataSource!=null)
                {
                    saveMedia.record(videoDataSource);
                }
                else if(audioDataSource!=null)
                {
                    saveMedia.record(audioDataSource);
                }

通过Debug调试可以看到创建的是克隆的混合的DataSource，当录音的时候，就会出现不可以Configure the processor 的异常。我一直找不到为什么不可以configure，请问哪位大侠可以指点一二不？急急！！1111111111111

分享到：