Xmpp作为WebRTC信令的音视频通话03-实现PeerConnection方法

创建PeerConnection对象之后，我们就要实现几个方法

1、首先实现SdpObserver接口

private class SDPObserver implements SdpObserver {

    @Override
    public void onCreateSuccess(SessionDescription sessionDescription) {//创建offer/answer成功之后触发
        Log.d(TAG,"SDPObserver onCreateSuccess!");
        if (localSdp != null) {
            reportError("Multiple SDP create.");
            return;
        }
        localSdp = getLocalSdp(sessionDescription.type,sessionDescription.description);
        executor.execute(new Runnable() {
            @Override
            public void run() {
                if (peerConnection != null && !isError) {
                    Log.d(TAG, "Set local SDP from " + localSdp.type);
                    peerConnection.setLocalDescription(sdpObserver, localSdp);
                }
            }
        });
    }

    @Override
    public void onSetSuccess() {//setLocalDescription/setRemoteDescription成功之后触发
        Log.d(TAG,"SDPObserver onSetSuccess!");
        executor.execute(new Runnable() {
            @Override
            public void run() {
                if (peerConnection == null || isError) {
                    return;
                }
                if (isCallout) {//呼叫方
                    if (peerConnection.getRemoteDescription() == null) {//还没有收到接听方的sdp，所以调用events.onLocalDescription(localSdp)把本地的sdp发送给接听方
                        Log.d(TAG, "Local SDP set succesfully");
                        events.onLocalDescription(localSdp);//将保存的本地sdp发送给对方
                    } else {//已经接受到接听方的sdp和IceCandidate
                        Log.d(TAG, "Remote SDP set succesfully");
                        drainCandidates();//将接听方的IceCandidate添加到本地peerConnection对象中
                    }
                } else {//接听方
                    if (peerConnection.getLocalDescription() != null) {
                        Log.d(TAG, "Local SDP set succesfully");
                        events.onLocalDescription(localSdp);//将保存的本地sdp发送给对方
                        drainCandidates();//将呼叫方的IceCandidate添加到本地peerConnection对象中
                    } else {
                        Log.d(TAG, "Remote SDP set succesfully");
                    }
                }
            }
        });
    }

    @Override
    public void onCreateFailure(String s) {
        Log.d(TAG,"SDPObserver onCreateFailure!");
        reportError("createSDP error: " + s);
    }

    @Override
    public void onSetFailure(String s) {
        Log.d(TAG,"SDPObserver onSetFailure!");
        reportError("setSDP error: " + s);
    }
}

保存接收端的IceCandidate

private void drainCandidates() {
    linkedRemoteCandidates = getQueuedRemoteCandidates().get(peerName);
    if (linkedRemoteCandidates != null) {
        Log.d(TAG, "Add " + linkedRemoteCandidates.size() + " remote candidates");
        for (IceCandidate candidate : linkedRemoteCandidates) {
            peerConnection.addIceCandidate(candidate);
        }
        linkedRemoteCandidates.clear();
        linkedRemoteCandidates = null;
    }
}

2、呼叫方创建用于offer的sdp

1、呼叫方创建sdp成功后，会调用sdpObserver.onCreateSuccess(SessionDescription sessionDescription)，将创建的sdp作为参数传进去；
2、 然后调用peerConnection.setLocalDescription(sdpObserver, localSdp)保存在本地；
3、 保存成功后再调用adpObserver.onSetSuccess()中的events.onLocalDescription(localSdp)，将本地的sdp发送给接听方；

/**
 * 创建peerOffer
 * @param peerName
 */
public void createOffer(final String peerName) {
    executor.execute(new Runnable() {
        @Override
        public void run() {
            if (peerConnections == null)
                return;
            PeerConnection peerConnection  = peerConnections.get(peerName);
            Log.e(TAG,"pc ==== " + peerConnection);
            if (peerConnection != null) {
                Log.d(TAG, "PC Create OFFER");
                peerConnection.createOffer(sdpObserver,sdpMediaConstraints);
            }
        }
    });
}

3、接听方创建用于answer的sdp

1、接听方要接收到呼叫方发送来的sdp并且调用setRemoteDescription将该sdp保存起来后才会创建sdp，创建成功后，也会调用sdpObserver.onCreateSuccess(SessionDescription sessionDescription)，将创建的sdp作为参数传进去；
2、 然后调用peerConnection.setLocalDescription(sdpObserver, localSdp)保存在本地；
3、 保存成功后再调用adpObserver.onSetSuccess()中的events.onLocalDescription(localSdp)，将本地的sdp发送给呼叫方；
然后双方sdp交换就结束了

/**
 *创建peerAnswer
 * @param peerName
 */
public void createAnswer(final String peerName) {
    executor.execute(new Runnable() {
        @Override
        public void run() {
            if (peerConnections == null)
                return;
            PeerConnection peerConnection = peerConnections.get(peerName);
            if (peerConnection != null ) {
                Log.d(TAG, "PC create ANSWER");
                peerConnection.createAnswer(sdpObserver,sdpMediaConstraints);
            }
        }
    });
}

