OpenRTMFP/Cumulus性能优化(7) 基于RTMFP的p2p的实现

2.nearId的生成

#define ID_SIZE 0x20

class Entity {

public:

Entity();

virtual ~Entity();

...

const Poco::UInt8       id[ID_SIZE];

...

};

Entity::Entity():id() {

}

再把生成的peer.id进行16进制的编码，如下

Util::FormatHex(id,ID_SIZE);

该peer.id也即NetConnection进行连接时的NetConnection.nearId的值，比如：

如果某个peer.id=37007320,则16进制的编码后，其值为

        nearId=4275137c203bbaffc9bf8ee70ee83782d217dc409aa18dbfa7baa0a84c2230b2

3.服务器P2Phandshake的步骤：

根据publisher的nearId查找其session和地址；

向publisher下发player的地址；

向player下发publisher的地址。

然后进行p2phandshake，如下：

        _gateway.p2pHandshake(tag,response,peer.address,(const UInt8*)epd.c_str());

查找与该publisher相关的session:

        Session* pSession = NULL;

        Sessions::Iterator it;

        for(it=_sessions.begin();it!=_sessions.end();++it) {

            pSession = it->second;

            if(Util::SameAddress(pSession->peer.address,address))

                break;

        }

        ...

        ServerSession*pSessionWanted=(ServerSession*)_sessions.find(peerIdWanted);

然后进行握手，如下：

        pSessionWanted->p2pHandshake(address,tag,pSession);

4.向player下发publisher的nearId:

Player和publisher都连接server成功后，并且publisher发布了比如名为“media”的音视频流，则player要想通过p2p播放publisher的音视频流，需要先与publisher进行p2p连接，因此，首先需要得到publisher的nearId，可通过server下发给player，如下：

        AMFWriter& amf = client.writer().writeAMFMessage(RPCMessage::GET_PEER_IDS);

        ...

        amf.beginObject();

        amf.writeObjectProperty("peerId",Cumulus::Util::FormatHex(pSession->peer.id,ID_SIZE));

        amf.endObject();

        ...

5.player进行p2p连接：

Player接收Publisher的nearId，如下：

        public function getPeerIds(...args):void{
           if(args.length == 2){
                var value:uint = args[0] as uint;
                var peerObject:Object = args[1] as Object;
                if (peerObject.p2pFlag == 0) {
                    p2p = true;
                    _peerId1 = peerObject.peerId;
                }

           }
           if (p2p) {//p2p为true，则进行p2pHandshake连接
                call();
           }
           //login media front
           if (!p2p) {//p2p为false，则进行正常的登录流程
               startLogin();
           }
      }

Player接收到publisher的nearId后，进行如下操作：

        controlStream = new NetStream(_nc,publisherNearId);

        controlStream.addEventListener(NetStatusEvent.NET_STATUS, netStreamHandler);

        controlStream.play(publisherNearId);与之进行p2p连接

6.创建发送NetStream和接收NetStream

连接成功了，就可以和publisher建立一条双工的通道进行数据的收发，如下：

//同时对外发布呼叫者的信息流

        outgoingStream = new NetStream(_nc, NetStream.DIRECT_CONNECTIONS);        

        outgoingStream.addEventListener(NetStatusEvent.NET_STATUS, outgoingStreamHandler);

        outgoingStream.publish("caller");

//尝试播放被呼叫者的信息流

        incomingStream = new NetStream(_nc, publisherNearId);

        incomingStream.addEventListener(NetStatusEvent.NET_STATUS, incomingStreamHandler);

        incomingStream.play("callee");

7.实例：

在自己的机器上跑了一下p2p例子，如下图：

flash客户端：

RTMFPServer端：