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'
@@ -45,7 +45,6 @@ android {
 
 dependencies {
     implementation fileTree(dir: 'libs', include: ['*.jar'])
-    implementation 'com.android.support:appcompat-v7:27.1.1'
     implementation 'com.android.support.constraint:constraint-layout:1.1.3'
     implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
 }

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

@@ -1,187 +0,0 @@
-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.util.Log;
-import android.widget.FrameLayout;
-
-import java.sql.Time;
-import java.util.Arrays;
-import java.util.Date;
-
-import static java.lang.Thread.*;
-
-/**
- * Created by rt-zl on 2019/2/15.
- */
-
-public class Render extends VideoRender {
-
-
-
-    static {
-        System.loadLibrary("mixplayer");
-    }
-
-    private long handler = 0;
-
-    private native int setRenderHandler(long handler);
-
-    int asample, ach, abit;
-    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);
-            audioWPos += len;
-            audioHas +=len;
-            if(audioWPos == audioBufLen){
-                audioWPos = 0;
-            }
-            if(len<size){
-                int les = size - len;
-                System.arraycopy(data,len,audioBuf,audioWPos,les);
-                audioWPos +=les;
-                audioHas += les;
-            }
-            return 0;
-        }
-    }
-
-
-    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 -1;
-    }
-
-
-    public void mixClose(){
-        super.close();
-    }
-
-    public void renderClose(){
-        play = false;
-        if (audioTrack!=null){
-            audioTrack.stop();
-            totalAudioBuf = 0;
-        }
-    }
-
-    public Render(Context context){
-        super(context);
-    }
-
-    public void init(long handler){
-        this.handler = handler;
-        setMixHander(handler);
-        this.setRenderHandler(handler);
-    }
-
-    public double getPlaytime() {
-        return  playTime;
-    }
-
-    AudioTrack audioTrack ;
-
-    byte[] audioBuf ;
-    long totalAudioBuf;
-    int audioHas;
-    int audioRPos, audioWPos;
-    int audioBufLen = 4096*3;
-    long silenceLen = 0;
-    boolean play = false;
-    double playTime = 0;
-    byte[] silencBuf;
-    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);
-        play = true;
-        new Thread(new Runnable() {
-            @Override
-            public void run() {
-                int wsize = 1024;
-                long posPre = 0;
-                boolean needUpdate = false;
-                int retryCount = 0;
-                while (play) {
-                    synchronized (audioBuf) {
-                        long pos = audioTrack.getPlaybackHeadPosition();
-                        // 16bit 2channels = 4 Byte
-                        pos *= 4;
-                        pos -= silenceLen;
-                        if(posPre != pos){
-                            posPre = pos;
-                            retryCount = 0;
-                        }else {
-                            if(retryCount > 5)
-                                needUpdate = true;
-                            retryCount ++;
-                        }
-                        if (audioHas >= wsize && totalAudioBuf - pos < audioBufLen || pos <= 0 ||needUpdate ) {
-                            needUpdate = false;
-                            int len = audioBufLen - audioRPos;
-                            len = len > wsize? wsize:len;
-                            int ret = audioTrack.write(audioBuf, audioRPos, len);
-                            audioRPos += ret;
-                            audioHas -= ret;
-                            totalAudioBuf+=ret;
-                            if (audioRPos == audioBufLen) {
-                                audioRPos = 0;
-                            }
-                        }else {
-                        //    if (pos == totalAudioBuf && audioHas < wsize){
-                        //        int c = audioTrack.write(silencBuf,0,2048);
-                        //        silenceLen +=c;
-                        //    }
-                        }
-                        if(ispause){
-                            if(audioTrack.getPlayState() != AudioTrack.PLAYSTATE_PAUSED) {
-                                audioTrack.pause();
-                                audioTrack.setVolume(0);
-                            }
-                        }else{
-                            if(audioTrack.getPlayState()!=AudioTrack.PLAYSTATE_PLAYING) {
-                                audioTrack.play();
-                                audioTrack.setVolume(volume);
-                            }
-                        }
-                    }
-                    try {
-                        sleep(3);
-                    }catch (Exception ex){
-                    }
-                }
-                Log.d("mixplayer","audio close");
-            }
-        }).start();
-        audioTrack.play();
-    }
-
-    @Override
-    protected void finalize() throws Throwable {
-        super.finalize();
-        play = false;
-        renderClose();
-    }
-
-}

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/java/com/fgodt/mixplayer/Core.java → android/src/main/java/com/shuangyubang/mofun_flutter_plugin_video/mixplayer/Core.java

