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.support.design.widget.TextInputEditText;
   6 import android.support.v7.app.ActionBar;
   7 import android.support.v7.app.AppCompatActivity;
   8 import android.os.Bundle;
   9 import android.util.DisplayMetrics;
  10 import android.util.Log;
  11 import android.view.SurfaceHolder;
  12 import android.view.SurfaceView;
  13 import android.view.View;
  14 import android.view.Window;
  15 import android.view.WindowManager;
  16 import android.widget.Button;
  17 import android.widget.Toast;
  18 import android.content.Context;
  19
  20 import java.io.File;
  21 import android.content.Intent;
  22 import de.mindpipe.android.logging.log4j.LogConfigurator;
  23 import org.apache.log4j.Level;
  24 import org.apache.log4j.Logger;
  25 import android.net.wifi.WifiManager;
  26 import android.net.wifi.WifiInfo;
  27 import android.content.ServiceConnection;
  28 import android.content.ComponentName;
  29
  30 import ai.suanzi.rtmpclient.MyService.LocalBinder;
  31 import android.os.IBinder;
  32 import android.net.ConnectivityManager;
  33 import android.view.ViewGroup;
  34
  35 //"rtmp://gpussh.suanzi.ai:1935/myapp/suanzi_ac83f34ead90";
  36
  37 public class MainActivity extends AppCompatActivity implements MyService.MyServiceEventListener, CameraView.Callback {
  38
  39     //private static final String TAG = "MainActivity";
  40     private Logger gLogger;
  41
  42     //private String mMacAddr = "";
  43     private NetworkMonitor networkMonitor;
  44     private UsbMonitor mUsbMonitor;
  45     private ServiceHealthMonitor mServiceHealthMonitor;
  46     private static final int INTERVAL = 3 * 60; // seconds
  47
  48     boolean mBounded = false;
  49     MyService mServer;
  50     Intent mIntent;
  51
  52     private CameraView mCameraView;
  53
  54     private void init(){
  55         //UserInfo.setConfigPath(getExternalFilesDir(null) + File.separator + "config");
  56         //UserInfo.readConfig(getExternalFilesDir(null) + File.separator + "config", getMacAddr());
  57
  58
  59         //this.mMacAddr = getMacAddr();
  60
  61         mIntent = new Intent(this, MyService.class);
  62         mUsbMonitor = new UsbMonitor(new UsbMonitor.UsbListener() {
  63             @Override
  64             public void onCameraConnected() {
  65                 gLogger.error("onCameraConnected, current Usb Camera count: " + mUsbMonitor.getUsbCameraCount());
  66                 doUnbindService();
  67                 if(mUsbMonitor.hasUsbCamera()){
  68                     doBindService();
  69                 }
  70             }
  71
  72             @Override
  73             public void onCameraDisconnected() {
  74                 gLogger.error("onCameraDisconnected, current camera count: " + mUsbMonitor.getUsbCameraCount());
  75                 doUnbindService();
  76                 if(mUsbMonitor.hasUsbCamera()){
  77                     doBindService();
  78                 }
  79             }
  80         }, this);
  81
  82         networkMonitor = new NetworkMonitor(new NetworkMonitor.NetworkListener() {
  83             @Override
  84             public void onWifiConnected() {
  85                 gLogger.error("onWifiConnected");
  86                 doBindService();
  87             }
  88
  89             @Override
  90             public void onWifiDisconnected() {
  91                 gLogger.error("onWifiDisconnected");
  92                 doUnbindService();
  93             }
  94
  95             @Override
  96             public void onWifiEnabled() {
  97                 gLogger.error("onWifiEnabled");
  98             }
  99
 100             @Override
 101             public void onWifiDisabled() {
 102                 gLogger.error("onWifiDisabled");
 103             }
 104         });
 105         IntentFilter filter = new IntentFilter();
 106         filter.addAction(ConnectivityManager.CONNECTIVITY_ACTION);
 107         registerReceiver(networkMonitor, filter);
 108
 109         mServiceHealthMonitor = new ServiceHealthMonitor(new ServiceHealthMonitor.Callback() {
 110             @Override
 111             public void onNotHealthy() {
 112                 gLogger.error("onNotHealthy, in " + INTERVAL + " seconds, the publishing may stopped or have error ");
 113                 doUnbindService();
 114                 doBindService();
 115             }
 116         });
 117         mServiceHealthMonitor.setInterval(INTERVAL);
 118     }
 119
 120
 121     ServiceConnection mConnection = new ServiceConnection() {
 122         @Override
 123         public void onServiceDisconnected(ComponentName name) {
 124             Toast.makeText(MainActivity.this, "Service is disconnected", 1000).show();
 125             gLogger.error("onServiceDisconnected ---------->");
 126             mBounded = false;
 127             mServer = null;
 128         }
 129
 130         @Override
 131         public void onServiceConnected(ComponentName name, IBinder service) {
 132             Toast.makeText(MainActivity.this, "Service is connected", 1000).show();
 133             gLogger.error("onServiceConnected ---------->");
 134             mBounded = true;
 135             LocalBinder mLocalBinder = (LocalBinder)service;
 136             mServer = mLocalBinder.getServiceInstance();
 137             mServer.setServiceEventListener(MainActivity.this);
 138             if(mServer.setRtmpUrl(UserInfo.toUrl())){
 139                 mServer.startPreview(mCameraView.getHolder());
 140                 Camera.Size cs = mServer.getBestPictureSize();
 141                 mCameraView.setLayout(cs.width, cs.height);
 142             }
 143
 144
 145         }
 146     };
 147
 148     private void doBindService(){
 149         gLogger.debug("doBindService");
 150         if(!mBounded && canStartService()) {
 151             gLogger.debug("Start service --------->");
 152             bindService(mIntent, mConnection, BIND_AUTO_CREATE);
 153         }
 154     }
 155
 156     private void doUnbindService() {
 157         gLogger.debug("doUnbindService");
 158         if(mBounded){
 159             gLogger.debug("Stop service <---------");
 160             unbindService(mConnection);
 161             mBounded = false;
 162         }
 163     }
 164
 165     private void initCameraView (){
 166         getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN, WindowManager.LayoutParams.FLAG_FULLSCREEN);
 167         requestWindowFeature(Window.FEATURE_NO_TITLE);
 168         getWindow().setFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON, WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON);
 169         ///setContentView(R.layout.activity_main);
 170
 171         ActionBar actionBar = getSupportActionBar();
 172         actionBar.hide();
 173
 174         DisplayMetrics outMetrics = new DisplayMetrics();
 175         this.getWindowManager().getDefaultDisplay().getMetrics(outMetrics);
 176
 177         CameraView.SCREEN_WIDTH = outMetrics.widthPixels;
 178         CameraView.SCREEN_HEIGHT = outMetrics.heightPixels;
 179         gLogger.debug("Screen size is w: " + CameraView.SCREEN_WIDTH  + ", h: " + CameraView.SCREEN_HEIGHT);
 180
 181
 182
 183         mCameraView = new CameraView(getApplicationContext(), this);
 184         setContentView(R.layout.activity_main);
 185
 186         ViewGroup.LayoutParams lp = new ViewGroup.LayoutParams(640, 480);
 187         addContentView(mCameraView, lp);
 188         //setContentView(mCameraView);
 189     }
 190     @Override
 191     protected void onCreate(Bundle savedInstanceState) {
 192         super.onCreate(savedInstanceState);
 193         LogUtil.config(getExternalFilesDir(null));
 194         gLogger = Logger.getLogger(getClass());
 195         gLogger.error("#######################################");
 196         UserInfo.readConfig(getExternalFilesDir(null) + File.separator + "config", getMacAddr());
 197         initCameraView();
 198         init();
 199
 200         if(NetworkMonitor.isNetworkAvailable(this) && mUsbMonitor.hasUsbCamera()){
 201             gLogger.error("Current network is available");
 202             doBindService();
 203         } else {
 204             gLogger.error("Current network NOT available or no USB Camera connected");
 205         }
 206
 207         if(!mServiceHealthMonitor.isAlive()) {
 208             gLogger.debug("mServiceHealthMonitor start, interval " + INTERVAL);
 209             mServiceHealthMonitor.start();
 210         }
 211         ////////// LogUtil.sendLogs();  /// Log test
 212     }
 213
 214     @Override
 215     protected void onPause(){
 216         super.onPause();
 217         gLogger.error("OnPause --------->");
 218     }
 219
 220     @Override
 221     protected void onResume() {
 222         super.onResume();
 223         gLogger.error("OnResume ---------> ");
 224     }
 225
 226     @Override
 227     protected void onStop() {
 228         super.onStop();
 229         gLogger.debug("onStop --------->");
 230     }
 231
 232     @Override
 233     protected void onStart(){
 234         super.onStart();
 235         gLogger.debug("onStart --------->");
 236     }
 237
 238     @Override
 239     protected void onDestroy(){
 240         super.onDestroy();
 241         mUsbMonitor.unregisterReceiver();
 242         unregisterReceiver(networkMonitor);
 243         unbindService(mConnection);
 244         gLogger.debug("onDestroy --------->");
 245     }
 246
 247     @Override
 248     protected void onRestart(){
 249         super.onRestart();
 250         gLogger.debug("onRestart ---------->");
 251     }
 252
 253     @Override
 254     public void onBackPressed() {
 255         gLogger.error("onBackPressed  --------->");
 256         Intent intent = new Intent(Intent.ACTION_MAIN);
 257         intent.addCategory(Intent.CATEGORY_HOME);
 258         intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
 259         startActivity(intent);
 260     }
 261
 262     private String getMacAddr() {
 263         WifiManager manager = (WifiManager) getApplicationContext().getSystemService(Context.WIFI_SERVICE);
 264         WifiInfo info = manager.getConnectionInfo();
 265         gLogger.debug("Mac Address is " + info.getMacAddress());
 266         return info.getMacAddress().replace(":", ""); //02:00:00:00:00:00 - 020000000000
 267     }
 268
 269     private boolean canStartService(){
 270         return mUsbMonitor.hasUsbCamera() && NetworkMonitor.isNetworkAvailable(this);
 271     }
 272
 273     // MyServiceEventListener
 274     @Override
 275     public void onCameraError(String msg){
 276         gLogger.error("onCameraEvent " + msg);
 277         //if(mUsbMonitor.hasUsbCamera()){
 278             //mServer.reopenCamera();
 279         //}
 280     }
 281
 282     @Override
 283     public void onEncoderError(String msg){
 284         gLogger.error("onEncoderError: " + msg);
 285         doUnbindService();
 286         doBindService();
 287     }
 288
 289     @Override
 290     public void onPublishing(String msg){
 291         mServiceHealthMonitor.record();
 292     }
 293
 294     @Override
 295     public void onSurfaceChanged(SurfaceHolder holder, int format, int width, int height){
 296         if(mServer != null){
 297             mServer.startPreview(holder);
 298         }
 299     }
 300
 301     private void restartApplication() {
 302         final Intent intent = getPackageManager().getLaunchIntentForPackage(getPackageName());
 303         intent.addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
 304         startActivity(intent);
 305     }
 306 }