Блог

общедоступный класс VideoChatViewActivity расширяет возможности AppCompatActivity, реализует CameraDialog.CameraDialogParent, интерфейс просмотра камеры.Обратный вызов{ закрытый статический ТЕГ конечной строки = VideoChatViewActivity.class.getSimpleName();

 private static final int PERMISSION_REQ_ID = 22;   // Permission WRITE_EXTERNAL_STORAGE is not mandatory  // for Agora RTC SDK, just in case if you wanna save  // logs to external sdcard.  private static final String[] REQUESTED_PERMISSIONS = {  Manifest.permission.RECORD_AUDIO,  Manifest.permission.CAMERA  };   private RtcEngine mRtcEngine;  private boolean mCallEnd;  private boolean mMuted;   private FrameLayout mLocalContainer;  private RelativeLayout mRemoteContainer;  private VideoCanvas mLocalVideo;  private VideoCanvas mRemoteVideo;   private ImageView mCallBtn;  private ImageView mMuteBtn;  private ImageView mSwitchCameraBtn;   // Customized logger view  private LoggerRecyclerView mLogView;   private final IRtcEngineEventHandler mRtcEventHandler = new IRtcEngineEventHandler() {   @Override  public void onJoinChannelSuccess(String channel, final int uid, int elapsed) {  runOnUiThread(new Runnable() {  @Override  public void run() {  mLogView.logI("Join channel success, uid: "   (uid amp; 0xFFFFFFFFL));  }  });  }   @Override  public void onUserJoined(final int uid, int elapsed) {  runOnUiThread(new Runnable() {  @Override  public void run() {  mLogView.logI("First remote video decoded, uid: "   (uid amp; 0xFFFFFFFFL));  setupRemoteVideo(uid);  }  });  }    @Override  public void onUserOffline(final int uid, int reason) {  runOnUiThread(new Runnable() {  @Override  public void run() {  mLogView.logI("User offline, uid: "   (uid amp; 0xFFFFFFFFL));  onRemoteUserLeft(uid);  }  });  }  };   private void setupRemoteVideo(int uid) {  ViewGroup parent = mRemoteContainer;  if (parent.indexOfChild(mLocalVideo.view) gt; -1) {  parent = mLocalContainer;  }   if (mRemoteVideo != null) {  return;  }   SurfaceView view = RtcEngine.CreateRendererView(getBaseContext());  view.setZOrderMediaOverlay(parent == mLocalContainer);  parent.addView(view);  mRemoteVideo = new VideoCanvas(view, VideoCanvas.RENDER_MODE_HIDDEN, uid);  // Initializes the video view of a remote user.  mRtcEngine.setupRemoteVideo(mRemoteVideo);  }   private void onRemoteUserLeft(int uid) {  if (mRemoteVideo != null amp;amp; mRemoteVideo.uid == uid) {  removeFromParent(mRemoteVideo);  // Destroys remote view  mRemoteVideo = null;  }  }     //usb  private static final int DEFAULT_CAPTURE_WIDTH = 1280;  private static final int DEFAULT_CAPTURE_HEIGHT = 720;   @BindView(R.id.camer_view)  public View mTextureView;  private static final String TAG1 = "Debug";  private UVCCameraHelper mCameraHelper;   private CameraViewInterface mUVCCameraView;  private AlertDialog mDialog;   private boolean isRequest;  private boolean isPreview;  private UVCCameraHelper.OnMyDevConnectListener listener = new UVCCameraHelper.OnMyDevConnectListener() {   @Override  public void onAttachDev(UsbDevice device) {  // request open permission  if (!isRequest) {  isRequest = true;  if (mCameraHelper != null) {  mCameraHelper.requestPermission(0);  }  }  }   @Override  public void onDettachDev(UsbDevice device) {  // close camera  if (isRequest) {  isRequest = false;  mCameraHelper.closeCamera();  showShortMsg(device.getDeviceName()   " is out");  }  }   @Override  public void onConnectDev(UsbDevice device, boolean isConnected) {  if (!isConnected) {  showShortMsg("fail to connect,please check resolution params");  isPreview = false;  } else {  isPreview = true;  showShortMsg("connecting");  // initialize seekbar  // need to wait UVCCamera initialize over  new Thread(new Runnable() {  @Override  public void run() {  try {  Thread.sleep(2500);  } catch (InterruptedException e) {  e.printStackTrace();  }  Looper.prepare();  if(mCameraHelper != null amp;amp; mCameraHelper.isCameraOpened()) {   }  Looper.loop();  }  }).start();  }  }   @Override  public void onDisConnectDev(UsbDevice device) {  showShortMsg("disconnecting");  }  };  //usb    @Override  protected void onCreate(Bundle savedInstanceState) {  super.onCreate(savedInstanceState);   setContentView(R.layout.activity_video_chat_view);  ButterKnife.bind(this);//uvc  initUI();   mUVCCameraView = (CameraViewInterface) mTextureView;  mUVCCameraView.setCallback(this);  //mLocalContainer.setCallback(this);  mCameraHelper = UVCCameraHelper.getInstance();  mCameraHelper.setDefaultPreviewSize(1280,720);  mCameraHelper.initUSBMonitor(this, mUVCCameraView, listener);  mCameraHelper.setOnPreviewFrameListener(new AbstractUVCCameraHandler.OnPreViewResultListener() {  @Override  public void onPreviewResult(byte[] bytes) {  try {   AgoraVideoFrame frame = new AgoraVideoFrame();  frame.buf = bytes;  frame.format = AgoraVideoFrame.FORMAT_NV21;   frame.stride = DEFAULT_CAPTURE_WIDTH;  frame.height = DEFAULT_CAPTURE_HEIGHT;   frame.timeStamp = System.currentTimeMillis();   mRtcEngine.pushExternalVideoFrame(frame);   }catch (Exception e){  e.printStackTrace();  }  }  });  // Ask for permissions at runtime.  // This is just an example set of permissions. Other permissions  // may be needed, and please refer to our online documents.  if (checkSelfPermission(REQUESTED_PERMISSIONS[0], PERMISSION_REQ_ID) amp;amp;  checkSelfPermission(REQUESTED_PERMISSIONS[1], PERMISSION_REQ_ID)) {  initEngineAndJoinChannel();    }  }                private void initUI() {  mLocalContainer = findViewById(R.id.local_video_view_container);  mRemoteContainer = findViewById(R.id.remote_video_view_container);   mCallBtn = findViewById(R.id.btn_call);  mMuteBtn = findViewById(R.id.btn_mute);  mSwitchCameraBtn = findViewById(R.id.btn_switch_camera);   mLogView = findViewById(R.id.log_recycler_view);   // Sample logs are optional.  showSampleLogs();  }   private void showSampleLogs() {  mLogView.logI("Welcome to Agora 1v1 video call");  mLogView.logW("You will see custom logs here");  mLogView.logE("You can also use this to show errors");  }   private boolean checkSelfPermission(String permission, int requestCode) {  if (ContextCompat.checkSelfPermission(this, permission) !=  PackageManager.PERMISSION_GRANTED) {  ActivityCompat.requestPermissions(this, REQUESTED_PERMISSIONS, requestCode);  return false;  }   return true;  }   @Override  public void onRequestPermissionsResult(int requestCode,  @NonNull String[] permissions, @NonNull int[] grantResults) {  if (requestCode == PERMISSION_REQ_ID) {  if (grantResults[0] != PackageManager.PERMISSION_GRANTED ||  grantResults[1] != PackageManager.PERMISSION_GRANTED ||  grantResults[2] != PackageManager.PERMISSION_GRANTED) {  showLongToast("Need permissions "   Manifest.permission.RECORD_AUDIO    "/"   Manifest.permission.CAMERA);  finish();  return;  }   // Here we continue only if all permissions are granted.  // The permissions can also be granted in the system settings manually.  initEngineAndJoinChannel();  }  }   private void showLongToast(final String msg) {  this.runOnUiThread(new Runnable() {  @Override  public void run() {  Toast.makeText(getApplicationContext(), msg, Toast.LENGTH_LONG).show();  }  });  }   private void initEngineAndJoinChannel() {   initializeEngine();  setupVideoConfig();  setupLocalVideo();  joinChannel();  }   private void initializeEngine() {  try {  mRtcEngine = RtcEngine.create(getBaseContext(), getString(R.string.agora_app_id), mRtcEventHandler);  } catch (Exception e) {  Log.e(TAG, Log.getStackTraceString(e));  throw new RuntimeException("NEED TO check rtc sdk init fatal errorn"   Log.getStackTraceString(e));  }  }   private void setupVideoConfig() {   mRtcEngine.enableVideo();    mRtcEngine.setVideoEncoderConfiguration(new VideoEncoderConfiguration(  VideoEncoderConfiguration.VD_640x360,  VideoEncoderConfiguration.FRAME_RATE.FRAME_RATE_FPS_15,  VideoEncoderConfiguration.STANDARD_BITRATE,  VideoEncoderConfiguration.ORIENTATION_MODE.ORIENTATION_MODE_FIXED_PORTRAIT));  }   private void setupLocalVideo() {  

. Вид с видом на поверхность = RtcEngine.CreateRendererView(getBaseContext()); view.setZOrderMediaOverlay(true); mLocalContainer.addView(просмотр); mLocalVideo = новые видеоканалы(просмотр, ВидеоКаналы.RENDER_MODE_HIDDEN, 0); mRtcEngine.setupLocalVideo(mLocalVideo); }

 private void joinChannel() {   String token = getString(R.string.agora_access_token);  if (TextUtils.isEmpty(token) || TextUtils.equals(token, "#YOUR ACCESS TOKEN#")) {  token = null; // default, no token  }  mRtcEngine.joinChannel(token, "streaming", "Extra Optional Data", 0);  }   @Override  protected void onDestroy() {  super.onDestroy();  if (!mCallEnd) {  leaveChannel();  }   RtcEngine.destroy();  }   private void leaveChannel() {  mRtcEngine.leaveChannel();  }   public void onLocalAudioMuteClicked(View view) {  mMuted = !mMuted;  mRtcEngine.muteLocalAudioStream(mMuted);  int res = mMuted ? R.drawable.btn_mute : R.drawable.btn_unmute;  mMuteBtn.setImageResource(res);  }   public void onSwitchCameraClicked(View view) {  mRtcEngine.switchCamera();  }   public void onCallClicked(View view) {  if (mCallEnd) {  startCall();  mCallEnd = false;  mCallBtn.setImageResource(R.drawable.btn_endcall);  } else {  endCall();  mCallEnd = true;  mCallBtn.setImageResource(R.drawable.btn_startcall);  }   showButtons(!mCallEnd);  }   private void startCall() {  setupLocalVideo();  joinChannel();  }   private void endCall() {  removeFromParent(mLocalVideo);  mLocalVideo = null;  removeFromParent(mRemoteVideo);  mRemoteVideo = null;  leaveChannel();  }   private void showButtons(boolean show) {  int visibility = show ? View.VISIBLE : View. SurfaceView view .GONE;  mMuteBtn.setVisibility(visibility);  mSwitchCameraBtn.setVisibility(visibility);  }   private ViewGroup removeFromParent(VideoCanvas canvas) {  if (canvas != null) {  ViewParent parent = canvas.view.getParent();  if (parent != null) {  ViewGroup group = (ViewGroup) parent;  group.removeView(canvas.view);  return group;  }  }  return null;  }   private void switchView(VideoCanvas canvas) {  ViewGroup parent = removeFromParent(canvas);  if (parent == mLocalContainer) {  if (canvas.view instanceof SurfaceView) {  ((SurfaceView) canvas.view).setZOrderMediaOverlay(false);  }  mRemoteContainer.addView(canvas.view);  } else if (parent == mRemoteContainer) {  if (canvas.view instanceof SurfaceView) {  ((SurfaceView) canvas.view).setZOrderMediaOverlay(true);  }  mLocalContainer.addView(canvas.view);  }  }   public void onLocalContainerClick(View view) {  switchView(mLocalVideo);  switchView(mRemoteVideo);  }    ///uvc   @Override  protected void onStart() {  super.onStart();  // step.2 register USB event broadcast  if (mCameraHelper != null) {  mCameraHelper.registerUSB();  }  }   @Override  protected void onStop() {  super.onStop();  // step.3 unregister USB event broadcast  if (mCameraHelper != null) {  mCameraHelper.unregisterUSB();  }  }     private void showShortMsg(String msg) {  //  Toast.makeText(this, msg, Toast.LENGTH_SHORT).show();  }      @Override  public USBMonitor getUSBMonitor(){ return mCameraHelper.getUSBMonitor();  }   @Override  public void onDialogResult(boolean canceled) {  if (canceled) {  showShortMsg("cancel");  }  }   @Override  public void onSurfaceCreated(CameraViewInterface cameraViewInterface, Surface surface) {  if (!isPreview amp;amp; mCameraHelper.isCameraOpened()) {  mCameraHelper.startPreview(mUVCCameraView);  isPreview = true;  }  }   @Override  public void onSurfaceChanged(CameraViewInterface cameraViewInterface, Surface surface, int i, int i1) {   }   @Override  public void onSurfaceDestroy(CameraViewInterface cameraViewInterface, Surface surface) {  if (isPreview amp;amp; mCameraHelper.isCameraOpened()) {  mCameraHelper.stopPreview();  isPreview = false;  }  }  

}