tencent cloud

dependencies {
    // TRTC 精简版 SDK, 包含 TRTC 和直播播放两项功能
    implementation 'com.tencent.liteav:LiteAVSDK_TRTC:latest.release'
    
    // 添加 IM SDK，推荐填写最新的版本号
    implementation 'com.tencent.imsdk:imsdk-plus:Version number'

    // 如果您需要添加 Quic 插件，请取消下一行的注释（注意：要求插件版本号和 IM SDK 版本号相同）
    // implementation 'com.tencent.imsdk:timquic-plugin:Version number'
}

defaultConfig {
     ndk {
             abiFilters "armeabi-v7a", "arm64-v8a"
     }
}

<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
<uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />
<uses-permission android:name="android.permission.RECORD_AUDIO" />
<uses-permission android:name="android.permission.MODIFY_AUDIO_SETTINGS" />
<uses-permission android:name="android.permission.BLUETOOTH" />
<uses-permission android:name="android.permission.CAMERA" />
<uses-feature android:name="android.hardware.camera.autofocus" />

-keep class com.tencent.** { *; }

// 添加事件监听器
V2TIMManager.getInstance().addIMSDKListener(imSdkListener);
// 初始化 IM SDK，调用这个接口后，可以立即调用登录接口
V2TIMManager.getInstance().initSDK(context, sdkAppID, null);

// SDK 初始化后会抛出一些事件，例如连接状态、登录票据过期等
private V2TIMSDKListener imSdkListener = new V2TIMSDKListener() {
    @Override
    public void onConnecting() {
        Log.d(TAG, "IM SDK 正在连接到腾讯云服务器");
    }

    @Override
    public void onConnectSuccess() {
        Log.d(TAG, "IM SDK 已经成功连接到腾讯云服务器");
    }
};

// 移除事件监听器
V2TIMManager.getInstance().removeIMSDKListener(imSdkListener);
// 反初始化 IM SDK
V2TIMManager.getInstance().unInitSDK();

// 创建 TRTC SDK 实例（单例模式）
TRTCCloud mTRTCCloud = TRTCCloud.sharedInstance(context);
// 添加 TRTC 事件监听器
mTRTCCloud.addListener(trtcSdkListener);

// 来自 SDK 的各类事件通知（比如：错误码，警告码，音视频状态参数等）
private TRTCCloudListener trtcSdkListener = new TRTCCloudListener() {
    @Override
    public void onError(int errCode, String errMsg, Bundle extraInfo) {
        Log.d(TAG, errCode + errMsg);
    }
    
    @Override
    public void onWarning(int warningCode, String warningMsg, Bundle extraInfo) {
        Log.d(TAG, warningCode + warningMsg);
    }
};

// 移除 TRTC 事件监听器
mTRTCCloud.removeListener(trtcSdkListener);
// 销毁 TRTC SDK 实例（单例模式）
TRTCCloud.destroySharedInstance();

// 登录：userID 可自定义，userSig 参考步骤一生成获取
V2TIMManager.getInstance().login(userID, userSig, new V2TIMCallback() {
    @Override
    public void onSuccess() {
        Log.i("imsdk", "success");
    }
    
    @Override
    public void onError(int code, String desc) {
        // 如果返回以下错误码，表示使用 UserSig 已过期，请您使用新签发的 UserSig 进行再次登录。
        // 1. ERR_USER_SIG_EXPIRED（6206）
        // 2. ERR_SVR_ACCOUNT_USERSIG_EXPIRED（70001）
        // 注意：其他的错误码，请不要在这里调用登录接口，避免 IM SDK 登录进入死循环。
        Log.i("imsdk", "failure, code:" + code + ", desc:" + desc);
    }
});

// 登出
V2TIMManager.getInstance().logout(new V2TIMCallback() {
    @Override
    public void onSuccess() {
        Log.i("imsdk", "success");
    }
    
    @Override
    public void onError(int code, String desc) {
        Log.i("imsdk", "failure, code:" + code + ", desc:" + desc);
    }
});

// 设置视频编码参数，决定远端用户看到的画面质量
TRTCCloudDef.TRTCVideoEncParam encParam = new TRTCCloudDef.TRTCVideoEncParam();
encParam.videoResolution = TRTCCloudDef.TRTC_VIDEO_RESOLUTION_960_540;
encParam.videoFps = 15;
encParam.videoBitrate = 850;
encParam.videoResolutionMode = TRTCCloudDef.TRTC_VIDEO_RESOLUTION_MODE_PORTRAIT;
mTRTCCloud.setVideoEncoderParam(encParam);

// 开启本地摄像头预览(可指定使用前置/后置摄像头进行视频采集)
mTRTCCloud.startLocalPreview(isFrontCamera, previewView);

