p2p音视频解决方案

逃离我推掉我的手 2024-03-27 13:24 103阅读 0赞

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是要连接的设备ID
            p2p_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传输实时视频的例子。

[完整示例代码下载][Link 1]

[Link 1]: https://www.haoyou456.com/test/test.rar

发表评论取消回复

表情：

评论列表（有 0 条评论，103人围观）

还没有评论，来说两句吧...

相关阅读

相关 p2p音视频解决方案

P2P音视频传输技术,是为节省服务器带宽而设计的。好游科技 HYP2P SDK是一套与业务无关的通用的p2p sdk库，接入简单，支持用tcp或udp开发的各种情景，比如：rt

逃离我推掉我的手/ 2024年03月27日 13:24/ 0 赞/ 104 阅读

相关流媒体发展新趋势 p2p网络技术 p2p穿透 p2p音视频解决方案

一、流媒体系统及其发展趋势　　所谓流媒体是指用户通过网络或者特定数字信道边下载边播放多媒体数据的一种工作方式。流媒体应用的一个最大的好处是用户不需要花费很长时间将多媒体数

ゝ一世哀愁。/ 2024年03月16日 17:59/ 0 赞/ 92 阅读

相关 P2P原理

简介前面文章在分布式计算泛型中介绍过P2P泛型，他是一种是一种无中心服务器的对等网络泛型。P2P即Peer-to-Peer的缩写，翻译为点对点或者端对端，就是我们常

秒速五厘米/ 2022年07月30日 13:30/ 0 赞/ 375 阅读

相关第三方cookie丢失解决方案-P3P

<!\[endif\]--> 首先，什么是 P3P （ Platform for Privacy Preferences ），其实就是一种可以提供个人隐私保护策略的平台协议

不念不忘少年蓝@/ 2022年07月16日 14:41/ 0 赞/ 194 阅读

相关做一个完整的P2P视频点播系统

做一个完整的P2P视频点播系统标签： [ p2p][p2p][网络][Link 1][点播][Link 2][视频][Link 3][vod][] 2016-02-29

阳光穿透心脏的1/2处/ 2022年07月16日 00:43/ 0 赞/ 180 阅读

相关 P2P技术详解(二)：P2P中的NAT穿越(打洞)方案详解

1、内容概述 P2P即点对点通信，或称为对等联网，与传统的服务器客户端模式（如下图“P2P结构模型”所示）有着明显的区别，在即时通讯方案中应用广泛（比如IM应用中的

╰半夏微凉°/ 2022年04月01日 07:28/ 0 赞/ 1535 阅读

相关 P2P中的NAT穿越方案

王军 P2P简介 P2P即点对点通信，或称为对等联网，与传统的服务器客户端模式（如左图所示）有着明显的区别。P2P可以是一种通信模式、一种逻辑网络模型、一

左手的ㄟ右手/ 2022年01月21日 03:51/ 0 赞/ 270 阅读

相关音视频即时通讯解决方案

　　AnyChat SDK，也叫音视频互动开发平台；是一套跨平台的即时通讯解决方案，基于先进的H.264视频编码标准、AAC音频编码标准与P2P技术，整合了佰锐科技在音视频编码

布满荆棘的人生/ 2022年01月17日 03:49/ 0 赞/ 437 阅读

相关实时音视频技术（WebRTC/voip/Linphone/P2P）

实时音视频技术（WebRTC/voip/Linphone/P2P）视频社交与语音社交？？？实时视频（直播）/语音通信。多媒体技术团队在音视频编解码、前后

Love The Way You Lie/ 2021年11月10日 11:44/ 0 赞/ 1020 阅读

相关 P2P协议简介

最近因为有些需要业务大文件分发，传统文件分发策略都是中心化，要么是推送，要么是拉取，中心节点很容易成为瓶颈，而P2P的点对点，去中心化能很好的解决这个问题。 P2P协议

深碍√TFBOYSˉ_/ 2021年06月24日 16:00/ 0 赞/ 736 阅读