ApsaraVideo Live:Get started with ARTC

Android

private void createEngine() {
    mAliRtcEngine = AliRtcEngine.getInstance(getApplicationContext());
    mAliRtcEngine.setRtcEngineEventListener(new AliRtcEngineEventListener() {

        /* The notification about the SDK connection to the server. You must handle connection failures. */
        @Override
        public void onConnectionStatusChange(AliRtcEngine.AliRtcConnectionStatus aliRtcConnectionStatus, AliRtcEngine.AliRtcConnectionStatusChangeReason aliRtcConnectionStatusChangeReason) {
            super.onConnectionStatusChange(aliRtcConnectionStatus, aliRtcConnectionStatusChangeReason);
            if (aliRtcConnectionStatus == AliRtcEngine.AliRtcConnectionStatus.AliRtcConnectionStatusFailed) {
                /* TODO: Be sure to handle the exception. The SDK has tried various recovery policies but still cannot recover. */
            } else {
                /* TODO: Handle the exception as needed. Business code is added, usually for data statistics and UI changes. */
            }
        }

        /* The SDK attempts to fix the local device exception. */
        @Override
        public void OnLocalDeviceException(AliRtcEngine.AliRtcEngineLocalDeviceType aliRtcEngineLocalDeviceType, AliRtcEngine.AliRtcEngineLocalDeviceExceptionType aliRtcEngineLocalDeviceExceptionType, String s) {
            super.OnLocalDeviceException(aliRtcEngineLocalDeviceType, aliRtcEngineLocalDeviceExceptionType, s);
            /* TODO: Be sure to handle the exception. The SDK has tried various recovery policies but still cannot recover. */
        }

        @Override
        public void onJoinChannelResult(int result, String channel, String userId, int elapsed) {
            super.onJoinChannelResult(result, channel, userId, elapsed);
            /* TODO: Handle the exception as needed. Business code is added, usually for data statistics and UI changes. */
            Log.i(TAG, "onJoinChannelResult result=" + result + ",channel=" + channel + ",userId=" + userId + ",elapsed=" + elapsed);
        }

        @Override
        public void onLeaveChannelResult(int result, AliRtcEngine.AliRtcStats stats) {
            super.onLeaveChannelResult(result, stats);
            Log.i(TAG, "onLeaveChannelResult result=" + result);
        }
    });
    mAliRtcEngine.setRtcEngineNotify(new AliRtcEngineNotify() {

        /* The callback is returned when authentication is about to expire in 30 seconds. You must refresh authentication. */
        @Override
        public void onAuthInfoWillExpire() {
            super.onAuthInfoWillExpire();
            /* TODO: Be sure to handle the exception. Obtain the authentication information of the channel and users, and then call refreshAuthInfo. */
        }

        /* The kicking-out operation may be triggered. You must handle the exception. */
        @Override
        public void onBye(int code) {
            super.onBye(code);
            /* TODO: We recommend that you perform handling operations based on your actual scenario. */
        }

        @Override
        public void onRemoteUserOnLineNotify(String uid, int elapsed) {
            super.onRemoteUserOnLineNotify(uid, elapsed);
            Log.i(TAG, "onRemoteUserOnLineNotify uid=" + uid + ",elapsed=" + elapsed);
        }

        @Override
        public void onRemoteUserOffLineNotify(String uid, AliRtcEngine.AliRtcUserOfflineReason aliRtcUserOfflineReason) {
            super.onRemoteUserOffLineNotify(uid, aliRtcUserOfflineReason);
            Log.i(TAG, "onRemoteUserOnLineNotify uid=" + uid + ",aliRtcUserOfflineReason=" + aliRtcUserOfflineReason);
        }

        @Override
        public void onRemoteTrackAvailableNotify(String uid, AliRtcEngine.AliRtcAudioTrack aliRtcAudioTrack, AliRtcEngine.AliRtcVideoTrack aliRtcVideoTrack) {
            super.onRemoteTrackAvailableNotify(uid, aliRtcAudioTrack, aliRtcVideoTrack);
            Log.i(TAG, "onRemoteUserOnLineNotify uid=" + uid + ",aliRtcAudioTrack=" + aliRtcAudioTrack + ",aliRtcVideoTrack=" + aliRtcVideoTrack);
            mMainHandler.post(new Runnable() {
                @Override
                public void run() {
                    if (aliRtcVideoTrack == AliRtcEngine.AliRtcVideoTrack.AliRtcVideoTrackCamera
                            || aliRtcVideoTrack == AliRtcEngine.AliRtcVideoTrack.AliRtcVideoTrackBoth) {
                        AliRtcEngine.AliRtcVideoCanvas remote_canvas = new AliRtcEngine.AliRtcVideoCanvas();
                        SurfaceView remoteView = mAliRtcEngine.createRenderSurfaceView(mContext);
                        if (remoteView != null) {
                            remoteView.setZOrderOnTop(true);
                            remoteView.setZOrderMediaOverlay(true);
                        }
                        remote_canvas.view = remoteView;
                        mLocalSurfaceContainer.addView(remote_canvas.view, new FrameLayout.LayoutParams(
                                findViewById(R.id.local_surface_container).getWidth()/4,
                                findViewById(R.id.local_surface_container).getHeight()/4));
                        mAliRtcEngine.setRemoteViewConfig(remote_canvas,uid,AliRtcEngine.AliRtcVideoTrack.AliRtcVideoTrackCamera);
                    } else {
                        mAliRtcEngine.setRemoteViewConfig(null, uid, AliRtcEngine.AliRtcVideoTrack.AliRtcVideoTrackCamera);
                    }
                }
            });
        }
    });
}

