xmpp作為信令主要用于客戶端之間進行sdp和ice候選的交換赛惩，基于smack4.1.4隘世。
1均芽、自定義消息格式
1.1云头、SessionDescription消息格式
根據(jù)org.webrtc.SessionDescription的內(nèi)容，自定義需要發(fā)送的SessionDescription消息格式
package org.webrtc;
public SessionDescription(SessionDescription.Type type, String description) {
this.type = type;
this.description = description;
}
自定義的SessionDescription消息格式：
public class SDPExtensionElement implements ExtensionElement {
public static final String NAME_SPACE = "com.webrtc.sdp";
public static final String ELEMENT_NAME = "sdp";
//代表SessionDescription.Type.type
private String typeElement = "type";
private String typeText = "";
//代表 SessionDescription.description
private String descriptionElement = "description";
private String descriptionText = "";
public void setDescriptionText(String descriptionText) {
this.descriptionText = descriptionText;
}
public void setTypeText(String typeText) {
this.typeText = typeText;
}
@Override
public String getNamespace() {
return NAME_SPACE;
}
@Override
public String getElementName() {
return ELEMENT_NAME;
}
@Override
public CharSequence toXML() {
StringBuilder sb = new StringBuilder();
sb.append("<").append(ELEMENT_NAME).append(" xmlns=\"").append(NAME_SPACE).append("\">");
sb.append("<" + typeElement + ">").append(typeText).append("</"+typeElement+">");
sb.append("<" + descriptionElement + ">").append(descriptionText).append("</"+descriptionElement+">");
sb.append("</"+ELEMENT_NAME+">");
return sb.toString();
}
}
1.2量愧、IceCandidate消息格式
根據(jù)org.webrtc.IceCandidate的內(nèi)容钾菊，自定義需要發(fā)送的IceCandidate消息格式
package org.webrtc;
public IceCandidate(String sdpMid, int sdpMLineIndex, String sdp) {
this.sdpMid = sdpMid;
this.sdpMLineIndex = sdpMLineIndex;
this.sdp = sdp;
this.serverUrl = "";
}
自定義的IceCandidate消息格式：
public class IceCandidateExtensionElement implements ExtensionElement {
public static final String NAME_SPACE = "com.webrtc.ice_candidate";
public static final String ELEMENT_NAME = "ice_candidate";
//代表IceCandidate.sdpMid;
private String sdpMidElement = "sdpMid";
private String sdpMidText = "";
//代表IceCandidate.sdpMLineIndex;
private String sdpMLineIndexElement = "sdpMLineIndex";
private int sdpMLineIndexText = 0;
//代表IceCandidate.sdp;
private String sdpElement = "sdp";
private String sdpText = "";
public void setSdpMidText(String sdpMidText) {
this.sdpMidText = sdpMidText;
}
public void setSdpMLineIndexText(int sdpMLineIndexText) {
this.sdpMLineIndexText = sdpMLineIndexText;
}
public void setSdpText(String sdpText) {
this.sdpText = sdpText;
}
@Override
public String getNamespace() {
return NAME_SPACE;
}
@Override
public String getElementName() {
return ELEMENT_NAME;
}
@Override
public CharSequence toXML() {
StringBuilder sb = new StringBuilder();
sb.append("<").append(ELEMENT_NAME).append(" xmlns=\"").append(NAME_SPACE).append("\">");
sb.append("<" + sdpMidElement + ">").append(sdpMidText).append("</"+sdpMidElement+">");
sb.append("<" + sdpMLineIndexElement + ">").append(sdpMLineIndexText).append("</"+sdpMLineIndexElement+">");
sb.append("<" + sdpElement + ">").append(sdpText).append("</"+sdpElement+">");
sb.append("</"+ELEMENT_NAME+">");
return sb.toString();
}
}
2、消息發(fā)送
2.1偎肃、消息發(fā)送公共方法
首先在XmppUtils工具類中寫一個發(fā)送message的靜態(tài)方法
/**
*發(fā)送Message消息
* @param mXMPPConnection 與服務(wù)器連接類
* @param message org.jivesoftware.smack.packet.Message煞烫，消息實體
* @param touser 接收方
*/
public static void sendMessage(XMPPTCPConnection mXMPPConnection, Message message, String touser){
ChatManager chatmanager = ChatManager.getInstanceFor(mXMPPConnection);
Chat chat = chatmanager.createChat(touser,null);
if (chat != null) {
try {
chat.sendMessage(message);
} catch (SmackException.NotConnectedException e) {
e.printStackTrace();
}
Log.e(TAG, "發(fā)送成功 === " + message.getBody());
}
}
2.2、發(fā)送SessionDescription消息
/**
* 發(fā)送SessionDescription消息
* @param remotePeerName 接收方累颂，對于呼叫方來說就是接聽方滞详，對于接聽方來說就是呼叫方
* @param sdp 客戶端創(chuàng)建的用于offer或answer的SessionDescription
*/
private void sendSdp(final String remotePeerName, final SessionDescription sdp) {
Message message = new Message();
SDPExtensionElement sdpExtensionElement = new SDPExtensionElement();
sdpExtensionElement.setTypeText(sdp.type.canonicalForm());
sdpExtensionElement.setDescriptionText(sdp.description);
message.addExtension(sdpExtensionElement);
XmppUtils.sendMessage(MyApplication.xmpptcpConnection,message,remotePeerName);
}
2.3、發(fā)送IceCandidate消息
/**
* 發(fā)送IceCandidate
* @param remotePeerName 接收方紊馏，對于呼叫方來說就是接聽方料饥，對于接聽方來說就是呼
* @param candidate IceCandidate
*/
private void sendIceCandidate(String remotePeerName, IceCandidate candidate) {
Message message = new Message();
IceCandidateExtensionElement iceCandidateExtensionElement = new IceCandidateExtensionElement();
iceCandidateExtensionElement.setSdpMidText(candidate.sdpMid);
iceCandidateExtensionElement.setSdpMLineIndexText(candidate.sdpMLineIndex);
iceCandidateExtensionElement.setSdpText(candidate.sdp);
message.addExtension(iceCandidateExtensionElement);
XmppUtils.sendMessage(MyApplication.xmpptcpConnection,message,remotePeerName);
}
3、消息接收
在MsfService中添加Message監(jiān)聽器
ChatManager chatManager = ChatManager.getInstanceFor(mXmpptcpConnection);
chatManager.addChatListener(new ChatManagerListener() {
@Override
public void chatCreated(Chat chat, boolean b) {
chat.addMessageListener(new MsgListener(MsfService.this,mNotificationManager));
}
});
Message監(jiān)聽器
public class MsgListener implements ChatMessageListener {
private static final String TAG = "MsgListener";
private MsfService context;
public MsgListener(MsfService context){
this.context = context;
}
@Override
public void processMessage(Chat chat,Message message) {
try {
String remotePeerName = (message.getFrom()).split("/")[0];
Log.d(TAG,"remotePeerName === " + remotePeerName);
if (message.hasExtension(SDPExtensionElement.ELEMENT_NAME,SDPExtensionElement.NAME_SPACE)) {
DefaultExtensionElement defaultExtensionElement =
message.getExtension(SDPExtensionElement.ELEMENT_NAME, SDPExtensionElement.NAME_SPACE);
String type = defaultExtensionElement.getValue("type");
String description = defaultExtensionElement.getValue("description");
if (type.equals("offer")) {//接聽方 接收到 呼叫方 發(fā)的offer sdp
Log.d(TAG,"=============type ===offer============");
if (CallUtils.getInst().isHangUp()) {
CallUtils.getInst().setHangUp(false);
}
SessionDescription sessionDescription = new SessionDescription(SessionDescription.Type.fromCanonicalForm(type),description);
//Map保存發(fā)送方的sdp
CallUtils.getInst().setSdpMap(remotePeerName,sessionDescription);
//設(shè)為接聽方
CallUtils.getInst().setCallOutModel(false);
//peerConnectionClient保存發(fā)送方的sdp朱监，此處調(diào)用PeerConnection.setRemoteDescription
CallUtils.getInst().onRemoteDescription(remotePeerName,sessionDescription);
} else if (type.equals("answer")){//呼叫方 接收到 接聽方 發(fā)的answer sdp
Log.d(TAG,"=============type ===answer============");
if (CallUtils.getInst().isCallOutModel()) {
SessionDescription sessionDescription = new SessionDescription(SessionDescription.Type.fromCanonicalForm(type),description);
//設(shè)為呼叫方
CallUtils.getInst().setCallOutModel(true);
//peerConnectionClient保存接聽方的sdp,此處調(diào)用PeerConnection.setRemoteDescription
CallUtils.getInst().onRemoteDescription(remotePeerName,sessionDescription);
}
}
} else if (message.hasExtension(IceCandidateExtensionElement.ELEMENT_NAME,IceCandidateExtensionElement.NAME_SPACE)) {
DefaultExtensionElement defaultExtensionElement =
message.getExtension(IceCandidateExtensionElement.ELEMENT_NAME, IceCandidateExtensionElement.NAME_SPACE);
String sdpMid = defaultExtensionElement.getValue("sdpMid");
int sdpMLineIndex = Integer.parseInt(defaultExtensionElement.getValue("sdpMLineIndex"));
String sdp = defaultExtensionElement.getValue("sdp");
IceCandidate iceCandidate = new IceCandidate(sdpMid,sdpMLineIndex,sdp);
//接收到IceCandidate就保存起來岸啡，此處調(diào)用PeerConnection.addIceCandidate()方法
CallUtils.getInst().onRemoteIceCandidate(remotePeerName,iceCandidate);
} else if (message.hasExtension(VideoCallExtensionElement.ELEMENT_NAME,VideoCallExtensionElement.NAME_SPACE)) {
DefaultExtensionElement defaultExtensionElement = message.getExtension(VideoCallExtensionElement.ELEMENT_NAME,
VideoCallExtensionElement.NAME_SPACE);
String type = defaultExtensionElement.getValue("type");
switch (type) {
case "video-end"://掛斷命令
break;
default:
break;
}
}
}catch (Exception e){
e.printStackTrace();
}
}
}
4、實現(xiàn)PeerConnectionEvents
客戶端之間發(fā)送和接收SessionDescription 赫编、IceCandidate已經(jīng)實現(xiàn)了巡蘸，那么什么情況下用他們呢奋隶？
首先，客戶端通過createOffer或者createAnswer方法創(chuàng)建sdp后悦荒，會向?qū)Ψ桨l(fā)送sdp唯欣，這時調(diào)用private void sendSdp(final String remotePeerName, final SessionDescription sdp)；
其次搬味，客戶端收集到IceCandidate后境氢，會向?qū)Ψ桨l(fā)送IceCandidate，這時調(diào)用private void sendIceCandidate(String remotePeerName, IceCandidate candidate)碰纬；
這些先不管产还，先實現(xiàn)PeerConnectionEvents接口。
4嘀趟、1 PeerConnectionEvents接口
public interface PeerConnectionEvents {
/**
* Callback fired once local SDP is created and set.
*/
void onLocalDescription(final SessionDescription sdp);
/**
* Callback fired once local Ice candidate is generated.
*/
void onIceCandidate(final IceCandidate candidate);
/**
* Callback fired once local ICE candidates are removed.
*/
void onIceCandidatesRemoved(final IceCandidate[] candidates);
/**
* Callback fired once connection is established (IceConnectionState is
* CONNECTED).
*/
void onIceConnected();
/**
* Callback fired once connection is closed (IceConnectionState is
* DISCONNECTED).
*/
void onIceDisconnected();
/**
* Callback fired once peer connection is closed.
*/
void onPeerConnectionClosed();
/**
* Callback fired once peer connection statistics is ready.
*/
void onPeerConnectionStatsReady(final StatsReport[] reports);
/**
* Callback fired once peer connection error happened.
*/
void onPeerConnectionError(final String description);
}
4脐区、2 PeerConnectionEvents接口實現(xiàn)
PeerConnectionEvents events = new PeerConnectionEvents() {
@Override
public void onLocalDescription(final SessionDescription sdp) {//當本地sdp創(chuàng)建成功并保存到本地后調(diào)用
if (isHangUp()) return;
final long delta = System.currentTimeMillis() - callStartedTimeMs;
context.runOnUiThread(new Runnable() {
@Override
public void run() {
Log.d(TAG, "Sending " + sdp.type + ", delay=" + delta + "ms");
if (isHangUp()) return;
if (isCallOut) {
if (isHangUp()) {
Log.e(TAG,"掛斷002");
}
localSdp = sdp;
sendSdp(remotePeerName,sdp);//呼叫方發(fā)送用于offer的sdp
} else {
if (isHangUp()) return;
sendSdp(remotePeerName,sdp);//接聽方發(fā)送用于answer的sdp
}
}
});
}
@Override
public void onIceCandidate(final IceCandidate candidate) {//當本地收集到IceCandidate時調(diào)用
if (isHangUp()) return;
context.runOnUiThread(new Runnable() {
@Override
public void run() {
if (localCandidateList == null) {
localCandidateList = new ArrayList<>();
}
localCandidateList.add(candidate);//將本地的IceCandidate保存起來
sendIceCandidate(remotePeerName,candidate);//將本地的IceCandidate發(fā)送給接收端
}
});
}
@Override
public void onIceCandidatesRemoved(IceCandidate[] candidates) {
Log.d(TAG,"onIceCandidatesRemoved");
}
@Override
public void onIceConnected() {//當呼叫方接收到接聽方的sdp和IceCandidate后調(diào)用
if (isHangUp()) return;
final long delta = System.currentTimeMillis() - callStartedTimeMs;
context.runOnUiThread(new Runnable() {
@Override
public void run() {
Log.e(TAG, "ICE connected, delay=" + delta + "ms");
localCandidateList = null;
localSdp = null;
App.getInst().getVideoCallListener().onConnect(remotePeerName);//將對方的視頻渲染到本地
setConnected(true);
}
});
}
@Override
public void onIceDisconnected() {
if (isHangUp()) return;
context.runOnUiThread(new Runnable() {
@Override
public void run() {
Log.d(TAG,"onIceDisconnected");
}
});
}
@Override
public void onPeerConnectionClosed() {
if (isHangUp()) return;
Log.d(TAG,"onPeerConnectionClosed");
}
@Override
public void onPeerConnectionStatsReady(StatsReport[] reports) {
if (isHangUp()) return;
Log.d(TAG,"onPeerConnectionStatsReady");
}
@Override
public void onPeerConnectionError(final String description) {
if (isHangUp()) return;
context.runOnUiThread(new Runnable() {
@Override
public void run() {
Log.d(TAG,"onPeerConnectionError ：" + description);
}
});
}
};
總結(jié)
??至此客戶端之間已經(jīng)可以進行SessionDescription和IceCandidate的交換，雙方客戶端接收到對方的SessionDescription和IceCandidate后要進行的保存等操作以后再說她按！
