加载中…flutter推流范例
(2022-03-17 16:58:09)| 分类： Flutter-Dart |
使用的插件 video_stream: ^0.0.1
const CameraExampleHome({Key? key}) :
super(key: key);
@override
_CameraExampleHomeState createState()
{
return
_CameraExampleHomeState();
}
switch (direction) {
case
CameraLensDirection.back:
return Icons.camera_rear;
case
CameraLensDirection.front:
return Icons.camera_front;
case
CameraLensDirection.external:
return Icons.camera;
}
print('Error:
$code\nError Message: $message');
with
WidgetsBindingObserver, TickerProviderStateMixin {
CameraController? controller =
CameraController(cameras[1], ResolutionPreset.high);
String? imagePath;
String? videoPath;
String? url;
VideoPlayerController?
videoController;
late VoidCallback
videoPlayerListener;
bool enableAudio = true;
bool useOpenGL = true;
String streamURL =
"rtmp://我的地址:端口/live/szapp";
bool streaming = false;
String? cameraDirection;
Timer? _timer;
@override
void initState() {
_initialize();
super.initState();
WidgetsBinding.instance?.addObserver(this);
}
@override
void dispose() {
WidgetsBinding.instance?.removeObserver(this);
super.dispose();
}
Future _initialize() async {
streaming = false;
cameraDirection =
'front';
// controller =
CameraController(cameras[1], Resolution.high);
await
controller!.initialize();
if (!mounted) {
return;
}
setState(() {});
}
@override
void
didChangeAppLifecycleState(AppLifecycleState state) {
// App state changed
before we got the chance to initialize.
if (controller == null
|| !controller!.value.isInitialized) {
return;
}
if (state ==
AppLifecycleState.inactive) {
controller?.dispose();
if
(_timer != null) {
_timer!.cancel();
_timer = null;
}
} else if (state ==
AppLifecycleState.resumed) {
if
(controller != null) {
onNewCameraSelected(controller!.description!);
}
}
}
final GlobalKey _scaffoldKey =
GlobalKey();
toggleCameraDirection() async {
if (cameraDirection ==
'front') {
if
(controller != null) {
await controller?.dispose();
}
controller = CameraController(
cameras[0],
ResolutionPreset.high,
enableAudio: enableAudio,
androidUseOpenGL: useOpenGL,
);
// If
the controller is updated then update the UI.
controller!.addListener(() {
if (mounted) setState(() {});
if (controller!.value.hasError) {
showInSnackBar('Camera error
${controller!.value.errorDescription}');
if (_timer != null) {
_timer!.cancel();
_timer =
null;
}
Wakelock.disable();
}
});
try
{
await controller!.initialize();
} on
CameraException catch (e) {
_showCameraException(e);
}
if
(mounted) {
setState(() {});
}
cameraDirection = 'back';
} else {
if
(controller != null) {
await controller!.dispose();
}
controller = CameraController(
cameras[1],
ResolutionPreset.high,
enableAudio: enableAudio,
androidUseOpenGL: useOpenGL,
);
// If
the controller is updated then update the UI.
controller!.addListener(() {
if (mounted) setState(() {});
if (controller!.value.hasError) {
showInSnackBar('Camera error
${controller!.value.errorDescription}');
if (_timer != null) {
_timer!.cancel();
_timer =
null;
}
Wakelock.disable();
}
});
try
{
await controller!.initialize();
} on
CameraException catch (e) {
_showCameraException(e);
}
if
(mounted) {
setState(() {});
}
cameraDirection = 'front';
}
}
@override
Widget build(BuildContext context) {
return Scaffold(
extendBodyBehindAppBar: true,
resizeToAvoiomInset: true,
key:
_scaffoldKey,
body:
SingleChildScrollView(
child: SizedBox(
height:
MediaQuery.of(context).size.height,
child: Stack(
children:
[
Container(
color: Colors.black,
child: Center(
child:
_cameraPreviewWidget(),
),
),
Positioned(
top: 0.0,
left: 0.0,
right: 0.0,
child: AppBar(
backgroundColor: Colors.transparent,
elevation:
0.0,
title:
streaming
? Elevateon(
onPressed: () => onStopButtonPressed(),
style: ButtonStyle(
backgroundColor:
MaterialStateProperty.all(Colors.red)),
child: Row(
mainAxisSize:
MainAxisSize.min,
mainAxisAlignment:
MainAxisAlignment.center,
children: const [
Icon(Icons.videocam_off),
SizedBox(width: 10),
Text(
'End Stream',
style: TextStyle(
fontSize: 20.0,
fontWeight:
FontWeight.bold,
decoration:
TextDecoration.underline,
),
),
],
),
)
: Elevateon(
onPressed: () =>
onVideoStreamingButtonPressed(),
style: ButtonStyle(
backgroundColor: MaterialStateProperty.all(
Colors.blue)),
child: Row(
mainAxisSize:
MainAxisSize.min,
mainAxisAlignment:
MainAxisAlignment.center,
children: const [
Icon(Icons.videocam),
SizedBox(width: 10),
Text(
'Start Stream',
style: TextStyle(
fontSize: 20.0,
fontWeight:
FontWeight.bold,
decoration:
TextDecoration.underline,
),
),
],
),
),
actions:
[
Padding(
padding: const
EdgeInsets.all(10.0),
child: IconButton(
color:
Theme.of(context).primaryColor,
icon:
const Icon(Icons.switch_video),
tooltip:
'Switch Camera',
onPressed:
() {
toggleCameraDirection();
},
),
),
],
),
),
],
),
),
),
);
}
/// Display the preview from the camera (or
a message if the preview is not available).
Widget _cameraPreviewWidget() {
if (controller == null
|| !controller!.value.isInitialized) {
return const Text(
'Tap a camera',
style: TextStyle(
color: Colors.white,
fontSize: 24.0,
fontWeight:
FontWeight.w900,
),
);
} else {
return AspectRatio(
aspectRatio:
controller!.value.aspectRatio,
child: CameraPreview(controller!),
);
}
}
String timestamp() =>
DateTime.now().millisecondsSinceEpoch.toString();
void showInSnackBar(String message) {
ScaffoldMessenger.of(context)
.showSnackBar(SnackBar(content:
Text(message)));
}
void onNewCameraSelected(CameraDescription?
cameraDescription) async {
if (controller != null)
{
await
controller!.dispose();
}
if (cameraDescription ==
null) {
print('cameraDescription is null');
}
controller =
CameraController(
cameraDescription,
ResolutionPreset.medium,
enableAudio: enableAudio,
androidUseOpenGL: useOpenGL,
);
// If the controller is
updated then update the UI.
controller!.addListener(() {
if
(mounted) setState(() {});
if
(controller!.value.hasError) {
showInSnackBar('Camera error
${controller!.value.errorDescription}');
if (_timer != null) {
_timer!.cancel();
_timer = null;
}
Wakelock.disable();
}
});
try {
await
controller!.initialize();
} on CameraException
catch (e) {
_showCameraException(e);
}
if (mounted) {
setState(() {});
}
}
void onVideoStreamingButtonPressed()
{
startVideoStreaming().then((url) {
if
(mounted) {
setState(() {
streaming = true;
});
}
if
(url!.isNotEmpty) showInSnackBar('Streaming video to $url');
Wakelock.enable();
});
}
void onStopButtonPressed() {
stopVideoStreaming().then((_) {
if
(mounted) {
setState(() {
streaming = false;
});
}
showInSnackBar('Streaming to: $url');
});
Wakelock.disable();
}
void onPauseStreamingButtonPressed()
{
pauseVideoStreaming().then((_) {
if
(mounted) setState(() {});
showInSnackBar('Streaming paused');
});
}
void onResumeStreamingButtonPressed()
{
resumeVideoStreaming().then((_) {
if
(mounted) setState(() {});
showInSnackBar('Streaming resumed');
});
}
Future startVideoStreaming() async {
if
(!controller!.value.isInitialized) {
showInSnackBar('Error: select a camera first.');
return null;
}
// Open up a dialog for
the url
String myUrl =
streamURL;
try {
if
(_timer != null) {
_timer!.cancel();
_timer = null;
}
url =
myUrl;
await
controller!.startVideoStreaming(url!, androidUseOpenGL:
false);
//
_timer = Timer.periodic(Duration(seconds: 1), (timer) async {
// var stats = await
controller!.getStreamStatistics();
// print(stats);
//
});
} on CameraException
catch (e) {
_showCameraException(e);
return null;
}
return url;
}
Future stopVideoStreaming() async {
try {
await
controller!.stopVideoStreaming();
if
(_timer != null) {
_timer!.cancel();
_timer = null;
}
} on CameraException
catch (e) {
_showCameraException(e);
return;
}
}
Future pauseVideoStreaming() async {
if
(!controller!.value.isStreamingVideoRtmp) {
return;
}
try {
await
controller!.pauseVideoStreaming();
} on CameraException
catch (e) {
_showCameraException(e);
rethrow;
}
}
Future resumeVideoStreaming() async {
try {
await
controller!.resumeVideoStreaming();
} on CameraException
catch (e) {
_showCameraException(e);
rethrow;
}
}
void _showCameraException(CameraException
e) {
logError(e.code,
e.description);
showInSnackBar('Error:
${e.code}\n${e.description}');
}
const CameraApp({Key? key}) : super(key:
key);
@override
Widget build(BuildContext context) {
return const
MaterialApp(
home:
CameraExampleHome(),
);
}
// Fetch the available cameras before
initializing the app.
try {
WidgetsFlutterBinding.ensureInitialized();
cameras = await
availableCameras();
} on CameraException catch (e) {
logError(e.code,
e.description);
}
runApp(const CameraApp());
推流地址设置为rtmp://我的地址:端口/live/szapp
这里房间号直接挂后面
import 'dart:async';
import 'package:flutter/material.dart';
import 'package:video_player/video_player.dart';
import 'package:video_stream/camera.dart';
import 'package:wakelock/wakelock.dart';
class CameraExampleHome extends StatefulWidget {
}
/// Returns a suitable camera icon for [direction].
IconData getCameraLensIcon(CameraLensDirection direction)
{
}
void logError(String code, String message) =>
class _CameraExampleHomeState extends State
}
class CameraApp extends StatelessWidget {
}
List cameras = [];
Future main() async {
}
喜欢
0
赠金笔
前一篇：fluttervlc播放范例
后一篇：ubuntu不显示彩色解决