Go语言开发浏览器视频流rtsp转webrtc播放_Golang_

package main /* #cgo CFLAGS: -I ./ -I /usr/local/ #cgo LDFLAGS: -L ./build -lc_onvif_static -lpthread -ldl -lssl -lcrypto #include "client.h" #include "malloc.h" */ import "C" import ( "encoding/json" "fmt" "log" "net/http" "os" "sort" "strconv" "time" "unsafe" "github.com/deepch/vdk/av" webrtc "github.com/deepch/vdk/format/webrtcv3" "github.com/gin-gonic/gin" ) type JCodec struct { Type string } func serveHTTP() { gin.SetMode(gin.ReleaseMode) router := gin.Default() router.Use(CORSMiddleware()) if _, err := os.Stat("./web"); !os.IsNotExist(err) { router.LoadHTMLGlob("web/templates/*") router.GET("/", HTTPAPIServerIndex) router.GET("/stream/player/:uuid", HTTPAPIServerStreamPlayer) } router.POST("/stream/receiver/:uuid", HTTPAPIServerStreamWebRTC) //增加新的post接口 router.POST("/stream/ptz/", HTTPAPIServerStreamPtz) router.POST("/stream/preset/", HTTPAPIServerStreamPreset) router.GET("/stream/codec/:uuid", HTTPAPIServerStreamCodec) router.POST("/stream", HTTPAPIServerStreamWebRTC2) router.StaticFS("/static", http.Dir("web/static")) err := router.Run(Config.Server.HTTPPort) if err != nil { log.Fatalln("Start HTTP Server error", err) } } //HTTPAPIServerIndex index func HTTPAPIServerIndex(c *gin.Context) { _, all := Config.list() if len(all) > 0 { c.Header("Cache-Control", "no-cache, max-age=0, must-revalidate, no-store") c.Header("Access-Control-Allow-Origin", "*") c.Redirect(http.StatusMovedPermanently, "stream/player/"+all[0]) } else { c.HTML(http.StatusOK, "index.tmpl", gin.H{ "port": Config.Server.HTTPPort, "version": time.Now().String(), }) } } //HTTPAPIServerStreamPlayer stream player func HTTPAPIServerStreamPlayer(c *gin.Context) { _, all := Config.list() sort.Strings(all) c.HTML(http.StatusOK, "player.tmpl", gin.H{ "port": Config.Server.HTTPPort, "suuid": c.Param("uuid"), "suuidMap": all, "version": time.Now().String(), }) } //HTTPAPIServerStreamCodec stream codec func HTTPAPIServerStreamCodec(c *gin.Context) { if Config.ext(c.Param("uuid")) { Config.RunIFNotRun(c.Param("uuid")) codecs := Config.coGe(c.Param("uuid")) if codecs == nil { return } var tmpCodec []JCodec for _, codec := range codecs { if codec.Type() != av.H264 && codec.Type() != av.PCM_ALAW && codec.Type() != av.PCM_MULAW && codec.Type() != av.OPUS { log.Println("Codec Not Supported WebRTC ignore this track", codec.Type()) continue } if codec.Type().IsVideo() { tmpCodec = append(tmpCodec, JCodec{Type: "video"}) } else { tmpCodec = append(tmpCodec, JCodec{Type: "audio"}) } } b, err := json.Marshal(tmpCodec) if err == nil { _, err = c.Writer.Write(b) if err != nil { log.Println("Write Codec Info error", err) return } } } } //HTTPAPIServerStreamWebRTC stream video over WebRTC func HTTPAPIServerStreamWebRTC(c *gin.Context) { if !Config.ext(c.PostForm("suuid")) { log.Println("Stream Not Found") return } Config.RunIFNotRun(c.PostForm("suuid")) codecs := Config.coGe(c.PostForm("suuid")) if codecs == nil { log.Println("Stream Codec Not Found") return } var AudioOnly bool if len(codecs) == 1 && codecs[0].Type().IsAudio() { AudioOnly = true } muxerWebRTC := webrtc.NewMuxer(webrtc.Options{ICEServers: Config.GetICEServers(), ICEUsername: Config.GetICEUsername(), ICECredential: Config.GetICECredential(), PortMin: Config.GetWebRTCPortMin(), PortMax: Config.GetWebRTCPortMax()}) answer, err := muxerWebRTC.WriteHeader(codecs, c.PostForm("data")) if err != nil { log.Println("WriteHeader", err) return } _, err = c.Writer.Write([]byte(answer)) if err != nil { log.Println("Write", err) return } go func() { cid, ch := Config.clAd(c.PostForm("suuid")) defer Config.clDe(c.PostForm("suuid"), cid) defer muxerWebRTC.Close() var videoStart bool noVideo := time.NewTimer(10 * time.Second) for { select { case <-noVideo.C: log.Println("noVideo") return case pck := <-ch: if pck.IsKeyFrame || AudioOnly { noVideo.Reset(10 * time.Second) videoStart = true } if !videoStart && !AudioOnly { continue } err = muxerWebRTC.WritePacket(pck) if err != nil { log.Println("WritePacket", err) return } } } }() } func HTTPAPIServerStreamPtz(c *gin.Context) { action := c.PostForm("action") direction, err := strconv.Atoi(action) if err != nil { log.Println(err) return } var soap C.P_Soap soap = C.new_soap(soap) username := C.CString("admin") password := C.CString("admin") serviceAddr := C.CString("http://40.40.40.101:80/onvif/device_service") C.get_device_info(soap, username, password, serviceAddr) mediaAddr := [200]C.char{} C.get_capabilities(soap, username, password, serviceAddr, &mediaAddr[0]) profileToken := [200]C.char{} C.get_profiles(soap, username, password, &profileToken[0], &mediaAddr[0]) videoSourceToken := [200]C.char{} C.get_video_source(soap, username, password, &videoSourceToken[0], &mediaAddr[0]) switch direction { case 0: break case 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11: C.ptz(soap, username, password, C.int(direction), C.float(0.5), &profileToken[0], &mediaAddr[0]) case 12, 13, 14: C.focus(soap, username, password, C.int(direction), C.float(0.5), &videoSourceToken[0], &mediaAddr[0]) default: fmt.Println("Unknown direction.") } C.del_soap(soap) C.free(unsafe.Pointer(username)) C.free(unsafe.Pointer(password)) C.free(unsafe.Pointer(serviceAddr)) c.JSON(http.StatusOK, gin.H{"message":"success"}) } func HTTPAPIServerStreamPreset(c *gin.Context) { var soap C.P_Soap soap = C.new_soap(soap) username := C.CString("admin") password := C.CString("admin") serviceAddr := C.CString("http://40.40.40.101:80/onvif/device_service") C.get_device_info(soap, username, password, serviceAddr) mediaAddr := [200]C.char{} C.get_capabilities(soap, username, password, serviceAddr, &mediaAddr[0]) profileToken := [200]C.char{} C.get_profiles(soap, username, password, &profileToken[0], &mediaAddr[0]) videoSourceToken := [200]C.char{} C.get_video_source(soap, username, password, &videoSourceToken[0], &mediaAddr[0]) action := c.PostForm("action") presetAction, err := strconv.Atoi(action) if err != nil { log.Println(err) return } fmt.Println("请输入数字进行preset,1-4分别代表查询、设置、跳转、删除预置点；退出输入0:") switch presetAction { case 0: break case 1: C.preset(soap, username, password, C.int(presetAction), nil, nil, &profileToken[0], &mediaAddr[0]) case 2: fmt.Println("请输入要设置的预置点token信息：") presentToken := "" _, _ = fmt.Scanln(&presentToken) fmt.Println("请输入要设置的预置点name信息长度不超过200：") presentName := "" _, _ = fmt.Scanln(&presentName) C.preset(soap, username, password, C.int(presetAction), C.CString(presentToken), C.CString(presentName), &profileToken[0], &mediaAddr[0]) case 3: fmt.Println("请输入要跳转的预置点token信息：") presentToken := "" _, _ = fmt.Scanln(&presentToken) C.preset(soap, username, password, C.int(presetAction), C.CString(presentToken), nil, &profileToken[0], &mediaAddr[0]) case 4: fmt.Println("请输入要删除的预置点token信息：") presentToken := "" _, _ = fmt.Scanln(&presentToken) C.preset(soap, username, password, C.int(presetAction), C.CString(presentToken), nil, &profileToken[0], &mediaAddr[0]) default: fmt.Println("unknown present action.") break } C.del_soap(soap) C.free(unsafe.Pointer(username)) C.free(unsafe.Pointer(password)) C.free(unsafe.Pointer(serviceAddr)) c.JSON(http.StatusOK, gin.H{"message":"success"}) } func CORSMiddleware() gin.HandlerFunc { return func(c *gin.Context) { c.Header("Access-Control-Allow-Origin", "*") c.Header("Access-Control-Allow-Credentials", "true") c.Header("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept, Authorization, x-access-token") c.Header("Access-Control-Expose-Headers", "Content-Length, Access-Control-Allow-Origin, Access-Control-Allow-Headers, Cache-Control, Content-Language, Content-Type") c.Header("Access-Control-Allow-Methods", "POST, OPTIONS, GET, PUT") if c.Request.Method == "OPTIONS" { c.AbortWithStatus(http.StatusNoContent) return } c.Next() } } type Response struct { Tracks []string `json:"tracks"` Sdp64 string `json:"sdp64"` } type ResponseError struct { Error string `json:"error"` } func HTTPAPIServerStreamWebRTC2(c *gin.Context) { url := c.PostForm("url") if _, ok := Config.Streams[url]; !ok { Config.Streams[url] = StreamST{ URL: url, OnDemand: t
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：Go语言开源库实现Onvif协议客户端设备搜索_Golang_
                                                                
下一篇：Go语言利用ffmpeg转hls实现简单视频直播_Golang_