java – 使用RTP在JMF中实现播放器
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了java – 使用RTP在JMF中实现播放器，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4875字，纯文字阅读大概需要7分钟。
内容图文
我有一个问题,我在一周的大部分时间里一直在努力,并尝试过至少10种不同的实现,但似乎都失败了.必须有一些我不理解的东西.
我正在使用jmf通过rtp传输音频.问题是客户端玩家永远不会意识到代码块,因此也没有任何东西可以播放.
Transmitter的代码如下：
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)
令我非常沮丧的是,这是一个简单的测试用例,这些文件可以直接从示例中进行调整.此外,它们尽可能简单,但它们似乎仍无法正常工作.
任何帮助将不胜感激！
谢谢！
解决方法:
嘿,我能理解沮丧.我自己也有类似的问题.无论如何我有几乎相同的发射器,但在接收器中我使用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");
}
}
}
这有一个额外的好处,即controllerUpdate方法中的print语句可以让您了解玩家的最新动态.
内容总结
以上是互联网集市为您收集整理的java – 使用RTP在JMF中实现播放器全部内容，希望文章能够帮你解决java – 使用RTP在JMF中实现播放器所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】