app/src/main/java/ai/suanzi/rtmpclient/MainActivity.java

   1 package ai.suanzi.rtmpclient;
   2
   3 import android.content.IntentFilter;
   4 import android.hardware.Camera;
   5 import android.net.Uri;
   6 import android.support.design.widget.TextInputEditText;
   7 import android.support.v7.app.ActionBar;
   8 import android.support.v7.app.AppCompatActivity;
   9 import android.os.Bundle;
  10 import android.util.DisplayMetrics;
  11 import android.util.Log;
  12 import android.view.SurfaceHolder;
  13 import android.view.SurfaceView;
  14 import android.view.View;
  15 import android.view.Window;
  16 import android.view.WindowManager;
  17 import android.widget.Button;
  18 import android.widget.Toast;
  19 import android.content.Context;
  20
  21 import java.io.File;
  22 import android.content.Intent;
  23 import de.mindpipe.android.logging.log4j.LogConfigurator;
  24 import org.apache.log4j.Level;
  25 import org.apache.log4j.Logger;
  26 import android.net.wifi.WifiManager;
  27 import android.net.wifi.WifiInfo;
  28 import android.content.ServiceConnection;
  29 import android.content.ComponentName;
  30
  31 import ai.suanzi.rtmpclient.MyService.LocalBinder;
  32 import android.os.IBinder;
  33 import android.net.ConnectivityManager;
  34 import android.view.ViewGroup;
  35 import org.apache.http.impl.client.HttpClients;
  36 import org.apache.http.impl.client.CloseableHttpClient;
  37 import org.apache.http.client.methods.CloseableHttpResponse;
  38
  39 //import org.apache.http.client.methods;
  40 import android.view.MotionEvent;
  41 import android.graphics.Color;
  42 import android.os.Build;
  43 import android.content.pm.ActivityInfo;
  44 import android.view.Display;
  45 import android.graphics.Point;
  46
  47 public class MainActivity extends AppCompatActivity implements MyService.MyServiceEventListener, CameraView.Callback {
  48
  49     private Logger gLogger;
  50     private NetworkMonitor networkMonitor;
  51     private UsbMonitor mUsbMonitor;
  52     private ServiceHealthMonitor mServiceHealthMonitor;
  53     private static final int INTERVAL = 3 * 60; // seconds
  54
  55     boolean mBounded = false;
  56     MyService mServer;
  57     Intent mIntent;
  58     private boolean isFullScreen = false;
  59
  60     private CameraView mCameraView;
  61
  62     private void init(){
  63
  64         mIntent = new Intent(this, MyService.class);
  65         mUsbMonitor = new UsbMonitor(new UsbMonitor.UsbListener() {
  66             @Override
  67             public void onCameraConnected() {
  68                 gLogger.error("onCameraConnected, current Usb Camera count: " + mUsbMonitor.getUsbCameraCount());
  69                 doUnbindService();
  70                 if(mUsbMonitor.hasUsbCamera()){
  71                     doBindService();
  72                 }
  73             }
  74
  75             @Override
  76             public void onCameraDisconnected() {
  77                 gLogger.error("onCameraDisconnected, current camera count: " + mUsbMonitor.getUsbCameraCount());
  78                 doUnbindService();
  79                 if(mUsbMonitor.hasUsbCamera()){
  80                     doBindService();
  81                 }
  82             }
  83         }, this);
  84
  85         networkMonitor = new NetworkMonitor(new NetworkMonitor.NetworkListener() {
  86             @Override
  87             public void onWifiConnected() {
  88                 gLogger.error("onWifiConnected");
  89                 doBindService();
  90             }
  91
  92             @Override
  93             public void onWifiDisconnected() {
  94                 gLogger.error("onWifiDisconnected");
  95                 doUnbindService();
  96             }
  97
  98             @Override
  99             public void onWifiEnabled() {
 100                 gLogger.error("onWifiEnabled");
 101             }
 102
 103             @Override
 104             public void onWifiDisabled() {
 105                 gLogger.error("onWifiDisabled");
 106             }
 107         });
 108         IntentFilter filter = new IntentFilter();
 109         filter.addAction(ConnectivityManager.CONNECTIVITY_ACTION);
 110         registerReceiver(networkMonitor, filter);
 111
 112         mServiceHealthMonitor = new ServiceHealthMonitor(new ServiceHealthMonitor.Callback() {
 113             @Override
 114             public void onNotHealthy() {
 115                 gLogger.error("onNotHealthy, in " + INTERVAL + " seconds, the publishing may stopped or have error ");
 116                 doUnbindService();
 117                 doBindService();
 118             }
 119         });
 120         mServiceHealthMonitor.setInterval(INTERVAL);
 121     }
 122
 123
 124     ServiceConnection mConnection = new ServiceConnection() {
 125         @Override
 126         public void onServiceDisconnected(ComponentName name) {
 127             Toast.makeText(MainActivity.this, "Service is disconnected", 1000).show();
 128             gLogger.error("onServiceDisconnected ---------->");
 129             mBounded = false;
 130             mServer = null;
 131         }
 132
 133         @Override
 134         public void onServiceConnected(ComponentName name, IBinder service) {
 135             Toast.makeText(MainActivity.this, "Service is connected", 1000).show();
 136             gLogger.error("onServiceConnected ---------->");
 137             mBounded = true;
 138             LocalBinder mLocalBinder = (LocalBinder)service;
 139             mServer = mLocalBinder.getServiceInstance();
 140             mServer.setServiceEventListener(MainActivity.this);
 141             if(mServer.setRtmpUrl(UserInfo.toUrl())){
 142                 mServer.startPreview(mCameraView.getHolder());
 143                 Camera.Size cs = mServer.getBestPictureSize();
 144                 mCameraView.setLayout(cs.width, cs.height);
 145             } else {
 146                 gLogger.error("onServiceConnected - setRtmpUrl failed");
 147             }
 148         }
 149     };
 150
 151     private void doBindService(){
 152         gLogger.debug("doBindService");
 153         if(!mBounded && canStartService()) {
 154             gLogger.debug("Start service --------->");
 155             bindService(mIntent, mConnection, BIND_AUTO_CREATE);
 156         }
 157     }
 158
 159     private void doUnbindService() {
 160         gLogger.debug("doUnbindService");
 161         if(mBounded){
 162             gLogger.debug("Stop service <---------");
 163             unbindService(mConnection);
 164             mBounded = false;
 165         }
 166     }
 167
 168     private class ScreenSize {
 169         public ScreenSize(){ }
 170         public int width = 0;
 171         public int height = 0;
 172     }
 173
 174     private ScreenSize getScreenSize(){
 175         ScreenSize size = new ScreenSize();
 176         WindowManager windowManager = (WindowManager) getSystemService(Context.WINDOW_SERVICE);
 177         final Display display = windowManager.getDefaultDisplay();
 178         Point outPoint = new Point();
 179         if(Build.VERSION.SDK_INT >= 19) {
 180             display.getRealSize(outPoint); // include navigation bar
 181         } else {
 182             display.getSize(outPoint); // exclude navigation bar
 183         }
 184         if(outPoint.y > outPoint.x) {
 185             size.height = outPoint.y;
 186             size.width = outPoint.x;
 187         } else {
 188             size.height = outPoint.x;
 189             size.width = outPoint.y;
 190         }
 191         return size;
 192     }
 193
 194     private void initCameraView (){
 195 //        getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN, WindowManager.LayoutParams.FLAG_FULLSCREEN);
 196 //        requestWindowFeature(Window.FEATURE_NO_TITLE);
 197 //        getWindow().setFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON, WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON);
 198 //        ///setContentView(R.layout.activity_main);
 199 //        //getWindow().setNavigationBarColor(Color.TRANSPARENT);
 200 //
 201 //        View decorView = getWindow().getDecorView();
 202 //        int uiOptions = View.SYSTEM_UI_FLAG_HIDE_NAVIGATION
 203 //                | View.SYSTEM_UI_FLAG_FULLSCREEN;
 204 //        decorView.setSystemUiVisibility(uiOptions);
 205 //
 206 //
 207 //        ActionBar actionBar = getSupportActionBar();
 208 //        try {
 209 //            actionBar.hide();
 210 //        }catch (NullPointerException e){
 211 //            gLogger.error("initCameraView - " + e.getMessage());
 212 //            e.printStackTrace();
 213 //        }
 214
 215
 216
 217         //DisplayMetrics outMetrics = new DisplayMetrics();
 218         //this.getWindowManager().getDefaultDisplay().getMetrics(outMetrics);
 219
 220         //CameraView.SCREEN_WIDTH = outMetrics.widthPixels;
 221         //CameraView.SCREEN_HEIGHT = outMetrics.heightPixels;
 222         //gLogger.debug("Screen size is w: " + CameraView.SCREEN_WIDTH  + ", h: " + CameraView.SCREEN_HEIGHT);
 223
 224         ScreenSize size = getScreenSize();
 225
 226         CameraView.SCREEN_WIDTH = size.width;
 227         CameraView.SCREEN_HEIGHT = size.height;
 228         gLogger.debug("Screen size is w: " + CameraView.SCREEN_WIDTH  + ", h: " + CameraView.SCREEN_HEIGHT);
 229
 230
 231         mCameraView = new CameraView(getApplicationContext(), this);
 232         setContentView(R.layout.activity_main);
 233
 234         ViewGroup.LayoutParams lp = new ViewGroup.LayoutParams(640, 480);
 235         addContentView(mCameraView, lp);
 236         //setContentView(mCameraView);
 237     }
 238     @Override
 239     protected void onCreate(Bundle savedInstanceState) {
 240         super.onCreate(savedInstanceState);
 241         LogUtil.config(this);
 242         gLogger = Logger.getLogger(getClass());
 243         gLogger.error("onCreate ---------> ");
 244         UserInfo.readConfig(getExternalFilesDir(null) + File.separator + "config", getMacAddr());
 245         initCameraView();
 246         init();
 247
 248         if(canStartService()){
 249             gLogger.error("Current network is available");
 250             doBindService();
 251         } else {
 252             gLogger.error("Current network NOT available or no USB Camera connected");
 253         }
 254
 255         if(!mServiceHealthMonitor.isAlive()) {
 256             gLogger.debug("mServiceHealthMonitor start, interval " + INTERVAL);
 257             mServiceHealthMonitor.start();
 258         }
 259         ////////// LogUtil.sendLogs();  /// Log test
 260         //LogUtil.sendLogs();
 261         // test
 262         //new CheckVersionInfoTask(MainActivity.this).execute();
 263     }
 264
 265     @Override
 266     protected void onPause(){
 267         super.onPause();
 268         gLogger.debug("OnPause --------->");
 269     }
 270
 271     @Override
 272     protected void onResume() {
 273         super.onResume();
 274         gLogger.debug("OnResume ---------> ");
 275     }
 276
 277     @Override
 278     protected void onStop() {
 279         super.onStop();
 280         gLogger.debug("onStop --------->");
 281     }
 282
 283     @Override
 284     protected void onStart(){
 285         super.onStart();
 286         gLogger.debug("onStart --------->");
 287     }
 288
 289     @Override
 290     protected void onDestroy(){
 291         super.onDestroy();
 292         mUsbMonitor.unregisterReceiver();
 293         unregisterReceiver(networkMonitor);
 294         unbindService(mConnection);
 295         gLogger.debug("onDestroy --------->");
 296     }
 297
 298     @Override
 299     protected void onRestart(){
 300         super.onRestart();
 301         gLogger.debug("onRestart ---------->");
 302     }
 303
 304     @Override
 305     public void onBackPressed() {
 306         gLogger.debug("onBackPressed  --------->");
 307         Intent intent = new Intent(Intent.ACTION_MAIN);
 308         intent.addCategory(Intent.CATEGORY_HOME);
 309         intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
 310         startActivity(intent);
 311     }
 312
 313     @Override
 314     public boolean onTouchEvent(MotionEvent event) {
 315         if(event.getAction() == MotionEvent.ACTION_UP) {
 316             toggleFullScreen();
 317         }
 318         return super.onTouchEvent(event);
 319     }
 320
 321     @Override
 322     public void onWindowFocusChanged(boolean hasFocus) {
 323         super.onWindowFocusChanged(hasFocus);
 324         if (hasFocus && Build.VERSION.SDK_INT >= 19) {
 325             toggleFullScreen();
 326         }
 327     }
 328
 329     private String getMacAddr() {
 330         WifiManager manager = (WifiManager) getApplicationContext().getSystemService(Context.WIFI_SERVICE);
 331         WifiInfo info = manager.getConnectionInfo();
 332         gLogger.debug("Mac Address is " + info.getMacAddress());
 333         return info.getMacAddress().replace(":", ""); //02:00:00:00:00:00 - 020000000000
 334     }
 335
 336     private boolean canStartService(){
 337
 338         if(System.getProperty("os.arch").equals("i686")){
 339             return  true;
 340         }
 341         return mUsbMonitor.hasUsbCamera() && NetworkMonitor.isNetworkAvailable(this);
 342     }
 343
 344     // MyServiceEventListener
 345     @Override
 346     public void onCameraError(String msg){
 347         gLogger.error("onCameraEvent " + msg);
 348         //if(mUsbMonitor.hasUsbCamera()){
 349             //mServer.reopenCamera();
 350         //}
 351     }
 352
 353     @Override
 354     public void onEncoderError(String msg){
 355         gLogger.error("onEncoderError: " + msg);
 356         doUnbindService();
 357         doBindService();
 358     }
 359
 360     @Override
 361     public void onPublishing(String msg){
 362         mServiceHealthMonitor.record();
 363     }
 364
 365     @Override
 366     public void onSurfaceChanged(SurfaceHolder holder, int format, int width, int height){
 367         if(mServer != null){
 368             mServer.startPreview(holder);
 369         }
 370     }
 371
 372     private void restartApplication() {
 373         final Intent intent = getPackageManager().getLaunchIntentForPackage(getPackageName());
 374         intent.addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
 375         startActivity(intent);
 376     }
 377
 378     private void toggleFullScreen (){
 379         View decorView = getWindow().getDecorView();
 380         if(!isFullScreen) {
 381             decorView.setSystemUiVisibility(
 382                     View.SYSTEM_UI_FLAG_LAYOUT_STABLE
 383                             | View.SYSTEM_UI_FLAG_LAYOUT_HIDE_NAVIGATION
 384                             | View.SYSTEM_UI_FLAG_LAYOUT_FULLSCREEN
 385                             | View.SYSTEM_UI_FLAG_HIDE_NAVIGATION
 386                             | View.SYSTEM_UI_FLAG_FULLSCREEN
 387                             | View.SYSTEM_UI_FLAG_IMMERSIVE_STICKY);
 388         } else {
 389             decorView.setSystemUiVisibility(View.SYSTEM_UI_FLAG_LAYOUT_STABLE | View.SYSTEM_UI_FLAG_VISIBLE);
 390         }
 391         isFullScreen = !isFullScreen;
 392     }
 393 }