For #1653, #1500, Support GB28181, another solution.

trunk/conf/push.gb28181.conf

@@ -0,0 +1,72 @@
+# push gb28281 stream to SRS.
+
+listen                  1935;
+max_connections         1000;
+daemon                  off;
+pid                     ./objs/srs28181.pid;
+srs_log_file            ./objs/srs28181.log;
+srs_log_tank            console;
+stream_caster {
+    enabled             on;
+    caster              gb28181;
+
+    #rtmp输出地址，可以参数化
+    #[stream] 代表客户端sip设备编号
+    #[timestamp] 时间戳
+    output              rtmp://127.0.0.1/live/[stream];
+    #sip监听udp端口
+    listen              15060;
+
+    #服务器主机号，可以域名或ip地址
+    #也就是设备端将媒体发送的地址，如果是服务器是内外网
+    #需要写外网地址
+    host                192.168.1.27;
+
+    #服务器端编号
+    #设备端配置编号需要与该值一致，否则无法注册
+    serial              34020000002000000001;
+
+    #服务器端域
+    realm               3402000000;
+
+    #是否转发音频流
+    #目前只支持aac格式，所以需要设备支持aac格式
+    #on:转发音频  
+    #off:不转发音频，只有视频
+    #*注意*!!!:flv 只支持11025  22050  44100 三种
+    #如果设备端没有三种中任何一个，转发时为自动选择一种格式
+    #同时也会将adts的头封装在flv aac raw数据中
+    #这样的话播放器为自动通过adts头自动选择采样频率
+    #像ffplay, vlc都可以，但是flash是没有声音，
+    #因为flash,只支持11025 22050 44100
+    audio_enable        on;
+
+    #服务端发送ack后，接收回应的超时时间，单位为秒
+    #如果指定时间没有回应，认为失败
+    ack_timeout         30;
+
+    #设备心跳维持时间，如果指定时间内(秒）没有接收一个心跳
+    #认为设备离线
+    keepalive_timeout   30;
+
+    #是否等待关键帧之后，再转发，
+    #off:不需等待，直接转发
+    #on:等第一个关键帧后，再转发
+    wait_keyframe       off;
+
+    #日志打印是否打印sip信息
+    #off:不打印
+    #on:打印接收或发送sip命令信息
+    print_sip_message   off;
+
+    #rtp包空闲等待时间，如果指定时间没有收到任何包
+    #rtp监听连接自动停止，发送BYE命令
+    rtp_idle_timeout    30;
+
+    #rtp接收监听端口范围，最小值
+    rtp_port_min        58200;
+    #rtp接收监听端口范围，最大值
+    rtp_port_max        58300;
+}
+vhost __defaultVhost__ {
+}

trunk/configure

@@ -213,7 +213,7 @@ MODULE_DEPENDS=("CORE" "KERNEL")
 ModuleLibIncs=(${SRS_OBJS_DIR} ${LibSSLRoot})
 MODULE_FILES=("srs_protocol_amf0" "srs_protocol_io" "srs_rtmp_stack"
         "srs_rtmp_handshake" "srs_protocol_utility" "srs_rtmp_msg_array" "srs_protocol_stream"
-        "srs_raw_avc" "srs_rtsp_stack" "srs_http_stack" "srs_protocol_kbps" "srs_protocol_json"
+        "srs_raw_avc" "srs_rtsp_stack" "srs_sip_stack" "srs_http_stack" "srs_protocol_kbps" "srs_protocol_json"
         "srs_protocol_format")
 PROTOCOL_INCS="src/protocol"; MODULE_DIR=${PROTOCOL_INCS} . auto/modules.sh
 PROTOCOL_OBJS="${MODULE_OBJS[@]}"
@@ -257,7 +257,7 @@ if [ $SRS_EXPORT_LIBRTMP_PROJECT = NO ]; then
             "srs_app_mpegts_udp" "srs_app_rtsp" "srs_app_listener" "srs_app_async_call"
             "srs_app_caster_flv" "srs_app_process" "srs_app_ng_exec"
             "srs_app_hourglass" "srs_app_dash" "srs_app_fragment" "srs_app_dvr"
