Reliable Multicast Programming (PGM)實際通用可靠多播協議，在某種程度上保證多播的可靠性。是IP上層協議，和TCP還有UDP同級，工作在傳輸層。

在組播傳輸視頻項目中，發現在網絡較差的時候，組播傳輸視頻性能下降迅猛，組播的視頻幾乎到了無法直視的地步，已經不是馬賽克什么的問題了，簡直就是一張臭抹布。

但是上面的要求是讓接收端達到1080p 16fps的播放效果，此時組播接收端的實時網絡速率只有50KB/s左右，這種情況下要從軟件上處理的話（因為路由器不好換），需要讓組播的丟包率降低才行，但是使用iperf測了下當時網絡的丟包率，能丟到80%，丟到他姥姥家？

但是此時帶寬利用率卻很低，趕緊換成udp單播試了一下，速度能上去，也不怎么花屏了，不清楚是不是確認機制的問題。
但是總不能說把組播換成單播，當接入的接收端變多的時候，不清楚單播效果會不會也變差。

這個時候發現了PGM，“可靠”多播協議，有不少基于PGM實現的庫，打算先用windows上的寫個demo出來。

想要使用PGM需要先在網絡適配器上安裝協議，安裝完成后會在屬性中出現可靠多播協議

然后就是開發了，官網文檔提供的demo很棒，copy下來幾乎就能跑起來。但是除了官網文檔，相關資料就比較少了，頭文件我還找了半天，環境上坑不少，記錄一下

wsrm.h頭文件

首先是windows sdk，我試了一下如果是8.1的sdk的話，是找不到wsrm.h頭文件的，我有裝10.0.17134.0，8.1還有10.0.15063.0三個版本的windows sdk，用everything找了一下這個頭文件，得到了下面圖示結果

8.1應該是沒有，剩下兩個版本均可以使用，更新的版本應該也行。

vs2017以上的話在visual studio installer里面修改多裝個sdk就行了

傳輸速度

PGM本身也有發送窗口的概念，如果使用默認設置，窗口小，發送速度非常慢，每秒最多只有70KB左右，這時候需要設置socket選項
RateKbitsPerSec的單位是kilobits/s，是一個上限

RM_SEND_WINDOW send_window;send_window.WindowSizeInBytes = 8000 * 1000;send_window.WindowSizeInMSecs = 1;send_window.RateKbitsPerSec = (send_window.WindowSizeInBytes/send_window.WindowSizeInMSecs)*8;int rc = setsockopt(s, IPPROTO_RM, RM_RATE_WINDOW_SIZE, (char *)&send_window, sizeof(send_window));if (rc == SOCKET_ERROR){cout << "setsockopt(): RM_RATE_WINDOW_SIZE failed with error code " << WSAGetLastError() << endl;}

RM_SEND_WINDOW結構體就這么三個成員，第一個是每秒速度了，第二個是發送窗口的大小，第三個是窗口大小毫秒，其中windows會強制讓
RateKbitsPerSec/8 = WindowSizeInBytes * WindowSizeInMSecs

PS：WindowSzieInMSecs的值需要調整，當WindowSizeInBytes=8000并且WindowSzieInMSecs=1時，發送端較大概率會阻塞，原因未知，可能是發包速度過快導致

真的可靠么？

在文章一開始的時候可靠被加上了雙引號，為的是表明這個協議并不是想象中的那么可靠。

發送窗口大小有限，如果需要恢復重傳的數據在發送窗口之外了，那數據就是不可恢復的，一般當發送端速率過快接收端接收速度明顯跟不上時，就會出現不可恢復現象。一旦出現不可恢復數據時，windows就會讓接收端的連接重置，此時就不能繼續接收。

源碼

因為找不到對應的頭文件讓我著實頭疼了很久，相關文檔少，還不告訴我頭文件是什么，這太不爽了，就好比讓你看著門后面有啥，就是不給你鑰匙。

pgm分為server端和client端，功能是發送文件，根據msdn的文檔編寫的

下面是server端代碼

