Android端做RTP实时发送音频数据实现

       如果你也在Android端做RTP发送数据的话，通过网上查找资料，相信你不难发现，在使用RTP/RTCP协议发送数据是有现成的库进行调用的，Jlibrtp这个库就是Java实现的，但是这个库是没有说明文档的，比较抠脚，而且百度谷歌找到例子又很少，基本上都没什么卵用；一般搜到都是Jrtplib库，这是C实现库，对我们没多大用，除非你愿意先研究这个库的RTP实现，在用JNI调用，明显更蛋疼。这个没文档就只能自己瞎倒腾一下，还好勉强倒腾出来了。

       首先，你必须下一个Jlibrtp库：https://download.csdn.net/download/jwq1220/10355482 里面包含Jlibrtp的实现和java调用的Demo。

       下完后，新建一个Android工程，将Jlibrtp-0.2.2中的jlibrtp文件夹中的所有.java文件导入工程，全丢到一个新建的jlibrtp包里面，准备工作算是完成，在需要地方直接import这个包，就可以使用了。

demo中标已经将源码打包成jar形式可以直接使用，也可以通过上面链接下载最新的C库和java库。C库中包含demo亲测在linux上面机器间通讯正常

简单整理一下Jlibrtp实现RTP的过程：

1、首先建立收发端的会话，调用Jlibrtp库的实时传输会话类RTPSession，该类可以创建一个RTP会话，并设置传输的RTP端口和RTCP端口，以及与RTP包的相关的时间戳数据等。

2、然后通过RTPSessionRegister方法用于添加RTP会话的参与者，同时开启接收包的AppCallerThread线程类，其run方法调用回调函数receiveData，才开始接收RTP包，receiveData函数会去掉RTP包头，直接将RTP负载存入缓存，之后再进行分包的判断。

具体实现过程如下：

1、InitSession.java类初始化会话基础参数,设置目标IP及RTP端口号和RTCP端口号等；

数据发送和接收需要分包来处理，这里没有贴出来，demo中有完整的分包发送和接收的处理以及数据同步的多线程实现

[java] view plain copy

1. package com.eric.androidrtpsenddata;  
2. import java.net.DatagramSocket;  
3. import java.net.InetSocketAddress;  
4. import jlibrtp.*;  
5. public class InitSession implements RTPAppIntf{  
6.     public RTPSession rtpSession = null;  
7.     public InitSession() {  
8.         DatagramSocket rtpSocket = null;  
9.         DatagramSocket rtcpSocket = null;  
10.         try {  
11.             rtpSocket = new DatagramSocket(8002);  
12.             rtcpSocket = new DatagramSocket(8003);  
13.         } catch (Exception e) {  
14.             System.out.println("发送创建会话异常抛出:"+e);  
15.         }  
16.         //建立会话  
17.         rtpSession = new RTPSession(rtpSocket, rtcpSocket);  
18.         rtpSession.RTPSessionRegister(this,null,null);  
19.         //设置参与者（目标IP地址，RTP端口，RTCP端口）  
20.         Participant p = new Participant("192.168.226.116", 8004, 8005);  
21.         rtpSession.addParticipant(p);  
22.     }  
23.     public void receiveData(DataFrame frame, Participant p){  
24.         String s = new String(frame.getConcatenatedData());  
25.         System.out.println("接收到数据: "+s+" , 参与者CNAME： "  
26.                 +p.getCNAME()+"同步源标识符("+p.getSSRC()+")");  
27.     }  
28.     public void userEvent(int type, Participant[] participant) {  
29.         // TODO Auto-generated method stub  
30.     }  
31.     public int frameSize(int payloadType) {  
32.         return 1;  
33.     }  
34. }  

2、MainActivity.java中发送数据；其中数据发送部分demo中做了修改数据来自真实的音频数据采集，采用AudioRecod，接收端采用AudioPlay来播放发送客户端采集来的实时音频数据，达到语音通话的效果。测试效果还不错。

以下是别人写的，下面demo下载中与下面是不一致的，完实际demo已经完全按照实际sdk的要求进行了封装，解决了大数据实时发送和接收的问题。有兴趣的可以自行下载。也可以操作以下简单例子的实现自行实现。

[java] view plain copy

1. package com.eric.androidrtpsenddata;  
2. import android.app.Activity;  
3. import android.os.Bundle;  
4. public class MainActivity extends Activity{  
5.      @Override  
6.         protected void onCreate(Bundle savedInstanceState) {  
7.             super.onCreate(savedInstanceState);  
8.             setContentView(R.layout.activity_main);   
9.             Thread sendThread = new Thread(new Runnable() {  
10.                 @Override  
11.                 public void run() {  
12.                     try {  
13.                         openSession();  
14.                     } catch (Exception e) {  
15.                         e.printStackTrace();  
16.                         System.out.println("RTP发送数据异常:"+e);  
17.                     }  
18.                 }  
19.             });  
20.             sendThread.start();  
21.         }  
22.      //Jlibrtp开启会话发送数据  ，这里的伪代码，实际demo中的代码输入的实时流通过MIC采集的数据然后分包发送给服务端
23.      public void openSession(){  
24.         InitSession test = new InitSession();  
25.         long teststart = System.currentTimeMillis();  
26.         String str = "abce abcd abce abce abce abcd abcd abce " +  
27.                 "abcd abce abcd abce abcd abce abcd abce abcd abce " +  
28.                 "abcd abce abcd abce abcd abce abcd abce abcd abce abcd " +  
29.                 "abce abcd abce abcd abce abcd abce abcd abce abcd abce " +  
30.                 "abcd abce abcd abce abcd abce abcd abce abcd abce abcd " +  
31.                 "abce abcd abce abcd abce abcd abce abcd abce abcd abce " +  
32.                 "abcd abce abcd abce abcd abce abcd abce abcd abce abcd " +  
33.                 "abce abcd abce abcd abce abcd abce abcd abce abcd abce " +  
34.                 "abcd abce abcd abce abcd abce abcd abce abcd abce abcd " +  
35.                 "abce abcd abce abcd abce abcd abce abcd abce abcd abce " +  
36.                 "abcd abce abcd abce abcd abce abcd abce abcd abce abcd " +  
37.                 "abce abcd abce abcd abce abcd abce abcd ";  
38.         byte[] data = str.getBytes();  
39.         System.out.println(data.length);  
40.         int i=0;  
41.         while(i<data.length) {  
42.                 System.out.println("已发送第"+i+"个字节数组："+data);  
43.                 test.rtpSession.sendData(data);  
44.                 i++;  
45.         }  
46.         long testend = System.currentTimeMillis();  
47.         System.out.println("发送用时：" + (testend - teststart));  
48.         System.out.println("结束时间：" + testend);  
49.         System.out.println("开始时间：" + teststart);  
50.      }  
51.      public void receiveData(){  
52.          ReceiveData receive = new ReceiveData();  
53.      }  
54. }  

例子Demo运行结果：

附上SDK地址：https://download.csdn.net/download/jwq1220/12088825

SDK是源码基于android studio编码的里面包含客户端和服务端的封装

用法如下：

  ServerManager serverManager = new ServerManager ();

  serverManager.setMode(ServerManager.SEVER);//如果是客户此处配置需要改为ServerManager.CLIENT

  serverManager.setRunning(true);

  serverManager.setRecording(true);

这个是没有封装的很早写的demo，上的例子都在这个demo里面：

https://download.csdn.net/download/jwq1220/10355482