-            "srs_app_coworkers" "srs_app_hybrid")
+            "srs_app_coworkers" "srs_app_hybrid" "srs_app_gb28181")
     DEFINES=""
     # add each modules for app
     for SRS_MODULE in ${SRS_MODULES[*]}; do

trunk/src/app/srs_app_config.cpp

@@ -275,6 +275,11 @@ bool srs_stream_caster_is_flv(string caster)
     return caster == "flv";
 }
 
+bool srs_stream_caster_is_gb28181(string caster)
+{
+    return caster == "gb28181";
+}
+
 bool srs_config_apply_filter(SrsConfDirective* dvr_apply, SrsRequest* req)
 {
     static bool DEFAULT = true;
@@ -2137,7 +2142,26 @@ srs_error_t SrsConfig::global_to_json(SrsJsonObject* obj)
                     sobj->set(sdir->name, sdir->dumps_arg0_to_integer());
                 } else if (sdir->name == "rtp_port_max") {
                     sobj->set(sdir->name, sdir->dumps_arg0_to_integer());
+                } else if (sdir->name == "rtp_idle_timeout") {
+                    sobj->set(sdir->name, sdir->dumps_arg0_to_integer());
+                } else if (sdir->name == "ack_timeout") {
+                    sobj->set(sdir->name, sdir->dumps_arg0_to_integer());
+                } else if (sdir->name == "keepalive_timeout") {
+                    sobj->set(sdir->name, sdir->dumps_arg0_to_integer());
+                } else if (sdir->name == "audio_enable") {
+                    sobj->set(sdir->name, sdir->dumps_arg0_to_boolean());
+                } else if (sdir->name == "host") {
+                    sobj->set(sdir->name, sdir->dumps_arg0_to_str());
+                } else if (sdir->name == "serial") {
+                    sobj->set(sdir->name, sdir->dumps_arg0_to_str());
+                } else if (sdir->name == "realm") {
+                    sobj->set(sdir->name, sdir->dumps_arg0_to_str());
+                } else if (sdir->name == "wait_keyframe") {
+                    sobj->set(sdir->name, sdir->dumps_arg0_to_str());
+                } else if (sdir->name == "print_sip_message") {
+                    sobj->set(sdir->name, sdir->dumps_arg0_to_str());
                 }
+
             }
             obj->set(dir->name, sobj);
         } else {
@@ -3650,7 +3674,11 @@ srs_error_t SrsConfig::check_normal_config()
             SrsConfDirective* conf = stream_caster->at(i);
             string n = conf->name;
             if (n != "enabled" && n != "caster" && n != "output"
-                && n != "listen" && n != "rtp_port_min" && n != "rtp_port_max") {
+                && n != "listen" && n != "rtp_port_min" && n != "rtp_port_max"
+                && n != "rtp_idle_timeout" && n != "ack_timeout" && n != "keepalive_timeout"
+                && n != "host" && n != "serial" && n != "realm" 
+                && n != "audio_enable" && n != "wait_keyframe"
+                && n != "print_sip_message") {
                 return srs_error_new(ERROR_SYSTEM_CONFIG_INVALID, "illegal stream_caster.%s", n.c_str());
             }
         }
@@ -4266,6 +4294,150 @@ int SrsConfig::get_stream_caster_rtp_port_max(SrsConfDirective* conf)
     return ::atoi(conf->arg0().c_str());
 }
 
