如何优化HLS的访问路径?

举报
TSINGSEE青犀视频 发表于 2021/10/28 14:39:34 2021/10/28
【摘要】 在原先的EasyDSS设计中,EasyDSS平台直接获取到流媒体的存储hls的路径,然后将该路径变为可访问资源路径即可。但是该种设计方式,在流媒体在其他机器上的时候就会出现无法访问hls流的情况,因此更改hls的访问路径。

EasyDSS视频平台观看视频推流直播不需要安装插件,网页直接即可播放,通过浏览器进入平台即可进行配置,对用户来说,便捷可控,无需另行搭建服务器,具有很大的优势。

b20a3d56b59a621e13db47168393a679.png

在原先的EasyDSS设计中,EasyDSS平台直接获取到流媒体的存储hls的路径,然后将该路径变为可访问资源路径即可。但是该种设计方式,在流媒体在其他机器上的时候就会出现无法访问hls流的情况,因此更改hls的访问路径。

func HlsHandler() gin.HandlerFunc {
   return func(c *gin.Context) {
      defer func() {
         if err := recover(); err != nil {
            gErrorLogger.Error(fmt.Sprintf("panic %s\n", err))
            gErrorLogger.Error(fmt.Sprint(string(debug.Stack())))
         }
      }()

      // /hls/stream_1/playlist.m3u8
      path := c.Request.URL.Path

      if strings.HasSuffix(path, ".m3u8") || strings.HasSuffix(path, ".ts") {
         target := fmt.Sprintf("127.0.0.1:%v", mediaserver.GetHttpPort())
         director := func(req *http.Request) {
            req.URL.Scheme = "http"
            req.URL.Host = target
            req.URL.RawQuery = ""

            if strings.HasSuffix(path, ".m3u8") {
               // 如果是老的 EasyDSS 路径,则修改为新的 m3u8 路径
               // 老的路径为 /hls/stream_1/stream_1_live.m3u8
               if strings.HasSuffix(path, "_live.m3u8") {
                  index := strings.LastIndex(path, "/")
                  basePath := path[:index+1]
                  req.URL.Path = basePath + mediaserver.HlsPlayList
               }
            }

         }
         tranport := &ShutDownTransport{
            Trans: &http.Transport{
               Proxy: http.ProxyFromEnvironment,
               DialContext: (&net.Dialer{
                  Timeout:   30 * time.Second,
                  KeepAlive: 30 * time.Second,
               }).DialContext,
               ForceAttemptHTTP2:     true,
               MaxIdleConns:          100,
               IdleConnTimeout:       90 * time.Second,
               TLSHandshakeTimeout:   10 * time.Second,
               ExpectContinueTimeout: 1 * time.Second,
               ResponseHeaderTimeout: 10 * time.Second,
            },
         }

         errHandle := func(res http.ResponseWriter, req *http.Request, err error) {
            log.Println("hls proxy is error : ", err)
            c.AbortWithError(http.StatusVariantAlsoNegotiates, err)
         }
         proxy := &httputil.ReverseProxy{
            Director:     director,
            Transport:    tranport,
            ErrorHandler: errHandle,
         }

         proxy.ServeHTTP(c.Writer, c.Request)

         c.Next()
         return
      } else {
         c.AbortWithStatusJSON(http.StatusBadRequest, "BadRequest")
      }

      return
   }
}

以上代码主要使用httputil.ReverseProxy实现反向代理。proxy.ServeHTTP()函数即可实现http的反向代理功能。

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。