下列将用两个例子来说明解释 RTMP 中消息交换：
场景一：发布录制视频
客户端发布一个直播流传递视频流到服务器，然后其他客户端采用对发布的流进行订阅并播放视频。
推流端与服务端的信息交互流程：
+--------------------+ +-----------+
| Publisher Client | | | Server |
+----------+---------+ | +-----+-----+
| Handshaking Done |
| | |
| | |
---+---- |----- Command Message(connect) ----->|
| | |
| |<----- Window Acknowledge Size ------|
| | |
| |<-------Set Peer BandWidth ----------|
| | |
Connect | |------ Window Acknowledge Size ----->|
| | |
| |<------User Control(StreamBegin)-----|
| | |
---+---- |<---------Command Message -----------|
| | (_result- connect response) |
| | |
---+---- |--- Command Message(createStream)--->|
Create | | |
Stream | | |
---+---- |<------- Command Message ------------|
| (_result- createStream response) |
| |
---+---- |---- Command Message(publish) ------>|
| | |
| |<------User Control(StreamBegin)-----|
| | |
| |-----Data Message (Metadata)-------->|
| | |
Publishing | |------------ Audio Data ------------>|
Content | | |
| |------------ SetChunkSize ---------->|
| | |
| |<----------Command Message ----------|
| | (_result- publish result) |
| | |
| |------------- Video Data ----------->|
| | | |
| | | |
| Until the stream is complete |
| | |
Message flow in publishing a video stream
- Connect
- 客户端 --> 服务端：发送
Connect请求命令消息，请求获取与服务端应用实例的连接 - 服务端 --> 客户端：发送
Window Acknowledge Size协议控制消息，通知客户端应答窗口大小 - 服务端 --> 客户端：发送
Set Peer BandWidth协议控制消息，通知客户端自己未被应答的消息数据大小，控制客户端的输出带宽 - 客户端 --> 服务端：发送
Window Acknowledge Size协议控制消息，通知服务端应答窗口大小 - 服务端 --> 客户端：发送带有
StreamBegin事件的用户控制消息，通知客户端指定流已经准备就绪可以用来通信 - 服务端 --> 客户端：发送
Connect响应命令消息，返回连接的信息
- 客户端 --> 服务端：发送
- Create Stream
- 客户端 --> 服务端：发送
createStream请求命令消息，请求服务端创建一条流 - 服务端 --> 客户端：发送
createStream响应命令消息，返回NetConnection的流 ID
- 客户端 --> 服务端：发送
- Publishing Content
- 客户端 --> 服务端：发送
Publish请求命令消息，请求发布内容信息 - 服务端 --> 客户端：发送带有
StreamBegin事件的用户控制消息，通知客户端指定流已经准备就绪可以用来通信 - 客户端 --> 服务端：发送元数据消息
- 客户端 --> 服务端：发送音频数据
- 客户端 --> 服务端：设置块大小
- 服务端 --> 客户端：响应
Publish状态 - 客户端 --> 服务端：发送视频数据
- 客户端 --> 服务端：发送
场景二：广播一个共享对象消息
以下展示的是示例是创建、改变和广播共享对象：
+----------+ +-----------+
| Client | | | Server |
+-----+----+ | +-----+-----+
| Handshaking and Application |
| connect done |
| | |
| | |
| | |
Create and ---+---- |---- Shared Object Event(Use)---->|
connect | | |
Shared Object | | |
---+---- |<---- Shared Object Event---------|
| (UseSuccess,Clear) |
| |
---+---- |------ Shared Object Event ------>|
Shared object | | |
Set Property | | |
---+---- |<------ Shared Object Event ------|
| (Success) |
| |
---+---- |------- Shared Object Event ----->|
Shared object | | (SendMessage) |
Message | | |
Broadcast ---+---- |<------- Shared Object Event -----|
| | (SendMessage) |
|
|
Shared object message broadcast
场景三：从录制流中发布元数据
下列描述的是通过发布元数据进行消息交互：
+--------------------+ +-----------+
| Publisher Client | | | Server |
+----------+---------+ | +-----+-----+
| Handshaking and Application |
| connect done |
| | |
| | |
---+--- |---Command Messsage(createStream) -->|
Create | | |
Stream | | |
---+--- |<---------Command Message------------|
| (_result - command response) |
| |
---+--- |---- Command Message(publish) ------>|
Publishing | | |
metadata | |<------ UserControl(StreamBegin)-----|
from file | | |
| |-----Data Message (Metadata) ------->|
| |
Publishing metadata
交互过程分析
握手及通用命令
- 客户端发：C0 + C1
- 服务端发：S0 + S1 + S2
- 客户端发：C2
- 客户端发：connect
- 服务端发：设置应答窗口大小
- 服务端发：设置流带宽
- 服务端发：设置 chunk 块大小
- 服务端发：_result('NetConnection.Connect.Success')
之后 publisher 和 player 的命令就不相同了
Publish 过程分析
- 客户端发：设置 chunk 块大小
- 客户端发：releaseStream
- 客户端发：FCPublish
- 客户端发：createStream
- 服务端发：_result()
- 客户端发：publish
- 服务端发： onStatus('NetStream.Publish.Start')
- 客户端发：setDataFrame
- 客户端发：音/视频数据
之后就是不断的发送音视频数据了
Play 过程分析
- 客户端发：设置应答窗口大小
- 客户端发：createStream
- 服务端发：_result()
- 客户端发：getStreamLength()
- 客户端发：play
- 客户端发：Set Buffer
- 服务端发：onStatus('NetStream.Play.Start')
- 服务端发：|RtmpSampleAccess()
- 服务端发：Stream Begin
- 服务端发：onMetaData()
- 服务端发：音/视频数据
之后就是不断的发送音视频数据了
网友评论