iOS

- (AliRtcEngine *)engine{
    if (!_engine) {
        NSString *extras = @"";
        /* Construct the engine and pass in delegate. */
        _engine = [AliRtcEngine sharedInstance:self extras:extras];
    }
    return _engine;
}

#pragma mark - "Delegates of engine"
/* The callback is returned when authentication is about to expire in 30 seconds. You must refresh authentication. */
- (void)onAuthInfoWillExpire{
    /* TODO: Be sure to handle the exception. Obtain the authentication information of the channel and users, and then call refreshAuthInfo. */
}

/* The notification about the SDK connection to the server. You must handle connection failures. */
- (void)onConnectionStatusChange:(AliRtcConnectionStatus)status reason:(AliRtcConnectionStatusChangeReason)reason {
    if (status == AliRtcConnectionStatusFailed) {
        /* TODO: Be sure to handle the exception. The SDK has tried various recovery policies but still cannot recover. */
    } else {
        /* TODO: Handle the exception as needed. Business code is added, usually for data statistics and UI changes. */
    }
}

/* The SDK attempts to fix the local device exception. */
- (void)onLocalDeviceException:(AliRtcLocalDeviceType)deviceType exceptionType:(AliRtcLocalDeviceExceptionType)exceptionType message:(NSString *_Nullable)msg {
    /* TODO: Be sure to handle the exception. The SDK has tried various recovery policies but still cannot recover. */
}

/* The kicking-out operation may be triggered. You must handle the exception. */
/* The kicking-out operation may be triggered. You must handle the exception. */
- (void)onBye:(int)code {
    /* TODO: We recommend that you perform handling operations based on your actual scenario. */
}

/* The notification about remote stream ingest. If automatic subscription is enabled, you can configure the black screen time and time to first frame for adaption. */
- (void)onRemoteTrackAvailableNotify:(NSString *_Nonnull)uid audioTrack:(AliRtcAudioTrack)audioTrack videoTrack:(AliRtcVideoTrack)videoTrack {
    /* TODO: Be sure to handle the exception. Set a video rendering window for the SDK. */
    dispatch_async(dispatch_get_main_queue(), ^{
        if (videoTrack & AliRtcVideoTrackCamera) {
            AliVideoCanvas *canvas = [[AliVideoCanvas alloc] init];
            canvas.view = self.remoteRenderView;
            canvas.renderMode = AliRtcRenderModeAuto;
            [self.engine setRemoteViewConfig:canvas uid:uid forTrack:AliRtcVideoTrackCamera];
        } else {
            /* Clear the rendering window of the remote user. However, the remote user may directly leave the channel. */
            [self.engine setRemoteViewConfig:nil uid:uid forTrack:AliRtcVideoTrackCamera];
        }
    });
}