@@ -1,11 +1,7 @@
-package com.fgodt.mixplayer;
+package com.shuangyubang.mofun_flutter_plugin_video.mixplayer;
 
 import android.util.Log;
 import android.view.Surface;
-import android.view.SurfaceHolder;
-
-
-import java.util.Arrays;
 
 /**
  * Created by rt-zl on 2019/2/15.

android/src/main/java/com/fgodt/mixplayer/Player.java → android/src/main/java/com/shuangyubang/mofun_flutter_plugin_video/mixplayer/Player.java

@@ -1,4 +1,4 @@
-package com.fgodt.mixplayer;
+package com.shuangyubang.mofun_flutter_plugin_video.mixplayer;
 
 import android.content.Context;
 
@@ -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/shuangyubang/mofun_flutter_plugin_video/mixplayer/Render.java

@@ -0,0 +1,188 @@
+package com.shuangyubang.mofun_flutter_plugin_video.mixplayer;
+
+import android.content.Context;
+import android.media.AudioFormat;
+import android.media.AudioManager;
+import android.media.AudioTrack;
+import android.os.Build;
+import android.util.Log;
+
+import static java.lang.Thread.sleep;
+
+/**
+ * Created by rt-zl on 2019/2/15.
+ */
+
+public class Render extends VideoRender {
+
+
+    static {
+        System.loadLibrary("mixplayer");
+    }
+
+    private long handler = 0;
+
+    private native int setRenderHandler(long handler);
+
+    int asample, ach, abit;
+
+    public int mixUpdateAudio(byte[] data, int size, double pts) {
+        playTime = pts;
+        synchronized (audioBufLock) {
+            if (audioBufLen - audioHas < size) {
+                return -1;
+            }
+            int len = audioBufLen - audioWPos;
+            len = len > size ? size : len;
+            System.arraycopy(data, 0, audioBuf, audioWPos, len);
+            audioWPos += len;
+            audioHas += len;
+            if (audioWPos == audioBufLen) {
+                audioWPos = 0;
+            }
+            if (len < size) {
+                int les = size - len;
+                System.arraycopy(data, len, audioBuf, audioWPos, les);
+                audioWPos += les;
+                audioHas += les;
+            }
+            return 0;
+        }
+    }
+
+
+    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 -1;
+    }
+
+
+    public void mixClose() {
+        super.close();
+    }
+
+    public void renderClose() {
+        play = false;
+        if (audioTrack != null) {
+            audioTrack.stop();
+            totalAudioBuf = 0;
+        }
+    }
+
+    public Render(Context context) {
+        super(context);
+    }
+
+    public void init(long handler) {
+        this.handler = handler;
+        setMixHander(handler);
+        this.setRenderHandler(handler);
+    }
+
+    public double getPlaytime() {
+        return playTime;
+    }
+
+    AudioTrack audioTrack;
+
+    final Object audioBufLock = new Object();
+    byte[] audioBuf;
+    long totalAudioBuf;
+    int audioHas;
+    int audioRPos, audioWPos;
+    int audioBufLen = 4096 * 3;
+    long silenceLen = 0;
+    boolean play = false;
+    double playTime = 0;
+    byte[] silencBuf;
+
+    private void initAudioTrack() {
+        silencBuf = new byte[4096];
+        synchronized (audioBufLock) {
+            audioBuf = new byte[audioBufLen];
+        }
+        audioTrack = new AudioTrack(AudioManager.STREAM_MUSIC, asample,
+                AudioFormat.CHANNEL_IN_STEREO, AudioFormat.ENCODING_PCM_16BIT, audioBufLen, AudioTrack.MODE_STREAM);
+        play = true;
+        new Thread(() -> {
+            int wsize = 1024;
+            long posPre = 0;
+            boolean needUpdate = false;
+            int retryCount = 0;
+            while (play) {
+                synchronized (audioBufLock) {
+                    long pos = audioTrack.getPlaybackHeadPosition();
+                    // 16bit 2channels = 4 Byte
+                    pos *= 4;
+                    pos -= silenceLen;
+                    if (posPre != pos) {
+                        posPre = pos;
+                        retryCount = 0;
+                    } else {
+                        if (retryCount > 5)
+                            needUpdate = true;
+                        retryCount++;
+                    }
+                    if (audioHas >= wsize && totalAudioBuf - pos < audioBufLen || pos <= 0 || needUpdate) {
+                        needUpdate = false;
+                        int len = audioBufLen - audioRPos;
+                        len = len > wsize ? wsize : len;
+                        int ret = audioTrack.write(audioBuf, audioRPos, len);
+                        audioRPos += ret;
+                        audioHas -= ret;
+                        totalAudioBuf += ret;
+                        if (audioRPos == audioBufLen) {
+                            audioRPos = 0;
+                        }
+                    } else {
+                        //    if (pos == totalAudioBuf && audioHas < wsize){
+                        //        int c = audioTrack.write(silencBuf,0,2048);
+                        //        silenceLen +=c;
+                        //    }
+                    }
+                    if (ispause) {
+                        if (audioTrack.getPlayState() != AudioTrack.PLAYSTATE_PAUSED) {
+                            audioTrack.pause();
+                            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {
+                                audioTrack.setVolume(0);
+                            } else {
+                                audioTrack.setStereoVolume(0, 0);
+                            }
+                        }
+                    } else {
+                        if (audioTrack.getPlayState() != AudioTrack.PLAYSTATE_PLAYING) {
+                            audioTrack.play();
+                            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {
+                                audioTrack.setVolume(volume);
+                            } else {
+                                audioTrack.setStereoVolume(volume, volume);
+                            }
+                        }
+                    }
+                }
+                try {
+                    sleep(3);
+                } catch (Exception ignored) {
+                }
+            }
+            Log.d("mixplayer", "audio close");
+        }).start();
+        audioTrack.play();
+    }
+
+    @Override
+    protected void finalize() throws Throwable {
+        super.finalize();
+        play = false;
+        renderClose();
+    }
+
+}

