pushing and previewing work when switch background/foreground

[rtmpclient.git] / app / src / main / java / ai / suanzi / rtmpclient / MyService.java

diff --git a/app/src/main/java/ai/suanzi/rtmpclient/MyService.java b/app/src/main/java/ai/suanzi/rtmpclient/MyService.java
index 9053b35..1d9dc60 100644 (file)
--- a/app/src/main/java/ai/suanzi/rtmpclient/MyService.java
+++ b/app/src/main/java/ai/suanzi/rtmpclient/MyService.java
@@ -2,11 +2,16 @@ package ai.suanzi.rtmpclient;
 
 import android.app.Service;
 import android.content.Intent;
+import android.graphics.SurfaceTexture;
+import android.hardware.Camera;
 import android.os.Handler;
 import android.os.HandlerThread;
 import android.os.IBinder;
 import android.os.Looper;
 import android.util.Log;
+import android.view.SurfaceHolder;
+import android.view.SurfaceView;
+import android.view.WindowManager;
 import android.widget.Toast;
 import android.support.v4.app.NotificationCompat;
 import android.graphics.BitmapFactory;
@@ -14,30 +19,69 @@ import android.app.Notification;
 import android.os.Message;
 import org.apache.log4j.Level;
 import org.apache.log4j.Logger;
+import android.hardware.Camera.PreviewCallback;
+import android.os.IBinder;
+import android.os.Binder;
+import android.content.Context;
+import android.graphics.PixelFormat;
+import java.io.IOException;
+import android.view.Gravity;
 
-public class MyService extends Service {
+public class MyService extends Service  implements Camera.PreviewCallback {
 
     private Logger gLogger = Logger.getLogger("MyService");
 
     private Ffmpeg ffmpeg = Ffmpeg.getInstance();
     private  Boolean isRunning = false;
     private FfmpegRunnable  runnable;
+    private Camera mCamera = null;
+    IBinder mBinder = new LocalBinder();
+    private WindowManager mWindowManager;
+    private SurfaceView mOutComeVideoView;
+
+
+    public class LocalBinder extends Binder {
+        public MyService getServiceInstance(){
+            return MyService.this;
+        }
+    }
 
     private class FfmpegRunnable implements Runnable {
         private String url;
-        public FfmpegRunnable(String _url){
+        private Camera.PreviewCallback cb;
+        public FfmpegRunnable(String _url, Camera.PreviewCallback _cb){
             this.url = _url;
+            this.cb = _cb;
         }
         @Override
         public void run(){
             gLogger.error("Run Ffmpeg url: " + url);
             isRunning = true;
-            ffmpeg.push(null, this.url);
+            //ffmpeg.push(null, this.url);
+            if (mCamera == null) {
+                gLogger.error("open camea");
+                try {
+                    mCamera = Camera.open(1);
+                }catch (Exception e){
+                    e.printStackTrace();
+                }
+            }
+            /*
+            SurfaceTexture st = new SurfaceTexture(0);
+            try {
+                mCamera.setPreviewTexture(st);
+            }catch (Exception e){
+                e.printStackTrace();
+            }*/
+            gLogger.error("start preview");
+            mCamera.setPreviewCallback(this.cb);
+            mCamera.startPreview();
+
         }
     }
 
     private static final int NOTIFICATION_DOWNLOAD_PROGRESS_ID = 0x0001;                                        //id不可设置为0,否则不能设置为前台service
-    public void createNotification(){
+    private void createNotification(){
         gLogger.error("createNotification");
         NotificationCompat.Builder builder=new NotificationCompat.Builder(this);                        //使用兼容版本
         builder.setSmallIcon(R.mipmap.ic_launcher);                                                             //设置状态栏的通知图标
@@ -52,13 +96,33 @@ public class MyService extends Service {
 
     @Override
     public IBinder onBind(Intent intent) {
-        return null;
+        return mBinder;
     }
 
     @Override
     public void onCreate() {
         super.onCreate();
         gLogger.error("onCreate");
+
+
+//        mWindowManager = (WindowManager) this.getSystemService(Context.WINDOW_SERVICE);
+//        mOutComeVideoView = new SurfaceView(this);
+//
+//
+//        WindowManager.LayoutParams layoutParams = new WindowManager.LayoutParams(1, 1, WindowManager.LayoutParams.TYPE_APPLICATION_OVERLAY,
+//                WindowManager.LayoutParams.FLAG_WATCH_OUTSIDE_TOUCH, PixelFormat.TRANSLUCENT);
+//        layoutParams.gravity = Gravity.LEFT | Gravity.TOP;
+//        mWindowManager.addView(mOutComeVideoView, layoutParams);
+//        mOutComeVideoView.getHolder().addCallback(this);
+//
+//
+        createNotification();
+        runnable = new FfmpegRunnable("xxxxxx", this);
+        new Thread(runnable).start();
+
+
+
+
     }
 
     @Override
@@ -79,9 +143,11 @@ public class MyService extends Service {
 
     @Override
     public int onStartCommand(Intent intent, int flags, int startId) {
-        String url = intent.getExtras().getString("url");
+        String url = "hahahahhah"; //intent.getExtras().getString("url");
+
+
         gLogger.error("onStartCommand: url is:" + url + ". isRunning: " + isRunning);
-        runnable = new FfmpegRunnable(url);
+        runnable = new FfmpegRunnable(url, this);
         if (!isRunning) {
             createNotification();
             Toast.makeText(this, "Video stream pushed to " + url, Toast.LENGTH_LONG).show();
@@ -95,4 +161,53 @@ public class MyService extends Service {
         super.onLowMemory();
         gLogger.error("onLowMemory");
     }
+
+    // Camera.PreviewCallback
+    @Override
+    public void  onPreviewFrame(final byte[] data, Camera camera){
+        gLogger.error("onPreviewFrame");
+        ffmpeg.process(data);
+    }
+
+    public void onChange (SurfaceHolder holder){
+        gLogger.error("onChange");
+        try {
+            if (holder == null){
+                gLogger.error("xxxx holder is null xxxxxx");
+            }
+            if (mCamera == null) {
+                gLogger.error("xxxx camera is null xxxx");
+            }
+
+            mCamera.setPreviewDisplay(holder);
+            mCamera.startPreview();
+        } catch (Exception e){
+            e.printStackTrace();
+        }
+    }
+
+
+
+//    // SurfaceHolder.Callback implementation
+//    @Override
+//    public void surfaceCreated(final SurfaceHolder holder){
+//        gLogger.error("SurfacedCreated");
+//    }
+//
+//    @Override
+//    public void surfaceChanged(SurfaceHolder holder, int format, int widht, int height){
+//        gLogger.error("surfaceChanged");
+//        try {
+//            mCamera.setPreviewDisplay(holder);
+//        } catch (Exception e){
+//            e.printStackTrace();
+//        }
+//        mCamera.startPreview();
+//
+//    }
+//
+//    @Override
+//    public void surfaceDestroyed(SurfaceHolder holder){
+//        gLogger.error("surfaceDestroyed");
+//    }
 }