![\"menu-r.4af5f7ec.gif\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418203137-6802b6a98ca0e.gif\")
<\/p>\n \u672c\u6587\u8fd8\u6709\u914d\u5957\u7684\u7cbe\u54c1\u8d44\u6e90，\u70b9\u51fb\u83b7\u53d6 <\/p>\n
\u7b80\u4ecb：RTP\u534f\u8bae\u662f\u7f51\u7edc\u901a\u4fe1\u4e2d\u7528\u4e8e\u5b9e\u65f6\u4f20\u8f93\u591a\u5a92\u4f53\u6570\u636e\u7684\u5173\u952e\u534f\u8bae，\u5e38\u4e0eRTCP\u5e76\u7528\u4ee5\u76d1\u63a7\u670d\u52a1\u8d28\u91cf\u3002\u672c\u5b9e\u73b0\u7a0b\u5e8f\u5c55\u793a\u4e86\u5982\u4f55\u540c\u65f6\u4f5c\u4e3a\u670d\u52a1\u5668\u548c\u5ba2\u6237\u7aef\u8fd0\u884cRTP\u4f1a\u8bdd，\u6db5\u76d6\u4ece\u6570\u636e\u5305\u751f\u6210\u3001\u53d1\u9001\u3001\u63a5\u6536\u5230\u540c\u6b65\u7684\u5b8c\u6574\u6d41\u7a0b\u3002\u5f00\u53d1\u8005\u901a\u8fc7\u638c\u63e1\u7f51\u7edc\u7f16\u7a0b\u548c\u591a\u7ebf\u7a0b\u6280\u672f，\u80fd\u591f\u6784\u5efa\u51fa\u652f\u6301\u53cc\u5411\u901a\u4fe1\u7684RTP\u7cfb\u7edf，\u5e76\u5904\u7406\u5982\u5ef6\u8fdf\u3001\u6296\u52a8\u7b49\u5b9e\u65f6\u6027\u95ee\u9898\u3002 ![\"RTP\u534f\u8bae\u5b9e\u73b0\u7a0b\u5e8f（\u53ef\u4ee5\u540c\u65f6\u8fd0\u884c\u670d\u52a1\u5668\u548c\u5ba2\u6237\u7aef）\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418203137-6802b6a99fc6b.png\")
<\/p>\n
RTP（Real-time Transport Protocol，\u5b9e\u65f6\u4f20\u8f93\u534f\u8bae）\u662f\u4e3a\u97f3\u9891\u548c\u89c6\u9891\u6570\u636e\u4f20\u8f93\u800c\u8bbe\u8ba1\u7684\u7f51\u7edc\u534f\u8bae，\u5b83\u4e3a\u5e94\u7528\u7a0b\u5e8f\u63d0\u4f9b\u7aef\u5230\u7aef\u7684\u4f20\u8f93\u529f\u80fd，\u652f\u6301\u70b9\u5bf9\u70b9\u6216\u591a\u64ad\u7684\u5206\u53d1\u3002RTP\u672c\u8eab\u4e0d\u63d0\u4f9b\u6570\u636e\u5305\u7684\u53ef\u9760\u6027\u4fdd\u969c，\u800c\u662f\u4f9d\u8d56\u4e8e\u5e95\u5c42\u4f20\u8f93\u534f\u8bae\u6765\u5b9e\u73b0\u53ef\u9760\u4f20\u8f93，\u5982\u4f7f\u7528UDP\u534f\u8bae\u6765\u5b9e\u73b0\u4f20\u8f93\u5c42\u7684\u57fa\u672c\u670d\u52a1\u3002 <\/p>\n
\u5728\u672c\u7ae0\u4e2d，\u6211\u4eec\u5c06\u9996\u5148\u4ecb\u7ecdRTP\u534f\u8bae\u7684\u57fa\u672c\u7ed3\u6784\u548c\u529f\u80fd，\u4e3a\u540e\u7eed\u7ae0\u8282\u4e2d\u670d\u52a1\u5668\u7aefRTP\u6570\u636e\u5305\u7684\u751f\u6210\u3001\u53d1\u9001\u4ee5\u53ca\u5ba2\u6237\u7aef\u6570\u636e\u63a5\u6536\u548c\u89e3\u5c01\u88c5\u7b49\u5185\u5bb9\u6253\u4e0b\u57fa\u7840\u3002 <\/p>\n
\u63a5\u4e0b\u6765，\u6211\u4eec\u5c06\u6df1\u5165\u63a2\u8ba8RTP\u534f\u8bae\u7684\u8fd9\u4e9b\u7ec4\u6210\u90e8\u5206，\u5e76\u63a2\u8ba8\u5b83\u4eec\u5982\u4f55\u534f\u540c\u5de5\u4f5c\u4ee5\u63d0\u4f9b\u5b9e\u65f6\u5a92\u4f53\u6d41\u670d\u52a1\u3002 <\/p>\n
\u5728\u5b9e\u65f6\u4f20\u8f93\u534f\u8bae（RTP）\u7684\u670d\u52a1\u5668\u7aef\u5b9e\u73b0\u4e2d，\u5305\u7684\u751f\u6210\u548c\u53d1\u9001\u662f\u4fdd\u8bc1\u6570\u636e\u5b9e\u65f6\u6027\u4e0e\u5b8c\u6574\u6027\u7684\u5173\u952e\u6b65\u9aa4\u3002\u672c\u7ae0\u8282\u5c06\u6df1\u5165\u63a2\u8ba8RTP\u5305\u7684\u5c01\u88c5\u4e0e\u683c\u5f0f\u3001\u6570\u636e\u53d1\u9001\u673a\u5236，\u4ee5\u53ca\u670d\u52a1\u5668\u7aef\u6027\u80fd\u4f18\u5316\u7684\u76f8\u5173\u5185\u5bb9\u3002 <\/p>\n
RTP\u5934\u90e8\u5305\u542b\u4e86\u591a\u4e2a\u5173\u952e\u5b57\u6bb5，\u8fd9\u4e9b\u5b57\u6bb5\u7528\u4e8e\u786e\u4fddRTP\u5305\u80fd\u591f\u6b63\u786e\u5730\u5728\u7f51\u7edc\u4e2d\u4f20\u8f93，\u5e76\u5141\u8bb8\u63a5\u6536\u7aef\u5bf9\u6570\u636e\u6d41\u8fdb\u884c\u540c\u6b65\u3001\u6392\u5e8f\u548c\u6062\u590d\u3002RTP\u5934\u90e8\u4e3b\u8981\u5b57\u6bb5\u5305\u62ec： <\/p>\n
\u4ee3\u7801\u5757\u4e2d\u5c06\u5c55\u793aRTP\u5305\u5934\u90e8\u7684\u57fa\u672c\u7ed3\u6784，\u4ee5\u53ca\u5173\u952e\u5b57\u6bb5\u7684\u793a\u4f8b\u503c\u3002 <\/p>\n
\/\/ RTP\u5934\u90e8\u7ed3\u6784\u793a\u4f8b
\nstruct RTPHeader {
\n uint8_t version; \/\/ \u7248\u672c\u53f7，\u901a\u5e38\u4e3a2
\n uint8_t padding; \/\/ \u586b\u5145\u6807\u8bb0
\n uint8_t extension; \/\/ \u5934\u90e8\u6269\u5c55\u6807\u8bb0
\n uint8_t csrc_count; \/\/ CSRC\u8ba1\u6570
\n uint8_t marker:1; \/\/ \u6807\u8bb0\u4f4d
\n uint8_t payload_type:7; \/\/ \u8d1f\u8f7d\u7c7b\u578b
\n uint16_t sequence_number; \/\/ \u5e8f\u5217\u53f7
\n uint32_t timestamp; \/\/ \u65f6\u95f4\u6233
\n uint32_t ssrc; \/\/ \u540c\u6b65\u6e90\u6807\u8bc6\u7b26
\n \/\/ … \u5176\u4ed6\u53ef\u80fd\u7684CSRC\u6807\u8bc6\u7b26
\n};<\/p>\n
\u5728\u4e0a\u8ff0\u4ee3\u7801\u5757\u4e2d，\u6bcf\u4e2a\u5b57\u6bb5\u90fd\u5bf9\u5e94RTP\u5934\u90e8\u7684\u4e8c\u8fdb\u5236\u4f4d，\u5176\u4e2d marker \u548c payload_type \u5b57\u6bb5\u90fd\u662f\u4f7f\u7528\u4e00\u4e2a\u5b57\u8282\u5185\u7684\u4f4d\u6765\u8868\u793a\u7684，\u5206\u522b\u8868\u793a\u8d1f\u8f7d\u6570\u636e\u7684\u91cd\u8981\u6027\u4ee5\u53ca\u8d1f\u8f7d\u6570\u636e\u7684\u7c7b\u578b\u3002 <\/p>\n
\u8d1f\u8f7d\u6570\u636e\u901a\u5e38\u7531\u5e94\u7528\u5c42\u4ea7\u751f，\u5e76\u901a\u8fc7RTP\u534f\u8bae\u8fdb\u884c\u5c01\u88c5\u4f20\u8f93\u3002\u8d1f\u8f7d\u6570\u636e\u7684\u7c7b\u578b\u901a\u8fc7RTP\u5934\u90e8\u7684\u8d1f\u8f7d\u7c7b\u578b\u5b57\u6bb5\u6765\u6807\u8bc6\u3002\u5728\u5c01\u88c5\u8d1f\u8f7d\u6570\u636e\u65f6，\u9700\u8981\u8003\u8651\u6570\u636e\u7684\u5e8f\u5217\u5316\u548c\u6253\u5305\u65b9\u6cd5，\u4ee5\u786e\u4fdd\u63a5\u6536\u7aef\u80fd\u591f\u6b63\u786e\u89e3\u6790\u3002 <\/p>\n
\/\/ RTP\u8d1f\u8f7d\u6570\u636e\u5c01\u88c5\u793a\u4f8b
\nvoid\u5c01\u88c5RTP\u8d1f\u8f7d(struct RTPHeader *header, uint8_t *payload, size_t payload_size) {
\n \/\/ \u5c06\u8d1f\u8f7d\u6570\u636e\u76f4\u63a5\u9644\u52a0\u5230RTP\u5934\u90e8\u540e\u9762
\n memcpy(header + 1, payload, payload_size);
\n \/\/ \u8bbe\u7f6e\u8d1f\u8f7d\u7684\u957f\u5ea6
\n size_t packet_size = sizeof(*header) + payload_size;
\n \/\/ … \u5176\u4ed6\u8bbe\u7f6e，\u5982\u5e8f\u5217\u53f7\u3001\u65f6\u95f4\u6233\u9012\u589e\u7b49
\n}<\/p>\n
\u5728\u6b64\u4ee3\u7801\u5757\u4e2d，\u8d1f\u8f7d\u6570\u636e payload \u88ab\u76f4\u63a5\u9644\u52a0\u5230RTP\u5934\u90e8 header \u7684\u540e\u9762\u3002\u5728\u5b9e\u9645\u5e94\u7528\u4e2d，\u8fd8\u9700\u8981\u8bbe\u7f6e\u8d1f\u8f7d\u957f\u5ea6\u3001\u5e8f\u5217\u53f7\u9012\u589e\u7b49\u6b65\u9aa4\u3002 <\/p>\n
\u5728RTP\u4f1a\u8bdd\u7684\u5efa\u7acb\u9636\u6bb5，\u901a\u5e38\u9700\u8981\u8fdb\u884c\u4e00\u7cfb\u5217\u7684\u914d\u7f6e，\u5305\u62ec\u4f1a\u8bdd\u53c2\u6570\u7684\u534f\u5546，\u5982\u8d1f\u8f7d\u7c7b\u578b\u3001\u7f16\u7801\u683c\u5f0f\u3001\u65f6\u95f4\u6233\u9891\u7387\u7b49\u3002\u670d\u52a1\u5668\u7aef\u9700\u8981\u6839\u636e\u5e94\u7528\u7684\u9700\u6c42\u6765\u914d\u7f6e\u8fd9\u4e9b\u53c2\u6570\u3002 <\/p>\n
\u5728RTP\u6570\u636e\u53d1\u9001\u8fc7\u7a0b\u4e2d，\u670d\u52a1\u5668\u7aef\u9700\u8981\u6839\u636eRTP\u5305\u7684\u6784\u9020\u89c4\u5219\u548c\u7f51\u7edc\u72b6\u51b5\u6765\u53d1\u9001\u6570\u636e\u5305\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u7b80\u5316\u7684\u6570\u636e\u53d1\u9001\u6d41\u7a0b\u7684\u4ee3\u7801\u793a\u4f8b，\u4ee5\u53ca\u5173\u952e\u4ee3\u7801\u5757\u7684\u903b\u8f91\u5206\u6790\u3002 <\/p>\n
\/\/ RTP\u6570\u636e\u53d1\u9001\u6d41\u7a0b\u793a\u4f8b
\nvoid \u53d1\u9001RTP\u6570\u636e(uint32_t ssrc, uint8_t payload_type, uint8_t *payload, size_t payload_size) {
\n static uint16_t sequence_number = 0;
\n static uint32_t timestamp = 0;<\/p>\n
struct RTPHeader header;
\n header.version = 2;
\n header.padding = 0;
\n header.extension = 0;
\n header.csrc_count = 0;
\n header.marker = 0;
\n header.payload_type = payload_type;
\n header.sequence_number = htons(sequence_number++);
\n header.timestamp = htonl(timestamp);
\n header.ssrc = htonl(ssrc);<\/p>\n
\/\/ \u5c01\u88c5\u8d1f\u8f7d\u6570\u636e
\n \u5c01\u88c5RTP\u8d1f\u8f7d(&header, payload, payload_size);<\/p>\n
\/\/ \u53d1\u9001RTP\u5305\u5230\u7f51\u7edc
\n sendto(socket, (uint8_t *)&header, sizeof(header) + payload_size, 0, (struct sockaddr *)&dest_addr, sizeof(dest_addr));<\/p>\n
\/\/ \u66f4\u65b0\u65f6\u95f4\u6233（\u4f8b\u5982，\u97f3\u9891\u6bcf20ms\u4e00\u4e2a\u5305，\u89c6\u9891\u6bcf33ms\u4e00\u4e2a\u5305）
\n timestamp += 330; \/\/ \u5047\u8bbe\u4ee5330\u4e3a\u65f6\u95f4\u6233\u5355\u4f4d
\n}<\/p>\n
\u5728\u4ee3\u7801\u5757\u4e2d，\u9996\u5148\u8bbe\u7f6eRTP\u5934\u90e8\u7684\u5404\u4e2a\u5b57\u6bb5，\u5176\u4e2d htons \u548c htonl \u662f\u7528\u4e8e\u7aef\u5230\u7aef\u4f20\u8f93\u7684\u4e3b\u673a\u5b57\u8282\u5e8f\u4e0e\u7f51\u7edc\u5b57\u8282\u5e8f\u4e4b\u95f4\u7684\u8f6c\u6362\u51fd\u6570\u3002\u7136\u540e，\u901a\u8fc7 sendto \u7cfb\u7edf\u8c03\u7528\u5c06RTP\u5305\u53d1\u9001\u5230\u6307\u5b9a\u7684\u76ee\u7684\u5730\u3002 <\/p>\n
\u4e3a\u4e86\u786e\u4fdd\u6570\u636e\u6d41\u7684\u5e73\u6ed1\u4f20\u8f93，\u670d\u52a1\u5668\u7aef\u9700\u8981\u8fdb\u884c\u9002\u5f53\u7684\u7f13\u51b2\u533a\u7ba1\u7406，\u4ee5\u53ca\u540c\u6b65\u673a\u5236\u7684\u8bbe\u8ba1\u3002\u5728RTP\u5c42\u9762\u4e0a，\u63a5\u6536\u7aef\u5229\u7528\u65f6\u95f4\u6233\u6765\u540c\u6b65\u548c\u6392\u5e8f\u5230\u8fbe\u7684\u6570\u636e\u5305\u3002 <\/p>\n
\u5f02\u5e38\u5904\u7406\u662f\u786e\u4fddRTP\u670d\u52a1\u5668\u7a33\u5b9a\u8fd0\u884c\u7684\u5173\u952e\u3002\u670d\u52a1\u5668\u7aef\u5fc5\u987b\u80fd\u591f\u5904\u7406\u7f51\u7edc\u5f02\u5e38\u3001\u8d44\u6e90\u77ed\u7f3a\u7b49\u95ee\u9898，\u5e76\u8fdb\u884c\u8be6\u7ec6\u65e5\u5fd7\u8bb0\u5f55\u4ee5\u4fbf\u540e\u7eed\u5206\u6790\u3002 <\/p>\n
\/\/ \u5f02\u5e38\u5904\u7406\u4e0e\u65e5\u5fd7\u8bb0\u5f55\u793a\u4f8b
\nvoid \u5904\u7406\u53d1\u9001\u5f02\u5e38(int error_code) {
\n \/\/ \u6839\u636e\u9519\u8bef\u7801\u8fdb\u884c\u5f02\u5e38\u5904\u7406
\n switch (error_code) {
\n case EAGAIN:
\n \/\/ \u975e\u963b\u585e\u6a21\u5f0f\u4e0b，\u9700\u8981\u91cd\u65b0\u5c1d\u8bd5\u53d1\u9001
\n break;
\n \/\/ … \u5176\u4ed6\u9519\u8bef\u7801\u7684\u5904\u7406\u903b\u8f91
\n default:
\n \/\/ \u8bb0\u5f55\u9519\u8bef\u4fe1\u606f\u5230\u65e5\u5fd7\u6587\u4ef6
\n \u65e5\u5fd7\u8bb0\u5f55("\u53d1\u9001RTP\u6570\u636e\u5305\u65f6\u51fa\u73b0\u9519\u8bef：%d", error_code);
\n break;
\n }
\n}<\/p>\n
\u5728\u4ee3\u7801\u5757\u4e2d，\u6839\u636e\u4e0d\u540c\u7684\u9519\u8bef\u7801\u6267\u884c\u4e0d\u540c\u7684\u5f02\u5e38\u5904\u7406\u7b56\u7565，\u5e76\u8bb0\u5f55\u9519\u8bef\u4fe1\u606f\u5230\u65e5\u5fd7\u4e2d，\u4ee5\u4fbf\u8ddf\u8e2a\u548c\u8c03\u8bd5\u3002 <\/p>\n
\u5b9e\u65f6\u4f20\u8f93\u534f\u8bae（RTP）\u5728\u5ba2\u6237\u7aef\u7684\u5b9e\u73b0\u662f\u786e\u4fdd\u97f3\u89c6\u9891\u6570\u636e\u53ca\u65f6\u51c6\u786e\u5730\u5448\u73b0\u7ed9\u7528\u6237\u7684\u5173\u952e\u3002\u672c\u7ae0\u8282\u6df1\u5165\u63a2\u8ba8\u4e86\u5ba2\u6237\u7aef\u5982\u4f55\u63a5\u6536RTP\u6570\u636e\u5305，\u4ee5\u53ca\u5982\u4f55\u901a\u8fc7\u89e3\u5c01\u88c5\u8fc7\u7a0b\u8fd8\u539f\u51fa\u539f\u59cb\u7684\u5a92\u4f53\u6d41\u3002 <\/p>\n
\u5728\u672c\u5c0f\u8282\u4e2d，\u6211\u4eec\u5c06\u63a2\u8ba8\u5982\u4f55\u5728\u5ba2\u6237\u7aef\u8bbe\u7f6e\u5957\u63a5\u5b57\u4ee5\u63a5\u6536\u6765\u81ea\u670d\u52a1\u5668\u7684\u6570\u636e，\u5e76\u7ba1\u7406\u63a5\u6536\u7f13\u51b2\u533a\u4ee5\u4fdd\u8bc1\u6570\u636e\u6d41\u7684\u7a33\u5b9a\u6027\u548c\u5b9e\u65f6\u6027\u3002 <\/p>\n
\u5728\u5ba2\u6237\u7aef，\u9996\u5148\u9700\u8981\u521b\u5efa\u4e00\u4e2a\u5957\u63a5\u5b57\u5e76\u7ed1\u5b9a\u5230\u671f\u671b\u63a5\u6536\u6570\u636e\u7684\u7aef\u53e3\u4e0a\u3002\u8fd9\u901a\u5e38\u662f\u901a\u8fc7\u7f51\u7edc\u7f16\u7a0b\u63a5\u53e3\u8fdb\u884c\u7684\u3002 <\/p>\n
#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h>
\n#include <unistd.h><\/p>\n
\/\/ \u521b\u5efa\u4e00\u4e2aUDP\u5957\u63a5\u5b57
\nint sockfd = socket(AF_INET, SOCK_DGRAM, 0);<\/p>\n
\/\/ \u5b9a\u4e49\u670d\u52a1\u5668\u5730\u5740\u7ed3\u6784\u4f53
\nstruct sockaddr_in server_addr;
\nmemset(&server_addr, 0, sizeof(server_addr));
\nserver_addr.sin_family = AF_INET; \/\/ \u4f7f\u7528IPv4
\nserver_addr.sin_port = htons(8000); \/\/ \u670d\u52a1\u5668\u7aef\u53e3\u53f7
\nserver_addr.sin_addr.s_addr = inet_addr("***.***.*.***"); \/\/ \u670d\u52a1\u5668IP\u5730\u5740<\/p>\n
\/\/ \u7ed1\u5b9a\u5957\u63a5\u5b57\u5230\u6307\u5b9a\u7aef\u53e3
\nbind(sockfd, (const struct sockaddr *)&server_addr, sizeof(server_addr));<\/p>\n
\u5728\u4e0a\u8ff0\u4ee3\u7801\u4e2d， socket \u51fd\u6570\u7528\u4e8e\u521b\u5efa\u4e00\u4e2a\u65b0\u7684UDP\u5957\u63a5\u5b57，\u800c bind \u51fd\u6570\u5219\u5c06\u5957\u63a5\u5b57\u7ed1\u5b9a\u5230\u6307\u5b9a\u7684IP\u5730\u5740\u548c\u7aef\u53e3\u3002UDP\u534f\u8bae\u56e0\u4e3a\u5176\u65e0\u8fde\u63a5\u7684\u7279\u6027，\u4e0d\u9700\u8981\u50cfTCP\u4e00\u6837\u8fdb\u884c\u8fde\u63a5\u5efa\u7acb\u3002 <\/p>\n
\u4e00\u65e6\u5957\u63a5\u5b57\u51c6\u5907\u5c31\u7eea，\u5ba2\u6237\u7aef\u9700\u8981\u5b9e\u73b0\u4e00\u4e2a\u5faa\u73af\u6765\u6301\u7eed\u76d1\u542c\u5e76\u63a5\u6536\u6765\u81ea\u670d\u52a1\u5668\u7684\u6570\u636e\u5305\u3002 <\/p>\n
#define BUFFER_SIZE 65535<\/p>\n
\/\/ \u63a5\u6536\u7f13\u51b2\u533a
\nchar buffer[BUFFER_SIZE];
\nstruct sockaddr_in client_addr;
\nsocklen_t client_addr_len = sizeof(client_addr);<\/p>\n
\/\/ \u5faa\u73af\u63a5\u6536\u6570\u636e
\nwhile (1) {
\n int len = recvfrom(sockfd, buffer, BUFFER_SIZE, 0, (struct sockaddr*)&client_addr, &client_addr_len);
\n if (len < 0) {
\n perror("recvfrom error");
\n continue;
\n }<\/p>\n
\/\/ \u5904\u7406\u63a5\u6536\u5230\u7684\u6570\u636e\u5305
\n process_received_data(buffer, len);
\n}<\/p>\n
\u5728\u63a5\u6536\u6570\u636e\u65f6，\u6211\u4eec\u4f7f\u7528 recvfrom \u51fd\u6570，\u5b83\u662f\u4e00\u4e2a\u963b\u585e\u8c03\u7528，\u76f4\u5230\u6709\u6570\u636e\u5230\u8fbe\u624d\u4f1a\u7ee7\u7eed\u6267\u884c\u3002 process_received_data \u51fd\u6570\u8d1f\u8d23\u5904\u7406\u63a5\u6536\u5230\u7684\u6570\u636e\u5305\u3002 <\/p>\n
RTP\u6570\u636e\u5305\u4e00\u65e6\u88ab\u63a5\u6536，\u5ba2\u6237\u7aef\u9700\u8981\u5bf9\u6570\u636e\u5305\u8fdb\u884c\u89e3\u6790，\u4ee5\u83b7\u53d6\u5176\u4e2d\u7684\u5934\u90e8\u4fe1\u606f\u548c\u5a92\u4f53\u8d1f\u8f7d\u3002 <\/p>\n
RTP\u5934\u90e8\u5305\u542b\u4e86\u591a\u4e2a\u5b57\u6bb5，\u5982\u5e8f\u5217\u53f7\u3001\u65f6\u95f4\u6233\u3001\u8d1f\u8f7d\u7c7b\u578b\u7b49，\u5ba2\u6237\u7aef\u9700\u8981\u6309\u7167RTP\u89c4\u8303\u89e3\u6790\u8fd9\u4e9b\u4fe1\u606f\u3002 <\/p>\n
\/\/ RTP\u5934\u90e8\u7ed3\u6784\u5b9a\u4e49
\ntypedef struct {
\n unsigned short version:2;
\n unsigned short padding:1;
\n unsigned short extension:1;
\n unsigned short csrc_count:4;
\n unsigned short marker:1;
\n unsigned short payload_type:7;
\n unsigned short sequence_number:16;
\n unsigned int timestamp;
\n unsigned int ssrc;
\n \/\/ … \u6269\u5c55\u5934\u90e8\u5b57\u6bb5
\n} RTPHeader;<\/p>\n
\/\/ \u89e3\u6790RTP\u5934\u90e8
\nRTPHeader header;
\nmemcpy(&header, buffer, sizeof(RTPHeader));<\/p>\n
\u5728\u6210\u529f\u89e3\u6790\u5934\u90e8\u4fe1\u606f\u540e，\u5ba2\u6237\u7aef\u9700\u8981\u6839\u636e\u5934\u90e8\u4fe1\u606f\u4e2d\u7684\u8d1f\u8f7d\u7c7b\u578b\u548c\u957f\u5ea6\u5b57\u6bb5，\u4ece\u7f13\u51b2\u533a\u63d0\u53d6\u51fa\u5b9e\u9645\u7684\u6570\u636e\u8d1f\u8f7d\u3002 <\/p>\n
\/\/ \u8ba1\u7b97\u6570\u636e\u8d1f\u8f7d\u7684\u8d77\u59cb\u4f4d\u7f6e\u548c\u957f\u5ea6
\nsize_t payload_start = sizeof(RTPHeader);
\nsize_t payload_length = len – payload_start;<\/p>\n
\/\/ \u4ece\u7f13\u51b2\u533a\u4e2d\u63d0\u53d6\u8d1f\u8f7d\u6570\u636e
\nchar *payload = buffer + payload_start;
\nprocess_payload(payload, payload_length);<\/p>\n
\u5728\u8fd9\u6bb5\u4ee3\u7801\u4e2d， process_payload \u51fd\u6570\u7528\u4e8e\u5904\u7406\u63d0\u53d6\u51fa\u6765\u7684\u8d1f\u8f7d\u6570\u636e\u3002\u9700\u8981\u6ce8\u610f\u7684\u662f，\u6839\u636e\u4e0d\u540c\u7684\u8d1f\u8f7d\u7c7b\u578b（\u5982\u97f3\u89c6\u9891\u6570\u636e），\u53ef\u80fd\u9700\u8981\u4e0d\u540c\u7684\u5904\u7406\u65b9\u5f0f\u3002 <\/p>\n
\u5728\u63d0\u53d6\u4e86\u6570\u636e\u8d1f\u8f7d\u540e，\u5ba2\u6237\u7aef\u8fd8\u9700\u8981\u5b9e\u73b0\u4e00\u7cfb\u5217\u7684\u5904\u7406\u903b\u8f91，\u4ee5\u786e\u4fdd\u6570\u636e\u80fd\u591f\u5b9e\u65f6\u64ad\u653e\u5e76\u4fdd\u8bc1\u7528\u6237\u4f53\u9a8c\u3002 <\/p>\n
\u4e3a\u4e86\u786e\u4fdd\u5a92\u4f53\u6570\u636e\u80fd\u591f\u7a33\u5b9a\u64ad\u653e，\u5ba2\u6237\u7aef\u901a\u5e38\u9700\u8981\u5b9e\u73b0\u4e00\u4e2a\u7f13\u5b58\u673a\u5236\u6765\u5bf9\u6570\u636e\u5305\u8fdb\u884c\u7f13\u51b2\u3002 <\/p>\n
#define CACHE_SIZE 1024 \/\/ \u7f13\u5b58\u5927\u5c0f，\u5355\u4f4d\u4e3a\u6570\u636e\u5305\u6570\u91cf<\/p>\n
\/\/ \u7f13\u5b58\u961f\u5217\u7684\u5b9a\u4e49
\nstruct RTPPacketQueue {
\n RTPHeader packets[CACHE_SIZE];
\n int count;
\n};<\/p>\n
RTPPacketQueue cache;<\/p>\n
\/\/ \u63a5\u6536\u5e76\u7f13\u5b58\u6570\u636e\u5305
\nvoid receive_and_cache_data() {
\n \/\/ \u4ece3.1.2\u8282\u63a5\u6536\u6570\u636e
\n \/\/ …
\n if (cache.count < CACHE_SIZE) {
\n cache.packets[cache.count++] = header;
\n play_audio(); \/\/ \u5f53\u7f13\u5b58\u4e2d\u6709\u8db3\u591f\u7684\u6570\u636e\u5305\u65f6，\u5f00\u59cb\u64ad\u653e
\n }
\n}<\/p>\n
\/\/ \u64ad\u653e\u97f3\u9891
\nvoid play_audio() {
\n \/\/ \u6839\u636e\u7f13\u5b58\u4e2d\u7684\u6570\u636e\u5305\u987a\u5e8f\u64ad\u653e\u97f3\u9891
\n \/\/ …
\n}<\/p>\n
\u5ba2\u6237\u7aef\u8fd8\u53ef\u4ee5\u5b9e\u73b0\u4e00\u7cfb\u5217\u7684\u8d28\u91cf\u8bc4\u4f30\u673a\u5236，\u5982\u4e22\u5305\u7387\u68c0\u6d4b\u548c\u5e26\u5bbd\u9002\u5e94\u6027\u5904\u7406，\u4ee5\u4f18\u5316\u63a5\u6536\u7aef\u7684\u6027\u80fd\u3002 <\/p>\n
\/\/ \u7edf\u8ba1\u4e22\u5305\u4fe1\u606f
\nunsigned short last_seq_num = 0;
\nvoid evaluate_quality() {
\n unsigned short current_seq_num = header.sequence_number;
\n if (current_seq_num < last_seq_num) {
\n \/\/ \u4e22\u5305\u5904\u7406
\n handle_packet_loss(current_seq_num);
\n }
\n last_seq_num = current_seq_num;
\n}<\/p>\n
\/\/ \u4e22\u5305\u5904\u7406\u51fd\u6570
\nvoid handle_packet_loss(unsigned short seq_num) {
\n \/\/ \u5b9e\u73b0\u4e22\u5305\u5904\u7406\u903b\u8f91，\u4f8b\u5982\u8bf7\u6c42\u91cd\u4f20\u3001\u63d2\u503c\u7b49
\n}<\/p>\n
\u901a\u8fc7\u8fd9\u79cd\u65b9\u5f0f，\u5ba2\u6237\u7aef\u53ef\u4ee5\u5bf9\u5b9e\u65f6\u4f20\u8f93\u7684\u6570\u636e\u8fdb\u884c\u6709\u6548\u7684\u7ba1\u7406\u548c\u4f18\u5316，\u4ece\u800c\u786e\u4fdd\u9ad8\u8d28\u91cf\u7684\u901a\u4fe1\u4f53\u9a8c\u3002 <\/p>\n
\u5b9e\u65f6\u4f20\u8f93\u63a7\u5236\u534f\u8bae（RTCP）\u4f5c\u4e3aRTP\u534f\u8bae\u7684\u8865\u5145，\u63d0\u4f9b\u4e86\u76d1\u63a7\u670d\u52a1\u8d28\u91cf（QoS）\u548c\u4f20\u8f93\u7edf\u8ba1\u4fe1\u606f\u7684\u529f\u80fd\u3002RTCP\u901a\u8fc7\u5468\u671f\u6027\u5730\u53d1\u9001\u76d1\u63a7\u62a5\u6587\u6765\u5e2e\u52a9\u53c2\u4e0e\u8005\u8bc4\u4f30\u670d\u52a1\u8d28\u91cf，\u5e76\u51cf\u5c11\u4f20\u8f93\u4e2d\u53ef\u80fd\u51fa\u73b0\u7684\u62e5\u585e\u3002\u8fd9\u4e00\u7ae0\u8282\u5c06\u8be6\u7ec6\u4ecb\u7ecdRTCP\u534f\u8bae\u7684\u7ec4\u6210\u3001\u5de5\u4f5c\u539f\u7406\u3001\u4ee5\u53ca\u5982\u4f55\u5229\u7528RTCP\u8fdb\u884cQoS\u7684\u76d1\u63a7\u4e0e\u8c03\u6574\u3002 <\/p>\n
RTCP\u662f\u5b9e\u65f6\u4f20\u8f93\u63a7\u5236\u534f\u8bae\u7684\u7f29\u5199，\u5176\u4e3b\u8981\u76ee\u7684\u662f\u63d0\u4f9b\u5173\u4e8e\u6570\u636e\u4f20\u8f93\u8d28\u91cf\u7684\u53cd\u9988\u4fe1\u606f\u3002RTCP\u4e0eRTP\u5171\u540c\u5de5\u4f5c，\u4f46\u4e0d\u76f4\u63a5\u53c2\u4e0e\u6570\u636e\u7684\u627f\u8f7d\u3002RTCP\u62a5\u6587\u901a\u5e38\u5728\u4f20\u8f93RTP\u6570\u636e\u6d41\u4e4b\u5916\u7684\u7b2c\u4e8c\u4e2a\u534f\u8bae\u7aef\u53e3\u4e0a\u53d1\u9001\u3002 <\/p>\n
RTCP\u62a5\u6587\u4e3b\u8981\u6709\u4ee5\u4e0b\u51e0\u79cd\u7c7b\u578b，\u5404\u81ea\u627f\u62c5\u7740\u4e0d\u540c\u7684\u529f\u80fd： <\/p>\n
RTCP\u4e0eRTP\u534f\u540c\u5de5\u4f5c，\u4e3a\u5b9e\u65f6\u591a\u5a92\u4f53\u4f1a\u8bdd\u63d0\u4f9b\u8d28\u91cf\u76d1\u63a7\u4e0e\u53cd\u9988\u3002\u6bcf\u5f53RTP\u6570\u636e\u5305\u88ab\u53d1\u9001\u6216\u63a5\u6536\u65f6，\u76f8\u5173\u7684RTCP\u62a5\u6587\u4e5f\u4f1a\u88ab\u751f\u6210\u3002\u8fd9\u4e9b\u62a5\u6587\u8bb0\u5f55\u548c\u4f20\u8fbe\u4f20\u8f93\u6027\u80fd\u7684\u5173\u952e\u4fe1\u606f，\u5982\u5305\u4e22\u5931\u7387\u3001\u6296\u52a8\u548c\u5ef6\u8fdf\u7b49\u3002\u53c2\u4e0e\u8005\u901a\u8fc7\u5206\u6790\u8fd9\u4e9b\u4fe1\u606f，\u53ef\u4ee5\u4e86\u89e3\u7f51\u7edc\u72b6\u51b5，\u5e76\u4f5c\u51fa\u8c03\u6574\u6765\u4f18\u5316\u4f20\u8f93\u3002\u4f8b\u5982，\u5982\u679c\u4e22\u5305\u7387\u8fc7\u9ad8，\u53d1\u9001\u7aef\u53ef\u80fd\u9700\u8981\u964d\u4f4e\u53d1\u9001\u901f\u7387\u4ee5\u51cf\u5c11\u7f51\u7edc\u62e5\u585e\u3002 <\/p>\n
\u4e86\u89e3RTCP\u53cd\u9988\u4fe1\u606f\u7684\u5904\u7406\u5bf9\u4e8e\u5f00\u53d1\u8005\u6765\u8bf4\u81f3\u5173\u91cd\u8981，\u56e0\u4e3a\u8fd9\u4e9b\u4fe1\u606f\u76f4\u63a5\u5f71\u54cd\u5230RTP\u6d41\u7684\u8d28\u91cf\u548c\u7a33\u5b9a\u6027\u3002 <\/p>\n
\u63a5\u6536\u7aef\u62a5\u544a(RR)\u7684\u751f\u6210\u4e0e\u89e3\u6790\u8fc7\u7a0b\u5982\u4e0b： <\/p>\n
graph LR
\nA[\u5f00\u59cb] –> B[\u63a5\u6536\u7aef\u52a0\u5165\u4f1a\u8bdd]
\nB –> C[\u5468\u671f\u6027\u751f\u6210RR\u62a5\u544a]
\nC –> D[\u5c01\u88c5RR\u62a5\u544a\u4e3aRTCP\u5305]
\nD –> E[\u53d1\u9001RTCP\u5305]
\nE –> F[\u53d1\u9001\u7aef\u63a5\u6536RTCP\u5305]
\nF –> G[\u89e3\u6790RR\u62a5\u544a]
\nG –> H[\u8c03\u6574\u53d1\u9001\u7b56\u7565]<\/p>\n
\u53d1\u9001\u7aef\u62a5\u544a（SR）\u7684\u751f\u6210\u4e0e\u89e3\u6790\u8fc7\u7a0b\u76f8\u4f3c： <\/p>\n
\u670d\u52a1\u8d28\u91cf（QoS）\u76d1\u63a7\u662fRTCP\u7684\u6838\u5fc3\u529f\u80fd\u4e4b\u4e00，\u5b83\u5141\u8bb8\u4f1a\u8bdd\u53c2\u4e0e\u8005\u4e86\u89e3\u7f51\u7edc\u7684\u5b9e\u65f6\u72b6\u51b5，\u5e76\u636e\u6b64\u4f5c\u51fa\u76f8\u5e94\u7684\u8c03\u6574\u3002 <\/p>\n
\u7f51\u7edc\u5ef6\u8fdf\u548c\u6296\u52a8\u662f\u5f71\u54cd\u5b9e\u65f6\u4f20\u8f93\u6027\u80fd\u7684\u4e24\u4e2a\u5173\u952e\u56e0\u7d20\u3002RTCP\u901a\u8fc7RR\u548cSR\u62a5\u6587\u63d0\u4f9b\u6709\u5173\u5b83\u4eec\u7684\u6570\u636e，\u5e2e\u52a9\u5f00\u53d1\u8005\u76d1\u6d4b\u548c\u8c03\u6574\u7f51\u7edc\u72b6\u51b5\u3002 <\/p>\n
\u5e26\u5bbd\u5229\u7528\u7387\u548c\u62e5\u585e\u63a7\u5236\u662f\u786e\u4fdd\u6d41\u5a92\u4f53\u4f20\u8f93\u9ad8\u6548\u548c\u7a33\u5b9a\u7684\u5173\u952e： <\/p>\n
\u7ed3\u5408\u4ee5\u4e0a\u7ae0\u8282\u5185\u5bb9，\u5f00\u53d1\u8005\u53ef\u4ee5\u6839\u636eRTCP\u63d0\u4f9b\u7684\u6570\u636e\u8c03\u6574RTP\u4f1a\u8bdd\u7684\u6027\u80fd，\u4ece\u800c\u63d0\u9ad8\u6570\u636e\u4f20\u8f93\u7684\u8d28\u91cf\u548c\u53ef\u9760\u6027\u3002\u5728\u63a5\u4e0b\u6765\u7684\u7ae0\u8282\u4e2d，\u6211\u4eec\u5c06\u8ba8\u8bba\u5982\u4f55\u4f7f\u7528RTP\u5e93\u6765\u7ba1\u7406RTP\u4f1a\u8bdd，\u5e76\u6df1\u5165\u63a2\u8ba8\u7f51\u7edc\u7f16\u7a0b\u7684\u57fa\u7840\u77e5\u8bc6，\u4ee5\u53ca\u5982\u4f55\u5b9e\u73b0\u9ad8\u8d28\u91cf\u7684\u53cc\u5411\u901a\u4fe1\u3002 <\/p>\n
RTP (Real-time Transport Protocol) \u5e93\u662f\u5b9e\u73b0\u5b9e\u65f6\u6570\u636e\u4f20\u8f93\u7684\u5173\u952e\u7ec4\u4ef6\u3002\u4e0d\u540c\u7684RTP\u5e93\u6839\u636e\u5176\u529f\u80fd\u3001\u6027\u80fd\u3001\u517c\u5bb9\u6027\u548c\u6613\u7528\u6027\u5b58\u5728\u5dee\u5f02\u3002\u5728\u9009\u62e9\u5408\u9002\u7684RTP\u5e93\u65f6，\u5f00\u53d1\u8005\u9700\u8981\u7efc\u5408\u8003\u8651\u9879\u76ee\u7684\u5177\u4f53\u9700\u6c42\u3002 <\/p>\n
\u4f8b\u5982，\u5f00\u6e90\u9879\u76ee\u5982GStreamer\u3001Live555\u548cRTP-RTSP\u7b49\u63d0\u4f9b\u4e86\u4e30\u5bcc\u7684\u529f\u80fd，\u652f\u6301\u4e3b\u6d41\u7684\u64cd\u4f5c\u7cfb\u7edf\u548c\u7f16\u7a0b\u8bed\u8a00，\u5b83\u4eec\u5728\u6d41\u5a92\u4f53\u5e94\u7528\u4e2d\u5e94\u7528\u5e7f\u6cdb\u3002GStreamer \u652f\u6301\u591a\u79cd\u6d41\u5a92\u4f53\u6846\u67b6，\u5e76\u4e14\u63d0\u4f9b\u5f3a\u5927\u7684\u63d2\u4ef6\u673a\u5236；Live555 \u4e3b\u8981\u901a\u8fc7RTSP\/RTP\u534f\u8bae\u6808\u5904\u7406\u5a92\u4f53\u6d41；RTP-RTSP \u5e93\u5219\u63d0\u4f9b\u4e86\u8f83\u4e3a\u76f4\u63a5\u7684API\u63a5\u53e3，\u9002\u5408\u9700\u8981\u81ea\u884c\u5b9e\u73b0\u590d\u6742\u63a7\u5236\u903b\u8f91\u7684\u573a\u666f\u3002 <\/p>\n
\u5728\u5bf9\u6bd4\u529f\u80fd\u65f6，\u5e94\u5173\u6ce8\u4ee5\u4e0b\u7279\u6027： <\/p>\n
\u5b89\u88c5RTP\u5e93\u901a\u5e38\u6d89\u53ca\u51e0\u4e2a\u6b65\u9aa4，\u5305\u62ec\u4e0b\u8f7d\u3001\u7f16\u8bd1\u548c\u914d\u7f6e\u3002\u4ee5\u4e00\u4e2a\u5e38\u89c1\u7684RTP\u5e93\u5b89\u88c5\u8fc7\u7a0b\u4e3a\u4f8b： <\/p>\n
\u9996\u5148，\u4ece\u5e93\u7684\u5b98\u65b9\u7f51\u7ad9\u6216\u6e90\u4ee3\u7801\u7ba1\u7406\u5e73\u53f0\u4e0b\u8f7d\u6e90\u4ee3\u7801\u5305\u3002\u4f8b\u5982，\u4f7f\u7528Git\u4ece\u9879\u76ee\u4ed3\u5e93\u62c9\u53d6\u4ee3\u7801： <\/p>\n
git clone ***<\/p>\n
\u7136\u540e，\u6839\u636e\u9879\u76ee\u6587\u6863\u8fdb\u884c\u7f16\u8bd1\u5b89\u88c5\u3002\u5bf9\u4e8e\u4f7f\u7528CMake\u6784\u5efa\u7684\u5e93，\u901a\u5e38\u6267\u884c\u4ee5\u4e0b\u547d\u4ee4： <\/p>\n
cd your-rtp-library
\nmkdir build && cd build
\ncmake ..
\nmake
\nsudo make install<\/p>\n
\u5b89\u88c5\u5b8c\u6210\u540e，\u914d\u7f6eRTP\u5e93\u7684\u4f7f\u7528\u73af\u5883\u3002\u5728\u5e94\u7528\u7a0b\u5e8f\u4e2d，\u901a\u5e38\u9700\u8981\u5728\u7f16\u8bd1\u65f6\u94fe\u63a5\u5e93\u6587\u4ef6，\u5e76\u5728\u8fd0\u884c\u65f6\u6307\u5b9a\u5e93\u6587\u4ef6\u8def\u5f84，\u5982\u901a\u8fc7\u73af\u5883\u53d8\u91cf LD_LIBRARY_PATH \u8bbe\u7f6e\u5e93\u7684\u8def\u5f84： <\/p>\n
export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:\/usr\/local\/lib<\/p>\n
\u5728\u914d\u7f6e\u6587\u4ef6\u6216\u7a0b\u5e8f\u4ee3\u7801\u4e2d，\u8fd8\u9700\u6307\u5b9aRTP\u5e93\u7684\u53c2\u6570，\u5305\u62ec\u4f7f\u7528\u7684IP\u5730\u5740\u3001\u7aef\u53e3\u53f7\u3001\u4f1a\u8bdd\u6807\u8bc6\u7b26\u7b49\u3002\u8fd9\u901a\u5e38\u662f\u901a\u8fc7\u8c03\u7528\u5e93\u63d0\u4f9b\u7684\u521d\u59cb\u5316\u51fd\u6570\u6216\u8bbe\u7f6e\u51fd\u6570\u6765\u5b8c\u6210\u7684\u3002 <\/p>\n
RTP\u4f1a\u8bdd\u7684\u521b\u5efa\u548c\u7ba1\u7406\u6d89\u53ca\u4e00\u7cfb\u5217\u53c2\u6570\u7684\u914d\u7f6e\u548c\u534f\u5546\u8fc7\u7a0b\u3002\u8fd9\u4e9b\u53c2\u6570\u5305\u62ec\u4f46\u4e0d\u9650\u4e8e： <\/p>\n
\u5728RTP\u4f1a\u8bdd\u5f00\u59cb\u65f6，\u901a\u5e38\u901a\u8fc7RTCP\u7684\u534f\u5546\u8fc7\u7a0b\u786e\u5b9a\u8fd9\u4e9b\u53c2\u6570\u3002\u4f8b\u5982，\u4f7f\u7528SIP (Session Initiation Protocol) \u53ef\u4ee5\u5728\u5efa\u7acb\u4f1a\u8bdd\u65f6\u534f\u5546RTP\u53c2\u6570\u3002 <\/p>\n
\u4ee5\u4e0b\u662f\u4e00\u4e2a\u7b80\u5316\u7684\u4ee3\u7801\u793a\u4f8b，\u5c55\u793a\u5982\u4f55\u5728\u7a0b\u5e8f\u4e2d\u8bbe\u7f6eRTP\u4f1a\u8bdd\u53c2\u6570： <\/p>\n
#include "rtp_session.h"<\/p>\n
RtpSession session;
\nsession.setLocalSSRC(123456); \/\/ \u8bbe\u7f6e\u672c\u5730SSRC\u503c
\nsession.setRemoteSSRC(654321); \/\/ \u8bbe\u7f6e\u8fdc\u7aefSSRC\u503c，\u5982\u679c\u4e8b\u5148\u5df2\u77e5
\nsession.setPayloadType(96); \/\/ \u5047\u8bbe\u97f3\u9891\u8d1f\u8f7d\u7c7b\u578b\u4e3a96<\/p>\n
\/\/ \u521d\u59cb\u5316\u4f1a\u8bdd
\nsession.initialize();<\/p>\n
RTP\u4f1a\u8bdd\u7684\u751f\u547d\u5468\u671f\u901a\u5e38\u5305\u62ec\u4f1a\u8bdd\u7684\u521b\u5efa\u3001\u8fd0\u884c\u548c\u7ec8\u6b62\u3002\u4f1a\u8bdd\u7ba1\u7406\u4e3b\u8981\u6d89\u53ca\u5bf9\u8fd9\u4e9b\u72b6\u6001\u53d8\u5316\u7684\u63a7\u5236\u3002 <\/p>\n
\u5728\u521b\u5efa\u9636\u6bb5，\u4f1a\u8bdd\u88ab\u521d\u59cb\u5316，\u5e76\u6839\u636e\u534f\u5546\u7684\u53c2\u6570\u8fdb\u884c\u914d\u7f6e\u3002\u5728\u8fd0\u884c\u9636\u6bb5，RTP\u5305\u5f00\u59cb\u6309\u7167\u65e2\u5b9a\u7684\u53d1\u9001\u9891\u7387\u53d1\u9001，\u4e14\u53ef\u80fd\u6839\u636e\u7f51\u7edc\u6761\u4ef6\u52a8\u6001\u8c03\u6574\u3002\u5728\u7ec8\u6b62\u9636\u6bb5，\u4f1a\u8bdd\u4e2d\u7684\u8d44\u6e90\u88ab\u91ca\u653e，\u4f8b\u5982，\u505c\u6b62\u53d1\u9001RTP\u5305\u5e76\u5173\u95ed\u7f51\u7edc\u8fde\u63a5\u3002 <\/p>\n
\u5f00\u53d1\u8005\u5728\u7ba1\u7406RTP\u4f1a\u8bdd\u65f6，\u8fd8\u9700\u8981\u5904\u7406\u5f02\u5e38\u60c5\u51b5，\u6bd4\u5982\u7f51\u7edc\u4e0d\u7a33\u5b9a\u5bfc\u81f4\u7684\u4e22\u5305\u3001\u65f6\u5e8f\u95ee\u9898\u7b49\u3002\u6b64\u65f6，\u9700\u8981\u501f\u52a9RTCP\u53cd\u9988\u673a\u5236\u6765\u76d1\u63a7\u4f1a\u8bdd\u8d28\u91cf\u5e76\u76f8\u5e94\u5730\u8c03\u6574RTP\u5305\u7684\u53d1\u9001\u7b56\u7565\u3002 <\/p>\n
\u5728\u4ee3\u7801\u4e2d，\u4f1a\u8bdd\u7684\u751f\u547d\u5468\u671f\u53ef\u4ee5\u7531\u5982\u4e0b\u65b9\u5f0f\u7ba1\u7406： <\/p>\n
void manageRtpSession() {
\n while (true) {
\n session.sendAudioPacket(audioData, audioLength); \/\/ \u53d1\u9001\u97f3\u9891\u6570\u636e\u5305<\/p>\n
if (session \u043d\u0430\u0434\u043e \u0437\u0430\u0432\u0435\u0440\u0448\u0438\u0442\u044c) {
\n session.shutdown();
\n break;
\n }
\n }
\n}<\/p>\n
RTP\u901a\u5e38\u4e0eSIP (Session Initiation Protocol) \u534f\u8bae\u96c6\u6210\u4f7f\u7528\u3002SIP\u7528\u4e8e\u5efa\u7acb\u548c\u7ba1\u7406\u4f1a\u8bdd，\u800cRTP\u8d1f\u8d23\u4f20\u8f93\u5b9e\u9645\u7684\u5a92\u4f53\u6570\u636e\u3002\u901a\u8fc7SIP\u53ef\u4ee5\u534f\u5546\u5a92\u4f53\u7c7b\u578b\u3001\u7f16\u7801\u3001\u5e26\u5bbd\u3001RTP\u5730\u5740\u7b49\u53c2\u6570\u3002 <\/p>\n
\u5728\u96c6\u6210\u5b9e\u8df5\u65b9\u9762，\u5f00\u53d1\u8005\u9700\u8981\u5173\u6ce8\u4ee5\u4e0b\u6b65\u9aa4： <\/p>\n
\u4e00\u4e2a\u7b80\u5355\u7684\u793a\u4f8b\u662f\u4f7f\u7528SIP\u548cRTP\u7684\u4f2a\u4ee3\u7801\u6765\u5efa\u7acb\u4f1a\u8bdd： <\/p>\n
\/\/ SIP\u90e8\u5206
\nSipStack sipStack;
\nSipSession sipSession(&sipStack);
\nSipMessage inviteMessage = createInviteMessage();
\nsipSession.sendInvite(inviteMessage);<\/p>\n
\/\/ \u63a5\u6536180 Ringing\u54cd\u5e94
\nSipMessage ringingResponse = sipSession.receiveMessage();<\/p>\n
\/\/ \u63a5\u6536200 OK\u54cd\u5e94
\nSipMessage okResponse = sipSession.receiveMessage();<\/p>\n
\/\/ RTP\u90e8\u5206
\nRtpSession rtpSession;
\nrtpSession.initializeFromSDP(okResponse.getSDPInfo()); \/\/ \u4f7f\u7528SDP\u4fe1\u606f\u521d\u59cb\u5316RTP\u4f1a\u8bdd
\nrtpSession.startSendingAudio(); \/\/ \u5f00\u59cb\u53d1\u9001\u97f3\u9891\u6570\u636e<\/p>\n
WebRTC\u662f\u4e00\u4e2a\u652f\u6301\u7f51\u9875\u6d4f\u89c8\u5668\u8fdb\u884c\u5b9e\u65f6\u8bed\u97f3\u548c\u89c6\u9891\u901a\u4fe1\u7684\u6846\u67b6，\u5b83\u5185\u90e8\u4f7f\u7528RTP\u4f5c\u4e3a\u5a92\u4f53\u4f20\u8f93\u534f\u8bae\u3002WebRTC\u7684RTP\u4f1a\u8bdd\u7ba1\u7406\u6d89\u53ca\u5f88\u591a\u9ad8\u7ea7\u7279\u6027，\u6bd4\u5982NAT\u7a7f\u900f\u3001\u52a0\u5bc6\u4f20\u8f93\u548c\u5e26\u5bbd\u4f30\u8ba1\u3002 <\/p>\n
\u5728WebRTC\u4e2d，RTP\u4f1a\u8bdd\u7684\u521b\u5efa\u548c\u7ba1\u7406\u662f\u901a\u8fc7\u4e00\u7cfb\u5217\u590d\u6742\u7684\u4fe1\u4ee4\u8fc7\u7a0b\u6765\u5b9e\u73b0\u7684\u3002\u4fe1\u4ee4\u534f\u8bae\u53ef\u4ee5\u662f\u81ea\u5b9a\u4e49\u7684，\u4e5f\u53ef\u4ee5\u4f7f\u7528\u6807\u51c6\u7684\u534f\u8bae\u5982SIP\u3002WebRTC\u7684\u4fe1\u4ee4\u901a\u5e38\u5305\u62ecICE (Interactive Connectivity Establishment) \u534f\u8bae\u6765\u5b9e\u73b0NAT\u7a7f\u900f\u3002 <\/p>\n
RTP\u4f1a\u8bdd\u7684\u521b\u5efa\u548c\u7ba1\u7406\u6d41\u7a0b\u5982\u4e0b： <\/p>\n
\u5728WebRTC\u73af\u5883\u4e2d，RTP\u4f1a\u8bdd\u7ba1\u7406\u7684\u4ee3\u7801\u5b9e\u73b0\u6bd4\u8f83\u590d\u6742，\u6d89\u53ca\u5927\u91cf\u7684\u56de\u8c03\u51fd\u6570\u548c\u72b6\u6001\u5904\u7406\u903b\u8f91\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u975e\u5e38\u7b80\u5316\u7684\u4ee3\u7801\u793a\u4f8b： <\/p>\n
\/\/ JavaScript \u793a\u4f8b\u4ee3\u7801
\nlet peerConnection = new RTCPeerConnection({ iceServers: […iceServers] });<\/p>\n
peerConnection.onicecandidate = function(event) {
\n if (event.candidate) {
\n \/\/ \u53d1\u9001\u5019\u9009\u4eba\u5230\u8fdc\u7aef
\n sendCandidateToRemote(event.candidate);
\n }
\n};<\/p>\n
peerConnection.onaddstream = function(event) {
\n \/\/ \u8fdc\u7aef\u5a92\u4f53\u6d41\u63a5\u6536\u6210\u529f
\n let remoteStream = event.stream;
\n \/\/ \u5c06\u6d41\u7ed1\u5b9a\u5230\u89c6\u9891\u5143\u7d20\u4e0a
\n attachMediaStream(remoteVideo, remoteStream);
\n};<\/p>\n
\/\/ \u53d1\u8d77\u547c\u53eb\u6216\u5904\u7406\u547c\u53eb
\nfunction makeCall() {
\n \/\/ \u6dfb\u52a0\u672c\u5730\u6d41
\n navigator.mediaDevices.getUserMedia({video: true, audio: true})
\n .then(function(stream) {
\n stream.getTracks().forEach(track => peerConnection.addTrack(track, stream));
\n })
\n .catch(error => {
\n console.error("\u65e0\u6cd5\u83b7\u53d6\u5a92\u4f53\u6d41:", error);
\n });
\n}<\/p>\n
function handleIncomingCall() {
\n \/\/ \u5904\u7406\u8fdb\u5165\u7684\u547c\u53eb
\n \/\/ …
\n}<\/p>\n
\u4ee5\u4e0a\u4e3aRTP\u5e93\u7684\u4f7f\u7528\u4e0eRTP\u4f1a\u8bdd\u7ba1\u7406\u7684\u8be6\u7ec6\u8bb2\u89e3，\u6db5\u76d6\u4e86RTP\u5e93\u7684\u9009\u62e9\u3001\u5b89\u88c5\u3001\u4f1a\u8bdd\u7684\u521b\u5efa\u3001\u914d\u7f6e\u3001\u7ba1\u7406\u4ee5\u53ca\u4e0e\u5e94\u7528\u5c42\u534f\u8bae\u7684\u96c6\u6210\u3002\u8fd9\u4e9b\u77e5\u8bc6\u5bf9\u4e8e\u6df1\u5165\u7406\u89e3\u548c\u5b9e\u73b0\u9ad8\u8d28\u91cf\u7684\u5b9e\u65f6\u901a\u4fe1\u7cfb\u7edf\u81f3\u5173\u91cd\u8981\u3002 <\/p>\n
\u5957\u63a5\u5b57（Socket）\u662f\u7f51\u7edc\u7f16\u7a0b\u4e2d\u63d0\u4f9b\u8fdb\u7a0b\u901a\u4fe1\u7684\u4e00\u79cd\u62bd\u8c61\u673a\u5236，\u5141\u8bb8\u8fd0\u884c\u5728\u4e0d\u540c\u4e3b\u673a\u4e0a\u7684\u5e94\u7528\u7a0b\u5e8f\u8fdb\u884c\u6570\u636e\u4ea4\u6362\u3002\u5b83\u652f\u6301\u591a\u79cd\u534f\u8bae，\u5982TCP\/IP\u548cUDP\/IP\u7b49\u3002\u5728\u7f51\u7edc\u7f16\u7a0b\u4e2d，\u4e3b\u8981\u6709\u4e09\u79cd\u7c7b\u578b\u7684\u5957\u63a5\u5b57：\u6d41\u5f0f\u5957\u63a5\u5b57（SOCK_STREAM）\u3001\u6570\u636e\u62a5\u5957\u63a5\u5b57（SOCK_DGRAM）\u548c\u539f\u59cb\u5957\u63a5\u5b57（SOCK_RAW）\u3002 <\/p>\n
\u6d41\u5f0f\u5957\u63a5\u5b57\u57fa\u4e8eTCP\u534f\u8bae，\u63d0\u4f9b\u9762\u5411\u8fde\u63a5\u3001\u53ef\u9760\u7684\u6570\u636e\u4f20\u8f93\u670d\u52a1\u3002\u5b83\u4fdd\u8bc1\u6570\u636e\u6309\u987a\u5e8f\u3001\u65e0\u9519\u8bef\u3001\u4e0d\u91cd\u590d\u5730\u4f20\u9012\u7ed9\u5bf9\u65b9，\u9002\u7528\u4e8e\u8981\u6c42\u4e25\u683c\u6570\u636e\u5b8c\u6574\u6027\u7684\u573a\u666f\u3002\u6570\u636e\u62a5\u5957\u63a5\u5b57\u57fa\u4e8eUDP\u534f\u8bae，\u4f7f\u7528\u65e0\u8fde\u63a5\u7684\u670d\u52a1，\u53d1\u9001\u6570\u636e\u7684\u5927\u5c0f\u53d7\u9650\u4e8e\u534f\u8bae\u6808\u7684\u9650\u5236，\u53ef\u80fd\u5bfc\u81f4\u4e22\u5305\u6216\u4e71\u5e8f，\u9002\u7528\u4e8e\u5bf9\u5b9e\u65f6\u6027\u8981\u6c42\u8f83\u9ad8\u7684\u5e94\u7528\u3002\u539f\u59cb\u5957\u63a5\u5b57\u5219\u5141\u8bb8\u5bf9\u5e95\u5c42\u534f\u8bae\u8fdb\u884c\u76f4\u63a5\u8bbf\u95ee，\u63d0\u4f9b\u66f4\u591a\u7684\u63a7\u5236\u80fd\u529b，\u4f46\u4e5f\u9700\u8981\u8f83\u9ad8\u7684\u7f16\u7a0b\u6280\u5de7\u3002 <\/p>\n
\u4f7f\u7528\u5957\u63a5\u5b57\u7f16\u7a0b，\u901a\u5e38\u6d89\u53ca\u4ee5\u4e0b\u51e0\u4e2a\u4e3b\u8981\u6b65\u9aa4：\u521b\u5efa\u5957\u63a5\u5b57\u3001\u7ed1\u5b9a\u5957\u63a5\u5b57\u3001\u76d1\u542c\u8fde\u63a5\u3001\u63a5\u53d7\u8fde\u63a5\u3001\u6570\u636e\u4f20\u8f93\u548c\u5173\u95ed\u5957\u63a5\u5b57\u3002 <\/p>\n
\u4e0b\u9762\u662f\u4e00\u4e2a\u4f7f\u7528TCP\u6d41\u5f0f\u5957\u63a5\u5b57\u7684\u7b80\u5355\u793a\u4f8b\u4ee3\u7801，\u5c55\u793a\u4e86\u5982\u4f55\u5728Python\u4e2d\u521b\u5efa\u4e00\u4e2a\u670d\u52a1\u5668\u7aef\u7684\u5957\u63a5\u5b57： <\/p>\n
import socket<\/p>\n
# \u521b\u5efaTCP\u5957\u63a5\u5b57
\nserver_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)<\/p>\n
# \u7ed1\u5b9a\u5957\u63a5\u5b57\u5230\u7aef\u53e3
\nserver_address = ('localhost', 10000)
\nserver_socket.bind(server_address)<\/p>\n
# \u5f00\u59cb\u76d1\u542c\u7aef\u53e3
\nserver_socket.listen(1)<\/p>\n
while True:
\n print('Waiting for a connection')
\n connection, client_address = server_socket.accept()
\n try:
\n print('Connection from', client_address)
\n while True:
\n data = connection.recv(16)
\n print('Received {!r}'.format(data))
\n if data:
\n print('Sending data back to the client')
\n connection.sendall(data)
\n else:
\n print('No data from', client_address)
\n break
\n finally:
\n # \u6e05\u7406\u8fde\u63a5
\n connection.close()<\/p>\n
\u5728\u8fd9\u6bb5\u4ee3\u7801\u4e2d，\u9996\u5148\u521b\u5efa\u4e86\u4e00\u4e2aTCP\u5957\u63a5\u5b57，\u5e76\u5c06\u5176\u7ed1\u5b9a\u5230\u672c\u5730\u4e3b\u673a\u768410000\u7aef\u53e3\u4e0a\u3002\u7136\u540e\u5f00\u59cb\u76d1\u542c\u8fde\u63a5\u8bf7\u6c42，\u5e76\u63a5\u53d7\u4e00\u4e2a\u8fde\u63a5\u3002\u4e4b\u540e，\u670d\u52a1\u5668\u8fdb\u5165\u4e00\u4e2a\u5faa\u73af，\u63a5\u6536\u6765\u81ea\u5ba2\u6237\u7aef\u7684\u6570\u636e，\u5e76\u5c06\u5176\u56de\u4f20\u7ed9\u5ba2\u6237\u7aef，\u76f4\u5230\u5ba2\u6237\u7aef\u4e0d\u518d\u53d1\u9001\u6570\u636e\u4e3a\u6b62\u3002 <\/p>\n
\u591a\u7ebf\u7a0b\u7f16\u7a0b\u5141\u8bb8\u540c\u65f6\u6267\u884c\u591a\u4e2a\u4efb\u52a1，\u63d0\u9ad8\u7a0b\u5e8f\u6548\u7387\u3002\u5728Python\u4e2d，\u53ef\u4ee5\u4f7f\u7528 threading \u6a21\u5757\u521b\u5efa\u548c\u7ba1\u7406\u7ebf\u7a0b\u3002 <\/p>\n
\u4e0b\u9762\u7684\u4ee3\u7801\u5c55\u793a\u4e86\u4e00\u4e2a\u7b80\u5355\u7684\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u7aef\u7a0b\u5e8f\u793a\u4f8b： <\/p>\n
import socket
\nimport threading<\/p>\n
def client_handler(connection):
\n try:
\n while True:
\n data = connection.recv(1024)
\n if data:
\n print('Client sent:', data)
\n connection.sendall(data)
\n else:
\n break
\n finally:
\n connection.close()<\/p>\n
def main():
\n server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
\n server_address = ('localhost', 10000)
\n server_socket.bind(server_address)
\n server_socket.listen(5)<\/p>\n
print('Server is running on', server_address)<\/p>\n
try:
\n while True:
\n connection, client_address = server_socket.accept()
\n thread = threading.Thread(target=client_handler, args=(connection,))
\n thread.start()
\n finally:
\n server_socket.close()<\/p>\n
if __name__ == '__main__':
\n main()<\/p>\n
\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d，\u670d\u52a1\u5668\u5728\u63a5\u6536\u5230\u4e00\u4e2a\u65b0\u7684\u8fde\u63a5\u8bf7\u6c42\u540e，\u4f1a\u521b\u5efa\u4e00\u4e2a\u65b0\u7684\u7ebf\u7a0b\u6765\u5904\u7406\u8be5\u8fde\u63a5\u3002\u6bcf\u4e2a\u7ebf\u7a0b\u6267\u884c client_handler \u51fd\u6570，\u8d1f\u8d23\u4e0e\u5355\u4e2a\u5ba2\u6237\u7aef\u8fdb\u884c\u901a\u4fe1\u3002 <\/p>\n
\u5728\u591a\u7ebf\u7a0b\u7a0b\u5e8f\u4e2d，\u591a\u4e2a\u7ebf\u7a0b\u53ef\u80fd\u4f1a\u540c\u65f6\u8bbf\u95ee\u5171\u4eab\u8d44\u6e90，\u8fd9\u53ef\u80fd\u5bfc\u81f4\u7ade\u4e89\u6761\u4ef6\u548c\u6570\u636e\u4e0d\u4e00\u81f4\u3002\u4e3a\u4e86\u89e3\u51b3\u8fd9\u4e2a\u95ee\u9898，\u9700\u8981\u4f7f\u7528\u540c\u6b65\u673a\u5236，\u5982\u9501（Locks）\u3001\u4fe1\u53f7\u91cf（Semaphores）\u548c\u4e8b\u4ef6（Events）\u7b49\u3002 <\/p>\n
\u4ee5\u4e0b\u662f\u5982\u4f55\u4f7f\u7528\u9501\u6765\u9632\u6b62\u6570\u636e\u51b2\u7a81\u7684\u4ee3\u7801\u793a\u4f8b： <\/p>\n
import threading<\/p>\n
lock = threading.Lock()<\/p>\n
def thread_function(name):
\n with lock: # \u4f7f\u7528\u9501\u6765\u786e\u4fdd\u7ebf\u7a0b\u5b89\u5168
\n print(f"Thread {name} is starting")
\n # \u5728\u8fd9\u91cc\u6267\u884c\u4e34\u754c\u533a\u7684\u4ee3\u7801
\n print(f"Thread {name} will end")<\/p>\n
thread1 = threading.Thread(target=thread_function, args=(1,))
\nthread2 = threading.Thread(target=thread_function, args=(2,))<\/p>\n
thread1.start()
\nthread2.start()
\nthread1.join()
\nthread2.join()<\/p>\n
\u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d， lock \u5bf9\u8c61\u7528\u4e8e\u786e\u4fdd\u5728\u6267\u884c\u4e34\u754c\u533a\u4ee3\u7801\u65f6，\u540c\u4e00\u65f6\u523b\u53ea\u6709\u4e00\u4e2a\u7ebf\u7a0b\u53ef\u4ee5\u8fdb\u5165\u3002\u901a\u8fc7 with lock: \u8bed\u53e5，Python\u4f1a\u81ea\u52a8\u83b7\u53d6\u9501，\u5e76\u5728\u79bb\u5f00\u8be5\u8bed\u53e5\u5757\u65f6\u91ca\u653e\u9501\u3002 <\/p>\n
\u5f02\u6b65IO\u662f\u76f8\u5bf9\u4e8e\u540c\u6b65IO\u6765\u8bf4\u7684，\u5b83\u5141\u8bb8\u7a0b\u5e8f\u5728\u7b49\u5f85IO\u64cd\u4f5c\u5b8c\u6210\u65f6\u7ee7\u7eed\u6267\u884c\u5176\u4ed6\u4efb\u52a1，\u76f4\u5230\u9700\u8981\u7ed3\u679c\u65f6\u624d\u5904\u7406\u5b8c\u6210\u7684IO\u64cd\u4f5c\u3002 <\/p>\n
\u5728Python\u4e2d，\u53ef\u4ee5\u4f7f\u7528 asyncio \u6a21\u5757\u6765\u5904\u7406\u5f02\u6b65IO\u3002\u5f02\u6b65\u7f16\u7a0b\u7684\u6a21\u578b\u901a\u5e38\u57fa\u4e8e\u534f\u7a0b（Coroutines），\u662f\u4e00\u79cd\u8f7b\u91cf\u7ea7\u7684\u7ebf\u7a0b，\u53ef\u4ee5\u66f4\u9ad8\u6548\u5730\u6267\u884c\u4efb\u52a1\u3002 <\/p>\n
\u4ee5\u4e0b\u662f\u4e00\u4e2a\u5f02\u6b65IO\u7684\u7b80\u5355\u793a\u4f8b： <\/p>\n
import asyncio<\/p>\n
async def handle_client(reader, writer):
\n data = await reader.read(100)
\n message = data.decode()<\/p>\n
addr = writer.get_extra_info('peername')<\/p>\n
print(f"Received {message} from {addr}")<\/p>\n
print(f"Send: {message}")
\n writer.write(data)
\n await writer.drain()<\/p>\n
print("Close the client socket")
\n writer.close()<\/p>\n
async def main():
\n server = await asyncio.start_server(
\n handle_client, '***.*.*.*', 8888)<\/p>\n
addr = server.sockets[0].getsockname()
\n print(f'Serving on {addr}')<\/p>\n
async with server:
\n await server.serve_forever()<\/p>\n
asyncio.run(main())<\/p>\n
\u8fd9\u6bb5\u4ee3\u7801\u5b9a\u4e49\u4e86\u4e00\u4e2a\u5f02\u6b65\u7684 handle_client \u51fd\u6570，\u5b83\u63a5\u6536\u5ba2\u6237\u7aef\u7684\u8fde\u63a5，\u5e76\u5f02\u6b65\u8bfb\u53d6\u6570\u636e\u3002 main \u51fd\u6570\u542f\u52a8\u4e86\u4e00\u4e2a\u5f02\u6b65\u670d\u52a1\u5668，\u7528\u4e8e\u5904\u7406\u5ba2\u6237\u7aef\u8bf7\u6c42\u3002 <\/p>\n
\u4e8b\u4ef6\u9a71\u52a8\u6a21\u578b\u662f\u4e00\u79cd\u7f16\u7a0b\u8303\u5f0f，\u7a0b\u5e8f\u7684\u6d41\u7a0b\u7531\u5916\u90e8\u4e8b\u4ef6\u6765\u9a71\u52a8\u3002\u5728\u4e8b\u4ef6\u9a71\u52a8\u6a21\u578b\u4e2d，\u7a0b\u5e8f\u901a\u5e38\u5728\u7b49\u5f85\u4e8b\u4ef6\u53d1\u751f\u65f6\u5904\u4e8e\u963b\u585e\u72b6\u6001，\u5f53\u67d0\u4e2a\u4e8b\u4ef6\u53d1\u751f\u65f6，\u7a0b\u5e8f\u4f1a\u505a\u51fa\u54cd\u5e94\u3002 <\/p>\n
\u5728\u5f02\u6b65\u7f16\u7a0b\u4e2d，\u4e8b\u4ef6\u9a71\u52a8\u6a21\u578b\u53ef\u4ee5\u901a\u8fc7\u4e8b\u4ef6\u5faa\u73af（Event Loop）\u6765\u5b9e\u73b0\u3002\u4e8b\u4ef6\u5faa\u73af\u8d1f\u8d23\u76d1\u63a7\u4e8b\u4ef6\u7684\u53d1\u751f，\u5e76\u5728\u9002\u5f53\u7684\u4e8b\u4ef6\u53d1\u751f\u65f6\u6267\u884c\u76f8\u5e94\u7684\u56de\u8c03\u51fd\u6570\u3002 <\/p>\n
\u4e0b\u9762\u662f\u4e00\u4e2a\u4e8b\u4ef6\u9a71\u52a8\u6a21\u578b\u7684\u7b80\u5355\u5b9e\u73b0： <\/p>\n
import selectors<\/p>\n
def accept_wrapper(sock):
\n conn, addr = sock.accept() # Should be ready to read
\n print('accepted connection from', addr)
\n conn.setblocking(False)
\n events = selectors.EVENT_READ | selectors.EVENT_WRITE
\n selectors.register(conn, events, data=None)<\/p>\n
def service_connection(key, mask):
\n sock = key.fileobj
\n if mask & selectors.EVENT_READ:
\n recv_data = sock.recv(1024) # Should be ready to read
\n if recv_data:
\n print('received message:', recv_data.decode())
\n else:
\n print('closing connection')
\n sock.close()
\n if mask & selectors.EVENT_WRITE:
\n print('ready to send')<\/p>\n
# Create a selector object
\nsel = selectors.DefaultSelector()<\/p>\n
# Register a TCP socket to the selector
\nsock = socket.socket()
\nsock.bind(('localhost', 10000))
\nsock.listen()
\nsock.setblocking(False)
\nsel.register(sock, selectors.EVENT_READ, data=None)<\/p>\n
try:
\n while True:
\n events = sel.select(timeout=None)
\n for key, mask in events:
\n if key.data is None:
\n accept_wrapper(key.fileobj)
\n else:
\n service_connection(key, mask)
\nexcept KeyboardInterrupt:
\n print("caught keyboard interrupt, exiting")
\nfinally:
\n sel.close()<\/p>\n
\u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d，\u4f7f\u7528 selectors \u6a21\u5757\u521b\u5efa\u4e86\u4e00\u4e2a\u4e8b\u4ef6\u5faa\u73af，\u7528\u4e8e\u5904\u7406\u7f51\u7edc\u8fde\u63a5\u4e8b\u4ef6\u3002\u5f53\u4e8b\u4ef6\u5faa\u73af\u68c0\u6d4b\u5230\u4e8b\u4ef6（\u5982\u65b0\u8fde\u63a5\u6216\u53ef\u8bfb\u6570\u636e）\u65f6，\u5b83\u4f1a\u8c03\u7528\u76f8\u5e94\u7684\u56de\u8c03\u51fd\u6570\u6765\u5904\u7406\u8fd9\u4e9b\u4e8b\u4ef6\u3002 <\/p>\n
\u5728\u73b0\u4ee3\u7f51\u7edc\u901a\u4fe1\u4e2d，\u53cc\u5411\u901a\u4fe1\u662f\u4e0d\u53ef\u6216\u7f3a\u7684\u7ec4\u6210\u90e8\u5206，\u65e0\u8bba\u662f\u5728\u5ba2\u6237\u652f\u6301\u7cfb\u7edf\u3001\u5728\u7ebf\u6e38\u620f\u8fd8\u662f\u5b9e\u65f6\u89c6\u9891\u4f1a\u8bae\u4e2d，\u53cc\u5411\u901a\u4fe1\u90fd\u53d1\u6325\u7740\u5173\u952e\u4f5c\u7528\u3002\u5728\u672c\u7ae0\u4e2d，\u6211\u4eec\u5c06\u6df1\u5165\u4e86\u89e3\u53cc\u5411\u901a\u4fe1\u673a\u5236\u7684\u8bbe\u8ba1，\u5b9e\u73b0\u76d1\u542c\u673a\u5236，\u4ee5\u53ca\u5bf9\u5b9e\u65f6\u6570\u636e\u6d41\u8fdb\u884c\u5904\u7406\u7684\u6280\u672f\u548c\u7b56\u7565\u3002 <\/p>\n
\u53cc\u5411\u901a\u4fe1\u4e0d\u4ec5\u5305\u62ec\u6570\u636e\u7684\u53d1\u9001\u548c\u63a5\u6536，\u8fd8\u9700\u8981\u8003\u8651\u6570\u636e\u6d41\u7684\u63a7\u5236，\u786e\u4fdd\u6570\u636e\u80fd\u591f\u53ef\u9760\u5e76\u4e14\u9ad8\u6548\u5730\u5728\u5ba2\u6237\u7aef\u548c\u670d\u52a1\u5668\u4e4b\u95f4\u4f20\u8f93\u3002 <\/p>\n
\u5728\u8bbe\u8ba1\u53cc\u5411\u901a\u4fe1\u65f6，\u9996\u5148\u8981\u660e\u786e\u5ba2\u6237\u7aef\u4e0e\u670d\u52a1\u5668\u5404\u81ea\u7684\u89d2\u8272\u548c\u804c\u8d23\u3002\u670d\u52a1\u5668\u901a\u5e38\u8d1f\u8d23\u76d1\u542c\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u8bf7\u6c42，\u5e76\u5904\u7406\u5ba2\u6237\u7aef\u53d1\u9001\u7684\u6570\u636e，\u540c\u65f6\u5c06\u54cd\u5e94\u6570\u636e\u53d1\u9001\u56de\u5ba2\u6237\u7aef\u3002\u5ba2\u6237\u7aef\u5219\u4e3b\u52a8\u53d1\u8d77\u8fde\u63a5，\u5e76\u5411\u670d\u52a1\u5668\u53d1\u9001\u8bf7\u6c42，\u63a5\u6536\u670d\u52a1\u5668\u54cd\u5e94\u7684\u6570\u636e\u3002 <\/p>\n
\u4e3a\u4e86\u4fdd\u8bc1\u53cc\u5411\u901a\u4fe1\u7684\u987a\u7545，\u8bbe\u8ba1\u65f6\u9700\u8981\u9075\u5faa\u4e00\u4e9b\u57fa\u672c\u539f\u5219： <\/p>\n
\u76d1\u542c\u673a\u5236\u662f\u670d\u52a1\u5668\u7aef\u91cd\u8981\u7684\u529f\u80fd，\u5b83\u5141\u8bb8\u670d\u52a1\u5668\u7b49\u5f85\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u8bf7\u6c42，\u5e76\u5728\u6536\u5230\u8bf7\u6c42\u65f6\u4f5c\u51fa\u54cd\u5e94\u3002 <\/p>\n
\u8981\u5b9e\u73b0\u76d1\u542c，\u9996\u5148\u9700\u8981\u5728\u670d\u52a1\u5668\u7aef\u914d\u7f6e\u5957\u63a5\u5b57\u4ee5\u76d1\u542c\u7279\u5b9a\u7684\u7aef\u53e3\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528Python\u5b9e\u73b0TCP\u670d\u52a1\u5668\u76d1\u542c\u7684\u793a\u4f8b\u4ee3\u7801： <\/p>\n
import socket<\/p>\n
def start_server(host, port):
\n # \u521b\u5efa\u5957\u63a5\u5b57
\n server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
\n # \u5141\u8bb8\u7aef\u53e3\u91cd\u7528
\n server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
\n # \u7ed1\u5b9a\u5730\u5740\u548c\u7aef\u53e3
\n server_socket.bind((host, port))
\n # \u5f00\u59cb\u76d1\u542c
\n server_socket.listen(5)
\n print(f"Listening on {host}:{port}")<\/p>\n
start_server('***.*.*.*', 12345)<\/p>\n
\u5728\u76d1\u542c\u8fc7\u7a0b\u4e2d，\u53ef\u80fd\u4f1a\u9047\u5230\u5404\u79cd\u5f02\u5e38\u60c5\u51b5，\u4f8b\u5982\u7aef\u53e3\u5df2\u88ab\u5360\u7528\u3001\u6743\u9650\u4e0d\u8db3\u6216\u7f51\u7edc\u4e2d\u65ad\u7b49\u3002\u4e3a\u4e86\u63d0\u9ad8\u76d1\u542c\u7684\u9c81\u68d2\u6027，\u9700\u8981\u6dfb\u52a0\u5f02\u5e38\u5904\u7406\u4ee3\u7801\u6765\u6355\u83b7\u8fd9\u4e9b\u6f5c\u5728\u7684\u9519\u8bef： <\/p>\n
try:
\n start_server('***.*.*.*', 12345)
\nexcept socket.error as e:
\n print(f"Server error: {e}")
\nexcept KeyboardInterrupt:
\n print("Server stopped by user")
\nfinally:
\n server_socket.close()<\/p>\n
\u5b9e\u65f6\u5904\u7406\u6570\u636e\u6d41\u662f\u53cc\u5411\u901a\u4fe1\u7684\u6838\u5fc3，\u9700\u8981\u6839\u636e\u5e94\u7528\u573a\u666f\u7684\u4e0d\u540c\u9009\u62e9\u5408\u9002\u7684\u7b56\u7565\u3002 <\/p>\n
\u7531\u4e8e\u7f51\u7edc\u5ef6\u8fdf\u548c\u6570\u636e\u5305\u5230\u8fbe\u65f6\u95f4\u7684\u4e0d\u786e\u5b9a\u6027，\u6570\u636e\u6d41\u9700\u8981\u7f13\u51b2\u6765\u4fdd\u8bc1\u6570\u636e\u4e0d\u4f1a\u4e22\u5931\u3002\u53ef\u4ee5\u4f7f\u7528\u961f\u5217\u6216\u8005\u73af\u5f62\u7f13\u51b2\u533a\u6765\u5b9e\u73b0\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u7b80\u5355\u7684\u73af\u5f62\u7f13\u51b2\u533a\u7684\u5b9e\u73b0\u793a\u4f8b： <\/p>\n
class CircularBuffer:
\n def __init__(self, size):
\n self.buffer = bytearray(size)
\n self.head = 0
\n self.tail = 0
\n self.size = size<\/p>\n
def write(self, data):
\n if self.head == self.tail and self.buffer[self.head] is not None:
\n raise BufferError("Buffer full")
\n write_size = len(data)
\n buffer_free_space = self.size – (self.head – self.tail) % self.size
\n if write_size > buffer_free_space:
\n data = data[:buffer_free_space]
\n self.buffer[self.head:self.head + len(data)] = data
\n self.head = (self.head + len(data)) % self.size<\/p>\n
def read(self, size):
\n read_size = min(size, self.size – (self.tail – self.head) % self.size)
\n data = self.buffer[self.tail:self.tail + read_size]
\n self.tail = (self.tail + read_size) % self.size
\n return data<\/p>\n
\u5b9e\u65f6\u6570\u636e\u6d41\u5904\u7406\u4e2d，\u4f18\u5316\u7b56\u7565\u4e3b\u8981\u5173\u6ce8\u4e8e\u51cf\u5c11\u5ef6\u8fdf\u548c\u63d0\u9ad8\u541e\u5410\u91cf\u3002\u5e38\u89c1\u7684\u4f18\u5316\u624b\u6bb5\u5305\u62ec： <\/p>\n
\u8fd9\u91cc\u5c55\u793a\u4e00\u4e2a\u7b80\u5355\u7684\u4f7f\u7528\u7ebf\u7a0b\u6c60\u6765\u5904\u7406\u6570\u636e\u6d41\u7684\u4f8b\u5b50： <\/p>\n
import threading
\nimport queue<\/p>\n
def process_data(data_queue):
\n while True:
\n data = data_queue.get()
\n if data is None:
\n break
\n # \u5904\u7406\u6570\u636e
\n print(f"Processing data: {data}")
\n data_queue.task_done()<\/p>\n
data_queue = queue.Queue()
\nnum_workers = 4<\/p>\n
# \u542f\u52a8\u7ebf\u7a0b\u6c60
\nthreads = []
\nfor _ in range(num_workers):
\n t = threading.Thread(target=process_data, args=(data_queue,))
\n t.daemon = True
\n t.start()
\n threads.append(t)<\/p>\n
# \u5047\u8bbe\u8fd9\u91cc\u6709\u6570\u636e\u6d41\u9700\u8981\u5904\u7406
\nfor i in range(10):
\n data_queue.put(f"Data packet {i}")<\/p>\n
# \u7b49\u5f85\u6240\u6709\u6570\u636e\u5904\u7406\u5b8c\u6bd5
\ndata_queue.join()<\/p>\n
# \u5173\u95ed\u7ebf\u7a0b\u6c60
\nfor _ in range(num_workers):
\n data_queue.put(None)
\nfor t in threads:
\n t.join()<\/p>\n
\u5728\u672c\u7ae0\u4e2d，\u6211\u4eec\u8be6\u7ec6\u63a2\u8ba8\u4e86\u53cc\u5411\u901a\u4fe1\u7684\u5b9e\u73b0，\u76d1\u542c\u673a\u5236\u7684\u5efa\u7acb，\u4ee5\u53ca\u5b9e\u65f6\u6570\u636e\u6d41\u7684\u5904\u7406\u3002\u4e0b\u4e00\u7ae0\u5c06\u7ee7\u7eed\u63a2\u8ba8\u5728\u73b0\u4ee3\u7f51\u7edc\u5e94\u7528\u4e2d\u81f3\u5173\u91cd\u8981\u7684\u6027\u80fd\u76d1\u63a7\u4e0e\u670d\u52a1\u8d28\u91cf\u53cd\u9988\u673a\u5236\u3002 <\/p>\n
\u672c\u6587\u8fd8\u6709\u914d\u5957\u7684\u7cbe\u54c1\u8d44\u6e90，\u70b9\u51fb\u83b7\u53d6 <\/p>\n
\u7b80\u4ecb：RTP\u534f\u8bae\u662f\u7f51\u7edc\u901a\u4fe1\u4e2d\u7528\u4e8e\u5b9e\u65f6\u4f20\u8f93\u591a\u5a92\u4f53\u6570\u636e\u7684\u5173\u952e\u534f\u8bae，\u5e38\u4e0eRTCP\u5e76\u7528\u4ee5\u76d1\u63a7\u670d\u52a1\u8d28\u91cf\u3002\u672c\u5b9e\u73b0\u7a0b\u5e8f\u5c55\u793a\u4e86\u5982\u4f55\u540c\u65f6\u4f5c\u4e3a\u670d\u52a1\u5668\u548c\u5ba2\u6237\u7aef\u8fd0\u884cRTP\u4f1a\u8bdd，\u6db5\u76d6\u4ece\u6570\u636e\u5305\u751f\u6210\u3001\u53d1\u9001\u3001\u63a5\u6536\u5230\u540c\u6b65\u7684\u5b8c\u6574\u6d41\u7a0b\u3002\u5f00\u53d1\u8005\u901a\u8fc7\u638c\u63e1\u7f51\u7edc\u7f16\u7a0b\u548c\u591a\u7ebf\u7a0b\u6280\u672f，\u80fd\u591f\u6784\u5efa\u51fa\u652f\u6301\u53cc\u5411\u901a\u4fe1\u7684RTP\u7cfb\u7edf，\u5e76\u5904\u7406\u5982\u5ef6\u8fdf\u3001\u6296\u52a8\u7b49\u5b9e\u65f6\u6027\u95ee\u9898\u3002 <\/p>\n
\u672c\u6587\u8fd8\u6709\u914d\u5957\u7684\u7cbe\u54c1\u8d44\u6e90，\u70b9\u51fb\u83b7\u53d6 <\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.3k\u6b21\uff0c\u70b9\u8d5e10\u6b21\uff0c\u6536\u85cf14\u6b21\u3002\u672c\u6587\u8fd8\u6709\u914d\u5957\u7684\u7cbe\u54c1\u8d44\u6e90\uff0c\u70b9\u51fb\u83b7\u53d6 \u7b80\u4ecb\uff1aRTP\u534f\u8bae\u662f\u7f51\u7edc\u901a\u4fe1\u4e2d\u7528\u4e8e\u5b9e\u65f6\u4f20\u8f93\u591a\u5a92\u4f53\u6570\u636e\u7684\u5173\u952e\u534f\u8bae\uff0c\u5e38\u4e0eRTCP\u5e76\u7528\u4ee5\u76d1\u63a7\u670d\u52a1\u8d28\u91cf\u3002\u672c\u5b9e\u73b0\u7a0b\u5e8f\u5c55\u793a\u4e86\u5982\u4f55\u540c\u65f6\u4f5c\u4e3a\u670d\u52a1\u5668\u548c\u5ba2\u6237\u7aef\u8fd0\u884cRTP\u4f1a\u8bdd\uff0c\u6db5\u76d6\u4ece\u6570\u636e\u5305\u751f\u6210\u3001\u53d1\u9001\u3001\u63a5\u6536\u5230\u540c\u6b65\u7684\u5b8c\u6574\u6d41\u7a0b\u3002\u5f00\u53d1\u8005\u901a\u8fc7\u638c\u63e1\u7f51\u7edc\u7f16\u7a0b\u548c\u591a\u7ebf\u7a0b\u6280\u672f\uff0c\u80fd\u591f\u6784\u5efa\u51fa\u652f\u6301\u53cc\u5411\u901a\u4fe1\u7684RTP\u7cfb\u7edf\uff0c\u5e76\u5904\u7406\u5982\u5ef6\u8fdf\u3001\u6296\u52a8\u7b49\u5b9e\u65f6\u6027\u95ee\u9898\u3002 1. RTP\u534f\u8bae\u7684\u57fa\u672c\u7ed3\u6784\u548c…_rtp\u670d\u52a1\u5668<\/p>\n","protected":false},"author":2,"featured_media":21378,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"topic":[],"class_list":["post-21380","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server"],"yoast_head":"\n