android/src/main/java/com/fgodt/mixplayer/VideoRender.java → android/src/main/java/com/shuangyubang/mofun_flutter_plugin_video/mixplayer/VideoRender.java

@@ -1,4 +1,4 @@
-package com.fgodt.mixplayer;
+package com.shuangyubang.mofun_flutter_plugin_video.mixplayer;
 
 
 

android/src/main/java/com/fgodt/mixplayer/mixPlayerCallBack.java → android/src/main/java/com/shuangyubang/mofun_flutter_plugin_video/mixplayer/mixPlayerCallBack.java

@@ -1,4 +1,4 @@
-package com.fgodt.mixplayer;
+package com.shuangyubang.mofun_flutter_plugin_video.mixplayer;
 
 public interface mixPlayerCallBack{
     public int mix_call(String name, byte[] data, int len);

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

@@ -1,49 +1,114 @@
 package com.shuangyubang.mofun_flutter_plugin_video
 
 import android.content.Context
-import android.view.Gravity
+import android.media.AudioFormat
+import android.media.AudioRecord
+import android.media.MediaRecorder
 import android.view.View
-import android.widget.EditText
 import android.widget.FrameLayout
-import android.widget.LinearLayout
-import com.fgodt.mixplayer.Player
-import com.fgodt.mixplayer.mixPlayerCallBack
+import android.widget.Toast
+import com.shuangyubang.mofun_flutter_plugin_video.mixplayer.Player
+import com.shuangyubang.mofun_flutter_plugin_video.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,10 +40,11 @@ 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"
+
     }
 
     buildTypes {
@@ -59,6 +60,11 @@ flutter {
     source '../..'
 }
 
+tasks.withType(JavaCompile) {
+    options.encoding = 'UTF-8'
+    options.compilerArgs << '-Xlint:unchecked,deprecation'
+}
+
 dependencies {
     implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
     testImplementation 'junit:junit:4.12'

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/android/gradle.properties

@@ -1 +1,2 @@
 org.gradle.jvmargs=-Xmx1536M
+android.useAndroidX=true

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: transitive
+    description:
+      name: permission_handler
+      url: "https://pub.flutter-io.cn"
+    source: hosted
+    version: "3.0.1"
   quiver:
     dependency: transitive
     description:

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: