Можем ли мы вручную загрузить / кэшировать транспортный поток при потоковой передаче файла m3u8 - PullRequest
Новая
       32

Можем ли мы вручную загрузить / кэшировать транспортный поток при потоковой передаче файла m3u8

0 голосов
/ 18 октября 2019

Я пытаюсь воспроизвести транспортный поток из файла m3u8. Мое требование - обработать загруженные данные, прежде чем передавать их в AVPlayer. Для этого я использую прокси-сервер [GCDWebserver] для перехвата всех запросов. В прокси-сервере я скачаю данные, обработаю их и передам обратно.

Мне удалось загрузить файл мультимедиа, а также попытался вернуть данные с помощью GCDWebServerDataResponse (data: apiData, contentType: apiResponse.mimeType ?? ""). Но проигрыватель не воспроизводит медиа-контент.

  1. Я использую GCDWebserver в качестве моего прокси-сервера.

  2. Я создал экземпляр AVPlayerItem сследующий URL http://34.55.7.151:8080/, который фактически является ip & номером порта моего локального сервера.

    /// Инициализация элемента AVPlayer 

    let url = URL(string: "http://10.155.177.151:8080/")!
let playerItem = AVPlayerItem(url: url)
player = AVPlayer(playerItem: playerItem)
player.automaticallyWaitsToMinimizeStalling = false

let playerViewController = AVPlayerViewController()
playerViewController.player = player

DispatchQueue.main.async {
    self.present(playerViewController, animated: true) {
        playerViewController.player!.play()
    }
}

/// Обработчик прокси Http 

    webServer.addDefaultHandler(forMethod: "GET", request: GCDWebServerRequest.self) { (request, completion) in

        let  mediaUrl = URL(string: "http://clips.vorwaerts-gmbh.de/big_buck_bunny.mp4")!

        if self.session == nil {
            self.session = URLSession(configuration: URLSessionConfiguration.default)
        }

        let dataTask = self.session?.dataTask(with: mediaUrl, completionHandler: { (data, response, error) in
            if let apiData = data, let apiResponse = response {
                completion(GCDWebServerDataResponse(data: apiData, contentType: apiResponse.mimeType ?? ""))
            } else {
                completion(GCDWebServerDataResponse(text: "Error"))
            }
        })
        dataTask!.resume()
    }
...