Реализация плеера в JMF с использованием RTP - PullRequest
Новая
       43

Реализация плеера в JMF с использованием RTP

4 голосов
/ 09 октября 2011

У меня возникла проблема, с которой я боролся большую часть недели и перепробовал как минимум 10 различных реализаций, и все они, похоже, дают сбой.Должно быть что-то, чего я не понимаю.

Я использую jmf для передачи аудио через rtp.Проблема заключается в том, что проигрыватель клиентов никогда не реализует, и, следовательно, код блокирует, и ничто никогда не воспроизводится.

Код для передатчика следующий: 

import java.io.File;
import java.io.IOException;
import javax.media.DataSink;
import javax.media.Format;
import javax.media.Manager;
import javax.media.MediaLocator;
import javax.media.NoProcessorException;
import javax.media.NotRealizedError;
import javax.media.Processor;
import javax.media.control.FormatControl;
import javax.media.control.TrackControl;
import javax.media.format.AudioFormat;
import javax.media.protocol.ContentDescriptor;
import javax.media.protocol.DataSource;

public class RTPTransmitter
{

/**
 * @param args
 */
public static void main(String[] args)
{
    File f = new File("streamtest.wav");

    Format format;

    format = new AudioFormat(AudioFormat.ULAW_RTP, 8000, 8, 1);

    Processor processor = null;
    try
    {
        processor = Manager.createProcessor(f.toURI().toURL());
    } catch (IOException e)
    {
        e.printStackTrace();
        System.exit(-1);
    } catch (NoProcessorException e)
    {
        e.printStackTrace();
        System.exit(-1);
    }

    // configure the processor
    processor.configure();

    while (processor.getState() != Processor.Configured)
    {
        try
        {
            Thread.sleep(100);
        } catch (InterruptedException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    processor.setContentDescriptor(new ContentDescriptor(ContentDescriptor.RAW_RTP));

    TrackControl track[] = processor.getTrackControls();

    boolean encodingOk = false;

    // Go through the tracks and try to program one of them to
    // output gsm data.

    for (int i = 0; i < track.length; i++)
    {
        if (!encodingOk && track[i] instanceof FormatControl)
        {
            if (((FormatControl) track[i]).setFormat(format) == null)
            {

                track[i].setEnabled(false);
            } else
            {
                encodingOk = true;
            }
        } else
        {
            // we could not set this track to gsm, so disable it
            track[i].setEnabled(false);
        }
    }

    //realize the processor
    processor.realize();
    while(processor.getState() != processor.Realized){
        try
        {
            Thread.sleep(100);
        } catch (InterruptedException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    // At this point, we have determined where we can send out
    // gsm data or not.
    if (encodingOk)
    {       
        // get the output datasource of the processor and exit
        // if we fail
        DataSource ds = null;

        try
        {
            ds = processor.getDataOutput();
        } catch (NotRealizedError e)
        {
            e.printStackTrace();
            System.exit(-1);
        }

        // hand this datasource to manager for creating an RTP
        // datasink our RTP datasink will multicast the audio
        try
        {
            String url = "rtp://127.0.0.1:8000/audio/1";

            MediaLocator m = new MediaLocator(url);

            DataSink d = Manager.createDataSink(ds, m);
            d.open();
            d.start();

            System.out.println("Starting processor");
            processor.start();
            System.out.println("Processor Started");
            Thread.sleep(30000);
        } catch (Exception e)
        {
            e.printStackTrace();
            System.exit(-1);
        }
    }

}

}

Икод для приемника: 

import java.io.IOException;
import java.net.MalformedURLException;
import javax.media.Manager;
import javax.media.MediaLocator;
import javax.media.NoPlayerException;
import javax.media.Player;

public class RTPReceiver
{

/**
 * @param args
 */
public static void main(String[] args)
{
    String url = "rtp://127.0.0.1:8000/audio/1";

    MediaLocator mrl = new MediaLocator(url);

    // Create a player for this rtp session
    Player player = null;
    try
    {
        player = Manager.createPlayer(mrl);
    } catch (NoPlayerException e)
    {
        e.printStackTrace();
        System.exit(-1);
    } catch (MalformedURLException e)
    {
        e.printStackTrace();
        System.exit(-1);
    } catch (IOException e)
    {
        e.printStackTrace();
        System.exit(-1);
    }

    if (player != null)
    {
        System.out.println("Player created.");
        player.realize();
        // wait for realizing
        while (player.getState() != Player.Realized)
        {
            try
            {
                Thread.sleep(10);
            } catch (InterruptedException e)
            {
                e.printStackTrace();
            }
        }
        System.out.println("Starting player");
        player.start();
    } else
    {
        System.err.println("Player won't create.");
        System.exit(-1);
    }

    System.out.println("Exiting.");
}

}

Передатчик запускается нормально, все запускается, и все, кажется, работает.Поэтому я запускаю приемник, и он просто зацикливается на 

while (player.getState() != Player.Realized)

Что меня очень расстраивает, так это то, что это простой контрольный пример, и эти файлы напрямую адаптированы из примеров.Кроме того, они настолько просты, насколько я мог их сделать, и, тем не менее, они все еще не работают.

Любая помощь будет принята с благодарностью!Спасибо!

Ответы [ 2 ]

4 голосов
/ 28 ноября 2011

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

public AudioRTPRecv() {
    MediaLocator mrl= new MediaLocator("rtp://192.168.1.100:49151/audio/1");

    // Create a player for this rtp session
    try {
        player = Manager.createPlayer(mrl);
    } catch (Exception e) {
        System.err.println("Error:" + e);
        return;
    }

    if (player != null) {
        player.addControllerListener(this);
        player.realize();
    }
}

public synchronized void controllerUpdate(ControllerEvent ce) {
    System.out.println(ce);
    if(ce instanceof TransitionEvent) {
        if (((TransitionEvent)ce).getCurrentState() == Processor.Realized) {
            player.start();
            System.out.println("starting player now");
        }
    }
}

Это дает дополнительное преимущество, заключающееся в том, что оператор print в методе controllerUpdate дает вам представление о том, что происходит с проигрывателем.

3 голосов
/ 01 мая 2012

У меня тоже была такая же проблема.Он прилипает к «понимающему» состоянию.Ваша программа просто нуждается в небольшом изменении.Вы знаете, что после того, как прочитаете решение, вы будете бить по своей таблице: D

То есть вместо ввода "127.0.0.1" введите свой IP-адрес.Вот и все!

И запусти.

...