flutter_live 1.0.9

Live streaming player, iOS+Android, RTMP/HTTP-FLV/HLS/WebRTC, by Flutter+SRS.

example/lib/main.dart

import 'dart:io';

import 'package:flutter/material.dart';
import 'package:package_info/package_info.dart';

import 'package:flutter_live/flutter_live.dart';
import 'package:fijkplayer/fijkplayer.dart';

void main() {
  runApp(MaterialApp(
    debugShowCheckedModeBanner: false,
    home: Home(),
  ));
}

class Home extends StatefulWidget {
  @override
  State createState() => _HomeState();
}

class _HomeState extends State<Home> {
  String _url; // The final url, should equals to controller.text
  PackageInfo _info = PackageInfo(version: '0.0.0', buildNumber: '0');
  final TextEditingController _controller = TextEditingController();

  @override
  void initState() {
    super.initState();

    _controller.text = _url;
    _controller.addListener(onUserEditUrl);

    PackageInfo.fromPlatform().then((info) {
      setState(() {
        _info = info;
      });
    }).catchError((e) {
      print('platform error $e');
    });
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('SRS: Flutter Live Streaming'),
      ),
      body: Column(children: [
        UrlInputDisplay(_controller),
        DemoUrlsDisplay(_url, onUseSelectedUrl),
        ControlDisplay(() {
          this.startPlay(context);
        }),
        PlatformDisplay(this._info),
      ]),
    );
  }

  @override
  void dispose() {
    super.dispose();
    _controller.dispose();
  }

  void onUserEditUrl() {
    print('user edit event url=$_url, text=${_controller.text}');
    if (_url != _controller.text) {
      setState(() {
        _url = _controller.text;
      });
    }
  }

  void onUseSelectedUrl(String v) {
    print('user select $v, url=$_url, text=${_controller.text}');
    if (_url != v) {
      setState(() {
        _controller.text = _url = v;
      });
    }
  }

  void startPlay(BuildContext context) {
    Navigator.push(context, MaterialPageRoute(builder: (context) {
      return VideoPlayer(_url);
    }));
  }
}

class ControlDisplay extends StatelessWidget {
  final VoidCallback _onPlayUrl;
  ControlDisplay(this._onPlayUrl);

  @override
  Widget build(BuildContext context) {
    return Row(
      mainAxisAlignment: MainAxisAlignment.end,
      children: [
        RaisedButton(child: Text('Play'), onPressed: _onPlayUrl),
        Container(width: 10)
      ],
    );
  }
}

class DemoUrlsDisplay extends StatelessWidget {
  final String _url;
  final ValueChanged<String> _onUrlChanged;
  DemoUrlsDisplay(this._url, this._onUrlChanged);

  @override
  Widget build(BuildContext context) {
    return Column(children: [
      ListTile(
          title: Text('RTMP ${FlutterLive.rtmp}'),
          onTap: () {
            _onUrlChanged(FlutterLive.rtmp);
          },
          leading: Radio(
              value: FlutterLive.rtmp,
              groupValue: _url,
              onChanged: _onUrlChanged)),
      ListTile(
          title: Text('HLS ${FlutterLive.hls}'),
          onTap: () {
            _onUrlChanged(FlutterLive.hls);
          },
          leading: Radio(
              value: FlutterLive.hls,
              groupValue: _url,
              onChanged: _onUrlChanged)),
      ListTile(
          title: Text('HTTP-FLV ${FlutterLive.flv}'),
          onTap: () {
            _onUrlChanged(FlutterLive.flv);
          },
          leading: Radio(
              value: FlutterLive.flv,
              groupValue: _url,
              onChanged: _onUrlChanged)),
      ListTile(
          title: Text('HTTPS-FLV ${FlutterLive.flvs}'),
          onTap: () {
            _onUrlChanged(FlutterLive.flvs);
          },
          leading: Radio(
              value: FlutterLive.flvs,
              groupValue: _url,
              onChanged: _onUrlChanged)),
      ListTile(
          title: Text('HTTPS-HLS ${FlutterLive.hlss}'),
          onTap: () {
            _onUrlChanged(FlutterLive.hlss);
          },
          leading: Radio(
              value: FlutterLive.hlss,
              groupValue: _url,
              onChanged: _onUrlChanged)),
    ]);
  }
}

class UrlInputDisplay extends StatelessWidget {
  final TextEditingController _controller;
  UrlInputDisplay(this._controller);

  @override
  Widget build(BuildContext context) {
    return Container(
      child: TextField(controller: _controller, autofocus: false),
      padding: EdgeInsets.fromLTRB(5, 0, 5, 0),
    );
  }
}

class PlatformDisplay extends StatelessWidget {
  final PackageInfo _info;
  PlatformDisplay(this._info);

  @override
  Widget build(BuildContext context) {
    return Row(
      mainAxisAlignment: MainAxisAlignment.center,
      children: [Text('SRS/v${_info.version}+${_info.buildNumber}')],
    );
  }
}

class VideoPlayer extends StatefulWidget {
  final String _url;
  VideoPlayer(this._url);

  @override
  _VideoPlayerState createState() => _VideoPlayerState();
}

class _VideoPlayerState extends State<VideoPlayer> {
  final FijkPlayer player = FijkPlayer();

  @override
  void initState() {
    super.initState();
    player.setOption(FijkOption.playerCategory, "mediacodec-all-videos", 1);
    startPlay();
  }

  void startPlay() async {
    print('Start play ${widget._url}');

    await player.setOption(FijkOption.hostCategory, "request-screen-on", 1);
    await player.setOption(FijkOption.hostCategory, "request-audio-focus", 1);

    // Live low-latency: https://www.jianshu.com/p/d6a5d8756eec
    // For all options, read https://github.com/Bilibili/ijkplayer/blob/master/ijkmedia/ijkplayer/ff_ffplay_options.h
    await player.setOption(
        FijkOption.formatCategory, "probesize", 16 * 1024); // in bytes
    await player.setOption(
        FijkOption.formatCategory, "analyzeduration", 100 * 1000); // in us
    await player.setOption(
        FijkOption.playerCategory, "packet-buffering", 0); // 0, no buffer.
    await player.setOption(
        FijkOption.playerCategory, "max_cached_duration", 800); // in ms
    await player.setOption(
        FijkOption.playerCategory, "max-buffer-size", 32 * 1024); // in bytes
    await player.setOption(
        FijkOption.playerCategory, "infbuf", 1); // 1 for realtime.
    await player.setOption(
        FijkOption.playerCategory, "min-frames", 1); // in frames

    await player.setDataSource(widget._url, autoPlay: true).catchError((e) {
      print("setDataSource error: $e");
    });

    player.enterFullScreen();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
        appBar: AppBar(title: Text('SRS Live Streaming')),
        body: FijkView(
            player: player,
            panelBuilder: fijkPanel2Builder(),
            fsFit: FijkFit.fill));
  }

  @override
  void dispose() {
    super.dispose();
    player.release();
  }
}