整合Video 到 flutter

android/build.gradle

@@ -2,7 +2,7 @@ group 'com.shuangyubang.mofun_flutter_plugin_video'
 version '1.0-SNAPSHOT'
 
 buildscript {
-    ext.kotlin_version = '1.3.21'
+    ext.kotlin_version = '1.3.31'
     repositories {
         google()
         jcenter()
@@ -25,7 +25,7 @@ apply plugin: 'com.android.library'
 apply plugin: 'kotlin-android'
 
 android {
-    compileSdkVersion 27
+    compileSdkVersion 28
 
     sourceSets {
         main.java.srcDirs += 'src/main/kotlin'

android/src/main/java/com/fgodt/mixplayer/Player.java

@@ -12,12 +12,12 @@ import java.util.ArrayList;
 public class Player extends Render {
 
 
-    public final int STATUS_ERROR = 0;
-    public final int STATUS_STOP = 1;
-    public final int STATUS_START = 2;
-    public final int STATUS_PAUSE = 3;
-    public final int STATUS_BUFFING = 4;
-    public final int STATUS_RUNNING = 5;
+    public static final int STATUS_ERROR = 0;
+    public static final int STATUS_STOP = 1;
+    public static final int STATUS_START = 2;
+    public static final int STATUS_PAUSE = 3;
+    public static final int STATUS_BUFFING = 4;
+    public static final int STATUS_RUNNING = 5;
 
     private Core mixCore;
     private Core enMixCore;

android/src/main/java/com/fgodt/mixplayer/Render.java

@@ -1,21 +1,13 @@
 package com.fgodt.mixplayer;
 
 import android.content.Context;
-import android.content.res.Configuration;
-import android.media.AudioAttributes;
 import android.media.AudioFormat;
 import android.media.AudioManager;
 import android.media.AudioTrack;
-import android.opengl.GLSurfaceView;
-import android.support.v7.app.AppCompatActivity;
+import android.os.Build;
 import android.util.Log;
-import android.widget.FrameLayout;
 
-import java.sql.Time;
-import java.util.Arrays;
-import java.util.Date;
-
-import static java.lang.Thread.*;
+import static java.lang.Thread.sleep;
 
 /**
  * Created by rt-zl on 2019/2/15.
@@ -24,7 +16,6 @@ import static java.lang.Thread.*;
 public class Render extends VideoRender {
 
 
-
     static {
         System.loadLibrary("mixplayer");
     }
@@ -34,24 +25,25 @@ public class Render extends VideoRender {
     private native int setRenderHandler(long handler);
 
     int asample, ach, abit;
-    public int mixUpdateAudio(byte[] data, int size,double pts){
+
+    public int mixUpdateAudio(byte[] data, int size, double pts) {
         playTime = pts;
         synchronized (audioBuf) {
             if (audioBufLen - audioHas < size) {
                 return -1;
             }
             int len = audioBufLen - audioWPos;
-            len = len > size ? size :len;
-            System.arraycopy(data,0,audioBuf,audioWPos,len);
+            len = len > size ? size : len;
+            System.arraycopy(data, 0, audioBuf, audioWPos, len);
             audioWPos += len;
-            audioHas +=len;
-            if(audioWPos == audioBufLen){
+            audioHas += len;
+            if (audioWPos == audioBufLen) {
                 audioWPos = 0;
             }
-            if(len<size){
+            if (len < size) {
                 int les = size - len;
-                System.arraycopy(data,len,audioBuf,audioWPos,les);
-                audioWPos +=les;
+                System.arraycopy(data, len, audioBuf, audioWPos, les);
+                audioWPos += les;
                 audioHas += les;
             }
             return 0;
@@ -59,62 +51,63 @@ public class Render extends VideoRender {
     }
 
 
-    public int mixOpen(int vWidth,int vHeight,int asample, int ach, int abit){
-        if(vWidth>0){
-            Log.d("MIXOPEN","has video");
-            nativeInit(getScreenWidth(),getScreenHeight());
+    public int mixOpen(int vWidth, int vHeight, int asample, int ach, int abit) {
+        if (vWidth > 0) {
+            Log.d("MIXOPEN", "has video");
+            nativeInit(getScreenWidth(), getScreenHeight());
             this.abit = abit;
             this.asample = asample;
             this.ach = ach;
             initAudioTrack();
-            return  0;
+            return 0;
         }
         return -1;
     }
 
 
-    public void mixClose(){
+    public void mixClose() {
         super.close();
     }
 
-    public void renderClose(){
+    public void renderClose() {
         play = false;
-        if (audioTrack!=null){
+        if (audioTrack != null) {
             audioTrack.stop();
             totalAudioBuf = 0;
         }
     }
 
-    public Render(Context context){
+    public Render(Context context) {
         super(context);
     }
 
-    public void init(long handler){
+    public void init(long handler) {
         this.handler = handler;
         setMixHander(handler);
         this.setRenderHandler(handler);
     }
 
     public double getPlaytime() {
-        return  playTime;
+        return playTime;
     }
 
-    AudioTrack audioTrack ;
+    AudioTrack audioTrack;
 
-    byte[] audioBuf ;
+    byte[] audioBuf;
     long totalAudioBuf;
     int audioHas;
     int audioRPos, audioWPos;
-    int audioBufLen = 4096*3;
+    int audioBufLen = 4096 * 3;
     long silenceLen = 0;
     boolean play = false;
     double playTime = 0;
     byte[] silencBuf;
-    private void initAudioTrack(){
+
+    private void initAudioTrack() {
         silencBuf = new byte[4096];
         audioBuf = new byte[audioBufLen];
-        audioTrack = new AudioTrack(AudioManager.STREAM_MUSIC,asample,
-                AudioFormat.CHANNEL_IN_STEREO,AudioFormat.ENCODING_PCM_16BIT,audioBufLen,AudioTrack.MODE_STREAM);
+        audioTrack = new AudioTrack(AudioManager.STREAM_MUSIC, asample,
+                AudioFormat.CHANNEL_IN_STEREO, AudioFormat.ENCODING_PCM_16BIT, audioBufLen, AudioTrack.MODE_STREAM);
         play = true;
         new Thread(new Runnable() {
             @Override
@@ -129,49 +122,57 @@ public class Render extends VideoRender {
                         // 16bit 2channels = 4 Byte
                         pos *= 4;
                         pos -= silenceLen;
-                        if(posPre != pos){
+                        if (posPre != pos) {
                             posPre = pos;
                             retryCount = 0;
-                        }else {
-                            if(retryCount > 5)
+                        } else {
+                            if (retryCount > 5)
                                 needUpdate = true;
-                            retryCount ++;
+                            retryCount++;
                         }
-                        if (audioHas >= wsize && totalAudioBuf - pos < audioBufLen || pos <= 0 ||needUpdate ) {
+                        if (audioHas >= wsize && totalAudioBuf - pos < audioBufLen || pos <= 0 || needUpdate) {
                             needUpdate = false;
                             int len = audioBufLen - audioRPos;
-                            len = len > wsize? wsize:len;
+                            len = len > wsize ? wsize : len;
                             int ret = audioTrack.write(audioBuf, audioRPos, len);
                             audioRPos += ret;
                             audioHas -= ret;
-                            totalAudioBuf+=ret;
+                            totalAudioBuf += ret;
                             if (audioRPos == audioBufLen) {
                                 audioRPos = 0;
                             }
-                        }else {
-                        //    if (pos == totalAudioBuf && audioHas < wsize){
-                        //        int c = audioTrack.write(silencBuf,0,2048);
-                        //        silenceLen +=c;
-                        //    }
+                        } else {
+                            //    if (pos == totalAudioBuf && audioHas < wsize){
+                            //        int c = audioTrack.write(silencBuf,0,2048);
+                            //        silenceLen +=c;
+                            //    }
                         }
-                        if(ispause){
-                            if(audioTrack.getPlayState() != AudioTrack.PLAYSTATE_PAUSED) {
+                        if (ispause) {
+                            if (audioTrack.getPlayState() != AudioTrack.PLAYSTATE_PAUSED) {
                                 audioTrack.pause();
-                                audioTrack.setVolume(0);
+                                if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {
+                                    audioTrack.setVolume(0);
+                                } else {
+                                    audioTrack.setStereoVolume(0, 0);
+                                }
                             }
-                        }else{
-                            if(audioTrack.getPlayState()!=AudioTrack.PLAYSTATE_PLAYING) {
+                        } else {
+                            if (audioTrack.getPlayState() != AudioTrack.PLAYSTATE_PLAYING) {
                                 audioTrack.play();
-                                audioTrack.setVolume(volume);
+                                if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {
+                                    audioTrack.setVolume(volume);
+                                } else {
+                                    audioTrack.setStereoVolume(volume, volume);
+                                }
                             }
                         }
                     }
                     try {
                         sleep(3);
-                    }catch (Exception ex){
+                    } catch (Exception ex) {
                     }
                 }
-                Log.d("mixplayer","audio close");
+                Log.d("mixplayer", "audio close");
             }
         }).start();
         audioTrack.play();

android/src/main/java/com/fogdt/mixsample/MainActivity.java

@@ -1,252 +0,0 @@
-package com.fogdt.mixsample;
-
-import android.Manifest;
-import android.app.ActivityManager;
-import android.app.AlertDialog;
-import android.content.DialogInterface;
-import android.content.pm.PackageManager;
-import android.content.res.Configuration;
-import android.media.AudioFormat;
-import android.media.AudioRecord;
-import android.media.MediaCodecInfo;
-import android.media.MediaRecorder;
-import android.os.Environment;
-import android.os.PersistableBundle;
-import android.support.annotation.Nullable;
-import android.support.v4.app.ActivityCompat;
-import android.support.v4.content.ContextCompat;
-import android.support.v7.app.AppCompatActivity;
-import android.os.Bundle;
-import android.text.TextPaint;
-import android.util.DisplayMetrics;
-import android.util.Log;
-import android.view.Gravity;
-import android.view.SurfaceHolder;
-import android.view.SurfaceView;
-import android.view.View;
-import android.view.ViewGroup;
-import android.view.WindowManager;
-import android.widget.EditText;
-import android.widget.FrameLayout;
-import android.widget.TextView;
-import android.widget.Toast;
-
-import com.fgodt.mixplayer.Core;
-import com.fgodt.mixplayer.Player;
-import com.fgodt.mixplayer.mixPlayerCallBack;
-
-import java.io.File;
-
-
-public class MainActivity extends AppCompatActivity implements mixPlayerCallBack {
-
-
-    private long handler =0;
-
-    AudioRecord audioRecord = null;
-    @Override
-    protected void onCreate(Bundle savedInstanceState) {
-        super.onCreate(savedInstanceState);
-
-
-
-        setContentView(R.layout.activity_main);
-
-
-
-        // Example of a call to a native method
-        TextView tv = (TextView) findViewById(R.id.sample_text);
-
-        tv.setText("el");
-        getPermission();
-
-
-        if(savedInstanceState == null)
-            test();
-    }
-
-    @Override
-    public void onWindowAttributesChanged(WindowManager.LayoutParams params) {
-        super.onWindowAttributesChanged(params);
-    }
-
-    private Player mixplayer ;
-    private void test(){
-
-        FrameLayout.LayoutParams params = new FrameLayout.LayoutParams(FrameLayout.LayoutParams.FILL_PARENT,
-                FrameLayout.LayoutParams.WRAP_CONTENT);
-        params.gravity = Gravity.TOP;
-        params.height = 1080*9/16;
-        mixplayer = new Player(this);
-        mixplayer.setMixCall(this);
-        mixplayer.addMixSource("mix1",0,-1);
-        mixplayer.addMixSource("silence",0,-1);
-       // mixplayer.selectAudioSource("silence");
-       // mixplayer.selectAudioSource("mix1");
-        addContentView(mixplayer,params);
-        editText = findViewById(R.id.editText);
-    }
-
-    private String getPath(){
-        String  file = Environment.getExternalStoragePublicDirectory(
-                Environment.DIRECTORY_MOVIES)+"" ;
-        return file;
-    }
-
-    private EditText editText;
-    public void playClick(View sender){
-        if(!hasRWPermission) {
-            getPermission();
-            return;
-        }
-        mixplayer.open(editText.getText().toString());
-    }
-
-    public void savedClick(View view){
-        //mixplayer.selectAudioSource(editText.getText().toString());
-        mixplayer.saveFile(editText.getText().toString(),getPath()+"/mixtest.mp4");
-        //mixplayer.saveFile(editText.getText().toString(),"rtmp://192.168.3.10/live/abc1234");
-    }
-
-    //10s pcm data
-    int totalLen = 4*44100*10;
-    byte[] pcmData = new byte[4*44100*10];
-    int pcmWritePos = 0;
-    public void closeClick(View sender){
-       mixplayer.stop();
-    }
-
-    public void recorderClick(View view){
-        if(!hasRcordPermission) {
-            getPermission();
-            return;
-        }
-
-
-        audioRecord = new AudioRecord(MediaRecorder.AudioSource.MIC,44100, AudioFormat.CHANNEL_IN_STEREO,AudioFormat.ENCODING_PCM_16BIT,4096*3);
-        if(audioRecord.getState() != AudioRecord.STATE_INITIALIZED){
-            Toast.makeText(this,"初始化录音失败",Toast.LENGTH_SHORT).show();
-            return;
-        }
-
-        if(audioRecord != null){
-            audioRecord.startRecording();
-            pcmWritePos = 0;
-            pcmReadPos = 0;
-            new Thread(new Runnable() {
-                @Override
-                public void run() {
-                    while (pcmWritePos<totalLen){
-                        int wlen = totalLen-pcmWritePos > 4096? 4096:totalLen-pcmWritePos;
-                        int ret = audioRecord.read(pcmData,pcmWritePos,wlen);
-                        pcmWritePos+=ret;
-                    }
-                    audioRecord.stop();
-                }
-            }).start();
-        }
-    }
-
-    public void playerAndResume(View view){
-        if(mixplayer.getStatus() == mixplayer.STATUS_PAUSE){
-            mixplayer.resume();
-        }else if(mixplayer.getStatus() == mixplayer.STATUS_RUNNING){
-            mixplayer.pause();
-        }
-    }
-
-    @Override
-    protected void onSaveInstanceState(Bundle outState) {
-        super.onSaveInstanceState(outState);
-    }
-
-
-    @Override
-    protected void onRestoreInstanceState(Bundle savedInstanceState) {
-        super.onRestoreInstanceState(savedInstanceState);
-    }
-
-
-    int pcmReadPos = 0;
-    @Override
-    public int mix_call(String name, byte[] data, int len) {
-        if(name.equals("silence")){
-            return 0;
-        }
-        if(totalLen - pcmReadPos < len){
-            return 0;
-        }else {
-            System.arraycopy(pcmData,pcmReadPos,data,0,len);
-            pcmReadPos += len;
-            return len;
-        }
-    }
-
-    @Override
-    public void closeMsg(String msg) {
-        Toast.makeText(this,"MIX CLOSE",Toast.LENGTH_SHORT).show();
-    }
-
-
-    private boolean hasRWPermission = false;
-    private boolean hasRcordPermission = false;
-
-    private  void getPermission(){
-        int has = ContextCompat.checkSelfPermission(getApplication(), Manifest.permission.WRITE_EXTERNAL_STORAGE);
-        if (has == PackageManager.PERMISSION_GRANTED){
-            hasRWPermission = true;
-        }else {
-            ActivityCompat.requestPermissions(this,new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE  },1);
-        }
-
-        has = ContextCompat.checkSelfPermission(getApplication(), Manifest.permission.RECORD_AUDIO);
-        if (has == PackageManager.PERMISSION_GRANTED){
-            hasRcordPermission = true;
-        }else {
-            ActivityCompat.requestPermissions(this,new String[]{Manifest.permission.RECORD_AUDIO},2);
-        }
-    }
-
-    @Override
-    public void onRequestPermissionsResult(int requestCode, String[] permissions, int[] grantResults){
-        if(requestCode == 1){
-            if(grantResults.length>0&&grantResults[0] == PackageManager.PERMISSION_GRANTED){
-                hasRWPermission = true;
-            }else {
-                if(ActivityCompat.shouldShowRequestPermissionRationale(this,Manifest.permission.WRITE_EXTERNAL_STORAGE)){
-                    new AlertDialog.Builder(this)
-                            .setMessage("need read write permisson")
-                            .setPositiveButton("ok",(d,w)->{
-                                if (w == DialogInterface.BUTTON_POSITIVE){
-                                    ActivityCompat.requestPermissions(this,new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE},1);
-                                }
-                            })
-                            .setNegativeButton("cancle",null)
-                            .setTitle("需要提供相应权限")
-                            .create()
-                            .show();
-                }
-            }
-        }
-        if (requestCode == 2){
-            if(grantResults.length>0&&grantResults[0] == PackageManager.PERMISSION_GRANTED){
-                hasRcordPermission = true;
-            }else {
-                if(ActivityCompat.shouldShowRequestPermissionRationale(this,Manifest.permission.RECORD_AUDIO)){
-                    new AlertDialog.Builder(this)
-                            .setMessage("need record audio permisson")
-                            .setPositiveButton("ok",(dialog,which)->{
-                                if (which == DialogInterface.BUTTON_POSITIVE){
-                                    ActivityCompat.requestPermissions(this,new String[]{Manifest.permission.RECORD_AUDIO},1);
-                                }
-                            })
-                            .setNegativeButton("cancle",null)
-                            .setTitle("需要录音权限")
-                            .create()
-                            .show();
-                }
-            }
-        }
-    }
-
-}

android/src/main/kotlin/com/shuangyubang/mofun_flutter_plugin_video/MofunRealVideoView.kt

@@ -1,49 +1,116 @@
 package com.shuangyubang.mofun_flutter_plugin_video
 
 import android.content.Context
+import android.media.AudioFormat
+import android.media.AudioRecord
+import android.media.MediaRecorder
+import android.os.Environment
 import android.view.Gravity
 import android.view.View
-import android.widget.EditText
 import android.widget.FrameLayout
-import android.widget.LinearLayout
+import android.widget.Toast
 import com.fgodt.mixplayer.Player
 import com.fgodt.mixplayer.mixPlayerCallBack
 
 class MofunRealVideoView(val context: Context) : mixPlayerCallBack {
 
-    private var trueView:FrameLayout? = null
+    private var trueView: FrameLayout? = null
+    private var mixplayer: Player? = null
+    private var url: String? = null
 
-    fun getView(): View? {
+    //10s pcm data
+    private var totalLen = 4 * 44100 * 10
+    private var pcmData = ByteArray(4 * 44100 * 10)
+    private var pcmWritePos = 0
+
+    private var pcmReadPos = 0
+
+    fun getView(): View {
         synchronized(MofunRealVideoView::class) {
-            if (trueView == null){
+            if (trueView == null) {
                 initView()
             }
         }
-        return trueView
+        return trueView!!
+    }
+
+    fun dispose(){
+        mixplayer?.stop()
     }
 
-    private fun initView(){
+    private fun initView() {
         trueView = FrameLayout(context)
         val params = FrameLayout.LayoutParams(FrameLayout.LayoutParams.MATCH_PARENT,
-                FrameLayout.LayoutParams.WRAP_CONTENT)
-        params.gravity = Gravity.TOP
-        params.height = 1080 * 9 / 16
-        val mixplayer = Player(context)
-        mixplayer.setMixCall(this)
-        mixplayer.addMixSource("mix1", 0.0, -1.0)
-        mixplayer.addMixSource("silence", 0.0, -1.0)
-        // mixplayer.selectAudioSource("silence");
-        // mixplayer.selectAudioSource("mix1");
-
-        trueView?.addView(mixplayer, params)
+                FrameLayout.LayoutParams.MATCH_PARENT)
+        mixplayer = Player(context)
+        mixplayer?.apply {
+            this.setMixCall(this@MofunRealVideoView)
+            this.addMixSource("mix1", 0.0, -1.0)
+            this.addMixSource("silence", 0.0, -1.0)
+            // mixplayer.selectAudioSource("silence");
+            // mixplayer.selectAudioSource("mix1");
 
+            trueView?.addView(this, params)
+        }
     }
 
     override fun mix_call(name: String?, data: ByteArray?, len: Int): Int {
-        TODO("not implemented") //To change body of created functions use File | Settings | File Templates.
+        if (name == "silence") {
+            return 0
+        }
+        if (totalLen - pcmReadPos < len) {
+            return 0
+        } else {
+            System.arraycopy(pcmData, pcmReadPos, data, 0, len)
+            pcmReadPos += len
+            return len
+        }
     }
 
     override fun closeMsg(msg: String?) {
-        TODO("not implemented") //To change body of created functions use File | Settings | File Templates.
+        Toast.makeText(context, "MIX CLOSE", Toast.LENGTH_SHORT).show()
+    }
+
+    fun play(url: String) {
+        this.url = url
+        mixplayer?.open(url)
+    }
+
+    fun save(output: String) {
+        if (url != null)
+            mixplayer?.saveFile(url, output)
+    }
+
+    fun stop() {
+        mixplayer?.stop()
+    }
+
+    fun record() {
+        val audioRecord = AudioRecord(MediaRecorder.AudioSource.MIC, 44100, AudioFormat.CHANNEL_IN_STEREO, AudioFormat.ENCODING_PCM_16BIT, 4096 * 3)
+        if (audioRecord.getState() != AudioRecord.STATE_INITIALIZED) {
+            Toast.makeText(context, "初始化录音失败", Toast.LENGTH_SHORT).show()
+            return
+        }
+
+        audioRecord.startRecording()
+        pcmWritePos = 0
+        pcmReadPos = 0
+        Thread(Runnable {
+            while (pcmWritePos < totalLen) {
+                val wlen = if (totalLen - pcmWritePos > 4096) 4096 else totalLen - pcmWritePos
+                val ret = audioRecord.read(pcmData, pcmWritePos, wlen)
+                pcmWritePos += ret
+            }
+            audioRecord.stop()
+        }).start()
+
+    }
+
+    fun playerAndResume() {
+        if (mixplayer?.status == Player.STATUS_PAUSE) {
+            mixplayer?.resume()
+        } else if (mixplayer?.status == Player.STATUS_RUNNING) {
+            mixplayer?.pause()
+        }
     }
 }

android/src/main/kotlin/com/shuangyubang/mofun_flutter_plugin_video/MofunVideoView.kt

@@ -4,6 +4,7 @@ import android.content.Context
 import android.graphics.Color
 import android.view.View
 import android.widget.TextView
+import android.widget.Toast
 import io.flutter.plugin.common.BinaryMessenger
 import io.flutter.plugin.common.MethodCall
 import io.flutter.plugin.common.MethodChannel
@@ -17,35 +18,65 @@ const val Channel_Mofun_Video_Info = "plugins.shuangyunbang.mofun/mofunvideoview
 class MofunVideoView
     : PlatformView, MethodChannel.MethodCallHandler {
 
-    private val textView: TextView
+    private val videoView: MofunRealVideoView
 
     constructor(context: Context, messenger: BinaryMessenger, id: Int, creationParams: Any?) {
-        textView = TextView(context)
-        textView.setBackgroundColor(Color.BLUE)
+        videoView = MofunRealVideoView(context)
         MethodChannel(messenger, Channel_Mofun_Video_Info + "_$id").setMethodCallHandler(this)
     }
 
     override fun getView(): View {
-        return textView
+        return videoView.getView()
     }
 
     override fun dispose() {
-
+        videoView.dispose()
     }
 
     override fun onMethodCall(methodCall: MethodCall, result: MethodChannel.Result) {
         when (methodCall.method) {
-            "setText" -> setText(methodCall, result)
+            "toast" -> toast(methodCall, result)
+            "play" -> play(methodCall, result)
+            "stop" -> stop(methodCall, result)
+            "save" -> save(methodCall, result)
+            "record" -> record(methodCall, result)
+            "playerAndResume" -> playerAndResume(methodCall, result)
             else -> result.notImplemented()
         }
     }
 
-    private fun setText(methodCall: MethodCall, result: MethodChannel.Result) {
-        val text = methodCall.arguments as String
-        textView.text = text
+    private fun toast(methodCall: MethodCall, result: MethodChannel.Result) {
+        val url = methodCall.arguments as String
+        Toast.makeText(videoView.context, url, Toast.LENGTH_SHORT).show()
+        result.success(null)
+    }
+
+    private fun play(methodCall: MethodCall, result: MethodChannel.Result) {
+        val url = methodCall.arguments as String
+        videoView.play(url)
         result.success(null)
     }
 
+    private fun stop(methodCall: MethodCall, result: MethodChannel.Result) {
+        videoView.stop()
+        result.success(null)
+    }
+
+    private fun save(methodCall: MethodCall, result: MethodChannel.Result) {
+        val output = methodCall.arguments as String
+        videoView.save(output)
+        result.success(null)
+    }
+
+    private fun record(methodCall: MethodCall, result: MethodChannel.Result) {
+        videoView.record()
+        result.success(null)
+    }
+
+    private fun playerAndResume(methodCall: MethodCall, result: MethodChannel.Result) {
+        videoView.playerAndResume()
+        result.success(null)
+    }
 }
 
 class MofunVideoViewFactory(val messenger: BinaryMessenger) : PlatformViewFactory(StandardMessageCodec.INSTANCE) {

example/android/app/build.gradle

@@ -26,7 +26,7 @@ apply plugin: 'kotlin-android'
 apply from: "$flutterRoot/packages/flutter_tools/gradle/flutter.gradle"
 
 android {
-    compileSdkVersion 27
+    compileSdkVersion 28
 
     sourceSets {
         main.java.srcDirs += 'src/main/kotlin'
@@ -40,7 +40,7 @@ android {
         // TODO: Specify your own unique Application ID (https://developer.android.com/studio/build/application-id.html).
         applicationId "com.shuangyubang.mofun_flutter_plugin_video_example"
         minSdkVersion 16
-        targetSdkVersion 27
+        targetSdkVersion 28
         versionCode flutterVersionCode.toInteger()
         versionName flutterVersionName
         testInstrumentationRunner "android.support.test.runner.AndroidJUnitRunner"

example/android/build.gradle

@@ -1,5 +1,5 @@
 buildscript {
-    ext.kotlin_version = '1.3.21'
+    ext.kotlin_version = '1.3.31'
     repositories {
         google()
         jcenter()

example/lib/main.dart

@@ -43,31 +43,76 @@ class _MyAppState extends State<MyApp> {
 
   @override
   Widget build(BuildContext context) {
+    const String defaultUrl = 'rtmp://live.hkstv.hk.lxdns.com/live/hks1';
+
     return MaterialApp(
       home: Scaffold(
-        appBar: AppBar(
-          title: const Text('Plugin example app'),
-        ),
-        body: Column(
-          children: <Widget>[
-            Container(
-              alignment: Alignment.center,
-              height: 48,
-              child: Text('Running on: $_platformVersion'),
-            ),
-            Container(
-              height: 100.0,
-              child: MofunVideoView(
-                onMofunVideoViewCreated: _onMofunVideoViewCreated,
-              ),
-            ),
-          ],
-        ),
-      ),
+          appBar: AppBar(
+            title: const Text('Plugin example app'),
+          ),
+          body: Builder(builder: (context) {
+            TextEditingController textEditingController =
+                TextEditingController(text: defaultUrl);
+            MofunVideoViewController controller;
+            String url;
+
+            return Column(
+              children: <Widget>[
+                Container(
+                  height: 400.0,
+                  child: MofunVideoView(
+                    onMofunVideoViewCreated: (c) {
+                      controller = c;
+                      c.toast('Mofun video!');
+                    },
+                  ),
+                ),
+                TextField(
+                    controller: textEditingController,
+                    onChanged: (s) => url = s),
+                Row(
+                  mainAxisAlignment: MainAxisAlignment.spaceEvenly,
+                  children: <Widget>[
+                    RaisedButton(
+                      onPressed: () {
+                        controller?.play(url ?? defaultUrl);
+                      },
+                      child: Text('Play'),
+                    ),
+                    RaisedButton(
+                      onPressed: () {
+                        controller?.stop();
+                      },
+                      child: Text('Stop'),
+                    ),
+                    RaisedButton(
+                      onPressed: () {
+                        controller?.toast('暂不支持');
+                      },
+                      child: Text('Save'),
+                    ),
+                  ],
+                ),
+                Row(
+                  mainAxisAlignment: MainAxisAlignment.spaceEvenly,
+                  children: <Widget>[
+                    RaisedButton(
+                      onPressed: () {
+                        controller?.record();
+                      },
+                      child: Text('Record'),
+                    ),
+                    RaisedButton(
+                      onPressed: () {
+                        controller?.playerAndResume();
+                      },
+                      child: Text('PlayerAndResume'),
+                    ),
+                  ],
+                ),
+              ],
+            );
+          })),
     );
   }
 }
-
-void _onMofunVideoViewCreated(MofunVideoViewController controller) {
-  controller.setText('Hello from Android!');
-}

example/pubspec.lock

@@ -81,6 +81,13 @@ packages:
       url: "https://pub.flutter-io.cn"
     source: hosted
     version: "1.5.0"
+  permission_handler:
+    dependency: "direct main"
+    description:
+      name: permission_handler
+      url: "https://pub.flutter-io.cn"
+    source: hosted
+    version: "3.0.1"
   quiver:
     dependency: transitive
     description:

example/pubspec.yaml

@@ -12,6 +12,7 @@ dependencies:
   # The following adds the Cupertino Icons font to your application.
   # Use with the CupertinoIcons class for iOS style icons.
   cupertino_icons: ^0.1.2
+  permission_handler: ^3.0.0
 
 dev_dependencies:
   flutter_test:

lib/mofun_video_view.dart

@@ -3,6 +3,7 @@ import 'dart:async';
 import 'package:flutter/foundation.dart';
 import 'package:flutter/services.dart';
 import 'package:flutter/widgets.dart';
+import 'package:permission_handler/permission_handler.dart';
 
 typedef void MofunVideoViewCreatedCallback(MofunVideoViewController controller);
 
@@ -20,10 +21,11 @@ class MofunVideoView extends StatefulWidget {
   State<StatefulWidget> createState() {
     return _MofunVideoViewState();
   }
-
 }
 
 class _MofunVideoViewState extends State<MofunVideoView> {
+  MofunVideoViewController controller;
+
   @override
   Widget build(BuildContext context) {
     if (defaultTargetPlatform == TargetPlatform.android) {
@@ -31,7 +33,7 @@ class _MofunVideoViewState extends State<MofunVideoView> {
         viewType: _CHANNEL,
         onPlatformViewCreated: _onPlatformViewCreated,
       );
-    }else if (defaultTargetPlatform == TargetPlatform.iOS) {
+    } else if (defaultTargetPlatform == TargetPlatform.iOS) {
       return UiKitView(
         viewType: _CHANNEL,
         onPlatformViewCreated: _onPlatformViewCreated,
@@ -42,21 +44,85 @@ class _MofunVideoViewState extends State<MofunVideoView> {
   }
 
   void _onPlatformViewCreated(int id) {
-    if (widget.onMofunVideoViewCreated == null) {
-      return;
+    if (controller == null || controller.id != id) {
+      controller = MofunVideoViewController._(id);
+    }
+
+    if (widget.onMofunVideoViewCreated != null) {
+      widget.onMofunVideoViewCreated(controller);
     }
-    widget.onMofunVideoViewCreated(new MofunVideoViewController._(id));
   }
 }
 
 class MofunVideoViewController {
-  MofunVideoViewController._(int id)
+  final int id;
+  final MethodChannel _channel;
+
+  bool _hasPermission = false;
+
+  MofunVideoViewController._(this.id)
       : _channel = new MethodChannel('${_CHANNEL}_$id');
 
-  final MethodChannel _channel;
+  ///检查权限。返回是否权限充足
+  Future<bool> _checkPermission() async {
+    List<PermissionGroup> needCheck = List();
+
+    PermissionHandler permissionHandler = PermissionHandler();
+    PermissionStatus permission =
+        await permissionHandler.checkPermissionStatus(PermissionGroup.storage);
+    if (permission != PermissionStatus.granted) {
+      needCheck.add(PermissionGroup.storage);
+    }
+    permission = await permissionHandler
+        .checkPermissionStatus(PermissionGroup.microphone);
+    if (permission != PermissionStatus.granted) {
+      needCheck.add(PermissionGroup.microphone);
+    }
+
+    if (needCheck.isEmpty) {
+      return true;
+    }
+    Map<PermissionGroup, PermissionStatus> noPermissions =
+        await permissionHandler.requestPermissions(needCheck);
+    noPermissions.removeWhere((key, value) => value == PermissionStatus.granted);
+
+    return noPermissions.isEmpty;
+  }
 
-  Future<void> setText(String text) async {
-    assert(text != null);
-    return _channel.invokeMethod('setText', text);
+  Future<bool> checkPermission() async{
+    if(!_hasPermission){
+      return _checkPermission();
+    }
+    return true;
+  }
+
+  Future<void> toast(String msg) async {
+    return _channel.invokeMethod('toast', msg);
+  }
+
+  Future<void> play(String url) async {
+    await checkPermission();
+    return _channel.invokeMethod('play', url);
+  }
+
+  Future<void> stop() async {
+    await checkPermission();
+    return _channel.invokeMethod('stop');
   }
-}
+
+  Future<void> save(String output) async {
+    await checkPermission();
+    return _channel.invokeMethod('save', output);
+  }
+
+  Future<void> record() async {
+    await checkPermission();
+    return _channel.invokeMethod('record');
+  }
+
+  Future<void> playerAndResume() async {
+    await checkPermission();
+    return _channel.invokeMethod('playerAndResume');
+  }
+
+}

pubspec.lock

@@ -67,6 +67,13 @@ packages:
       url: "https://pub.flutter-io.cn"
     source: hosted
     version: "1.5.0"
+  permission_handler:
+    dependency: "direct main"
+    description:
+      name: permission_handler
+      url: "https://pub.flutter-io.cn"
+    source: hosted
+    version: "3.0.1"
   quiver:
     dependency: transitive
     description:

pubspec.yaml

@@ -10,6 +10,7 @@ environment:
 dependencies:
   flutter:
     sdk: flutter
+  permission_handler: '^3.0.0'
 
 dev_dependencies:
   flutter_test: