Описание
Данный пример демонстрирует публикацию одного WebRTC потока на сервер и проигрывание четырех WebRTC потоков с сервера (видеочат один-ко-многим). Может также использоваться как тест на потребление оперативной памяти при декодировании нескольких видеопотоков в высоком разрешении.
На скриншоте ниже представлен пример публикации и проигрывания потока 1280x720. Сверху отображается видео с камеры устройства, ниже - четыре проигрываемых потока
Работа с кодом примера
Для разбора кода возьмем версию примера MultiPlayerSwift, которая доступна для скачивания на GitHub.
Класс для основного вида приложения: MultiPlayerController (файл имплементации MultiPlayerController.swift).
1. Импорт API
import FPWCSApi2Swift
2. Создание сессии и подключение к серверу
WCSSession, WCSSession.connect code
В параметрах сессии указываются:
- URL WCS-сервера
- имя серверного REST hook приложения defaultApp
@IBAction func startPressed(_ sender: Any) {
...
if (startButton.title(for: .normal) == "PUBLISH AND PLAY") {
if (session == nil) {
let options = FPWCSApi2SessionOptions()
options.urlServer = urlField.text
options.appKey = "defaultApp"
do {
try session = WCSSession(options)
} catch {
print(error)
}
}
...
session?.connect()
} else {
...
}
}
3. Публикация видеопотока
WCSSession.createStream, WCSStream.publish code
Методу createStream передаются параметры:
- имя публикуемого потока
- вид для локального отображения
- ограничения высоты и ширины публикуемого потока
func publish() {
let options = FPWCSApi2StreamOptions()
options.name = streamName.text
options.display = localDisplay.videoView
let ret = FPWCSApi2MediaConstraints()
let video = FPWCSApi2VideoConstraints()
video.minWidth = Int(widthField.text ?? "0") ?? 0
video.maxWidth = video.minWidth
video.minHeight = Int(heightField.text ?? "0") ?? 0
video.maxHeight = video.minHeight
ret.video = video
options.constraints = ret
do {
publishStream = try session!.createStream(options)
} catch {
print(error);
}
...
do {
try publishStream?.publish()
} catch {
print(error);
}
}
4. Запуск воспроизведения четырех экземпларов потока при успешной публикации
fileprivate func onPublishing(_ stream:FPWCSApi2Stream) {
playStreamLT = self.play(display: remoteDisplayLT);
playStreamRT = self.play(display: remoteDisplayRT);
playStreamLB = self.play(display: remoteDisplayLB);
playStreamRB = self.play(display: remoteDisplayRB);
startButton.setTitle("STOP", for:.normal)
changeViewState(startButton, true);
changeViewState(switchCameraButton, true);
}
5. Воспроизведение потока
WCSSession.createStream, WCSStream.play code
Методу createStream передаются параметры:
- имя воспроизводимого потока
- вид для отображения потока
func play(display: WebRTCView) -> WCSStream? {
let options = FPWCSApi2StreamOptions()
options.name = streamName.text;
options.display = display.videoView;
do {
let playStream = try session!.createStream(options)
...
try playStream.play()
return playStream;
} catch {
print(error);
}
return nil;
}
6. Переключение камеры
WCSStream.switchCamera code
@IBAction func switchCameraPressed(_ sender: Any) {
publishStream?.switchCamera()
}
7. Остановка воспроизведения при остановке публикации потока
WCSStream.stop code
fileprivate func onUnpublished() {
do {
try playStreamLT?.stop();
} catch {
print(error);
}
do {
try playStreamRT?.stop();
} catch {
print(error);
}
do {
try playStreamLB?.stop();
} catch {
print(error);
}
do {
try playStreamRB?.stop();
} catch {
print(error);
}
}
8. Закрытие соединения
WCSSession.disconnect code
@IBAction func startPressed(_ sender: Any) {
changeViewState(startButton, false)
changeViewState(urlField, false)
changeViewState(streamName, false)
if (startButton.title(for: .normal) == "PUBLISH AND PLAY") {
...
session?.connect()
} else {
session?.disconnect()
}
}