- (void)onRemoteUserOffLineNotify:(NSString *)uid offlineReason:(AliRtcUserOfflineReason)reason {
    dispatch_async(dispatch_get_main_queue(), ^{
        /* Clear the rendering window of the remote user. */
        [self.engine setRemoteViewConfig:nil uid:uid forTrack:AliRtcVideoTrackBoth];
    });
}

- (void)onJoinChannelResult:(int)result channel:(NSString *)channel userId:(NSString *)userId elapsed:(int)elapsed {
    /* TODO: Handle the exception as needed. Business code is added, usually for data statistics and UI changes. */
}

- (void)onLeaveChannelResult:(int)result stats:(AliRtcStats)stats {
    /* TODO: Handle the exception as needed. Business code is added, usually for data statistics and UI changes. */
}

Windows

class AliEngineEventListenerImpl : public AliEngineEventListener {
public:
    AliEngineEventListenerImpl(AliEngine* engine, HWND hWnd) {
        mAliRtcEngine = engine;
        mHWnd = hWnd;
    };
    virtual AliEngineEventListenerImpl() {};

    virtual void OnConnectionStatusChange(int status, int reason) override {
        if (status == AliEngineConnectionFailed) {
            /* TODO: Be sure to handle the exception. The SDK has tried various recovery policies but still cannot recover. */
        } else {
            /* TODO: Handle the exception as needed. Business code is added, usually for data statistics and UI changes. */
        }
    };

    virtual void OnLocalDeviceException(AliEngineLocalDeviceType deviceType, AliEngineLocalDeviceExceptionType exceptionType, const char* msg) override {
        /* TODO: Be sure to handle the exception. The SDK has tried various recovery policies but still cannot recover. */
    };

    virtual void OnJoinChannelResult(int result, const char *channel, const char *userId, int elapsed) override {
        /* TODO: Handle the exception as needed. Business code is added, usually for data statistics and UI changes. */
    };

    virtual void OnLeaveChannelResult(int result, AliEngineStats stats) override {
        
    };

    virtual void OnAuthInfoWillExpire() override {
        /* TODO: Be sure to handle the exception. Obtain the authentication information of the channel and users, and then call refreshAuthInfo. */
    };

    virtual void OnBye(int code) override {
        /* TODO: We recommend that you perform handling operations based on your actual scenario. */
    };

    virtual void OnRemoteUserOnLineNotify(const char *uid, int elapsed) override {
        
    };

    virtual void OnRemoteUserOffLineNotify(const char *uid, AliEngineUserOfflineReason reason) override {
        
    };

    virtual void OnRemoteTrackAvailableNotify(const char *uid,
                                                  AliEngineAudioTrack audioTrack,
                                                  AliEngineVideoTrack videoTrack) {
        AliEngineVideoCanvas remote_canvas;
        if (videoTrack == AliEngineVideoTrackCamera
                            || videoTrack == AliEngineVideoTrackBoth) {
            RECT rect;
            ::GetWindowRect(mHWnd, &rect);
            remote_canvas.displayView = remoteView;
            remote_canvas.renderMode = AliEngineRenderModeAuto;
            mAliRtcEngine->SetRemoteViewConfig(remote_canvas,uid,AliEngineVideoTrackCamera);
        } else {
            mAliRtcEngine->SetRemoteViewConfig(remote_canvas, uid, AliEngineVideoTrackCamera);
        }
    }

private:
    AliEngine* mAliRtcEngine = nullptr;
    /* The window handle. */
    HWND mHWnd;
};


private:
void createEngine() {
    mAliRtcEngine = AliRtcEngine.Create("");
    mLisenter = new AliEngineEventListenerImpl(mAliRtcEngine, mHWnd);
    mAliRtcEngine->SetEngineEventListener(mLisenter);
}

HarmonyOS

