screen stream

android/app/src/main/java/com/izouma/mobilecybergames/ScreenStreamPlugin.java

@@ -5,6 +5,7 @@ import android.content.Context;
 import android.content.Intent;
 import android.media.projection.MediaProjectionManager;
 import android.text.TextUtils;
+import android.util.Log;
 import android.view.View;
 import android.widget.Toast;
 
@@ -23,7 +24,8 @@ import io.flutter.plugin.common.MethodChannel;
 import io.flutter.plugin.common.PluginRegistry;
 
 public class ScreenStreamPlugin implements MethodChannel.MethodCallHandler, PluginRegistry.ActivityResultListener {
-    public static final int CAPTURE_PERMISSION_REQUEST_CODE = 0x1123;
+    private static final String TAG                             = "ScreenStreamPlugin";
+    public static final  int    CAPTURE_PERMISSION_REQUEST_CODE = 0x1123;
 
     private final PluginRegistry.Registrar registrar;
 
@@ -54,10 +56,11 @@ public class ScreenStreamPlugin implements MethodChannel.MethodCallHandler, Plug
 
     @Override
     public void onMethodCall(MethodCall methodCall, MethodChannel.Result result) {
+        this.result = result;
         if ("start".equals(methodCall.method)) {
             url = methodCall.argument("url");
             if (!TextUtils.isEmpty(url)) {
-                if (Pattern.matches("^(?i)rtmp:\\\\/\\\\/", url)) {
+                if (Pattern.matches("^(?i)rtmp://.*", url)) {
                     if (!start()) {
                         result.error("start fail", "need android 5.0", null);
                     }
@@ -86,6 +89,9 @@ public class ScreenStreamPlugin implements MethodChannel.MethodCallHandler, Plug
     }
 
     public boolean stop() {
+        if (mAlivcLivePusher != null && mAlivcLivePusher.isPushing()) {
+            mAlivcLivePusher.stopPush();
+        }
         return true;
     }
 
@@ -112,55 +118,69 @@ public class ScreenStreamPlugin implements MethodChannel.MethodCallHandler, Plug
 
             @Override
             public void onPushStarted(AlivcLivePusher pusher) {
+                Log.d(TAG, "onPushStarted");
                 started = true;
+                registrar.activity().runOnUiThread(new Runnable() {
+                    @Override
+                    public void run() {
+                        Toast.makeText(registrar.context(), "开始录屏", Toast.LENGTH_SHORT).show();
+                    }
+                });
             }
 
             @Override
             public void onFirstAVFramePushed(AlivcLivePusher alivcLivePusher) {
-
+                Log.d(TAG, "onFirstAVFramePushed");
             }
 
             @Override
             public void onPushPauesed(AlivcLivePusher pusher) {
+                Log.d(TAG, "onPushPauesed");
 
             }
 
             @Override
             public void onPushResumed(AlivcLivePusher pusher) {
-
+                Log.d(TAG, "onPushResumed");
             }
 
             @Override
             public void onPushStoped(AlivcLivePusher pusher) {
+                Log.d(TAG, "onPushStopped");
                 started = false;
                 mAlivcLivePusher = null;
+                registrar.activity().runOnUiThread(new Runnable() {
+                    @Override
+                    public void run() {
+                        Toast.makeText(registrar.context(), "录屏结束", Toast.LENGTH_SHORT).show();
+                    }
+                });
             }
 
             @Override
             public void onPushRestarted(AlivcLivePusher pusher) {
-
+                Log.d(TAG, "onPushRestarted");
             }
 
             @Override
             public void onFirstFramePreviewed(AlivcLivePusher pusher) {
-
+                Log.d(TAG, "onFirstFramePreviewed");
             }
 
             @Override
             public void onDropFrame(AlivcLivePusher pusher, int countBef, int countAft) {
-
+                Log.d(TAG, "onDropFrame");
             }
 
             @Override
             public void onAdjustBitRate(AlivcLivePusher pusher, int curBr, int targetBr) {
-
+                Log.d(TAG, "onAdjustBitRate");
             }
 
             @Override
             public void onAdjustFps(AlivcLivePusher pusher, int curFps, int targetFps) {
-
+                Log.d(TAG, "onAdjustFps");
             }
-
         });
 
         mAlivcLivePusher.startPreview(null);

lib/pages/HomePage.dart

@@ -1,4 +1,5 @@
 import 'package:flutter/material.dart';
+import 'package:flutter_redux/flutter_redux.dart';
 import '../widgets/HomeDrawer.dart';
 import './Setting.dart';
 import './CreateRoom.dart';
@@ -11,6 +12,9 @@ import '../styles/totast.dart';
 import '../net/HttpManager.dart';
 import '../net/Result.dart';
 import 'TipList.dart';
+import '../plugins/ScreenStramPlugin.dart';
+import '../model/UserInfo.dart';
+import '../redux/AppState.dart';
 
 class HomePage extends StatefulWidget {
   @override
@@ -54,18 +58,17 @@ class _HomePageState extends State<HomePage> {
         width: double.infinity,
         height: double.infinity,
         decoration: BoxDecoration(
-            gradient: LinearGradient(colors: [
-          Color.fromARGB(255, 177, 59, 56),
-          Color.fromARGB(255, 147, 64, 61)
-        ], begin: Alignment.topCenter, end: Alignment.bottomCenter)),
+            gradient: LinearGradient(
+                colors: [Color.fromARGB(255, 177, 59, 56), Color.fromARGB(255, 147, 64, 61)], begin: Alignment.topCenter, end: Alignment.bottomCenter)),
         child: SafeArea(
-          child: centerWidget(),
+          child: centerWidget(context),
         ),
       ),
     );
   }
 
-  Widget centerWidget() {
+  Widget centerWidget(BuildContext context) {
+    UserInfo userInfo = StoreProvider.of<AppState>(context).state.userInfo;
     return Column(
       children: <Widget>[
         Expanded(
@@ -98,15 +101,12 @@ class _HomePageState extends State<HomePage> {
                                       Image.asset("images/home_icon_yuan.png"),
                                       Center(
                                         child: Row(
-                                          mainAxisAlignment:
-                                              MainAxisAlignment.center,
-                                          crossAxisAlignment:
-                                              CrossAxisAlignment.baseline,
+                                          mainAxisAlignment: MainAxisAlignment.center,
+                                          crossAxisAlignment: CrossAxisAlignment.baseline,
                                           textBaseline: TextBaseline.alphabetic,
                                           children: <Widget>[
                                             Text(
-                                              (seasonList[index].bonus / 1000)
-                                                  .toStringAsFixed(1),
+                                              (seasonList[index].bonus / 1000).toStringAsFixed(1),
                                               style: TextStyle(
                                                 color: Colors.white,
                                                 fontSize: 68,
@@ -178,10 +178,7 @@ class _HomePageState extends State<HomePage> {
                   color: Colors.transparent,
                   child: InkWell(
                     onTap: () {
-                      Navigator.push(
-                          context,
-                          new CupertinoPageRoute(
-                              builder: (context) => new Setting()));
+                      Navigator.push(context, new CupertinoPageRoute(builder: (context) => new Setting()));
                     },
                     child: Padding(
                       padding: EdgeInsets.all(12),
@@ -203,13 +200,33 @@ class _HomePageState extends State<HomePage> {
                       style: TextStyle(color: Colors.white, fontSize: 14),
                     ),
                     Text(
-                      seasonList.length > 0
-                          ? seasonList[nowIndex].gameInfo.gameName
-                          : '',
+                      seasonList.length > 0 ? seasonList[nowIndex].gameInfo.gameName : '',
                       style: TextStyle(color: Colors.white, fontSize: 14),
                     )
                   ],
                 ),
+              ),
+              Positioned(
+                bottom: 60,
+                left: 0,
+                child: FlatButton(
+                  child: Text("stream"),
+                  onPressed: () async {
+                    bool success = await ScreenStreamPlugin.start('rtmp://49.4.66.233:1935/myapp/' + userInfo.id.toString() + '?playerInfoId=' + '1234');
+                    print('stream screen:' + success.toString());
+                  },
+                ),
+              ),
+              Positioned(
+                bottom: 60,
+                right: 0,
+                child: FlatButton(
+                  child: Text("stop stream"),
+                  onPressed: () async {
+                    bool success = await ScreenStreamPlugin.stop();
+                    print('stop stream screen:' + success.toString());
+                  },
+                ),
               )
             ],
           ),
@@ -227,13 +244,9 @@ class _HomePageState extends State<HomePage> {
                   Navigator.of(context).push(PageRouteBuilder(
                       opaque: false,
                       transitionDuration: Duration(milliseconds: 300),
-                      transitionsBuilder: (BuildContext context,
-                          Animation<double> animation,
-                          Animation<double> secondaryAnimation,
-                          Widget child) {
+                      transitionsBuilder: (BuildContext context, Animation<double> animation, Animation<double> secondaryAnimation, Widget child) {
                         return FadeTransition(
-                          opacity: CurvedAnimation(
-                              parent: animation, curve: Curves.linear),
+                          opacity: CurvedAnimation(parent: animation, curve: Curves.linear),
                           child: child,
                         );
                       },
@@ -251,21 +264,14 @@ class _HomePageState extends State<HomePage> {
                 "images/home_icon_sousuo.png",
                 "搜索",
                 onTapHomeMenu: () {
-                  Navigator.push(
-                      context,
-                      new CupertinoPageRoute(
-                          builder: (context) => new RoomList()));
+                  Navigator.push(context, new CupertinoPageRoute(builder: (context) => new RoomList()));
                 },
               ),
               HomeMenu(
                 "images/home_icon_youjian.png",
                 "邮件",
                 onTapHomeMenu: () {
-                   Navigator.push(
-                      context,
-                      new CupertinoPageRoute(
-                          builder: (context) => new TipList()));
-                  
+                  Navigator.push(context, new CupertinoPageRoute(builder: (context) => new TipList()));
                 },
               ),
             ],
@@ -286,11 +292,8 @@ class HomeMenu extends StatelessWidget {
   @override
   Widget build(BuildContext context) {
     return Container(
-      decoration: BoxDecoration(
-          gradient: LinearGradient(
-              begin: Alignment.topCenter,
-              end: Alignment.bottomCenter,
-              colors: [Color(0xFF626C85), Color(0xFF3D3E6C)])),
+      decoration:
+          BoxDecoration(gradient: LinearGradient(begin: Alignment.topCenter, end: Alignment.bottomCenter, colors: [Color(0xFF626C85), Color(0xFF3D3E6C)])),
       child: AspectRatio(
         aspectRatio: 1,
         child: Container(

lib/plugins/ScreenStramPlugin.dart

@@ -1,18 +1,18 @@
 import 'package:flutter/services.dart';
 
 class ScreenStreamPlugin {
-  static const _channel = MethodChannel("screen_stram");
+  static const _channel = MethodChannel("screen_stream");
 
   static Future<bool> start(String url) async {
     try {
-      await _channel.invokeMethod("start", [url]);
+      await _channel.invokeMethod("start", {"url": url});
       return true;
     } catch (e) {
       return false;
     }
   }
 
-  static Future<bool> stop(String url) async {
+  static Future<bool> stop() async {
     try {
       await _channel.invokeMethod("stop", []);
       return true;