=====================================================

RTMPdump(libRTMP) 源代码分析系列文章：

RTMPdump 源代码分析 1： main()函数

RTMPDump (libRTMP) 源代码分析2：解析RTMP地址——RTMP_ParseURL()

RTMPdump (libRTMP) 源代码分析3： AMF编码

RTMPdump (libRTMP) 源代码分析4： 连接第一步——握手 (HandShake)

RTMPdump (libRTMP) 源代码分析5： 建立一个流媒体连接  (NetConnection部分)

RTMPdump (libRTMP) 源代码分析6： 建立一个流媒体连接  (NetStream部分 1)

RTMPdump (libRTMP) 源代码分析7： 建立一个流媒体连接  (NetStream部分 2)

RTMPdump (libRTMP) 源代码分析8： 发送消息 (Message)

RTMPdump (libRTMP) 源代码分析9： 接收消息 (Message)  (接收视音频数据)

RTMPdump (libRTMP) 源代码分析10： 处理各种消息 (Message)

=====================================================

函数调用结构图

RTMPDump (libRTMP)的整体的函数调用结构图如下图所示。

单击查看大图

详细分析

书接上回：RTMPdump 源代码分析 6： 建立一个流媒体连接 （NetStream部分 1）

上回说到，有两个函数尤为重要：

RTMP_ReadPacket()

RTMP_ClientPacket()

而且分析了第一个函数。现在我们再来看看第二个函数吧。 第二个函数的主要作用是：处理消息（Message），并做出响应。

先把带注释的代码贴上：

