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