转:使用Live555类库实现的网络直播系统

Live555主要有四个类库：

libUsageEnvironment.lib；libliveMedia.lib；libgroupsock.lib；libBasicUsageEnvironment.lib

将这四个类库以及相关的头文件导入VC++2010之后，可以轻松实现网络直播系统。

在这里直接贴上完整代码，粘贴到VC里面就可以运行。

注：程序运行后，使用播放器软件（VLC Media Player，FFplay等），打开URL：rtp://239.255.42.42:1234，即可收看直播的视频。

[cpp] view plaincopy

1. // 网络直播系统.cpp : 定义控制台应用程序的入口点。
2. // 雷霄骅
3. // 中国传媒大学/数字电视技术
4. // [email protected]
5. #include "stdafx.h"
6. #include "liveMedia.hh"
7. #include "BasicUsageEnvironment.hh"
8. #include "GroupsockHelper.hh"
9. //#define IMPLEMENT_RTSP_SERVER
10. //#define USE_SSM 1
11. #ifdef USE_SSM
12. Boolean const isSSM = True;
13. #else
14. Boolean const isSSM = False;
15. #endif
16. #define TRANSPORT_PACKET_SIZE 188
17. #define TRANSPORT_PACKETS_PER_NETWORK_PACKET 7
18. UsageEnvironment* env;
19. char const* inputFileName = "test.ts";
20. FramedSource* videoSource;
21. RTPSink* videoSink;
22. void play(); // forward
23. int main(int argc, char** argv) {
24. // 首先建立使用环境：
25. TaskScheduler* scheduler = BasicTaskScheduler::createNew();
26. env = BasicUsageEnvironment::createNew(*scheduler);
27. // 创建 ‘groupsocks‘ for RTP and RTCP:
28. char const* destinationAddressStr
29. #ifdef USE_SSM
30. = "232.255.42.42";
31. #else
32. = "239.255.42.42";
33. // Note: 这是一个多播地址。如果你希望流使用单播地址,然后替换这个字符串与单播地址
34. #endif
35. const unsigned short rtpPortNum = 1234;
36. const unsigned short rtcpPortNum = rtpPortNum+1;
37. const unsigned char ttl = 7; //
38. struct in_addr destinationAddress;
39. destinationAddress.s_addr = our_inet_addr(destinationAddressStr);
40. const Port rtpPort(rtpPortNum);
41. const Port rtcpPort(rtcpPortNum);
42. Groupsock rtpGroupsock(*env, destinationAddress, rtpPort, ttl);
43. Groupsock rtcpGroupsock(*env, destinationAddress, rtcpPort, ttl);
44. #ifdef USE_SSM
45. rtpGroupsock.multicastSendOnly();
46. rtcpGroupsock.multicastSendOnly();
47. #endif
48. // 创建一个适当的“RTPSink”:
49. videoSink =
50. SimpleRTPSink::createNew(*env, &rtpGroupsock, 33, 90000, "video", "mp2t",
51. 1, True, False /*no ‘M‘ bit*/);
52. const unsigned estimatedSessionBandwidth = 5000; // in kbps; for RTCP b/w share
53. const unsigned maxCNAMElen = 100;
54. unsigned char CNAME[maxCNAMElen+1];
55. gethostname((char*)CNAME, maxCNAMElen);
56. CNAME[maxCNAMElen] = ‘\0‘;
57. #ifdef IMPLEMENT_RTSP_SERVER
58. RTCPInstance* rtcp =
59. #endif
60. RTCPInstance::createNew(*env, &rtcpGroupsock,
61. estimatedSessionBandwidth, CNAME,
62. videoSink, NULL /* we‘re a server */, isSSM);
63. // 开始自动运行的媒体
64. #ifdef IMPLEMENT_RTSP_SERVER
65. RTSPServer* rtspServer = RTSPServer::createNew(*env);
66. if (rtspServer == NULL) {
67. *env << "Failed to create RTSP server: " << env->getResultMsg() << "\n";
68. exit(1);
69. }
70. ServerMediaSession* sms
71. = ServerMediaSession::createNew(*env, "testStream", inputFileName,
72. "Session streamed by \"testMPEG2TransportStreamer\"",
73. isSSM);
74. sms->addSubsession(PassiveServerMediaSubsession::createNew(*videoSink, rtcp));
75. rtspServer->addServerMediaSession(sms);
76. char* url = rtspServer->rtspURL(sms);
77. *env << "Play this stream using the URL \"" << url << "\"\n";
78. delete[] url;
79. #endif
80. *env << "开始发送流媒体...\n";
81. play();
82. env->taskScheduler().doEventLoop();
83. return 0; // 只是为了防止编译器警告
84. }
85. void afterPlaying(void* /*clientData*/) {
86. *env << "...从文件中读取完毕\n";
87. Medium::close(videoSource);
88. // 将关闭从源读取的输入文件
89. play();
90. }
91. void play() {
92. unsigned const inputDataChunkSize
93. = TRANSPORT_PACKETS_PER_NETWORK_PACKET*TRANSPORT_PACKET_SIZE;
94. // 打开输入文件作为一个“ByteStreamFileSource":
95. ByteStreamFileSource* fileSource
96. = ByteStreamFileSource::createNew(*env, inputFileName, inputDataChunkSize);
97. if (fileSource == NULL) {
98. *env << "无法打开文件 \"" << inputFileName
99. << "\" 作为 file source\n";
100. exit(1);
101. }
102. videoSource = MPEG2TransportStreamFramer::createNew(*env, fileSource);
103. *env << "Beginning to read from file...\n";
104. videoSink->startPlaying(*videoSource, afterPlaying, videoSink);
105. }