[cpp] view plaincopy
  1. //处理接收到的Chunk
  2. int
  3. RTMP_ClientPacket(RTMP *r, RTMPPacket *packet)
  4. {
  5. int bHasMediaPacket = 0;
  6. switch (packet->m_packetType)
  7. {
  8. //RTMP消息类型ID=1,设置块大小
  9. case 0x01:
  10. /* chunk size */
  11. //----------------
  12. r->dlg->AppendCInfo("处理收到的数据。消息 Set Chunk Size (typeID=1)。");
  13. //-----------------------------
  14. RTMP_LogPrintf("处理消息 Set Chunk Size (typeID=1)\n");
  15. HandleChangeChunkSize(r, packet);
  16. break;
  17. //RTMP消息类型ID=3，致谢
  18. case 0x03:
  19. /* bytes read report */
  20. RTMP_Log(RTMP_LOGDEBUG, "%s, received: bytes read report", __FUNCTION__);
  21. break;
  22. //RTMP消息类型ID=4，用户控制
  23. case 0x04:
  24. /* ctrl */
  25. //----------------
  26. r->dlg->AppendCInfo("处理收到的数据。消息 User Control (typeID=4)。");
  27. //-----------------------------
  28. RTMP_LogPrintf("处理消息 User Control (typeID=4)\n");
  29. HandleCtrl(r, packet);
  30. break;
  31. //RTMP消息类型ID=5
  32. case 0x05:
  33. /* server bw */
  34. //----------------
  35. r->dlg->AppendCInfo("处理收到的数据。消息 Window Acknowledgement Size (typeID=5)。");
  36. //-----------------------------
  37. RTMP_LogPrintf("处理消息 Window Acknowledgement Size (typeID=5)\n");
  38. HandleServerBW(r, packet);
  39. break;
  40. //RTMP消息类型ID=6
  41. case 0x06:
  42. /* client bw */
  43. //----------------
  44. r->dlg->AppendCInfo("处理收到的数据。消息 Set Peer Bandwidth (typeID=6)。");
  45. //-----------------------------
  46. RTMP_LogPrintf("处理消息 Set Peer Bandwidth (typeID=6)\n");
  47. HandleClientBW(r, packet);
  48. break;
  49. //RTMP消息类型ID=8，音频数据
  50. case 0x08:
  51. /* audio data */
  52. /*RTMP_Log(RTMP_LOGDEBUG, "%s, received: audio %lu bytes", __FUNCTION__, packet.m_nBodySize); */
  53. HandleAudio(r, packet);
  54. bHasMediaPacket = 1;
  55. if (!r->m_mediaChannel)
  56. r->m_mediaChannel = packet->m_nChannel;
  57. if (!r->m_pausing)
  58. r->m_mediaStamp = packet->m_nTimeStamp;
  59. break;
  60. //RTMP消息类型ID=9，视频数据
  61. case 0x09:
  62. /* video data */
  63. /*RTMP_Log(RTMP_LOGDEBUG, "%s, received: video %lu bytes", __FUNCTION__, packet.m_nBodySize); */
  64. HandleVideo(r, packet);
  65. bHasMediaPacket = 1;
  66. if (!r->m_mediaChannel)
  67. r->m_mediaChannel = packet->m_nChannel;
  68. if (!r->m_pausing)
  69. r->m_mediaStamp = packet->m_nTimeStamp;
  70. break;
  71. //RTMP消息类型ID=15，AMF3编码，忽略
  72. case 0x0F:          /* flex stream send */
  73. RTMP_Log(RTMP_LOGDEBUG,
  74. "%s, flex stream send, size %lu bytes, not supported, ignoring",
  75. __FUNCTION__, packet->m_nBodySize);
  76. break;
  77. //RTMP消息类型ID=16，AMF3编码，忽略
  78. case 0x10:          /* flex shared object */
  79. RTMP_Log(RTMP_LOGDEBUG,
  80. "%s, flex shared object, size %lu bytes, not supported, ignoring",
  81. __FUNCTION__, packet->m_nBodySize);
  82. break;
  83. //RTMP消息类型ID=17，AMF3编码，忽略
  84. case 0x11:          /* flex message */
  85. {
  86. RTMP_Log(RTMP_LOGDEBUG,
  87. "%s, flex message, size %lu bytes, not fully supported",
  88. __FUNCTION__, packet->m_nBodySize);
  89. /*RTMP_LogHex(packet.m_body, packet.m_nBodySize); */
  90. /* some DEBUG code */
  91. #if 0
  92. RTMP_LIB_AMFObject obj;
  93. int nRes = obj.Decode(packet.m_body+1, packet.m_nBodySize-1);
  94. if(nRes < 0) {
  95. RTMP_Log(RTMP_LOGERROR, "%s, error decoding AMF3 packet", __FUNCTION__);
  96. /*return; */
  97. }
  98. obj.Dump();
  99. #endif
  100. if (HandleInvoke(r, packet->m_body + 1, packet->m_nBodySize - 1) == 1)
  101. bHasMediaPacket = 2;
  102. break;
  103. }
  104. //RTMP消息类型ID=18，AMF0编码，数据消息
  105. case 0x12:
  106. /* metadata (notify) */
  107. RTMP_Log(RTMP_LOGDEBUG, "%s, received: notify %lu bytes", __FUNCTION__,
  108. packet->m_nBodySize);
  109. //处理元数据,暂时注释
  110. /*
  111. if (HandleMetadata(r, packet->m_body, packet->m_nBodySize))
  112. bHasMediaPacket = 1;
  113. break;
  114. */
  115. //RTMP消息类型ID=19，AMF0编码，忽略
  116. case 0x13:
  117. RTMP_Log(RTMP_LOGDEBUG, "%s, shared object, not supported, ignoring",
  118. __FUNCTION__);
  119. break;
  120. //RTMP消息类型ID=20，AMF0编码，命令消息
  121. //处理命令消息！
  122. case 0x14:
  123. //----------------
  124. r->dlg->AppendCInfo("处理收到的数据。消息 命令 (AMF0编码) (typeID=20)。");
  125. //-----------------------------
  126. /* invoke */
  127. RTMP_Log(RTMP_LOGDEBUG, "%s, received: invoke %lu bytes", __FUNCTION__,
  128. packet->m_nBodySize);
  129. RTMP_LogPrintf("处理命令消息 (typeID=20，AMF0编码)\n");
  130. /*RTMP_LogHex(packet.m_body, packet.m_nBodySize); */
  131. if (HandleInvoke(r, packet->m_body, packet->m_nBodySize) == 1)
  132. bHasMediaPacket = 2;
  133. break;
  134. //RTMP消息类型ID=22
  135. case 0x16:
  136. {
  137. /* go through FLV packets and handle metadata packets */
  138. unsigned int pos = 0;
  139. uint32_t nTimeStamp = packet->m_nTimeStamp;
  140. while (pos + 11 < packet->m_nBodySize)
  141. {
  142. uint32_t dataSize = AMF_DecodeInt24(packet->m_body + pos + 1);   /* size without header (11) and prevTagSize (4) */
  143. if (pos + 11 + dataSize + 4 > packet->m_nBodySize)
  144. {
  145. RTMP_Log(RTMP_LOGWARNING, "Stream corrupt?!");
  146. break;
  147. }
  148. if (packet->m_body[pos] == 0x12)
  149. {
  150. HandleMetadata(r, packet->m_body + pos + 11, dataSize);
  151. }
  152. else if (packet->m_body[pos] == 8 || packet->m_body[pos] == 9)
  153. {
  154. nTimeStamp = AMF_DecodeInt24(packet->m_body + pos + 4);
  155. nTimeStamp |= (packet->m_body[pos + 7] << 24);
  156. }
  157. pos += (11 + dataSize + 4);
  158. }
  159. if (!r->m_pausing)
  160. r->m_mediaStamp = nTimeStamp;
  161. /* FLV tag(s) */
  162. /*RTMP_Log(RTMP_LOGDEBUG, "%s, received: FLV tag(s) %lu bytes", __FUNCTION__, packet.m_nBodySize); */
  163. bHasMediaPacket = 1;
  164. break;
  165. }
  166. default:
  167. RTMP_Log(RTMP_LOGDEBUG, "%s, unknown packet type received: 0x%02x", __FUNCTION__,
  168. packet->m_packetType);
  169. #ifdef _DEBUG
  170. RTMP_LogHex(RTMP_LOGDEBUG, (const uint8_t *)packet->m_body, packet->m_nBodySize);
  171. #endif
  172. }
  173. return bHasMediaPacket;
  174. }

