// 创建引擎
rtcVideo = RTCVideo.createRTCVideo(this, Constants.APP_ID, videoEventHandler, null, null);
// 开启音视频采集
rtcVideo.startVideoCapture();
rtcVideo.startAudioCapture();

private void joinRoom(String roomId) {
    // 创建房间
    rtcRoom = rtcVideo.createRTCRoom(roomId);
    rtcRoom.setRTCRoomEventHandler(roomEventHandler);
    String token = requestRoomToken(roomId);
    // 用户信息
    UserInfo userInfo = new UserInfo(localUid, "");
    // 房间配置
    boolean isAutoPublish = true;
    boolean isAutoSubscribeAudio = true;
    boolean isAutoSubscribeVideo = true;
    RTCRoomConfig roomConfig = new RTCRoomConfig(ChannelProfile.CHANNEL_PROFILE_CHAT_ROOM, isAutoPublish, isAutoSubscribeAudio, isAutoSubscribeVideo);
    // 加入房间
    rtcRoom.joinRoom(token, userInfo, roomConfig);
}

private void startPushCDNStream() {
	String cdnAddr = cdnAddressInput.getText().toString();
  if (cdnAddr.isEmpty()) {
		ToastUtil.showAlert(this, "cdn address is null");
    return;
  }

  mixedStreamConfig.setUserID(localUid);
  mixedStreamConfig.setRoomID(roomID);
  // RTMP 推流地址
  mixedStreamConfig.setPushURL(cdnAddr);
  mixedStreamConfig.setPushURL(cdnAddr);mixedStreamConfig.setExpectedMixingType(ByteRTCStreamMixingType.STREAM_MIXING_BY_SERVER);

  MixedStreamConfig.MixedStreamLayoutConfig layoutConfig = new MixedStreamConfig.MixedStreamLayoutConfig();
  // 背景色
  layoutConfig.setBackgroundColor(layoutColorInput.getText().toString());
  // 设置合流布局
  layoutConfig.setRegions(getLayoutRegions());

  mixedStreamConfig.setLayout(layoutConfig);
  // 开始推流到 CDN
  rtcVideo.startPushMixedStreamToCDN(CDN_TASK_ID, mixedStreamConfig, mixedStreamObserver);
}
// 监听任务回调
IMixedStreamObserver mixedStreamObserver = new IMixedStreamObserver() {
	@Override
  public boolean isSupportClientPushStream() {
		ToastUtil.showShortToast(CDNStreamActivity.this, "isSupportClientPushStream");
    //应用层是否具备推流能力， false：不具备，使用 RTC 进行合流转推
    return false;
  }

@Override
public void onMixingEvent(ByteRTCStreamMixingEvent eventType, String taskId, ByteRTCTranscoderErrorCode error, MixedStreamType mixType) {
	String msg = String.format("onMixingEvent, type:%s, taskId:%s, error:%s, mixType:%s", eventType.toString(), taskId, error.toString(), mixType.toString());
  Log.d(TAG, msg);
  ToastUtil.showLongToast(CDNStreamActivity.this, msg);
    }

@Override
public void onMixingAudioFrame(String taskId, byte[] audioFrame, int frameNum, long timeStampMs) {
	String msg = String.format("onMixingEvent, taskId:%s, frameNum:%d, timeStampMs:%l", taskId, frameNum, timeStampMs);
  Log.d(TAG, msg);
  ToastUtil.showLongToast(CDNStreamActivity.this, msg);
  }

@Override
public void onMixingVideoFrame(String taskId, VideoFrame videoFrame) {
  String msg = String.format("onMixingVideoFrame, taskId:%s", taskId);
  Log.d(TAG, msg);
  ToastUtil.showLongToast(CDNStreamActivity.this, msg);
    }

@Override
public void onMixingDataFrame(String taskId, byte[] dataFrame, long time) {
  String msg = String.format("onMixingDataFrame, taskId:%s", taskId);
  Log.d(TAG, msg);
  ToastUtil.showLongToast(CDNStreamActivity.this, msg);
    }

@Override
public void onCacheSyncVideoFrames(String taskId, String[] userIds, VideoFrame[] videoFrame, byte[][] dataFrame, int count) {
	String msg = String.format("onCacheSyncVideoFrames, taskId:%s", taskId);
  Log.d(TAG, msg);
  ToastUtil.showLongToast(CDNStreamActivity.this, msg);
  }
};