另一个就是接收端，不停的接收发送出来的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 访问查阅。