// 构造自定义数据
JSONObject jsonObject = new JSONObject();
try {
    jsonObject.put("cmd", "av_call");
    JSONObject msgJsonObject = new JSONObject();
    msgJsonObject.put("callType", "videoCall");     // 指定通话类型(视频通话、语音通话)
    msgJsonObject.put("roomId", generateRoomId());  // 指定 TRTC 房间号(主叫端可随机生成)
    jsonObject.put("msg", msgJsonObject);
} catch (JSONException e) {
    e.printStackTrace();
}
String data = jsonObject.toString();

// 发送呼叫邀请信令
V2TIMManager.getSignalingManager().invite(receiver, data, false, v2TIMOfflinePushInfo, timeout, new V2TIMCallback() {
    @Override
    public void onError(int code, String desc) {
        // 发送呼叫邀请信令失败
        // 提示呼叫失败，可以尝试重试
    }

    @Override
    public void onSuccess() {
        // 发送呼叫邀请信令成功
        // 渲染呼叫页面，播放呼叫铃声
    }
});

// 被叫用户收到呼叫请求, inviteID 为该条请求 ID，inviter 为主叫用户 ID
V2TIMManager.getSignalingManager().addSignalingListener(new V2TIMSignalingListener() {
    @Override
    public void onReceiveNewInvitation(String inviteID, String inviter,
                                       String groupId, List<String> inviteeList, String data) {
        if (!data.isEmpty()) {
            try {
                JSONObject jsonObject = new JSONObject(data);
                String command = jsonObject.getString("cmd");
                JSONObject messageJsonObject = jsonObject.getJSONObject("msg");
                if (command.equals("av_call")) {
                    String callType = messageJsonObject.getString("callType");
                    String roomId = messageJsonObject.getString("roomId");
                    
                    // 渲染呼叫页面，播放呼叫铃声
                }
            } catch (JSONException e) {
                e.printStackTrace();
            }
        }
    }
});

if (callType.equals("videoCall")) {
    // 设置视频编码参数，决定远端用户看到的画面质量
    TRTCCloudDef.TRTCVideoEncParam encParam = new TRTCCloudDef.TRTCVideoEncParam();
    encParam.videoResolution = TRTCCloudDef.TRTC_VIDEO_RESOLUTION_960_540;
    encParam.videoFps = 15;
    encParam.videoBitrate = 850;
    encParam.videoResolutionMode = TRTCCloudDef.TRTC_VIDEO_RESOLUTION_MODE_PORTRAIT;
    mTRTCCloud.setVideoEncoderParam(encParam);

    // 开启本地摄像头预览(可指定使用前置/后置摄像头进行视频采集)
    mTRTCCloud.startLocalPreview(isFrontCamera, previewView);
}

V2TIMManager.getSignalingManager().cancel(inviteId, data, new V2TIMCallback() {
    @Override
    public void onError(int code, String desc) {
        // 取消呼叫请求失败
        // 提示取消失败，可以尝试重试
    }

    @Override
    public void onSuccess() {
        // 取消呼叫请求成功
        // 销毁呼叫页面，停止播放呼叫铃声
    }
});

@Override
public void onInvitationCancelled(String inviteID, String inviter, String data) {
    // 销毁呼叫页面，停止播放呼叫铃声
}

@Override
public void onInvitationTimeout(String inviteID, List<String> inviteeList) {
	// 提示呼叫超时，销毁呼叫页面，停止播放呼叫铃声
}

V2TIMManager.getSignalingManager().accept(inviteId, data, new V2TIMCallback() {
    @Override
    public void onError(int code, String desc) {
        // 接听失败，提示异常或重试
    }

    @Override
    public void onSuccess() {
        // 接听成功，渲染通话页面，停止播放呼叫铃声
        if (callType.equals("videoCall")) {
            // 开始视频通话
            startVideoCall();
        } else {
            // 开始语音通话
            startAudioCall();
        }
    }
});

@Override
public void onInviteeAccepted(String inviteID, String invitee, String data) {
    if (callType.equals("videoCall")) {
        // 开始视频通话
        startVideoCall();
    } else {
        // 开始语音通话
        startAudioCall();
    }
}

private void startAudioCall() {
    TRTCCloudDef.TRTCParams params = new TRTCCloudDef.TRTCParams();
    params.sdkAppId = SDKAPPID;    // TRTC应用标识, 在控制台获取
    params.userSig = USERSIG;      // TRTC鉴权凭证, 在服务端生成
    params.strRoomId = roomId;     // 房间号, 以字符串房间号为例
    params.userId = userId;        // 用户名, 建议和IM保持同步
    
    mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_SPEECH);
    mTRTCCloud.enterRoom(params, TRTCCloudDef.TRTC_APP_SCENE_AUDIOCALL);
}

// 标记是否正在通话中
boolean isOnCalling = false;

