RTP實時音視訊資料傳輸,傳送端和接收端

阿新 • • 發佈：2019-01-20

1.專案前期工作（配置好環境）

2.傳送端檔案編寫（見下面的send.cpp）

3.接收端檔案編寫（見下面的receive.cpp）

4.編譯檔案

（1）傳送端

g++ -o send send.cpp -I /usr/local/include/jrtplib3/ -ljrtp

（2）接收端

g++ -o receive receive.cpp -I /usr/local/include/jrtplib3/ -ljrtp

附錄：

（1）send.cpp

#include "rtpsession.h"
#include "rtppacket.h"
#include "rtpudpv4transmitter.h"
#include "rtpipv4address.h"
#include "rtpsessionparams.h"
#include "rtperrors.h"
#include "rtpmemorymanager.h"
#ifndef WIN32
	#include <netinet/in.h>
	#include <arpa/inet.h>
#else
	#include <winsock2.h>
#endif // WIN32
#include <stdlib.h>
#include <stdio.h>
#include <iostream>
#include <string>

//
// This function checks if there was a RTP error. If so, it displays an error
// message and exists.
//

void checkerror(int rtperr)
{
	if (rtperr < 0)
	{
		std::cout << "ERROR: " << RTPGetErrorString(rtperr) << std::endl;
		exit(-1);
	}
}

//
// The main routine
//

#ifdef RTP_SUPPORT_THREAD

class MyMemoryManager : public RTPMemoryManager
{
public:
	MyMemoryManager() 
	{ 
		mutex.Init();
		alloccount = 0; 
		freecount = 0; 
	}
	~MyMemoryManager() 
	{ 
		std::cout << "alloc: " << alloccount << " free: " << freecount << std::endl; 
	}
	void *AllocateBuffer(size_t numbytes, int memtype)
	{
		mutex.Lock();
		void *buf = malloc(numbytes);
		std::cout << "Allocated " << numbytes << " bytes at location " << buf << " (memtype = " << memtype << ")" << std::endl;
		alloccount++;
		mutex.Unlock();
		return buf;
	}

	void FreeBuffer(void *p)
	{
		mutex.Lock();
		std::cout << "Freeing block " << p << std::endl;
		freecount++;
		free(p);
		mutex.Unlock();
	}
private:
	int alloccount,freecount;
	JMutex mutex;
};

#else

class MyMemoryManager : public RTPMemoryManager
{
public:
	MyMemoryManager() 
	{ 
		alloccount = 0; 
		freecount = 0; 
	}
	~MyMemoryManager() 
	{ 
		std::cout << "alloc: " << alloccount << " free: " << freecount << std::endl; 
	}
	void *AllocateBuffer(size_t numbytes, int memtype)
	{
		void *buf = malloc(numbytes);
		std::cout << "Allocated " << numbytes << " bytes at location " << buf << " (memtype = " << memtype << ")" << std::endl;
		alloccount++;
		return buf;
	}

	void FreeBuffer(void *p)
	{
		std::cout << "Freeing block " << p << std::endl;
		freecount++;
		free(p);
	}
private:
	int alloccount,freecount;
};

#endif // RTP_SUPPORT_THREAD

int main(void)
{
#ifdef WIN32
	WSADATA dat;
	WSAStartup(MAKEWORD(2,2),&dat);
#endif // WIN32
	
	MyMemoryManager mgr;
	RTPSession sess(&mgr);
	uint16_t portbase,destport;
	uint32_t destip;
	std::string ipstr;
	int status,i,num;

        // First, we'll ask for the necessary information
		
	std::cout << "Enter local portbase:" << std::endl;
	std::cin >> portbase;
	std::cout << std::endl;
	
	std::cout << "Enter the destination IP address" << std::endl;
	std::cin >> ipstr;
	destip = inet_addr(ipstr.c_str());
	if (destip == INADDR_NONE)
	{
		std::cerr << "Bad IP address specified" << std::endl;
		return -1;
	}
	
	// The inet_addr function returns a value in network byte order, but
	// we need the IP address in host byte order, so we use a call to
	// ntohl
	destip = ntohl(destip);
	
	std::cout << "Enter the destination port" << std::endl;
	std::cin >> destport;
	
	std::cout << std::endl;
	std::cout << "Number of packets you wish to be sent:" << std::endl;
	std::cin >> num;
	
	// Now, we'll create a RTP session, set the destination, send some
	// packets and poll for incoming data.
	
	RTPUDPv4TransmissionParams transparams;
	RTPSessionParams sessparams;
	
	// IMPORTANT: The local timestamp unit MUST be set, otherwise
	//            RTCP Sender Report info will be calculated wrong
	// In this case, we'll be sending 10 samples each second, so we'll
	// put the timestamp unit to (1.0/10.0)
	sessparams.SetOwnTimestampUnit(1.0/10.0);		
	
	sessparams.SetAcceptOwnPackets(true);
	transparams.SetPortbase(portbase);
	status = sess.Create(sessparams,&transparams);	
	checkerror(status);
	
	RTPIPv4Address addr(destip,destport);
	
	status = sess.AddDestination(addr);
	checkerror(status);
	
	for (i = 1 ; i <= num ; i++)
	{
		printf("\nSending packet %d/%d\n",i,num);
		
		// send the packet
		status = sess.SendPacket((void *)"1234567890",10,0,false,10);
		checkerror(status);
		
		sess.BeginDataAccess();
		
		// check incoming packets
		if (sess.GotoFirstSourceWithData())
		{
			do
			{
				RTPPacket *pack;
				
				while ((pack = sess.GetNextPacket()) != NULL)
				{
					// You can examine the data here
					printf("Got packet !\n");
					
					// we don't longer need the packet, so
					// we'll delete it
					sess.DeletePacket(pack);
				}
			} while (sess.GotoNextSourceWithData());
		}
		
		sess.EndDataAccess();

#ifndef RTP_SUPPORT_THREAD
		status = sess.Poll();
		checkerror(status);
#endif // RTP_SUPPORT_THREAD
		
		RTPTime::Wait(RTPTime(1,0));
	}
	
	sess.BYEDestroy(RTPTime(10,0),0,0);

#ifdef WIN32
	WSACleanup();
#endif // WIN32
	return 0;
}

