Cara melaksanakan protokol HLS menggunakan bahasa Go

HLS, Penstriman Langsung HTTP, ialah protokol penstriman video yang dicadangkan oleh Apple. Dalam platform lain, protokol HLS juga boleh digunakan untuk menghantar strim video Contohnya, pada platform Android, Google ExoPlayer turut menyokong memainkan strim video HLS. Protokol HLS terutamanya memotong fail video asal kepada satu siri fail kecil. Fail kecil ini dipanggil segmen. Serpihan ini perlu dikodkan ke dalam format pengekodan yang sepadan, seperti H.264. Pelanggan akan mendapatkan siri serpihan ini melalui protokol HTTP. Apabila pelanggan mendapat serpihan, ia mula memainkan serpihan itu. Apabila segmen ini dimainkan, pelanggan akan memperoleh segmen seterusnya dan memainkannya. Dengan cara ini, video lengkap boleh dimainkan.

Bahasa Go ialah bahasa yang sangat mudah, cekap dan sangat sesuai untuk pengaturcaraan serentak. Dalam bahasa Go, melaksanakan protokol HLS adalah sangat mudah. Dalam artikel ini, kami akan memperkenalkan cara melaksanakan protokol HLS menggunakan bahasa Go.

Pertama, kita perlu membina beberapa kod pelayan HTTP asas. Bahagian kod ini sangat mudah Kami hanya perlu mencipta pelayan HTTP dengan alamat pendengaran dan port. Apabila klien mengakses pelayan, ia boleh mendapatkan fail pada pelayan dan mengembalikan kandungan fail kepada klien.

package main

import (
    "io/ioutil"
    "net/http"
)

func main() {
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        data, _ := ioutil.ReadFile("example.mp4")
        w.Write(data)
    })

    http.ListenAndServe(":8000", nil)
}

Dalam kod ini, kami mencipta pelayan HTTP mendengar pada port 8000. Apabila pelanggan mengakses pelayan ini, ia mengembalikan kandungan fail example.mp4 kepada klien.

Seterusnya, kita perlu menulis beberapa kod untuk melaksanakan penghirisan protokol HLS. Bahagian kod ini sangat kritikal. Teras keseluruhan protokol HLS adalah untuk memotong fail video kepada banyak serpihan kecil, dan kemudian menghantar serpihan ini kepada pelanggan melalui protokol HTTP. Kita perlu menulis kod untuk melaksanakan fungsi ini.

package main

import (
    "bytes"
    "fmt"
    "io/ioutil"
    "net/http"
    "os"
    "os/exec"
    "path/filepath"
)

func main() {

    // 执行 ffmpeg 命令将 example.mp4 文件切割成小的分片
    segmentDir := "segment"
    if _, err := os.Stat(segmentDir); os.IsNotExist(err) {
        os.Mkdir(segmentDir, os.ModePerm)
    }

    cmd := exec.Command("ffmpeg", "-i", "example.mp4", "-profile:v", "baseline", "-level", "3.0", "-start_number", "0", "-hls_time", "10", "-hls_list_size", "0", "-f", "hls", filepath.Join(segmentDir, "out.m3u8"))
    err := cmd.Run()
    if err != nil {
        fmt.Println("exec cmd failed")
        panic(err)
    }

    // 启动 HTTP 服务器用于客户端获取切片文件
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {

        if r.URL.Path == "/out.m3u8" {

            // 获取 m3u8 文件的内容，此文件是一个播放列表，里面包含了可以播放的 ts 文件的序列
            data, _ := ioutil.ReadFile(filepath.Join(segmentDir, "out.m3u8"))
            w.Write(data)

        } else if len(r.URL.Path) > len("/segment/") && r.URL.Path[0:9] == "/segment/" {

            // 如果客户端要求播放某个 ts 文件，那么我们就需要从本地文件系统读取这个文件并且返回给客户端
            data, _ := ioutil.ReadFile(filepath.Join(segmentDir, r.URL.Path[1:]))
            http.ServeContent(w, r, "", 0, bytes.NewReader(data))

        }

    })

    // 启动 HTTP 服务器
    http.ListenAndServe(":8000", nil)
}

Dalam kod ini, kami terutamanya menggunakan pakej os/exec bahasa Go untuk melaksanakan arahan luaran. Ia akan memulakan proses Shell dan melaksanakan arahan yang sepadan. Dalam contoh ini, kami menggunakan arahan ffmpeg untuk memotong fail example.mp4 kepada beberapa bahagian kecil dan menyimpan bahagian ini ke direktori segment. Kemudian, kami boleh menyediakan serpihan ini kepada klien untuk main balik melalui protokol HTTP.

Apabila pelanggan meminta /out.m3u8, kami akan terus mengembalikan senarai serpihan kepada pelanggan. Apabila pelanggan meminta /segment/xxx, kita perlu membaca serpihan yang sepadan pada sistem fail tempatan dan mengembalikannya kepada klien.

Akhir sekali, kami berjaya melaksanakan protokol HLS menggunakan bahasa Go. Kesederhanaan dan kecekapan bahasa Go sangat sesuai untuk senario aplikasi sedemikian yang memerlukan konkurensi tinggi dan daya pemprosesan yang tinggi. Jika anda mendapat peluang, pastikan anda cuba melaksanakan protokol HLS dalam Go.

Atas ialah kandungan terperinci Cara melaksanakan protokol HLS menggunakan bahasa Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!