里面注释的比较多，可以看出，大体的思路是，根据接收到的消息（Message）类型的不同，做出不同的响应。例如收到的消息类型为0x01，那么就是设置块（Chunk）大小的协议，那么就调用相应的函数进行处理。

因此，本函数可以说是程序的灵魂，收到的各种命令消息都要经过本函数的判断决定调用哪个函数进行相应的处理。

在这里注意一下消息类型为0x14的消息，即消息类型ID为20的消息，是AMF0编码的命令消息。这在RTMP连接中是非常常见的，比如说各种控制命令：播放，暂停，停止等等。我们来仔细看看它的调用。

可以发现它调用了HandleInvoke()函数来处理服务器发来的AMF0编码的命令，来看看细节：

[cpp] view plaincopy
  1. /* Returns 0 for OK/Failed/error, 1 for 'Stop or Complete' */
  2. static int
  3. HandleInvoke(RTMP *r, const char *body, unsigned int nBodySize)
  4. {
  5. AMFObject obj;
  6. AVal method;
  7. int txn;
  8. int ret = 0, nRes;
  9. if (body[0] != 0x02)      /* make sure it is a string method name we start with */
  10. {
  11. RTMP_Log(RTMP_LOGWARNING, "%s, Sanity failed. no string method in invoke packet",
  12. __FUNCTION__);
  13. return 0;
  14. }
  15. nRes = AMF_Decode(&obj, body, nBodySize, FALSE);
  16. if (nRes < 0)
  17. {
  18. RTMP_Log(RTMP_LOGERROR, "%s, error decoding invoke packet", __FUNCTION__);
  19. return 0;
  20. }
  21. AMF_Dump(&obj);
  22. AMFProp_GetString(AMF_GetProp(&obj, NULL, 0), &method);
  23. txn = (int)AMFProp_GetNumber(AMF_GetProp(&obj, NULL, 1));
  24. RTMP_Log(RTMP_LOGDEBUG, "%s, server invoking <%s>", __FUNCTION__, method.av_val);
  25. if (AVMATCH(&method, &av__result))
  26. {
  27. AVal methodInvoked = {0};
  28. int i;
  29. for (i=0; i<r->m_numCalls; i++) {
  30. if (r->m_methodCalls[i].num == txn) {
  31. methodInvoked = r->m_methodCalls[i].name;
  32. AV_erase(r->m_methodCalls, &r->m_numCalls, i, FALSE);
  33. break;
  34. }
  35. }
  36. if (!methodInvoked.av_val) {
  37. RTMP_Log(RTMP_LOGDEBUG, "%s, received result id %d without matching request",
  38. __FUNCTION__, txn);
  39. goto leave;
  40. }
  41. //----------------
  42. char temp_str[100];
  43. sprintf(temp_str,"接收数据。消息 %s 的 Result",methodInvoked.av_val);
  44. r->dlg->AppendCInfo(temp_str);
  45. //-----------------------------
  46. RTMP_Log(RTMP_LOGDEBUG, "%s, received result for method call <%s>", __FUNCTION__,
  47. methodInvoked.av_val);
  48. if (AVMATCH(&methodInvoked, &av_connect))
  49. {
  50. //----------------
  51. r->dlg->AppendMLInfo(20,0,"命令消息","Result (Connect)");
  52. //-----------------------------
  53. if (r->Link.token.av_len)
  54. {
  55. AMFObjectProperty p;
  56. if (RTMP_FindFirstMatchingProperty(&obj, &av_secureToken, &p))
  57. {
  58. DecodeTEA(&r->Link.token, &p.p_vu.p_aval);
  59. SendSecureTokenResponse(r, &p.p_vu.p_aval);
  60. }
  61. }
  62. if (r->Link.protocol & RTMP_FEATURE_WRITE)
  63. {
  64. SendReleaseStream(r);
  65. SendFCPublish(r);
  66. }
  67. else
  68. {
  69. //----------------
  70. r->dlg->AppendCInfo("发送数据。消息 Window Acknowledgement Size (typeID=5)。");
  71. //-----------------------------
  72. RTMP_LogPrintf("发送消息Window Acknowledgement Size(typeID=5)\n");
  73. RTMP_SendServerBW(r);
  74. RTMP_SendCtrl(r, 3, 0, 300);
  75. }
  76. //----------------
  77. r->dlg->AppendCInfo("发送数据。消息 命令 (typeID=20) (CreateStream)。");
  78. //-----------------------------
  79. RTMP_LogPrintf("发送命令消息“CreateStream” (typeID=20)\n");
  80. RTMP_SendCreateStream(r);
  81. if (!(r->Link.protocol & RTMP_FEATURE_WRITE))
  82. {
  83. /* Send the FCSubscribe if live stream or if subscribepath is set */
  84. if (r->Link.subscribepath.av_len)
  85. SendFCSubscribe(r, &r->Link.subscribepath);
  86. else if (r->Link.lFlags & RTMP_LF_LIVE)
  87. SendFCSubscribe(r, &r->Link.playpath);
  88. }
  89. }
  90. else if (AVMATCH(&methodInvoked, &av_createStream))
  91. {
  92. //----------------
  93. r->dlg->AppendMLInfo(20,0,"命令消息","Result (CreateStream)");
  94. //-----------------------------
  95. r->m_stream_id = (int)AMFProp_GetNumber(AMF_GetProp(&obj, NULL, 3));
  96. if (r->Link.protocol & RTMP_FEATURE_WRITE)
  97. {
  98. SendPublish(r);
  99. }
  100. else
  101. {
  102. if (r->Link.lFlags & RTMP_LF_PLST)
  103. SendPlaylist(r);
  104. //----------------
  105. r->dlg->AppendCInfo("发送数据。消息 命令 (typeID=20) (Play)。");
  106. //-----------------------------
  107. RTMP_LogPrintf("发送命令消息“play” (typeID=20)\n");
  108. SendPlay(r);
  109. RTMP_SendCtrl(r, 3, r->m_stream_id, r->m_nBufferMS);
  110. }
  111. }
  112. else if (AVMATCH(&methodInvoked, &av_play) ||
  113. AVMATCH(&methodInvoked, &av_publish))
  114. {
  115. //----------------
  116. r->dlg->AppendMLInfo(20,0,"命令消息","Result (Play or Publish)");
  117. //-----------------------------
  118. r->m_bPlaying = TRUE;
  119. }
  120. free(methodInvoked.av_val);
  121. }
  122. else if (AVMATCH(&method, &av_onBWDone))
  123. {
  124. //----------------
  125. r->dlg->AppendMLInfo(20,0,"命令消息","onBWDone");
  126. //-----------------------------
  127. if (!r->m_nBWCheckCounter)
  128. SendCheckBW(r);
  129. }
  130. else if (AVMATCH(&method, &av_onFCSubscribe))
  131. {
  132. /* SendOnFCSubscribe(); */
  133. }
  134. else if (AVMATCH(&method, &av_onFCUnsubscribe))
  135. {
  136. //----------------
  137. r->dlg->AppendMLInfo(20,0,"命令消息","onFCUnsubscribe");
  138. //-----------------------------
  139. RTMP_Close(r);
  140. ret = 1;
  141. }
  142. else if (AVMATCH(&method, &av_ping))
  143. {
  144. //----------------
  145. r->dlg->AppendMLInfo(20,0,"命令消息","Ping");
  146. //-----------------------------
  147. SendPong(r, txn);
  148. }
  149. else if (AVMATCH(&method, &av__onbwcheck))
  150. {
  151. //----------------
  152. r->dlg->AppendMLInfo(20,0,"命令消息","onBWcheck");
  153. //-----------------------------
  154. SendCheckBWResult(r, txn);
  155. }
  156. else if (AVMATCH(&method, &av__onbwdone))
  157. {
  158. //----------------
  159. r->dlg->AppendMLInfo(20,0,"命令消息","onBWdone");
  160. //-----------------------------
  161. int i;
  162. for (i = 0; i < r->m_numCalls; i++)
  163. if (AVMATCH(&r->m_methodCalls[i].name, &av__checkbw))
  164. {
  165. AV_erase(r->m_methodCalls, &r->m_numCalls, i, TRUE);
  166. break;
  167. }
  168. }
  169. else if (AVMATCH(&method, &av__error))
  170. {
  171. //----------------
  172. r->dlg->AppendMLInfo(20,0,"命令消息","error");
  173. //-----------------------------
  174. RTMP_Log(RTMP_LOGERROR, "rtmp server sent error");
  175. }
  176. else if (AVMATCH(&method, &av_close))
  177. {
  178. //----------------
  179. r->dlg->AppendMLInfo(20,0,"命令消息","close");
  180. //-----------------------------
  181. RTMP_Log(RTMP_LOGERROR, "rtmp server requested close");
  182. RTMP_Close(r);
  183. }
  184. else if (AVMATCH(&method, &av_onStatus))
  185. {
  186. //----------------
  187. r->dlg->AppendMLInfo(20,0,"命令消息","onStatus");
  188. //-----------------------------
  189. AMFObject obj2;
  190. AVal code, level;
  191. AMFProp_GetObject(AMF_GetProp(&obj, NULL, 3), &obj2);
  192. AMFProp_GetString(AMF_GetProp(&obj2, &av_code, -1), &code);
  193. AMFProp_GetString(AMF_GetProp(&obj2, &av_level, -1), &level);
  194. RTMP_Log(RTMP_LOGDEBUG, "%s, onStatus: %s", __FUNCTION__, code.av_val);
  195. if (AVMATCH(&code, &av_NetStream_Failed)
  196. || AVMATCH(&code, &av_NetStream_Play_Failed)
  197. || AVMATCH(&code, &av_NetStream_Play_StreamNotFound)
  198. || AVMATCH(&code, &av_NetConnection_Connect_InvalidApp))
  199. {
  200. r->m_stream_id = -1;
  201. RTMP_Close(r);
  202. RTMP_Log(RTMP_LOGERROR, "Closing connection: %s", code.av_val);
  203. }
  204. else if (AVMATCH(&code, &av_NetStream_Play_Start))
  205. {
  206. int i;
  207. r->m_bPlaying = TRUE;
  208. for (i = 0; i < r->m_numCalls; i++)
  209. {
  210. if (AVMATCH(&r->m_methodCalls[i].name, &av_play))
  211. {
  212. AV_erase(r->m_methodCalls, &r->m_numCalls, i, TRUE);
  213. break;
  214. }
  215. }
  216. }
  217. else if (AVMATCH(&code, &av_NetStream_Publish_Start))
  218. {
  219. int i;
  220. r->m_bPlaying = TRUE;
  221. for (i = 0; i < r->m_numCalls; i++)
  222. {
  223. if (AVMATCH(&r->m_methodCalls[i].name, &av_publish))
  224. {
  225. AV_erase(r->m_methodCalls, &r->m_numCalls, i, TRUE);
  226. break;
  227. }
  228. }
  229. }
  230. /* Return 1 if this is a Play.Complete or Play.Stop */
  231. else if (AVMATCH(&code, &av_NetStream_Play_Complete)
  232. || AVMATCH(&code, &av_NetStream_Play_Stop)
  233. || AVMATCH(&code, &av_NetStream_Play_UnpublishNotify))
  234. {
  235. RTMP_Close(r);
  236. ret = 1;
  237. }
  238. else if (AVMATCH(&code, &av_NetStream_Seek_Notify))
  239. {
  240. r->m_read.flags &= ~RTMP_READ_SEEKING;
  241. }
  242. else if (AVMATCH(&code, &av_NetStream_Pause_Notify))
  243. {
  244. if (r->m_pausing == 1 || r->m_pausing == 2)
  245. {
  246. RTMP_SendPause(r, FALSE, r->m_pauseStamp);
  247. r->m_pausing = 3;
  248. }
  249. }
  250. }
  251. else if (AVMATCH(&method, &av_playlist_ready))
  252. {
  253. //----------------
  254. r->dlg->AppendMLInfo(20,0,"命令消息","playlist_ready");
  255. //-----------------------------
  256. int i;
  257. for (i = 0; i < r->m_numCalls; i++)
  258. {
  259. if (AVMATCH(&r->m_methodCalls[i].name, &av_set_playlist))
  260. {
  261. AV_erase(r->m_methodCalls, &r->m_numCalls, i, TRUE);
  262. break;
  263. }
  264. }
  265. }
  266. else
  267. {
  268. }
  269. leave:
  270. AMF_Reset(&obj);
  271. return ret;
  272. }
  273. int
  274. RTMP_FindFirstMatchingProperty(AMFObject *obj, const AVal *name,
  275. AMFObjectProperty * p)
  276. {
  277. int n;
  278. /* this is a small object search to locate the "duration" property */
  279. for (n = 0; n < obj->o_num; n++)
  280. {
  281. AMFObjectProperty *prop = AMF_GetProp(obj, NULL, n);
  282. if (AVMATCH(&prop->p_name, name))
  283. {
  284. *p = *prop;
  285. return TRUE;
  286. }
  287. if (prop->p_type == AMF_OBJECT)
  288. {
  289. if (RTMP_FindFirstMatchingProperty(&prop->p_vu.p_object, name, p))
  290. return TRUE;
  291. }
  292. }
  293. return FALSE;
  294. }

