开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > IP电话/视频会议 > 查看源码
RTPVoiceSender.java
资源名称：SIPPhone.zip　[点击查看]
上传用户：pdtewte
上传日期：2021-10-16
资源大小：13k
文件大小：4k
源码类别：

IP电话/视频会议

开发平台：

Java

RTPVoiceSender.java：源码内容
  3. import   javax.media.*;   
  4. import   javax.media.format.*;   
  5. import   javax.media.rtp.*;   
  6. //import   javax.media.rtp.rtcp.*;   
  7. import   javax.media.protocol.*;   
  8. //import   javax.media.rtp.event.*;   
  9. import   javax.media.control.*;   
  10.   
  11. import   java.util.*;   
  12. //import   java.io.*;   
  13. import   java.net.*;   
  14.   
  15.    
  16. public class RTPVoiceSender 
  17. {
  18. private   Processor    mProcessor ;        
  19. private   DataSource   mDataSource;  
  20. private   String       destIP;
  21. private   int          destport;
  23. public RTPVoiceSender( String destIP,int port)
  24. {
  25.  this.destIP = destIP;
  26.  this.destport  = port;
  27.  
  28.  AudioFormat  format  = new   AudioFormat(AudioFormat.GSM_RTP,8000,8,1);   
  29.  Vector   devices =  CaptureDeviceManager.getDeviceList(format);  
  30.  CaptureDeviceInfo   di=   null;   
  31.   if ( devices.size() > 0 )   
  32.   {   
  33.      di = (CaptureDeviceInfo)devices.elementAt(0);
  34.      System.out.println("��ȡ��Ƶ�ɼ��豸�ɹ�!");
  35.   }   
  36.   else   
  37.   {   
  38.  di =  CaptureDeviceManager.getDevice("DirectSoundCapture");
  39.  System.out.println("��ȡ��Ƶ�ɼ��豸ʧ��!");
  40.   }
  41.   
  42.   try
  43.   {   
  44.             mProcessor   =   Manager.createProcessor(di.getLocator());   
  45.         }
  46.   catch (Exception e)  
  47.   {
  48.   System.out.println(e);
  49.         } 
  50.   
  51.   mProcessor.configure();
  52.   while( mProcessor.getState() < Processor.Configured )
  53.   {
  54.   
  55.   }
  56.   
  57.         mProcessor.setContentDescriptor(new   ContentDescriptor(   ContentDescriptor.RAW_RTP));   
  58.   
  59.         TrackControl   track[]   =   mProcessor.getTrackControls();   
  60.   
  61.         boolean   encodingOk   =   false;   
  62.         for   (int   i   =   0;   i   <   track.length;   i++)   
  63.         {   
  64.             if   (!encodingOk   &&   track[i]   instanceof   FormatControl)   
  65.             {   
  66.                 if   (((FormatControl)track[i]).setFormat(   new   AudioFormat(AudioFormat.GSM_RTP,8000,8,1))   ==   null)   
  67.                 {   
  68.                     track[i].setEnabled(false);   
  69.                 }   
  70.                 else  
  71.                 {   
  72.                     encodingOk  =  true;   
  73.                 }   
  74.             }   
  75.             else   
  76.             {   
  77.                 track[i].setEnabled(false);   
  78.             }   
  79.         }  
  80.         
  81.         mProcessor.realize();
  82.         while(mProcessor.getState()< Processor.Realized)
  83.         {
  84.          
  85.         }
  86.         
  87.         try   
  88.         {   
  89.             mDataSource   =   mProcessor.getDataOutput();   
  90.         }   catch   ( NotRealizedError  e)
  91.         {   
  92.              System.out.println(e); 
  93.         }   
  94.         
  95.         PushBufferDataSource pdbs = (PushBufferDataSource)mDataSource;
  96.         
  97.         PushBufferStream pbss[] = pdbs.getStreams();
  98.         
  99.         RTPManager rtpMgrs[] = new RTPManager[pbss.length];
  100.         
  101.         rtpMgrs[0] = RTPManager.newInstance();   
  102.         
  103.         try
  104.         {
  105.          InetAddress ipaddr = InetAddress.getByName(this.destIP);
  106.          SessionAddress localAddr = new SessionAddress(InetAddress.getLocalHost(),10002);
  107.          
  108.          //this.destport
  109.          SessionAddress destAddr = new SessionAddress(ipaddr,this.destport);
  110.          
  111.          rtpMgrs[0].initialize(localAddr);
  112.          
  113.          rtpMgrs[0].addTarget(destAddr);
  114.          
  115.          SendStream sendStream = rtpMgrs[0].createSendStream(mDataSource,0);
  116.          
  117.          sendStream.start();
  118.          
  119.          mProcessor.start();
  120.          
  121.         }
  122.         catch (Exception e)
  123.         {
  124.          System.out.println(e); 
  125.         }
  126.  
  127. }
  128. }