Pembangunan Golang: Melaksanakan aplikasi panggilan video berdasarkan WebRTC

Pembangunan Golang: Melaksanakan aplikasi panggilan video berdasarkan WebRTC

Abstrak:
WebRTC (Web Real-Time Communication) ialah teknologi komunikasi audio dan video masa nyata standard terbuka yang boleh digunakan untuk membina panggilan audio dan video , persidangan dan siaran langsung masa nyata serta aplikasi lain. Artikel ini akan memperkenalkan cara menggunakan Golang untuk membangunkan aplikasi panggilan video berdasarkan WebRTC dan menyediakan beberapa contoh kod khusus untuk membantu pembaca memahami dan menguasai teknologi yang berkaitan dengan lebih mendalam.

1. Latar Belakang
WebRTC ialah standard komunikasi audio dan video masa nyata terbuka yang boleh digunakan pada pelbagai pelayar web dan sistem pengendalian. Melalui WebRTC, kami boleh mencapai panggilan audio dan video masa nyata antara penyemak imbas. Disebabkan keterbukaan dan keserasiannya, WebRTC telah menjadi teknologi pilihan untuk membina aplikasi komunikasi audio dan video.

2. Persediaan persekitaran
Sebelum memulakan pembangunan, kita perlu memasang persekitaran pembangunan bahasa Go dan perpustakaan berkaitan WebRTC.

1. Pasang persekitaran pembangunan Golang:

• Lawati laman web rasmi https://golang.org/dl/, muat turun dan pasang versi Golang yang sesuai untuk sistem pengendalian anda.

2. Pasang perpustakaan WebRTC:

• Pelaksanaan Golang WebRTC dibangunkan dan diselenggara oleh Pion, dan mereka menyediakan perpustakaan Golang yang boleh digunakan secara langsung. Pasang perpustakaan Pion menggunakan arahan berikut:

  go get github.com/pion/webrtc/v3

3. Buat aplikasi panggilan video
Di bawah ialah contoh mudah yang menunjukkan cara membuat aplikasi panggilan video menggunakan Golang dan perpustakaan WebRTC.

package main

import (
    "encoding/json"
    "fmt"
    "log"
    "net/http"

    "github.com/gorilla/websocket"
    "github.com/pion/webrtc/v3"
)

var (
    upgrader = websocket.Upgrader{}
    peers    = map[*websocket.Conn]*webrtc.PeerConnection{}
)

func main() {
    http.HandleFunc("/offer", handleOffer)
    http.HandleFunc("/answer", handleAnswer)
    http.HandleFunc("/ws", handleWebSocket)
    log.Fatal(http.ListenAndServe(":8080", nil))
}

func handleOffer(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
        return
    }
    defer conn.Close()

    pc, err := webrtc.NewPeerConnection(webrtc.Configuration{})
    if err != nil {
        log.Println(err)
        return
    }

    pc.OnICECandidate(func(candidate *webrtc.ICECandidate) {
        if candidate != nil {
            jsonCandidate, _ := json.Marshal(candidate.ToJSON())
            conn.WriteMessage(websocket.TextMessage, jsonCandidate)
        }
    })

    pc.OnTrack(func(track *webrtc.TrackRemote, receiver *webrtc.RTPReceiver) {
        go func() {
            for {
                _, _, _ = track.ReadRTP()
            }
        }()
    })

    pc.AddTransceiver(webrtc.RTPCodecTypeVideo)

    peers[conn] = pc

    for {
        _, message, err := conn.ReadMessage()
        if err != nil {
            log.Println(err)
            delete(peers, conn)
            return
        }
        pc.AddICECandidate(webrtc.ICECandidateInit{
            Candidate: string(message),
        })
    }
}

// handleAnswer 处理answer请求
func handleAnswer(w http.ResponseWriter, r *http.Request) {
    var answer struct {
        Candidate string `json:"candidate"`
    }
    err := json.NewDecoder(r.Body).Decode(&answer)
    if err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }

    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
        return
    }
    defer conn.Close()

    pc := peers[conn]
    pc.AddICECandidate(webrtc.ICECandidateInit{
        Candidate: answer.Candidate,
    })
}

// handleWebSocket 处理WebSocket连接请求
func handleWebSocket(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
        return
    }
    defer conn.Close()

    pc, err := webrtc.NewPeerConnection(webrtc.Configuration{})
    if err != nil {
        log.Println(err)
        return
    }

    pc.OnICECandidate(func(candidate *webrtc.ICECandidate) {
        if candidate != nil {
            jsonCandidate, _ := json.Marshal(candidate.ToJSON())
            conn.WriteMessage(websocket.TextMessage, jsonCandidate)
        }
    })

    pc.OnTrack(func(track *webrtc.TrackRemote, receiver *webrtc.RTPReceiver) {
        go func() {
            for {
                _, _, _ = track.ReadRTP()
            }
        }()
    })

    offer, err := pc.CreateOffer(nil)
    if err != nil {
        log.Println(err)
        return
    }

    err = pc.SetLocalDescription(offer)
    if err != nil {
        log.Println(err)
        return
    }

    conn.WriteJSON(offer)

    peers[conn] = pc
}

Dalam kod di atas, kami menggunakan pakej net/http Golang untuk mencipta pelayan HTTP yang ringkas. Dalam pelayan, kami menggunakan websocket.Upgrader untuk mengendalikan permintaan sambungan WebSocket dan pustaka github.com/pion/webrtc/v3 untuk mengendalikan operasi berkaitan WebRTC. peers ialah peta yang digunakan untuk mengadakan sambungan dan kejadian sambungan rakan sebaya. net/http 包来创建一个简单的HTTP服务器。在服务器中，我们使用 websocket.Upgrader 来处理WebSocket连接请求，github.com/pion/webrtc/v3 库来处理WebRTC相关的操作。peers 是一个用于保存连接和对等连接实例的映射。

四、编译和运行
1.在项目根目录下执行 go mod init

4 Kompil dan jalankan

1 Jalankan perintah go mod init dalam direktori akar projek untuk memulakan modul go.

2. Jalankan arahan berikut untuk menyusun dan menjalankan kod:

go build -o video-call-app
./video-call-app

5. Ringkasan

Melalui contoh kod di atas, kami menunjukkan cara menggunakan perpustakaan Golang dan WebRTC untuk mencipta aplikasi panggilan video berasaskan WebRTC. Pembaca boleh menjalankan pembangunan sekunder dan pengembangan fungsi mengikut keperluan mereka sendiri. Saya berharap artikel ini dapat memberikan sedikit bantuan kepada pemula dan pembangun dalam melaksanakan aplikasi panggilan audio dan video berasaskan WebRTC dalam pembangunan Golang.

Bahan rujukan:
• Dokumentasi rasmi Pion: https://pkg.go.dev/github.com/pion/webrtc/v3

Dokumentasi rasmi WebRTC: https://webrtc.org/🎜🎜

Atas ialah kandungan terperinci Pembangunan Golang: Melaksanakan aplikasi panggilan video berdasarkan WebRTC. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!