+int SrsConfig::get_stream_caster_gb28181_rtp_ide_timeout(SrsConfDirective* conf)
+{
+    static int DEFAULT = 30;
+
+    if (!conf) {
+        return DEFAULT;
+    }
+
+    conf = conf->get("rtp_ide_timeout");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+
+    return ::atoi(conf->arg0().c_str());
+}
+
+int SrsConfig::get_stream_caster_gb28181_ack_timeout(SrsConfDirective* conf)
+{
+    static int DEFAULT = 30;
+
+    if (!conf) {
+        return DEFAULT;
+    }
+
+    conf = conf->get("ack_timeout");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+
+    return ::atoi(conf->arg0().c_str());
+}
+
+int SrsConfig::get_stream_caster_gb28181_keepalive_timeout(SrsConfDirective* conf)
+{
+    static int DEFAULT = 30;
+
+    if (!conf) {
+        return DEFAULT;
+    }
+
+    conf = conf->get("keepalive_timeout");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+
+    return ::atoi(conf->arg0().c_str());
+}
+
+string SrsConfig::get_stream_caster_gb28181_host(SrsConfDirective* conf)
+{
+    static string DEFAULT = "127.0.0.1";
+
+    if (!conf) {
+        return DEFAULT;
+    }
+
+    conf = conf->get("host");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+
+    return conf->arg0();
+}
+
+string SrsConfig::get_stream_caster_gb28181_serial(SrsConfDirective* conf)
+{
+    static string DEFAULT = "";
+
+    if (!conf) {
+        return DEFAULT;
+    }
+
+    conf = conf->get("serial");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+
+    return conf->arg0();
+}
+
+string SrsConfig::get_stream_caster_gb28181_realm(SrsConfDirective* conf)
+{
+    static string DEFAULT = "";
+
+    if (!conf) {
+        return DEFAULT;
+    }
+
+    conf = conf->get("realm");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+
+    return conf->arg0();
+}
+
+bool SrsConfig::get_stream_caster_gb28181_audio_enable(SrsConfDirective* conf)
+{
+    static bool DEFAULT = true;
+
+    if (!conf) {
+        return DEFAULT;
+    }
+
+    conf = conf->get("audio_enable");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+
+    return SRS_CONF_PERFER_FALSE(conf->arg0());
+}
+
+bool SrsConfig::get_stream_caster_gb28181_print_sip_message(SrsConfDirective* conf)
+{
+    static bool DEFAULT = false;
+
+    if (!conf) {
+        return DEFAULT;
+    }
+
+    conf = conf->get("print_sip_message");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+
+    return SRS_CONF_PERFER_FALSE(conf->arg0());
+}
+
+bool SrsConfig::get_stream_caster_gb28181_wait_keyframe(SrsConfDirective* conf)
+{
+    static bool DEFAULT = false;
+
+    if (!conf) {
+        return DEFAULT;
+    }
+
+    conf = conf->get("wait_keyframe");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+
+    return SRS_CONF_PERFER_FALSE(conf->arg0());
+}
+
 SrsConfDirective* SrsConfig::get_vhost(string vhost, bool try_default_vhost)
 {
     srs_assert(root);

trunk/src/app/srs_app_config.hpp

@@ -119,6 +119,7 @@ extern bool srs_config_dvr_is_plan_session(std::string plan);
 extern bool srs_stream_caster_is_udp(std::string caster);
 extern bool srs_stream_caster_is_rtsp(std::string caster);
 extern bool srs_stream_caster_is_flv(std::string caster);
+extern bool srs_stream_caster_is_gb28181(std::string caster);
 // Whether the dvr_apply active the stream specified by req.
 extern bool srs_config_apply_filter(SrsConfDirective* dvr_apply, SrsRequest* req);
 
@@ -498,6 +499,17 @@ class SrsConfig
     virtual int get_stream_caster_rtp_port_min(SrsConfDirective* conf);
     // Get the max udp port for rtp of stream caster rtsp.
     virtual int get_stream_caster_rtp_port_max(SrsConfDirective* conf);
+
+    virtual int get_stream_caster_gb28181_rtp_ide_timeout(SrsConfDirective* conf);
+    virtual int get_stream_caster_gb28181_ack_timeout(SrsConfDirective* conf);
+    virtual int get_stream_caster_gb28181_keepalive_timeout(SrsConfDirective* conf);
+    virtual bool get_stream_caster_gb28181_audio_enable(SrsConfDirective* conf);
+    virtual std::string get_stream_caster_gb28181_host(SrsConfDirective* conf);
+    virtual std::string get_stream_caster_gb28181_serial(SrsConfDirective* conf);
+    virtual std::string get_stream_caster_gb28181_realm(SrsConfDirective* conf);
+    virtual bool get_stream_caster_gb28181_print_sip_message(SrsConfDirective* conf);
+    virtual bool get_stream_caster_gb28181_wait_keyframe(SrsConfDirective* conf);
+
 // vhost specified section
 public:
     // Get the vhost directive by vhost name.