该函数主要做了以下几步：

1.调用AMF_Decode()解码AMF命令数据

2.调用AMFProp_GetString()获取具体命令的字符串

3.调用AVMATCH()比较字符串，不同的命令做不同的处理，例如以下几个：

[cpp] view plaincopy
  1. AVMATCH(&methodInvoked, &av_connect)
  2. AVMATCH(&methodInvoked, &av_createStream)
  3. AVMATCH(&methodInvoked, &av_play)
  4. AVMATCH(&methodInvoked, &av_publish)
  5. AVMATCH(&method, &av_onBWDone)

等等，不一一例举了

具体的处理过程如下所示。在这里说一个“建立网络流”（createStream）的例子，通常发生在建立网络连接（NetConnection）之后，播放（Play）之前。

[cpp] view plaincopy
  1. else if (AVMATCH(&methodInvoked, &av_createStream))
  2. {
  3. //----------------
  4. r->dlg->AppendMLInfo(20,0,"命令消息","Result (CreateStream)");
  5. //-----------------------------
  6. r->m_stream_id = (int)AMFProp_GetNumber(AMF_GetProp(&obj, NULL, 3));
  7. if (r->Link.protocol & RTMP_FEATURE_WRITE)
  8. {
  9. SendPublish(r);
  10. }
  11. else
  12. {
  13. if (r->Link.lFlags & RTMP_LF_PLST)
  14. SendPlaylist(r);
  15. //----------------
  16. r->dlg->AppendCInfo("发送数据。消息 命令 (typeID=20) (Play)。");
  17. //-----------------------------
  18. RTMP_LogPrintf("发送命令消息“play” (typeID=20)\n");
  19. SendPlay(r);
  20. RTMP_SendCtrl(r, 3, r->m_stream_id, r->m_nBufferMS);
  21. }
  22. }

