P2P音视频传输技术,是为节省服务器带宽而设计的。好游科技 HYP2P SDK是一套与业务无关的通用的p2p sdk库，接入简单，支持用tcp或udp开发的各种情景，比如：rtmp,rtstp协议，udp文件传输等。目前主要在网络摄像头、可视门锁、宠物机、扫地机、楼宇对讲等物联网相关行业中应用。支持安凯AK，海思HI，君正，安霸，瑞芯微等linux、安卓、IOS和windows平台。有示例代码提供参考，可以免费下载测试。

HYP2P SDK介绍

先通过一个简单的示例，建立p2p连接，并发送一个字符串"hello world"来说明sdk的使用。

本例子分两个程序配合演示，一个作为client，另一个作为device，模拟用户通过p2p连接某个设备的情景。以下示例代码在windows下用vc2008或以上编译并执行。先看client的代码，所有代码不足100行。

#include "stdafx.h"
#include "p2papi.h"int DEVICE_ID   = 1000;
int g_nP2PSetUp = 0;class CP2PHoleSink : public IP2PSessionSink
{
public:CP2PHoleSink(){}~CP2PHoleSink(){}virtual void onServerConnected(int session, int state){p2p_login_server(session, DEVICE_ID);}virtual void  onLoginServer(int session, int state){//13是要连接的设备IDp2p_connect_peer(session,13);}virtual void onHoleState(int session, int state){        g_nP2PSetUp =state;if (state > 0 ){char str[32] = {"hello world"};p2p_send(session,10,str,strlen(str));}}virtual void onRecvServerData(int cmd, int subcmd, const unsigned char * pDataBuffer, int wDataSize){}virtual void onRecvP2PData(int session,int channel, const unsigned char * pDataBuffer, int wDataSize){}virtual void onChannelState(int session,int state){}virtual bool OnSocketCommand(int wMain, int sub, const void* pData, int nLen){return true;}virtual void onProxyStarted(int session, int port){}
};int main(int argc, char* argv[])
{if (argc >= 2)DEVICE_ID = atoi(argv[1]);printf("my deviceid = %d\n", DEVICE_ID);p2p_engine_init("43.142.138.68",20000,"d:/p2p.log");//"192.168.3.166"int sessionID = p2p_get_free_session();CP2PHoleSink sink;p2p_set_sink(sessionID,&sink);int64_t p2puid = DEVICE_ID | 0x1000000000000000;p2p_connect_server(sessionID, p2puid, "");while (1){SleepEx(10,TRUE);}p2p_engine_destroy();return 0;
}

整个client的代码，main函数不到30行的代码，前面是一个IP2PSessionSink回调接口的实现类CP2PHoleSink。

建立p2p连接的步骤如下：

1. 调用p2p_engine_init("43.142.138.68",20000,"d:/p2p.log");设置p2p服务器的ip（域名）和端口。

1. 获取一个空闲的session：一个app可以同时与多个设备建立p2p连接，每个连接称作一个session.

1. 设置session的回调接口CP2PHoleSink。

1. 调用p2p_connect_server(sessionID, p2puid, ""); 连接p2p服务器。p2puid是本设备的id。

1. 如果连接p2p服务器成功，CP2PHoleSink::onServerConnected将会被回调，接着调用p2p_login_server(session, DEVICE_ID);登入p2p服务器。

1. 如果登入p2p服务器成功，CP2PHoleSink::onLoginServer将会被回调，此时调用p2p_connect_peer(session,13); 连接表示设备的另一个程序，与设备13建立p2p连接。

1. 当p2p连接成功建立后，CP2PHoleSink::onHoleState将会被回调。此时可以调用p2p_send(session,10,str,strlen(str)); 发送任意数据。

另一个程序device的完整代码如下:

#include "stdafx.h"
#include "p2papi.h"int DEVICE_ID   = 13;
int g_nP2PSetUp = 0;class CP2PHoleSink : public IP2PSessionSink
{
public:CP2PHoleSink(){}~CP2PHoleSink(){}virtual void onServerConnected(int session, int state){p2p_login_server(session, DEVICE_ID);}virtual void  onLoginServer(int session, int state){}virtual void onHoleState(int session, int state){        g_nP2PSetUp=state;printf("onHoleState g_nP2PSetUp=%d\n",g_nP2PSetUp);}virtual void onRecvServerData(int cmd, int subcmd, const unsigned char * pDataBuffer, int wDataSize){}virtual void onRecvP2PData(int session,int channel, const unsigned char * pDataBuffer, int wDataSize){printf("recv p2p data, %d bytes:%s\n",wDataSize,pDataBuffer);}virtual void onChannelState(int session,int state){}virtual void onProxyStarted(int session, int port){}
};int main(int argc, char* argv[])
{if (argc >= 2)DEVICE_ID = atoi(argv[1]);p2p_engine_init("43.142.138.68",20000,"d:/p2pserver.log");//"192.168.3.166"printf("my deviceid = %d\n", DEVICE_ID );int sessionID = p2p_get_free_session();CP2PHoleSink sink;p2p_set_sink(sessionID,&sink);//设备授权ID和密钥：4294967390,49uozeazd9//此授权ID与p2p_login_server中的设备ID不同p2p_connect_server(sessionID, 4294967390, "49uozeazd9");while (1){
//        checkReadWrite( );        SleepEx(10,TRUE);}p2p_engine_destroy();return 0;
}

device的代码与client的绝大多都是一样的，只是设备的id改为13，CP2PHoleSink::onRecvP2PData打印出收到的p2p数据。

以上通过两个控制台程序展示了p2p的简单使用，测试时必须先运行device，再运行client。

如有任何凝问，加我qq联系: 390090739

下一篇文章我将介绍 HYP2P SDK在rtsp协议中的使用，展示p2p传输实时视频的例子。

完整示例代码下载