(2) receive.cpp

#include "rtpsession.h"
#include "rtppacket.h"
#include "rtpudpv4transmitter.h"
#include "rtpipv4address.h"
#include "rtpsessionparams.h"
#include "rtperrors.h"
#ifndef WIN32
	#include <netinet/in.h>
	#include <arpa/inet.h>
#else
	#include <winsock2.h>
#endif // WIN32
#include "rtpsourcedata.h"
#include <stdlib.h>
#include <stdio.h>
#include <iostream>
#include <string>

//
// This function checks if there was a RTP error. If so, it displays an error
// message and exists.
//

void checkerror(int rtperr)
{
	if (rtperr < 0)
	{
		std::cout << "ERROR: " << RTPGetErrorString(rtperr) << std::endl;
		exit(-1);
	}
}

//
// The new class routine
//

class MyRTPSession : public RTPSession
{
protected:
	void OnNewSource(RTPSourceData *dat)
	{
		if (dat->IsOwnSSRC())
			return;

		uint32_t ip;
		uint16_t port;
		
		if (dat->GetRTPDataAddress() != 0)
		{
			const RTPIPv4Address *addr = (const RTPIPv4Address *)(dat->GetRTPDataAddress());
			ip = addr->GetIP();
			port = addr->GetPort();
		}
		else if (dat->GetRTCPDataAddress() != 0)
		{
			const RTPIPv4Address *addr = (const RTPIPv4Address *)(dat->GetRTCPDataAddress());
			ip = addr->GetIP();
			port = addr->GetPort()-1;
		}
		else
			return;
		
		RTPIPv4Address dest(ip,port);
		AddDestination(dest);

		struct in_addr inaddr;
		inaddr.s_addr = htonl(ip);
		std::cout << "Adding destination " << std::string(inet_ntoa(inaddr)) << ":" << port << std::endl;
	}

	void OnBYEPacket(RTPSourceData *dat)
	{
		if (dat->IsOwnSSRC())
			return;
		
		uint32_t ip;
		uint16_t port;
		
		if (dat->GetRTPDataAddress() != 0)
		{
			const RTPIPv4Address *addr = (const RTPIPv4Address *)(dat->GetRTPDataAddress());
			ip = addr->GetIP();
			port = addr->GetPort();
		}
		else if (dat->GetRTCPDataAddress() != 0)
		{
			const RTPIPv4Address *addr = (const RTPIPv4Address *)(dat->GetRTCPDataAddress());
			ip = addr->GetIP();
			port = addr->GetPort()-1;
		}
		else
			return;
		
		RTPIPv4Address dest(ip,port);
		DeleteDestination(dest);
		
		struct in_addr inaddr;
		inaddr.s_addr = htonl(ip);
		std::cout << "Deleting destination " << std::string(inet_ntoa(inaddr)) << ":" << port << std::endl;
	}