由代码可见，程序先获取了stream_id，然后发送了两个消息（Message），分别是SendPlaylist()和SendPlay()，用于获取播放列表，以及开始播放流媒体数据。

rtmpdump源代码（Linux）：http://download.csdn.net/detail/leixiaohua1020/6376561

rtmpdump源代码（VC 2005 工程）：http://download.csdn.net/detail/leixiaohua1020/6563163

RTMPdump（libRTMP） 源代码分析 7： 建立一个流媒体连接 （NetStream部分 2）相关推荐

  1. RTMPdump（libRTMP） 源代码分析 6： 建立一个流媒体连接 （NetStream部分 1）

    ===================================================== RTMPdump(libRTMP) 源代码分析系列文章: RTMPdump 源代码分析 1: ...

  2. RTMPdump（libRTMP） 源代码分析 5： 建立一个流媒体连接 （NetConnection部分）

    ===================================================== RTMPdump(libRTMP) 源代码分析系列文章: RTMPdump 源代码分析 1: ...

  3. 主机甲和主机乙之间已建立一个TCP连接，TCP最大段长为1000B。若主机甲的当前拥塞窗口为4000B，在主机甲向主机乙连续发送两个最大段后，成功收到主机乙发送的第一个段的确认段，确认段中通告的接收窗

    主机甲和主机乙之间已建立一个TCP连接,TCP最大段长为1000B.若主机甲的当前拥塞窗口为4000B,在主机甲向主机乙连续发送两个最大段后,成功收到主机乙发送的第一个段的确认段,确认段中通告的接收窗 ...

  4. Android通过WebSocket建立一个长连接（带心跳检测）从服务器端接收消息

    最近公司要做一款内部使用的工具类app,方便销售部门打电话(其实就是在后台有好多用户数据,之前销售部门同事拨打电话,需要自己从销售后台查看用户手机号等信息,然后自己拿自己手机拨号,然后打出去.现在想实 ...

  5. 客户端C和服务器S之间建立一个TCP连接，该连接总是以1KB的最大段长发送TCP段，客户端C有足够的数据要发送。当拥塞窗口为16KB的时候发生超时，如果接下来的4个RTT往返时间内的TCP段的传输是成

    客户端C和服务器S之间建立一个TCP连接,该连接总是以1KB的最大段长发送TCP段,客户端C有足够的数据要发送.当拥塞窗口为16KB的时候发生超时,如果接下来的4个RTT往返时间内的TCP段的传输是成 ...

  6. 建立一个GTalk连接和启动一个IM会话

    一个GTalk连接代表着设备和GTalk服务器之间的管道.一个IM会话是消息通道,用于处理所有的即时消息的交通:在一个会话中的所有的即时消息都在这个管道中流动. 你可以创建一些不同的连接和很多的IM会 ...

  7. LibRTMP源代码分析2：解释RTMP地址

    转载自:http://nkwavelet.blog.163.com/blog/static/227756038201412022720924/ 获取RTMP流媒体数据很重要的前提是RTMP的URL的解 ...

  8. telnetd源代码分析之输入一个字符的四个阶段

    下面的debug信息来自与/tmp/telenet.debug文件的一部分. 是客户端按下字母e后发生的四个阶段.这篇主要分析第一阶段和第二阶段. 也就是telrcv函数的主要的功能. td: net ...

  9. 主机甲和主机乙间已建立一个TCP连接，主机甲向主机乙发送了两个连续的TCP段，分别包含300字节和500字节的有效载荷，第一个段的序列号为200，主机乙正确接收到两个段后，发送给主机甲的确认序列号是？

    确认序列号=原始序列号+TCP段的长度,所以第一次的确认序列号为200+300=500,第二次确认序列号为500+500=1000

最新文章

  1. Jmeter工具中参数化、正则表达式提取器、响应断言的实现
  2. 黄煦涛教授逝世：获誉华人AI视觉鼻祖、一代宗师，完美家庭楷模
  3. Oracle 数据库 Database Express Edition 11g Release 2 (11.2) 错误解决集锦（安装方面）
  4. css 图片换行_前端学习口诀VI：html+css口诀结尾篇，值得收藏！
  5. adb 多点触碰_无法触及的神话
  6. 用PyMC3进行贝叶斯统计分析（代码+实例）
  7. springMVC 源码级别总结原理，DispatcherServlet核心方法
  8. ASP.NET Web API的Controller是如何被创建的？
  9. 第十次课：Python函数（一）
  10. linux 程序的权限设置,Linux权限设置详解
  11. LonLife-ACM 1129 - 喵哈哈村的战斗魔法师丶坏坏い月
  12. 看院线电影就用移动电影院V2.0App
  13. 学委参加博客之星评选啦
  14. 夜神模拟器抓取数据包
  15. [DSP 日常记录] #1 冯诺依曼结构、哈佛结构与改进型哈佛结构
  16. java点击车次显示详情_Web项目专项训练——火车车次信息管理系统代码分享
  17. initial commit
  18. 正点原子FreeRTOS(上)
  19. python自然语言处理学习笔记三
  20. matlab如何修复照片裂纹,把撕裂破旧老照片修复还原的PS技巧

热门文章

  1. 关于程序中查询效率的问题
  2. python的映射_Python学习：映射函数(map)和函数式编程工具(filter和reduce)
  3. Python高级语法-正则表达式
  4. 0x5f3759df的数学原理
  5. 秒杀多线程第九篇 经典线程同步总结 关键段 事件 互斥量 信号量
  6. STL 之map，multimap
  7. c++ template(5)模板实战
  8. 关于UAC执行级别的研究
  9. 数据结构与算法 | 插值查找
  10. 聚美app之 _sign参数分析