//以下为rtsp的服务器A
1 #include <gst/gst.h> 2 3 #include <gst/rtsp-server/rtsp-server.h> 4 #include <gst/rtsp-server/rtsp-session-pool.h> 5 6 static gboolean 7 timeout (GstRTSPServer * server) 8 { 9 GstRTSPSessionPool *pool; 10 11 pool = gst_rtsp_server_get_session_pool (server); 12 13 gst_rtsp_session_pool_cleanup (pool); 14 g_object_unref (pool); 15 16 return TRUE; 17 } 18 19 int 20 main (int argc, char *argv[]) 21 { 22 GMainLoop *loop; 23 GstRTSPServer *server; 24 GstRTSPMountPoints *mounts; 25 GstRTSPMediaFactory *factory; 26 GstRTSPMediaFactory *factory1; 27 GstRTSPSessionPool *session; 28 29 gst_init (&argc, &argv); 30 31 loop = g_main_loop_new (NULL, FALSE); 32 33 session = gst_rtsp_session_pool_new(); 34 gst_rtsp_session_pool_set_max_sessions (session, 255); 35 /* 创建服务器实例 */ 36 server = gst_rtsp_server_new (); 37 38 /* 获取服务器的rtsp流的管理器*/ 39 mounts = gst_rtsp_server_get_mount_points (server); 40 41 /* 创建两个rtsp的流管理器，设置流的源*/ 42 factory = gst_rtsp_media_factory_new (); 43 factory1 = gst_rtsp_media_factory_new (); 44 gst_rtsp_media_factory_set_launch (factory, 45 "( videotestsrc is-live=1 ! x264enc ! rtph264pay name=pay0 pt=96 )"); 46 47 gst_rtsp_media_factory_set_launch (factory1, 48 "( " 49 "filesrc location=/home/kkia/Downloads/My.mp4 ! qtdemux name=d " 50 "d. ! queue ! rtph264pay pt=96 name=pay0 " 51 "d. ! queue ! rtpmp4apay pt=97 name=pay1 " ")"); 52 53 gst_rtsp_media_factory_set_shared (factory, TRUE); 54 gst_rtsp_media_factory_set_shared (factory1, TRUE); 55 56 /*绑定流的地址，并加入流管理器中*/ 57 gst_rtsp_mount_points_add_factory (mounts, "/test", factory); 58 gst_rtsp_mount_points_add_factory (mounts, "/test1", factory1); 59 60 g_object_unref (mounts); 61 62 gst_rtsp_server_attach (server, NULL); 63 64 g_timeout_add_seconds (2, (GSourceFunc) timeout, server); 65 66 g_print ("stream ready at rtsp://127.0.0.1:8554/test "); 67 g_print ("stream ready at rtsp://127.0.0.1:8554/test1 "); 68 g_main_loop_run (loop); 69 70 return 0; 71 }
以上为rtsp的服务器A。
下面将创建rtsp转发服务器B，转发服务器A的rtsp流。
1 #include <gst/gst.h> 2 3 #include <gst/rtsp-server/rtsp-server.h> 4 5 int 6 main (int argc, char *argv[]) 7 { 8 GMainLoop *loop; 9 GstRTSPServer *server; 10 GstRTSPMountPoints *mounts; 11 GstRTSPMediaFactory *factory; 12 13 gst_init (&argc, &argv); 14 15 if (argc < 2) { 16 g_print ("usage: %s <launch line> " 17 "example: %s "( videotestsrc ! x264enc ! rtph264pay name=pay0 pt=96 )" ", 18 argv[0], argv[0]); 19 return -1; 20 } 21 22 loop = g_main_loop_new (NULL, FALSE); 23 24 /* create a server instance */ 25 server = gst_rtsp_server_new (); 26 gst_rtsp_server_set_service (server, "8555");//配置服务器端口 27 mounts = gst_rtsp_server_get_mount_points (server); 28 29 30 factory = gst_rtsp_media_factory_new (); 31 gst_rtsp_media_factory_set_launch (factory, "( rtspsrc location=rtsp://192.168.11.36:8554/test1 ! queue ! rtph264depay ! queue ! rtph264pay name=pay0 pt=96 )" 32 );//此处服务器的源来自主服务器的rtsp，ip地址改成相应的地址。 33 gst_rtsp_media_factory_set_shared (factory, TRUE); 34 35 gst_rtsp_mount_points_add_factory (mounts, "/test2", factory); 36 37 g_object_unref (mounts); 38 39 gst_rtsp_server_attach (server, NULL); 40 41 /* start serving */ 42 g_print ("stream ready at rtsp://127.0.0.1:8554/test "); 43 g_main_loop_run (loop); 44 45 return 0; 46 }
代码可以在gstreamer中 gst-rtsp-server 源代码examples目录下获取到，只是稍加了修改。