4、保存远端的sdp

我们前面一直提到保存远端的sdp，实现的方法就在这里，最后调用的是PeerConnection的方法，pc.setRemoteDescription(sdpObserver,sdpRemote)，保存成功后会触发sdpObserver.onSetSuccess()。
对于接听方来说，此时还没有创建本地的sdp,所以直接打印这句话 Log.d(TAG, "Remote SDP set succesfully");
对于呼叫方来说，要drainCandidates()，即将接受到的IceCandidate添加到peerConnection。

/**
 * 保存远端的sdp
 * @param peerName    接收端，对于呼叫方来说就是接听方，对于接听方来说就是呼叫方
 * @param sdp    接收端的sdp
 */
public void setRemoteDescription(final String peerName, final SessionDescription sdp) {
    executor.execute(new Runnable() {
        @Override
        public void run() {
            if (peerConnections == null)
                return;
            PeerConnection pc = peerConnections.get(peerName);
            if (pc == null) {
                return;
            }
            String sdpDescription = sdp.description;
            if (preferIsac) {
                sdpDescription = preferCodec(sdpDescription, AUDIO_CODEC_ISAC, true);
            }
            if (videoCallEnabled) {
                sdpDescription = preferCodec(sdpDescription, preferredVideoCodec, false);
            }
            if (videoCallEnabled && peerConnectionParameters.videoMaxBitrate > 0) {
                sdpDescription = setStartBitrate(VIDEO_CODEC_VP8, true,
                        sdpDescription, peerConnectionParameters.videoMaxBitrate);
                sdpDescription = setStartBitrate(VIDEO_CODEC_VP9, true,
                        sdpDescription, peerConnectionParameters.videoMaxBitrate);
                sdpDescription = setStartBitrate(VIDEO_CODEC_H264, true,
                        sdpDescription, peerConnectionParameters.videoMaxBitrate);
            }
            if (peerConnectionParameters.audioStartBitrate > 0) {
                sdpDescription = setStartBitrate(AUDIO_CODEC_OPUS, false,
                        sdpDescription, peerConnectionParameters.audioStartBitrate);
            }
            Log.d(TAG, "Set remote SDP.");
            SessionDescription sdpRemote = new SessionDescription(
                    sdp.type, sdpDescription);
            pc.setRemoteDescription(sdpObserver,sdpRemote);
        }
    });
}

5、添加远端的IceCandidate

/**
 * 添加远端的IceCandidate
 * @param peerName    接收端，对于呼叫方来说就是接听方，对于接听方来说就是呼叫方
 * @param candidate    接收到的对方的IceCandidate
 */
public void addRemoteIceCandidate(final String peerName, final IceCandidate candidate) {
    executor.execute(new Runnable() {
        @Override
        public void run() {
            if (peerConnections == null)
                return;
            if(toBeClosePeerNames!=null&&toBeClosePeerNames.size()>0){
                for(String l:toBeClosePeerNames){
                    if(l == peerName){
                        return;
                    }
                }
            }

            PeerConnection pc = peerConnections.get(peerName);
            if (pc != null) {
                Log.d(TAG, "Add Candidate");
                pc.addIceCandidate(candidate);
            }
            else{
                if(queuedRemoteCandidates.get(peerName)==null) {
                    queuedRemoteCandidates.put(peerName,new LinkedList<IceCandidate>());
                }
                queuedRemoteCandidates.get(peerName).add(candidate);
            }
        }
    });
}

总结

  自此，以Xmpp作为WebRTC信令的音视频通话所要实现的东西基本完成！

IceCandidate总感觉接收了两遍，向peerConnection对象中也添加了两遍

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成，浏览时请结合常识与多方信息审慎甄别。
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

相关阅读更多精彩内容

  • webrtc翻译
    这篇翻译不完整。请帮忙从英语翻译这篇文章。 这是一个实验中的功能 此功能某些浏览器尚在开发中，请参考浏览器兼容性表...
    小杰的简书阅读 5,065评论 0赞 0
  • WebRTC实现音视频通信
    一、方案选型 1、XMPP协议 + Jingle扩展协议：应用层协议，可以用来实现音视频传输，但完善的客户端开发资...
    意一ineyee阅读 13,769评论 1赞 11
  • WebRTC基于浏览器的开发
    WebRTC简介 WebRTC通信原理 WebRTC需要通过长链接查找到通信双方，然后通过 peer to pee...
    Shmily落墨阅读 13,995评论 1赞 18
  • MQTT作为WebRTC信令
    Stun Server是开源的coTurn穿透服务器，Signal Server是开源的Apache Active...
    张俊峰0613阅读 9,413评论 5赞 4
  • 今天你胖了吗？
    昨天，我随意拍了一组自己的照片到朋友圈，评论的全是“胖了”、“肥了”……大家也就是一个半月没见着我吧，本来自我感觉...
    雨雪霏霏ff阅读 3,860评论 0赞 1

友情链接更多精彩内容