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