// 进房结果事件回调
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // 进房成功，标识正在通话中
        isOnCalling = true;
    } else {
        // 进房失败，提示通话异常
        isOnCalling = false;
    }
}

private void startVideoCall() {
    TRTCCloudDef.TRTCParams params = new TRTCCloudDef.TRTCParams();
    params.sdkAppId = SDKAPPID;    // TRTC应用标识, 在控制台获取
    params.userSig = USERSIG;      // TRTC鉴权凭证, 在服务端生成
    params.strRoomId = roomId;     // 房间号, 以字符串房间号为例
    params.userId = userId;        // 用户名, 建议和IM保持同步
    
    mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_SPEECH);
    mTRTCCloud.enterRoom(params, TRTCCloudDef.TRTC_APP_SCENE_VIDEOCALL);
}

// 标记是否正在通话中
boolean isOnCalling = false;

// 进房结果事件回调
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // 进房成功，标识正在通话中
        isOnCalling = true;
    } else {
        // 进房失败，提示通话异常
        isOnCalling = false;
    }
}

// 拉取远端视频流
@Override
public void onUserVideoAvailable(String userId, boolean available) {
    // 远端用户发布/取消了主路视频画面
    if (available) {
        // 订阅远端用户的视频流，并绑定视频渲染控件
        mTRTCCloud.startRemoteView(userId, TRTCCloudDef.TRTC_VIDEO_STREAM_TYPE_BIG, view);
    } else {
        // 停止订阅远端用户的视频流，并释放渲染控件
        mTRTCCloud.stopRemoteView(userId, TRTCCloudDef.TRTC_VIDEO_STREAM_TYPE_BIG);
    }
}

private void rejectInvite(String inviteId, String data, final V2TIMCallback callback) {
    V2TIMManager.getSignalingManager().reject(inviteId, data, new V2TIMCallback() {
        @Override
        public void onError(int code, String desc) {
            if (callback != null) {
                callback.onError(code, desc);
            }
        }

        @Override
        public void onSuccess() {
            if (callback != null) {
                callback.onSuccess();
            }
        }
    });
}

JSONObject jsonObject = new JSONObject();
try {
    jsonObject.put("cmd", "av_call");
    JSONObject msgJsonObject = new JSONObject();
    msgJsonObject.put("callType", "videoCall");    // 指定通话类型(视频通话、语音通话)
    msgJsonObject.put("reason", "active");         // 指定拒接类型(主动拒接、忙线拒接)
    jsonObject.put("msg", msgJsonObject);
} catch (JSONException e) {
    e.printStackTrace();
}

rejectInvite(inviteId, jsonObject.toString(), new V2TIMCallback() {
    @Override
    public void onError(int code, String desc) {
        // 拒接失败，提示异常或重试
    }

    @Override
    public void onSuccess() {
        // 拒接成功，销毁呼叫页面，停止播放呼叫铃声
    }
});

@Override
public void onInviteeRejected(String inviteID, String invitee, String data) {
    if (!data.isEmpty()) {
        try {
            JSONObject jsonObject = new JSONObject(data);
            String command = jsonObject.getString("cmd");
            JSONObject messageJsonObject = jsonObject.getJSONObject("msg");
            if (command.equals("av_call")) {
                String reason = messageJsonObject.getString("reason");
                if (reason.equals("active")) {
                    // 提示对方拒绝接听
                } else if (reason.equals("busy")) {
                    // 提示对方忙线中
                }
                
                // 销毁呼叫页面，停止播放呼叫铃声
            }
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }
}

@Override
public void onReceiveNewInvitation(String inviteID, String inviter,
                                   String groupId, List<String> inviteeList, String data) {
    if (!data.isEmpty()) {
        try {
            JSONObject jsonObject = new JSONObject(data);
            String command = jsonObject.getString("cmd");
            JSONObject messageJsonObject = jsonObject.getJSONObject("msg");
            if (command.equals("av_call") && isOnCalling) {
                JSONObject jsonObject = new JSONObject();
                try {
                    jsonObject.put("cmd", "av_call");
                    JSONObject msgJsonObject = new JSONObject();
                    msgJsonObject.put("callType", "videoCall");    // 指定通话类型(视频通话、语音通话)
                    msgJsonObject.put("reason", "busy");           // 指定拒接类型(主动拒接、忙线拒接)
                    jsonObject.put("msg", msgJsonObject);
                } catch (JSONException e) {
                    e.printStackTrace();
                }
                // 本地正在通话中，发送忙线拒接信令
                rejectInvite(inviteId, jsonObject.toString(), new V2TIMCallback() {
                    @Override
                    public void onError(int code, String desc) {
                        // 忙线拒接失败
                    }
                
                    @Override
                    public void onSuccess() {
                        // 忙线拒接成功
                    }
                });
            }
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }
}