Flex 迷你教程 — 基于Stratus的P2P网络电话 (3)

//呼叫对方的方法，现在是呼叫者角色
private function call():void{
 
if(callYou.label == "接受"){
accpetHandle();
callYou.label = "挂断"
return;
}else if(callYou.label == "挂断"){
outgoingStream.send("onHangup")
this.hangup()
 
return;
}
 
...............
 
//发送视频
publishVideo();
//发送音频
publishAudio()
 
..........
 
//监听onConnectSuccess事件，确定链接成功
i.onConnectSuccess = function(name:String):void
{
info.text += "与"+name + "链接成功n";
sendMessageBtn.enabled = true;
incomingStream.receiveAudio(true)
incomingStream.receiveAudio(true)
remoteVideo = new Video();
remoteVideo.width = 160;
remoteVideo.height = 120;
remoteVideo.attachNetStream(incomingStream);
remoteVideoDisplay.addChild(remoteVideo);
sendMessageBtn.enabled = true;
}
 
i.onHangup = function():void{
hangup()
}
 
incomingStream.client = i
 
callYou.label = "挂断"

private function initSendStream():void{
 
..........
 
//监听onPeerConnect事件
var o:Object = new Object();
o.onPeerConnect = function(subscriberStream:NetStream):Boolean
{
..........
 
incomingStream.receiveAudio(false)
incomingStream.receiveAudio(false)
..........
 
//监听onIncomingCall事件，用于确定链接成功
i.onIncomingCall = function(name:String):void
{
//显示链接成功后，对呼叫者发布我的信息流，名称为callee
info.text += name + " 正在呼叫你n";
callYou.label = "接受"
}
 
i.onHangup = function():void{
hangup()
}
incomingStream.client = i;
 
return true;
}
 
myStream.client = o;
}

//同意链接后，发送stream到呼叫端，包括音频，视频的发送。 同时播放呼叫端发出的视频，音频
private function accpetHandle():void{
//向呼叫端发送信息流
outgoingStream = new NetStream(netConnection, NetStream.DIRECT_CONNECTIONS);
outgoingStream.addEventListener(NetStatusEvent.NET_STATUS, outgoingStreamHandler);
outgoingStream.publish("callee");
//将视频，音频附加到outgoingStream
publishAudio();
publishVideo()
 
//播放接受到的视频，音频
incomingStream.receiveAudio(true)
incomingStream.receiveAudio(true)
remoteVideo = new Video();
remoteVideo.width = 160;
remoteVideo.height = 120;
remoteVideo.attachNetStream(incomingStream);
remoteVideoDisplay.addChild(remoteVideo);
//链接成功事件，呼叫端响应
outgoingStream.send("onConnectSuccess",userName.text);
sendMessageBtn.enabled = true;
}

//挂断电话，清空所有stream，只保持于stratus的链接
public function hangup():void{
if (incomingStream){
incomingStream.close();
incomingStream.removeEventListener(NetStatusEvent.NET_STATUS, incomingStreamHandler);
}
 
if (outgoingStream){
outgoingStream.close();
outgoingStream.removeEventListener(NetStatusEvent.NET_STATUS, outgoingStreamHandler);
}
 
if (controlStream){
controlStream.close();
controlStream.removeEventListener(NetStatusEvent.NET_STATUS, netStreamHandler);
}
 
incomingStream = null;
outgoingStream = null;
controlStream = null;
if(localVideo != null){
localVideo.attachCamera(null)
}
 
if(remoteVideo != null){
remoteVideo.attachCamera(null)
}
 
info.text += "挂机！"
callYou.label = "呼叫"
sendMessageBtn.enabled = false;
}

//发送视频
private function publishVideo():void{
var cameras:Array = Camera.names;
var camera:Camera;
var findDefaultCamera:Boolean = false
if (cameras && cameras.length >0){
for(var j:int=0; j<cameras.length; j++){
if(cameras[j].toString() == "USB Video Class Video"){
camera = Camera.getCamera(j.toString())
outgoingStream.attachCamera(camera);
findDefaultCamera = true
}
}
if(!findDefaultCamera){
camera = Camera.getCamera()
outgoingStream.attachCamera(camera)
}
camera.setQuality(0,90)
 
localVideo = new Video();
localVideo.width = 160;
localVideo.height = 120;
localVideo.attachCamera(camera)
localVideoDisplay.addChild(localVideo);
}
}
//发送音频
private function publishAudio():void{
var mics:Array = Microphone.names;
if (mics && mics.length >0){
outgoingStream.attachAudio(Microphone.getMicrophone(0))
}
}