[cpp] view plaincopy

1. // 网络直播系统.cpp : 定义控制台应用程序的入口点。
2. // 雷霄骅
3. // 中国传媒大学/数字电视技术
4. // [email protected]
5. #include "stdafx.h"
6. #include "liveMedia.hh"
7. #include "BasicUsageEnvironment.hh"
8. #include "GroupsockHelper.hh"
9. //#define IMPLEMENT_RTSP_SERVER
10. //#define USE_SSM 1
11. #ifdef USE_SSM
12. Boolean const isSSM = True;
13. #else
14. Boolean const isSSM = False;
15. #endif
16. #define TRANSPORT_PACKET_SIZE 188
17. #define TRANSPORT_PACKETS_PER_NETWORK_PACKET 7
18. UsageEnvironment* env;
19. char const* inputFileName = "test.ts";
20. FramedSource* videoSource;
21. RTPSink* videoSink;
22. void play(); // forward
23. int main(int argc, char** argv) {
24. // 首先建立使用环境：
25. TaskScheduler* scheduler = BasicTaskScheduler::createNew();
26. env = BasicUsageEnvironment::createNew(*scheduler);
27. // 创建 ‘groupsocks‘ for RTP and RTCP:
28. char const* destinationAddressStr
29. #ifdef USE_SSM
30. = "232.255.42.42";
31. #else
32. = "239.255.42.42";
33. // Note: 这是一个多播地址。如果你希望流使用单播地址,然后替换这个字符串与单播地址
34. #endif
35. const unsigned short rtpPortNum = 1234;
36. const unsigned short rtcpPortNum = rtpPortNum+1;
37. const unsigned char ttl = 7; //
38. struct in_addr destinationAddress;
39. destinationAddress.s_addr = our_inet_addr(destinationAddressStr);
40. const Port rtpPort(rtpPortNum);
41. const Port rtcpPort(rtcpPortNum);
42. Groupsock rtpGroupsock(*env, destinationAddress, rtpPort, ttl);
43. Groupsock rtcpGroupsock(*env, destinationAddress, rtcpPort, ttl);
44. #ifdef USE_SSM
45. rtpGroupsock.multicastSendOnly();
46. rtcpGroupsock.multicastSendOnly();
47. #endif
48. // 创建一个适当的“RTPSink”:
49. videoSink =
50. SimpleRTPSink::createNew(*env, &rtpGroupsock, 33, 90000, "video", "mp2t",
51. 1, True, False /*no ‘M‘ bit*/);
52. const unsigned estimatedSessionBandwidth = 5000; // in kbps; for RTCP b/w share
53. const unsigned maxCNAMElen = 100;
54. unsigned char CNAME[maxCNAMElen+1];
55. gethostname((char*)CNAME, maxCNAMElen);
56. CNAME[maxCNAMElen] = ‘\0‘;
57. #ifdef IMPLEMENT_RTSP_SERVER
58. RTCPInstance* rtcp =
59. #endif
60. RTCPInstance::createNew(*env, &rtcpGroupsock,
61. estimatedSessionBandwidth, CNAME,
62. videoSink, NULL /* we‘re a server */, isSSM);
63. // 开始自动运行的媒体
64. #ifdef IMPLEMENT_RTSP_SERVER
65. RTSPServer* rtspServer = RTSPServer::createNew(*env);
66. if (rtspServer == NULL) {
67. *env << "Failed to create RTSP server: " << env->getResultMsg() << "\n";
68. exit(1);
69. }
70. ServerMediaSession* sms
71. = ServerMediaSession::createNew(*env, "testStream", inputFileName,
72. "Session streamed by \"testMPEG2TransportStreamer\"",
73. isSSM);
74. sms->addSubsession(PassiveServerMediaSubsession::createNew(*videoSink, rtcp));
75. rtspServer->addServerMediaSession(sms);
76. char* url = rtspServer->rtspURL(sms);
77. *env << "Play this stream using the URL \"" << url << "\"\n";
78. delete[] url;
79. #endif
80. *env << "开始发送流媒体...\n";
81. play();
82. env->taskScheduler().doEventLoop();
83. return 0; // 只是为了防止编译器警告
84. }
85. void afterPlaying(void* /*clientData*/) {
86. *env << "...从文件中读取完毕\n";
87. Medium::close(videoSource);
88. // 将关闭从源读取的输入文件
89. play();
90. }
91. void play() {
92. unsigned const inputDataChunkSize
93. = TRANSPORT_PACKETS_PER_NETWORK_PACKET*TRANSPORT_PACKET_SIZE;
94. // 打开输入文件作为一个“ByteStreamFileSource":
95. ByteStreamFileSource* fileSource
96. = ByteStreamFileSource::createNew(*env, inputFileName, inputDataChunkSize);
97. if (fileSource == NULL) {
98. *env << "无法打开文件 \"" << inputFileName
99. << "\" 作为 file source\n";
100. exit(1);
101. }
102. videoSource = MPEG2TransportStreamFramer::createNew(*env, fileSource);
103. *env << "Beginning to read from file...\n";
104. videoSink->startPlaying(*videoSource, afterPlaying, videoSink);
105. }

完整工程下载地址：http://download.csdn.net/detail/leixiaohua1020/6272839

[cpp] view plaincopy

1. <pre code_snippet_id="149063" snippet_file_name="blog_20140109_2_4549023"></pre>
2. <pre></pre>
3. <pre></pre>

[cpp] view plaincopy

1. <pre code_snippet_id="149063" snippet_file_name="blog_20140109_2_4549023"></pre>
2. <pre></pre>