	void OnRemoveSource(RTPSourceData *dat)
	{
		if (dat->IsOwnSSRC())
			return;
		if (dat->ReceivedBYE())
			return;
		
		uint32_t ip;
		uint16_t port;
		
		if (dat->GetRTPDataAddress() != 0)
		{
			const RTPIPv4Address *addr = (const RTPIPv4Address *)(dat->GetRTPDataAddress());
			ip = addr->GetIP();
			port = addr->GetPort();
		}
		else if (dat->GetRTCPDataAddress() != 0)
		{
			const RTPIPv4Address *addr = (const RTPIPv4Address *)(dat->GetRTCPDataAddress());
			ip = addr->GetIP();
			port = addr->GetPort()-1;
		}
		else
			return;
		
		RTPIPv4Address dest(ip,port);
		DeleteDestination(dest);
		
		struct in_addr inaddr;
		inaddr.s_addr = htonl(ip);
		std::cout << "Deleting destination " << std::string(inet_ntoa(inaddr)) << ":" << port << std::endl;
	}
};

//
// The main routine
// 

int main(void)
{
#ifdef WIN32
	WSADATA dat;
	WSAStartup(MAKEWORD(2,2),&dat);
#endif // WIN32
	
	MyRTPSession sess;
	uint16_t portbase;
	std::string ipstr;
	int status,i,num;

        // First, we'll ask for the necessary information
		
	std::cout << "Enter local portbase:" << std::endl;
	std::cin >> portbase;
	std::cout << std::endl;
	
	std::cout << std::endl;
	std::cout << "Number of seconds you wish to wait:" << std::endl;
	std::cin >> num;
	
	// Now, we'll create a RTP session, set the destination
	// and poll for incoming data.
	
	RTPUDPv4TransmissionParams transparams;
	RTPSessionParams sessparams;
	
	// IMPORTANT: The local timestamp unit MUST be set, otherwise
	//            RTCP Sender Report info will be calculated wrong
	// In this case, we'll be just use 8000 samples per second.
	sessparams.SetOwnTimestampUnit(1.0/8000.0);		
	
	sessparams.SetAcceptOwnPackets(true);
	transparams.SetPortbase(portbase);
	status = sess.Create(sessparams,&transparams);	
	checkerror(status);
	
	for (i = 1 ; i <= num ; i++)
	{
		sess.BeginDataAccess();
		
		// check incoming packets
		if (sess.GotoFirstSourceWithData())
		{
			do
			{
				RTPPacket *pack;
				
				while ((pack = sess.GetNextPacket()) != NULL)
				{
					// You can examine the data here
					printf("Got packet !\n");
					
					// we don't longer need the packet, so
					// we'll delete it
					sess.DeletePacket(pack);
				}
			} while (sess.GotoNextSourceWithData());
		}
		
		sess.EndDataAccess();

#ifndef RTP_SUPPORT_THREAD
		status = sess.Poll();
		checkerror(status);
#endif // RTP_SUPPORT_THREAD
		
		RTPTime::Wait(RTPTime(1,0));
	}
	
	sess.BYEDestroy(RTPTime(10,0),0,0);

#ifdef WIN32
	WSACleanup();
#endif // WIN32
	return 0;
}

RTP實時音視訊資料傳輸,傳送端和接收端

1.專案前期工作（配置好環境） 2.傳送端檔案編寫（見下面的send.cpp） 3.接收端檔案編寫（見下面的receive.cpp） 4.編譯檔案（1）傳送端 g++ -o send send.cpp -I /usr/loca

Java之UDP傳輸小Demo（無執行緒即傳送端和接收端為兩個獨立程序）：傳送端

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import j

用 Java 模擬 UDP 傳輸的傳送端和接收端

一、建立 UDP 傳輸的傳送端建立 UDP 的 Socket 服務；將要傳送的資料封裝到資料包中；通過 UDP 的 Socket 服務將資料包傳送出去；關閉 Socket 服務。 import java.io.IOException; impor

網際網路協議以及傳送端和接收端程式示例

InetAddress:類表示網際網路協議 (IP) 地址如果一個類中沒有構造方法,沒有欄位,只有成員方法?有什麼特徵 1)應該有一些靜態功能(Math類,Arrays,Collections...) 2)可能符合一種單例模式(餓漢/懶漢) 3)該類中的某些靜態成員方法的返

java_udp傳送端和接收端建立

傳送端： package cn.itcast.udp.demo; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import jav

Udp發送端和接收端

exc ont res udp lose ams send import -a //UdpReceive.java /* 定義udp的接收端。思路： 1.定義udpSocket服務。一般會監聽一個端口，事實上就是這個接收網絡應用程序定義一個數字標示。 2.定義一個數

開源實時音視訊技術WebRTC中RTP/RTCP資料傳輸協議的應用

1、前言 RTP/RTCP協議是流媒體通訊的基石。RTP協議定義流媒體資料在網際網路上傳輸的資料包格式，而RTCP協議則負責可靠傳輸、流量控制和擁塞控制等服務質量保證。在WebRTC專案中，RTP/RTCP模組作為傳輸模組的一部分，負責對傳送端採集到的媒體資料進行進行封包，然後交給上層網路模組