#define _WINSOCK_DEPRECATED_NO_WARNINGS #define WIN32_LEAN_AND_MEAN#include <iostream> #include<winsock2.h> #include<WS2tcpip.h> //ip_mreq? #include <wsrm.h> #include <stdio.h>using namespace std; #pragma comment(lib,"ws2_32.lib")int main() {WSADATA WSAData;WORD sockVersion = MAKEWORD(2, 2);if (WSAStartup(sockVersion, &WSAData) != 0)return 0;FILE *fp;fopen_s(&fp, "test.webm", "rb+");SOCKET s;SOCKADDR_IN salocal, sasession;int dwSessionPort;s = socket(AF_INET, SOCK_RDM, IPPROTO_RM);salocal.sin_family = AF_INET;salocal.sin_port = htons(0); // Port is ignored heresalocal.sin_addr.s_addr = htonl(INADDR_ANY);bind(s, (SOCKADDR *)&salocal, sizeof(salocal));//// Set all relevant sender socket options here////// Now, connect <entity type="hellip"/>// Setting the connection port (dwSessionPort) has relevance, and// can be used to multiplex multiple sessions to the same// multicast group address over different ports//dwSessionPort = 1234;sasession.sin_family = AF_INET;sasession.sin_port = htons(dwSessionPort);sasession.sin_addr.s_addr = inet_addr("224.4.5.6");RM_SEND_WINDOW send_window;send_window.WindowSizeInBytes = 8000;send_window.WindowSizeInMSecs = 1;send_window.RateKbitsPerSec = (send_window.WindowSizeInBytes/send_window.WindowSizeInMSecs)*8;int rc = setsockopt(s, IPPROTO_RM, RM_RATE_WINDOW_SIZE, (char *)&send_window, sizeof(send_window));if (rc == SOCKET_ERROR){cout << "setsockopt(): RM_RATE_WINDOW_SIZE failed with error code " << WSAGetLastError() << endl;}connect(s, (SOCKADDR *)&sasession, sizeof(sasession));//// We're now ready to send data!//char pSendBuffer[1400];sockaddr_in serverAddr;int iAddrlen = sizeof(serverAddr);while (1) {if (feof(fp))break;memset(pSendBuffer, 0, 1400);int data_size = fread(pSendBuffer, 1, 1400, fp);LONG error;error = sendto(s, pSendBuffer, data_size, 0, (sockaddr*)&serverAddr,iAddrlen);if (error == SOCKET_ERROR){fprintf(stderr, "send() failed: Error = %d\n",WSAGetLastError());}}WSACleanup();return 0; }

下面是client端代碼

#include <iostream> #include<winsock2.h> #include<WS2tcpip.h> //ip_mreq? #include <wsrm.h> #include <stdio.h>using namespace std; #pragma comment(lib,"ws2_32.lib")int main() {WSADATA WSAData;WORD sockVersion = MAKEWORD(2, 2);if (WSAStartup(sockVersion, &WSAData) != 0)return 0;SOCKET s,sclient;SOCKADDR_IN salocal,sasession;int sasessionsz, dwSessionPort;FILE * fp;fopen_s(&fp, "aaatest.webm", "wb+");s = socket(AF_INET, SOCK_RDM, IPPROTO_RM);//// The bind port (dwSessionPort) specified should match that// which the sender specified in the connect call//dwSessionPort = 1234;salocal.sin_family = AF_INET;salocal.sin_port = htons(dwSessionPort);salocal.sin_addr.s_addr = inet_addr("224.4.5.6");int receive_buf_size = 65536 * 10;if (setsockopt(s, SOL_SOCKET, SO_RCVBUF, (char*)&receive_buf_size, sizeof(receive_buf_size)) < 0){std::cout << "setsockopt():SO_RCVBUF failed with error code" << WSAGetLastError() << std::endl;}bind(s, (SOCKADDR *)&salocal, sizeof(salocal));//// Set all relevant receiver socket options here//listen(s, 10);sasessionsz = sizeof(sasession);sclient = accept(s, (SOCKADDR *)&sasession, &sasessionsz);if (setsockopt(sclient, SOL_SOCKET, SO_RCVBUF, (char*)&receive_buf_size, sizeof(receive_buf_size)) < 0){std::cout << "setsockopt():SO_RCVBUF failed with error code" << WSAGetLastError() << std::endl;}//// accept will return the client socket and we are now ready// to receive data on the new socket!//LONG BytesRead;char pTestBuffer[1400];sockaddr_in clientAddr;int iAddrlen = sizeof(clientAddr);while (1){memset(pTestBuffer, 0, 1400);cout << "start" << endl;BytesRead = recvfrom(sclient, pTestBuffer, 1400, 0, (sockaddr*)&clientAddr, &iAddrlen);cout << "end" << endl;if (BytesRead == 0){fprintf(stdout, "Session was terminated\n");}else if (BytesRead == -1){std::cout << "no data?!" << std::endl;}if (BytesRead > 0){fwrite(pTestBuffer, 1, BytesRead, fp);std::cout << BytesRead << std::endl;}}fclose(fp);WSACleanup();return 0; }

轉載于:https://www.cnblogs.com/lenomirei/p/11324394.html

總結

以上是生活随笔為你收集整理的Reliable Multicast Programming（PGM）协议的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。