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

   1 package ai.suanzi.rtmpclient;
   2
   3 import android.app.Activity;
   4 import android.app.PendingIntent;
   5 import android.content.BroadcastReceiver;
   6 import android.content.IntentFilter;
   7 import android.graphics.ImageFormat;
   8 import android.graphics.SurfaceTexture;
   9 import android.hardware.usb.UsbDevice;
  10 import android.hardware.usb.UsbManager;
  11 import android.os.Environment;
  12 import android.support.design.widget.TextInputEditText;
  13 import android.support.v7.app.AppCompatActivity;
  14 import android.os.Bundle;
  15 import android.text.TextUtils;
  16 import android.util.Log;
  17 import android.view.SurfaceHolder;
  18 import android.hardware.Camera;
  19 import android.view.SurfaceView;
  20 import android.view.View;
  21 import android.widget.Button;
  22 import android.widget.Toast;
  23 import android.content.Context;
  24 import android.content.pm.PackageManager;
  25 import android.os.AsyncTask;
  26
  27 import java.io.File;
  28 import java.util.HashMap;
  29 import java.util.Iterator;
  30 import java.util.List;
  31 import java.io.IOException;
  32 import java.util.concurrent.Executor;
  33 import java.util.concurrent.ExecutorService;
  34 import java.util.concurrent.Executors;
  35 import android.content.Intent;
  36 import java.io.OutputStream;
  37 import android.hardware.usb.UsbManager;
  38 import android.hardware.usb.UsbDeviceConnection;
  39
  40 import de.mindpipe.android.logging.log4j.LogConfigurator;
  41 import org.apache.log4j.Level;
  42 import org.apache.log4j.Logger;
  43 import android.net.wifi.WifiManager;
  44 import android.net.wifi.WifiInfo;
  45 import android.content.ServiceConnection;
  46 import android.content.ComponentName;
  47
  48 import ai.suanzi.rtmpclient.MyService.LocalBinder;
  49 import android.os.IBinder;
  50 import android.net.ConnectivityManager;
  51
  52 //"rtmp://gpussh.suanzi.ai:1935/myapp/suanzi_ac83f34ead90_cameraid";
  53
  54 public class MainActivity extends AppCompatActivity implements SurfaceHolder.Callback, Camera.PreviewCallback{
  55
  56     private static final String TAG = "PENG";
  57     //private Ffmpeg ffmpeg;
  58     //private Camera mCamera ;
  59     //private StreamTask mStreamTask;
  60     private SurfaceHolder mHolder;
  61     private SurfaceView mSufaceView;
  62     //private UVCCamera uvcCamera;
  63     //ExecutorService mExecutor = Executors.newSingleThreadExecutor();
  64     //Intent it = new Intent(getApplicationContext(), MyService.class);
  65     Intent intent = new Intent();
  66
  67     //private UsbManager usbManager;
  68     //private UsbDevice usbCamera;
  69
  70     private Logger gLogger;
  71
  72     private Button mBtnStart;
  73     private TextInputEditText mTextServer;
  74     private TextInputEditText mTextUser;
  75     private TextInputEditText mTextCamera;
  76     private String mMacAddr = "";
  77     //private CameraView mCameraView;
  78     private String mRtmpUrl;
  79     private NetworkMonitor networkMonitor;
  80
  81     boolean mBounded;
  82     MyService mServer;
  83     Intent mIntent;
  84
  85     private void configLog(){
  86         try {
  87             final LogConfigurator logConfigurator = new LogConfigurator();
  88             String fname = getExternalFilesDir(null) + File.separator + "log.txt";
  89             logConfigurator.setFileName(fname);
  90             Log.e(TAG, "Log file is located at: " + fname);
  91             logConfigurator.setRootLevel(Level.DEBUG);
  92             logConfigurator.setLevel("org.apache", Level.ERROR);
  93             logConfigurator.setMaxFileSize(1024 * 1024 * 10);
  94             logConfigurator.configure();
  95             gLogger = Logger.getLogger(getClass());
  96         } catch (Exception e){
  97             e.printStackTrace();
  98         }
  99     }
 100
 101     private void init(){
 102         configLog();
 103         gLogger.debug("#######################################");
 104         // set config file
 105         UserInfo.setConfigPath(getExternalFilesDir(null) + File.separator + "config");
 106
 107         this.mMacAddr = getMacAddr();
 108         mBtnStart = findViewById(R.id.button);
 109         mTextServer = findViewById(R.id.textServer);
 110         mTextUser = findViewById(R.id.textUser);
 111         mTextCamera = findViewById(R.id.textCamera);
 112         mSufaceView = findViewById(R.id.surfaceView);
 113         mHolder = mSufaceView.getHolder();
 114         mHolder.addCallback(this);
 115         //intent.setPackage(this.getPackageName());   // init service
 116         //intent.setAction("ai.suanzi.rtmpclient.service");
 117     }
 118
 119
 120     ServiceConnection mConnection = new ServiceConnection() {
 121         @Override
 122         public void onServiceDisconnected(ComponentName name) {
 123             Toast.makeText(MainActivity.this, "Service is disconnected", 1000).show();
 124             gLogger.error("onServiceDisconnected ---------->");
 125             mBounded = false;
 126             mServer = null;
 127         }
 128
 129         @Override
 130         public void onServiceConnected(ComponentName name, IBinder service) {
 131             Toast.makeText(MainActivity.this, "Service is connected", 1000).show();
 132             gLogger.error("onServiceConnected ---------->");
 133             mBounded = true;
 134             LocalBinder mLocalBinder = (LocalBinder)service;
 135             mServer = mLocalBinder.getServiceInstance();
 136             if(mServer.setRtmpUrl(UserInfo.getConfig().toUrl())){
 137                 mServer.startPreview(mHolder);
 138             }
 139         }
 140     };
 141
 142     private void doBindService(){
 143         if(!mBounded) {
 144             gLogger.debug("doBindService");
 145             bindService(mIntent, mConnection, BIND_AUTO_CREATE);
 146         }
 147     }
 148
 149     private void doUnbindService() {
 150         if(mBounded){
 151             gLogger.debug("doUnbindService");
 152             unbindService(mConnection);
 153             mBounded = false;
 154         }
 155     }
 156
 157     @Override
 158     protected void onCreate(Bundle savedInstanceState) {
 159         super.onCreate(savedInstanceState);
 160         setContentView(R.layout.activity_main);
 161
 162         init();
 163         loadConfig();
 164
 165         //startService(intent);
 166         mIntent = new Intent(this, MyService.class);
 167         if(NetworkMonitor.isNetworkAvailable(this)){
 168             gLogger.error("Current network is available");
 169             doBindService();
 170         } else {
 171             gLogger.error("Current network is NOT available");
 172         }
 173
 174         mBtnStart.setText("start");
 175         mBtnStart.setOnClickListener(new View.OnClickListener(){
 176             @Override
 177             public void onClick(View view){
 178                 gLogger.error("----------> onClick");
 179                 saveConfig();
 180                 doUnbindService();
 181
 182             }
 183         });
 184
 185         if ( networkMonitor == null) {
 186             networkMonitor = new NetworkMonitor(new NetworkMonitor.NetworkListener() {
 187                 @Override
 188                 public void onWifiConnected() {
 189                     gLogger.error("onWifiConnected");
 190                     doBindService();
 191                 }
 192
 193                 @Override
 194                 public void onWifiDisconnected() {
 195                     gLogger.error("onWifiDisconnected");
 196                     doUnbindService();
 197                 }
 198
 199                 @Override
 200                 public void onWifiEnabled() {
 201                     gLogger.error("onWifiEnabled");
 202                 }
 203
 204                 @Override
 205                 public void onWifiDisabled() {
 206                     gLogger.error("onWifiDisabled");
 207                 }
 208             });
 209         }
 210         IntentFilter filter = new IntentFilter();
 211         filter.addAction(ConnectivityManager.CONNECTIVITY_ACTION);
 212         registerReceiver(networkMonitor, filter);
 213     }
 214
 215     @Override
 216     protected void onPause(){
 217         super.onPause();
 218         gLogger.error("OnPause --------->");
 219     }
 220
 221     @Override
 222     protected void onResume() {
 223         super.onResume();
 224         gLogger.error("OnResume ---------> ");
 225     }
 226
 227     @Override
 228     protected void onStop() {
 229         super.onStop();
 230         gLogger.debug("onStop --------->");
 231     }
 232
 233     @Override
 234     protected void onStart(){
 235         super.onStart();
 236         gLogger.debug("onStart --------->");
 237     }
 238
 239     @Override
 240     protected void onDestroy(){
 241         super.onDestroy();
 242         unregisterReceiver(networkMonitor);
 243         gLogger.debug("onDestroy --------->");
 244     }
 245
 246     @Override
 247     protected void onRestart(){
 248         super.onRestart();
 249         gLogger.debug("onRestart ---------->");
 250     }
 251
 252     // SurfaceHolder.Callback implementation
 253     @Override
 254     public void surfaceCreated(final SurfaceHolder holder){
 255         gLogger.error("SurfacedCreated");
 256     }
 257
 258     @Override
 259     public void surfaceChanged(SurfaceHolder holder, int format, int widht, int height){
 260         gLogger.error("surfaceChanged");
 261         mHolder = holder;
 262         if (mServer != null) {
 263             mServer.startPreview(holder);
 264         }
 265     }
 266
 267     @Override
 268     public void surfaceDestroyed(SurfaceHolder holder){ gLogger.debug("surfaceDestroyed");
 269     }
 270
 271     @Override
 272     public void  onPreviewFrame(final byte[] data, Camera camera){
 273         gLogger.error("onPreviewFrame");
 274
 275     }
 276
 277
 278     private String getMacAddr() {
 279         WifiManager manager = (WifiManager) getApplicationContext().getSystemService(Context.WIFI_SERVICE);
 280         WifiInfo info = manager.getConnectionInfo();
 281         return info.getMacAddress().replace(":", ""); //02:00:00:00:00:00 - 020000000000
 282     }
 283
 284     private void loadConfig() {
 285         UserInfo info = UserInfo.getConfig();
 286         gLogger.error("server is:" + info.server);
 287         mTextServer.setText(info.server.equals("") ? "rtmp://gpussh.suanzi.ai:1935/myapp" : info.server);
 288         mTextUser.setText(info.user);
 289         mTextCamera.setText(info.cameraId);
 290         //mMacAddr = info.macAddr.equals("") ?  this.mMacAddr : info.macAddr;
 291         gLogger.error("loadConfig - url is :" + info.toUrl());
 292     }
 293
 294     private void saveConfig() {
 295         UserInfo info = UserInfo.getConfig();
 296         info.update(mTextServer.getText().toString(), mTextUser.getText().toString(), mMacAddr, mTextCamera.getText().toString());
 297         if(info.saveConfig()) {
 298             Toast.makeText(getApplicationContext(), "Config saved", Toast.LENGTH_LONG).show();
 299         } else {
 300             Toast.makeText(getApplicationContext(), "Error: config saved", Toast.LENGTH_LONG).show();
 301         }
 302         gLogger.error("saveConfig - url: " + info.toUrl());
 303     }
 304
 305     private void changePermission(){
 306         try {
 307             Log.e(TAG, "change permission");
 308             //Process sh = Runtime.getRuntime().exec(new String[]{"su", "-c", "chmod 666 /dev/video0"});
 309
 310             Process sh = Runtime.getRuntime().exec("/system/xbin/su", null,null);
 311             //Process sh = Runtime.getRuntime().exec("su", null,null);
 312
 313             OutputStream  os = sh.getOutputStream();
 314             os.write(("/system/bin/chmod 666 /dev/video0").getBytes("ASCII"));
 315             //os.write(("/system/bin/echo 'wowo' >> /data/local/test").getBytes("ASCII"));
 316             os.flush();
 317             os.close();
 318             sh.waitFor();
 319
 320
 321         }catch (Exception e){
 322             e.printStackTrace();
 323         }
 324     }
 325
 326     private boolean checkCameraHardware(Context context) {
 327         return context.getPackageManager().hasSystemFeature(PackageManager.FEATURE_CAMERA);
 328     }
 329
 330     private static Camera getCameraInstance(){
 331         Camera c = null;
 332         try {
 333             Log.e(TAG, "Open Camera");
 334             c = Camera.open(1);
 335         } catch (Exception e){
 336             e.printStackTrace();
 337         }
 338         return c;
 339     }
 340
 341     private void configCamera(Camera camera){
 342         Camera.Parameters paras = camera.getParameters();
 343         gLogger.error("Supported Picture Sizes:");
 344         for (Camera.Size cc : paras.getSupportedPictureSizes()){
 345             gLogger.error(cc.width + "x" + cc.height);
 346         }
 347         gLogger.error("Supported Preview fps range:");
 348         for(int[] i : paras.getSupportedPreviewFpsRange()){
 349             gLogger.error("[" + i[0] + "," + i[1] + "]");
 350         }
 351         gLogger.error("Set parameters");
 352         camera.setParameters(paras);
 353         camera.setDisplayOrientation(0);
 354         gLogger.error("Preview Format: " + paras.getPreviewFormat() + ". Size: " + paras.getPreviewSize().width + "x" + paras.getPreviewSize().height);
 355         gLogger.error("Picture Format: " + paras.getPictureFormat() + ". Size: " + paras.getPictureSize().width + "x" + paras.getPictureSize().height);
 356
 357         try {
 358             camera.setPreviewDisplay(mHolder);
 359         } catch (IOException e){
 360             e.printStackTrace();
 361         }
 362         //camera.setPreviewCallback(this);
 363     }
 364
 365     private void switchToBackground(){
 366         Intent i = new Intent();
 367         i.setAction(Intent.ACTION_MAIN);
 368         i.addCategory(Intent.CATEGORY_HOME);
 369         this.startActivity(i);
 370     }
 371 }