基於iOS的網路音視訊實時傳輸系統（三）- VideoToolbox編碼音視訊資料為H264、AAC

server端 -- 編碼音視訊資料為H264、AAC 這部分花了好多時間，本身就不具備這方面的相關知識，查閱了不少資料，不過關於VideoToolbox和AudioToolbox方面的編碼資料寥寥無幾，雖然網上搜索結果看似特別多，其實一看內容也大同小異，建議還是看看官方

QOS FEC NACK 實時音視訊傳輸庫測試報告（聲網、騰訊實時音視訊測試）

目錄實驗環境測試項說明測試結果競品分析總結 QOS FEC NACK 實時音視訊傳輸庫測試報告 QOS-FEC-NACK傳輸庫簡介 QOS-FEC-NACK是一套集FEC前向糾錯、

從零到一，使用實時音視訊 SDK 一起開發一款 Zoom 吧

zoom(zoom.us) 是一款受到廣泛使用的線上會議軟體。相信各位一定在辦公、會議、聊天等各種場景下體驗或者使用過，作為一款成熟的商業軟體，zoom 提供了穩定的實時音視訊通話質量，以及白板、聊天、螢幕共享、PPT放映等常用功能。但是在當今瀏覽器成為端上主流的時代，實時音視訊又怎甘於落後呢？相比

AR+ 實時音視訊通話，虛擬與現實無縫結合

今年中旬 Google 在萬眾期待下推出了 ARCore，能將現實與數碼完美無縫地融合在一起，豐富我們的現實世界。通過它開發者可以更加快速方便地在 Android 平臺開發 AR 應用，憑藉 AR 技術大量產品能找到新穎的應用場景，甚至開闢出新的一條產品線。目前市場上已經有不少基於 AR 技術的產品，例如

AR+ 實時音視訊通話，×××無縫結合

18個實時音視訊開發中會用到開源專案(轉）

本文轉載自部落格：https://blog.csdn.net/dittychen/article/details/79345828 ----------------------------------------------------------------------------------

RTP解析音視訊幀

RTP解析音視訊幀 RTP解析H264、AAC負載解析H264 解析AAC 封裝AAC的ADTS頭部 CADTS.h CADTS.cpp

打造專遞課堂，即構成為希沃專遞課堂實時音視訊技術唯一提供方

日前，在南昌舉辦的第75屆中國教育裝備展上，希沃和即構zego打造的互動錄播方案亮相。現場將展廳設定為授課教室，廣州、贛州、南昌三個分會場為聽課教室，以每分鐘一場的高頻次互動演示，模擬了身處不同地區的4個教室的互動教學，現場效果令人震撼。據瞭解，該方案也稱“專遞課堂”，目前已在江西、雲南

中老年人計算機基礎與應用培訓通知18個實時音視訊開發中會用到開源專案

　　實時音視訊的開發學習有很多可以參考的開源專案。一個實時音視訊應用共包括幾個環節：採集、編碼、前後處理、傳輸、解碼、緩衝、渲染等很多環節。每一個細分環節，還有更細分的技術模組。比如，前後處理環節有美顏、濾鏡、回聲消除、噪聲抑制等，採集有麥克風陣列等，編解碼有VP8、VP9、H.264、H.

基於TCP的客戶端和服務端資料傳輸

功能描述：從客戶端向服務端傳送字串，服務端接收之後，把字串轉成大寫，並返回給客戶端，客戶端程式碼 import java.io.IOException; import java.io.InputStream; import java.io.OutputStrea

如何用 React Native 開發實時音視訊應用

對於 Web、iOS、Android 開發者來講，React Native 給跨平臺開發工作帶來了很大的幫助。僅用 JavaScript 就可以建立運行於移動端的應用。同時，你也可以將 React Native 程式碼與 Native 程式碼結合，不論你是用 Objective C、Java 還是用 Sw

WebRTC實時音視訊技術基礎：基本架構和協議棧

概述本文主要介紹WebRTC的架構和協議棧。最基本的三角形WebRTC架構為了便於理解，我們來看一個最基本的三角形WebRTC架構（見下圖）：在這個架構中，行動電話用“瀏覽器M”表示，膝上型電腦用“瀏覽器L”表示，通過Web伺服器將它們連線起來。要建立

如何為實時音視訊設計小且優的深度學習模型？

在 GDG 組織的 DevFest 2018 上，聲網Agora 首席科學家鐘聲與在座的上千位開發者分享了演講《Deep Learning for MobilePlatforms: Complexity and Performance Analysis》。以下是由 GDG 整理髮布的演講實錄。

RTP實時音視訊資料傳輸,傳送端和接收端

相關推薦