Android设备实时音视频传输有效方案，android面试复习

Android设备实时音视频传输有效方案，android面试复习

另一个就是接收端，不停的接收发送出来的socket数据，这个socket数据就是实时的pcm流，接收方，在实时播放pcm流，就能实现音频的实时同步了。

关于视频流，是如何实现同步的，大家也可以猜猜？

1）AudioTrack.cpp中的代码实现

#define DEST_PORT 5046

#define DEST_IP_ADDRESS “192.168.7.6”

int mSocket;

bool mSocketHasInit;

bool mCurrentPlayMusicStream;

struct sockaddr_in mRemoteAddr;

ssize_t AudioTrack::write(const void* buffer, size_t userSize, bool blocking)

{

…

size_t toWrite = audioBuffer.size;

memcpy(audioBuffer.i8, buffer, toWrite);

mBuffer = malloc(toWrite);

memcpy(mBuffer,buffer,toWrite);

//我们添加的代码：把音频流实时的发送出去

if(mCurrentPlayMusicStream && mSocketHasInit){

onSocketSendData(toWrite);

}

…

}

int AudioTrack::onSocketSendData(uint32_t len){

assert(NULL != mBuffer);

assert(-1 != len);

if(!mSocketHasInit){

initTcpSocket();

}

unsigned int ret = send(mSocket, mBuffer,len, 0);

free(mBuffer);

return 0;

}

2) 接收端的代码处理

(我这里是用的Android设备调试，如果是linux系统，思路是同样的)

接收端的处理逻辑流程图如下：

1、设置socket监听；

2、循环监听socket端口数据；

3、接收到pcm流；

4、播放pcm流；

---------- PlayActivity.java ------------

private ServerSocket mTcpServerSocket = null;

private List mSocketList =
new ArrayList<>();

private MyTcpListener mTcpListener = null;

private boolean isAccept = true;

public void startTcpService() {

Log.v(TAG,“startTcpService();”);

if(mTcpListener == null){

mTcpListener = new MyTcpListener();

}

new Thread() {

@Override

public void run() {

super.run();

try {

mTcpServerSocket = new ServerSocket();

mTcpServerSocket.setReuseAddress(true);

InetSocketAddress socketAddress = new InetSocketAddress(AndroidBoxProtocol.TCP_AUDIO_STREAM_PORT);

mTcpServerSocket.bind(socketAddress);

while (isAccept) {

Socket socket = mTcpServerSocket.accept();

mSocketList.add(socket);

//开启新线程接收socket 数据

new Thread(new TcpServerThread(socket,mTcpListener)).start();

}

} catch (Exception e) {

Log.e(“TcpServer”, “” + e.toString());

}

}

}.start();

}

private void stopTcpService(){

isAccept = false;

if(mTcpServerSocket != null){

new Thread() {

@Override

public void run() {

super.run();

try {

for(Socket socket:mSocketList) {

socket.close();

}

mTcpServerSocket.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}.start();

}

}

private void playPcmStream(byte[] buffer) {

if (mAudioTrack != null && buffer != null) {

mAudioTrack.play();

mAudioTrack.write(buffer, 0, buffer.length);

}

}

private Handler mUiHandler = new Handler() {

@Override

public void handleMessage(Message msg) {

super.handleMessage(msg);

switch (msg.what) {

case HANDLER_MSG_PLAY_PCM:

playPcmStream((byte[]) msg.obj);

break;

default:

break;

}

}

};

private class MyTcpListener implements ITcpSocketListener{

@Override

public void onRec(Socket socket, byte[] buffer) {

sendHandlerMsg(HANDLER_MSG_PLAY_PCM,0,buffer);

}

}

总结

---

刚开始接到这个开发需求，也是思考了良久才想到这个方案。也再次验证了，熟悉了解framework层，可以给我们提供很多实现问题的思路。中间调试的时候，也是遇到了不少的问题。不过欣喜的是结果还不错，最后都给跑通了。

该方案，我在Android 5.0和Android 7.0上都运行测试通过，希望对大家有帮助。

最后

---

我给大家分享一份我在网上收集整理的 Android 开发和音视频的相关学习文档、面试题、学习笔记等等文档，希望能帮助到大家学习提升，如有需要参考的可以直接去我 CodeChina地址：https://codechina.csdn.net/u012165769/Android-T3 访问查阅。

最后

---

我给大家分享一份我在网上收集整理的 Android 开发和音视频的相关学习文档、面试题、学习笔记等等文档，希望能帮助到大家学习提升，如有需要参考的可以直接去我 CodeChina地址：https://codechina.csdn.net/u012165769/Android-T3 访问查阅。