this.rtcSdk = AliRtcEngine.getInstance(NULL, getContext(this));
this.engineEventListener: AliRtcEngineEventListener = new AliRtcEngineEventListener();
this.engineEventListener
      .onRemoteUserOnline((uid: string, elapsed: boolean)=> {
        // Triggered when a remote user joins the channel
      })
      .onRemoteUserOffline((uid:string, reason: AliRtcUserOfflineReason)=> {
        // Triggered when a remote user leaves the channel
      })
      .onJoinChannel((result : number, channel : string, userId : string, elapsed : number)=> {
        // Triggered when you joins the channel
      })
      .onLeaveChannel((result : number, stat : AliRtcStats)=> {
        // Triggered when you leaves the channel
      })
      
      .onBye((code : AliRtcOnByeType)=> {
        // Triggered when you are kicked out of the server or the channel is closed
      })
      .onOccurError((error : number, msg : string)=> {
        // Triggered when an error occurs
      })
      
      .onConnectionStatusChange((status : number, reason : number)=> {
        // Triggered when the network connection status changes
      })
    ;

  this.rtcSdk?.setRtcEngineEventListener(this.engineEventListener);

Android

    private void initEngineBeforeJoin() {
        /* (Optional) Configure parameters before users join the channel. */
        mAliRtcEngine.setChannelProfile(AliRtcEngine.AliRTCSdkChannelProfile.AliRTCSdkInteractiveLive);
        mAliRtcEngine.setClientRole(AliRtcEngine.AliRTCSdkClientRole.AliRTCSdkInteractive);
        /* Set the audio properties. */
        mAliRtcEngine.setAudioProfile(AliRtcEngine.AliRtcAudioProfile.AliRtcEngineStereoHighQualityMode, AliRtcEngine.AliRtcAudioScenario.AliRtcSceneMusicMode);

        /* (Optional) Configure camera preview. If you do not configure camera preview, stream ingest is also performed. */
        AliRtcEngine.AliRtcVideoCanvas canvas = new AliRtcEngine.AliRtcVideoCanvas();
        canvas.view = mAliRtcEngine.createRenderSurfaceView(mContext);
        mLocalSurfaceContainer.removeAllViews();
        if (canvas.view != null) {
            mLocalSurfaceContainer.addView(canvas.view, new FrameLayout.LayoutParams(FrameLayout.LayoutParams.MATCH_PARENT, FrameLayout.LayoutParams.MATCH_PARENT));
        }
        mAliRtcEngine.setLocalViewConfig(canvas, AliRtcEngine.AliRtcVideoTrack.AliRtcVideoTrackCamera);
    }

iOS

- (void)initBeforeJoin {
    /* (Optional) Configure parameters before users join the channel. */
    [self.engine setChannelProfile:AliRtcInteractivelive];
    [self.engine setClientRole:AliRtcClientRoleInteractive];
    /* Set the audio properties. */
    [self.engine setAudioProfile:AliRtcEngineStereoHighQualityMode audio_scene:AliRtcSceneMusicMode];
    /* (Optional) Configure camera preview. If you do not configure camera preview, stream ingest is also performed. */
    AliVideoCanvas *canvas = [[AliVideoCanvas alloc] init];
    canvas.view = self.previewView;
    canvas.renderMode = AliRtcRenderModeAuto;
    [self.engine setLocalViewConfig:canvas forTrack:AliRtcVideoTrackCamera];
    return;
}

Windows

private:
void initEngineBeforeJoin() {
    /* (Optional) Configure parameters before users join the channel. */
    mAliRtcEngine->SetChannelProfile(AliEngineInteractiveLive);
    mAliRtcEngine->SetClientRole(AliEngineClientRoleInteractive);
    /* Set the audio properties. */
    mAliRtcEngine->SetAudioProfile(AliEngineBasicQualityMode, AliEngineSceneMusicMode);

    /* (Optional) Configure camera preview. If you do not configure camera preview, stream ingest is also performed. */
    AliEngineVideoCanvas canvas;
    /* The window handle. */
    canvas.view = mHWnd;
    mAliRtcEngine.setLocalViewConfig(canvas, AliEngineVideoTrackCamera);
}

HarmonyOS

