睿豐德科技 專注RFID識別技術和條碼識別技術與管理軟件的集成項目。質量追溯系統、MES系統、金蝶與條碼系統對接、用友與條碼系統對接

上一篇文章我們介紹了關于RTP協議的知識，那么我們現在就自己寫一個簡單的傳輸TS流媒體的RTP服務器吧。

預備知識

關于TS流的格式：TS流封裝的具體格式請參考文檔ISO/IEC 13818-1。這里我們只需要了解一些簡單的信息就好。首先TS流是有許多的TS Packet組成的，每個TS Packet的長度固定為188 bytes，每個packet都是以sync_byte：0x47開頭。

MTU(Maximum Transmission Unit)： 最大傳輸單元。是指一種通信協議的某一層上面所能通過的最大數據包大小（以字節為單位）。最大傳輸單元這個參數通常與通信接口有關（網絡接口卡、串口等）。例如：以太網無法接收大于1500 字節的數據包。

參考代碼

下面我會把自己寫的簡單的代碼貼出來，并且一步步地說明。

新建main.c文件，內容如下：

 

[cpp] view plaincopy    

1. #include <stdio.h>  
2. #include <string.h>  
3. #include <sys/types.h>  
4. #include <sys/socket.h>  
5. #include <netinet/in.h>  
6.   
7. #define TS_PACKET_SIZE 188  
8. #define MTU 1500  

說明：包含一些必要的頭文件，并且定義了TS Packet的長度(188 bytes)，MTU的限制(1500 bytes)。

 

 

[cpp] view plaincopy    

1. struct rtp_header{  
2.     unsigned char cc:4;  
3.     unsigned char x:1;  
4.     unsigned char p:1;  
5.     unsigned char v:2;  
6.       
7.     unsigned char pt:7;  
8.     unsigned char m:1;  
9.   
10.     unsigned short sequence_number;  
11.     unsigned int timestamp;  
12.     unsigned int ssrc;  
13. };  
14.   
15. void init_rtp_header(struct rtp_header *h){  
16.     h->v = 2;  
17.     h->p = 0;  
18.     h->x = 0;  
19.     h->cc = 0;  
20.     h->m = 0;  
21.     h->pt = 33;  
22.     h->sequence_number = 123;  
23.     h->timestamp = 123;  
24.     h->ssrc = 123;  
25. }  

說明：這里定義了RTP Header的結構體，以及初始化的方法。這里用到了位域，這是實現協議的時候常常會用到的方法。

 

需要注意的是：

你會發現這里定義RTP Header的時候，上一篇講到的具體順序不同。原因是本機和網絡字節流的順序相反，如果按照v p x cc的順序來定義一個byte，在這個byte內部v p x cc就會按照從低位到高位的順序放置；而在RTP流中，應該是順序從高位到低位放置的。所以每個byte我都把順序做了倒置。

初始化RTP Header的函數的初始化值的意義請參考rfc3550。為了實現簡單，其中的sequence_number、timestamp、ssrc，都是隨意填寫的。在發送包的時候需要將sequence_number遞增。

 

[cpp] view plaincopy    

1. void sequence_number_increase(struct rtp_header *header){  
2.     unsigned short sequence = ntohs(header->sequence_number);  
3.     sequence++;  
4.     header->sequence_number = htons(sequence);  
5. }  

說明：這個函數的目的就是讓sequence_number加一，還是由于本機與網絡字節序不同的原因，所以顯得略微復雜些。

 

 

[cpp] view plaincopy    

1. int main(){  
2.     // RTP Packet we will send  
3.     char buf[MTU];  
4.     unsigned int count = 0;  
5.   
6.     // Init RTP Header  
7.     init_rtp_header((struct rtp_header*)buf);  
8.     count = sizeof(struct rtp_header);  
9.   
10.     // Init socket  
11.     int sock = socket(AF_INET, SOCK_DGRAM, 0);  
12.     struct sockaddr_in dest_addr;  
13.       
14.     dest_addr.sin_family=AF_INET;  
15.     dest_addr.sin_port = htons(6666);  
16.     dest_addr.sin_addr.s_addr = INADDR_ANY;  
17.     bzero(&(dest_addr.sin_zero),8);  
18.       
19.     // Open TS file  
20.     FILE *ts_file = fopen("/home/baby/Videos/480p.ts", "r+");  

說明：終于到了main函數了，main函數的開始很簡單，四個部分的初始化：代表RTP Packet的buffer，RTP Header，Socket，TS流媒體文件。如果你手頭沒有現成的TS文件，可以用ffmpeg轉碼得到一個ts文件：“ffmpeg -i video.xxx video.ts”， 其中 video.xxx 表示輸入的視頻文件，video.ts 為輸出的TS文件。

 

 

[cpp] view plaincopy    

1. while(!feof(ts_file)){  
2.     int read_len = fread(buf+count, 1, TS_PACKET_SIZE, ts_file);  
3.     if(*(buf+count) != 0x47){  
4.         fprintf(stderr, "Bad sync header!\n");  
5.         continue;  
6.     }  
7.     count += read_len;  
8.       
9.     if (count + TS_PACKET_SIZE > MTU){// We should send  
10.         sequence_number_increase((struct rtp_header*)buf);  
11.         sendto(sock, buf, count, 0, (const struct sockaddr*)&dest_addr, sizeof(dest_addr));  
12.         count = sizeof(struct rtp_header);  
13.         usleep(10000);  
14.     }  
15. }  
16.   
17. fclose(ts_file);  

說明：一切就緒后就可以不斷的用UDP發送RTP Packet了。每次從ts_file中讀取188 bytes，附加到buf之后，如果buf的長度還沒用到達MTU的限制，那么就繼續添加，否則就將buf發送出去。每次發送會將sequence_number加一，并且間隔10000微秒。當然這只是個簡單的例子，實際發送視頻是要根據時間戳的。

 

測試

短短幾十行代碼是否就能完成一個RTP服務器？我們需要用實驗來驗證。

我的測試環境是Linux，用gcc編譯通過，使用VLC(MPlayer 測試也可以通過了)作為接收端。

首先啟動我們的發送端程序，然后再執行“vlc rtp://127.0.0.1:6666”，等待幾秒后，發現真的可以進行播放啦！

RFID管理系統集成商 RFID中間件 條碼系統中間層 物聯網軟件集成