** 系列文章**：
Nginx rtmp 推流(publish) 解析_fdsafwagdagadg6576的專欄-CSDN博客
Nginx rtmp 拉流播放(play)_fdsafwagdagadg6576的專欄-CSDN博客
Nginx rtmp 拉流(轉(zhuǎn)發(fā)pull)_fdsafwagdagadg6576的專欄-CSDN博客
Nginx rtmp 轉(zhuǎn)推_fdsafwagdagadg6576的專欄-CSDN博客
Nginx rtmp 點(diǎn)播流程_fdsafwagdagadg6576的專欄-CSDN博客
兩種情況觸發(fā)轉(zhuǎn)推：
一種是在終端publish之后轉(zhuǎn)推，一種是在relay server pull之后的轉(zhuǎn)推.
ngx_rtmp_relay_send_publish-->ngx_rtmp_relay_play_local： 本地作為subscribe
ngx_rtmp_relay_send_play-->ngx_rtmp_relay_publish_local :pull同時轉(zhuǎn)推
流程圖
**流程步驟: **
1） 信令交互：
轉(zhuǎn)推server的流程和終端publish的流程是一樣的. （包括handshake,connect,createStream,publish都一樣的流程）
右側(cè)Nginx rtmp參見推流(publish)篇.上圖綠色模塊參見rela拉流(pull)篇,即轉(zhuǎn)推同時也做了拉流.
2）流媒體audio/video
將遠(yuǎn)端（remote）server注冊成為subscribe，接收本機(jī)ngx_rtmp_live_av轉(zhuǎn)發(fā)的流。
對轉(zhuǎn)發(fā)碼流來說，把遠(yuǎn)端看成subscribe（play） 角色
源碼分析
- 轉(zhuǎn)推入口 ngx_rtmp_relay_publish
static ngx_int_t
ngx_rtmp_relay_publish(ngx_rtmp_session_t *s, ngx_rtmp_publish_t *v)
{
//1.a 進(jìn)程之間的relay
if (s->auto_pushed) {
goto next;
}
ctx = ngx_rtmp_get_module_ctx(s, ngx_rtmp_relay_module);
//1.b //s->relay無論是轉(zhuǎn)推還是relay ；init is 0，轉(zhuǎn)推,relay 一次之后變成1.直接next
if (ctx && s->relay) {
goto next;
}
...
//1.c
for (n = 0; n < racf->pushes.nelts; ++n, ++t) {
...
//轉(zhuǎn)推
if (ngx_rtmp_relay_push(s, &name, target) == NGX_OK) {
continue;
}
....
}
next:
//2 ngx_rtmp_live_publish
return next_publish(s, v);
}
- s->auto_pushed : worker進(jìn)程之間推流，直接到ngx_rtmp_live_publish
2）s->relay： 已經(jīng)轉(zhuǎn)推過了（同一個流只能publish一次），直接到ngx_rtmp_live_publish
3） 遍歷所有推流server推流
4） 執(zhí)行ngx_rtmp_live_publish轉(zhuǎn)流
- 轉(zhuǎn)推信令入口
ngx_rtmp_relay_on_result {
...
//轉(zhuǎn)推是將push server作為play即subsribe注冊到liveav.
//具體分成兩步向上游發(fā)送publish消息,準(zhǔn)備推流;將自身設(shè)置為play即subscribe
if (ngx_rtmp_relay_send_publish(s) != NGX_OK) {
return NGX_ERROR;
}
return ngx_rtmp_relay_play_local(s);
}