initEngineBeforeJoin = (surfaceId: string) => {
 
  let encoderConfig : AliRtcVideoEncoderConfiguration = new AliRtcVideoEncoderConfiguration();
  encoderConfig.dimensions = new AliRtcVideoDimensions();
  encoderConfig.dimensions.width = 480
  encoderConfig.dimensions.height = 640
  encoderConfig.frameRate = AliRtcFrameRate.AliEngineFrameRateFps15
  this.rtcSdk?.setVideoEncoderConfiguration(encoderConfig)

  let profile : AliRtcChannelProfile = AliRtcChannelProfile.AliEngineInteractiveLive
  if (this.mainPageParams.interactive_mode == 0) {
    profile = AliRtcChannelProfile.AliEngineCommunication
  } else if (this.mainPageParams.interactive_mode == 2) {
    profile = AliRtcChannelProfile.AliEngineInteractiveWithLowLatencyLive
  }
  this.rtcSdk?.setChannelProfile(profile);
  this.rtcSdk?.setClientRole(this.mainPageParams.is_anchor ? AliRtcClientRole.AliEngineClientRoleInteractive : AliRtcClientRole.AliEngineClientRoleLive);


  this.localVideoCanvas.surfaceId = surfaceId;
  this.rtcSdk?.setLocalViewConfig(this.localVideoCanvas, this.componentController, AliRtcVideoTrack.AliEngineVideoTrackCamera);

}

Android

initEngineBeforeJoin();
mAliRtcEngine.joinChannel("Authentication information", null, null, "testUserName");

iOS

[self initBeforeJoin];
/* The channel ID and user ID are issued by the server. The app does not obtain the IDs. */
[self.engine joinChannel:@"Authentication information" channelId:nil userId:nil name:@"testUserName" onResultWithUserId:nil];

Windows

initEngineBeforeJoin();
mAliRtcEngine->joinChannel("Authentication information", null, null, "testUserName");

HarmonyOS

this.initEngineBeforeJoin();
this.rtcSdk?.joinChannel("Authentication information", null, null, "testUserName");

Android

/* TODO: Set the roles based on your business requirements. */
/* Set the streamer role. Users of this role participate in interaction. */
mAliRtcEngine.setClientRole(AliRtcEngine.AliRTCSdkClientRole.AliRTCSdkInteractive);
/* Set the viewer role. Users of this role can only watch the stream. */
mAliRtcEngine.setClientRole(AliRtcEngine.AliRTCSdkClientRole.AliRTCSdkLive);

iOS

/* TODO: Set the roles based on your business requirements. */
/* Set the streamer role. Users of this role participate in interaction. */
[self.engine setClientRole:AliRtcClientRoleInteractive];
/* Set the viewer role. Users of this role can only watch the stream. */
[self.engine setClientRole:AliRtcClientRolelive];

Windows

/* TODO: Set the roles based on your business requirements. */
/* Set the streamer role. Users of this role participate in interaction. */
mAliRtcEngine->SetClientRole(AliEngineClientRoleInteractive);
/* Set the viewer role. Users of this role can only watch the stream. */
mAliRtcEngine->SetClientRole(AliEngineClientRoleLive);

HarmonyOS

/* TODO: Set the roles based on your business requirements. */
/* Set the streamer role. Users of this role participate in interaction. */
this.rtcSdk?.setClientRole(AliRtcClientRole.AliEngineClientRoleInteractive);
/* Set the viewer role. Users of this role can only watch the stream. */
this.rtcSdk?.setClientRole(AliRtcClientRole.AliEngineClientRoleLive);

Android

mAliRtcEngine.leaveChannel();

iOS

[self.engine leaveChannel];

Windows

mAliRtcEngine->LeaveChannel();

HarmonyOS

this.rtcSdk?.leaveChannel();

Android

mAliRtcEngine.destroy();
mAliRtcEngine = null;

iOS

[AliRtcEngine destroy];

Windows

mAliRtcEngine->Destroy();
mAliRtcEngine = nullptr;

HarmonyOS

AliRtcEngine.destroyInstance();
this.rtcSdk? = null;

Android

iOS

Windows