Android

// TRTC 精简版 SDK, 包含 TRTC 和直播播放两项功能（推荐）
dependencies {
    implementation 'com.tencent.liteav:LiteAVSDK_TRTC:latest.release'
}
?
// 全功能版 SDK, 包含 TRTC、直播、短视频、播放器等多项功能
dependencies {
    implementation 'com.tencent.liteav:LiteAVSDK_Professional:latest.release'
}
?
// 基础版 IM SDK 
dependencies {
     api 'com.tencent.imsdk:imsdk:latest.release'
}
?
// 增强版 IM SDK（推荐）
dependencies {
     api 'com.tencent.imsdk:imsdk-plus:latest.release'
}

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" />

-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);
// 设置事件监听器
mTRTCCloud.setListener(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);
    }
};
?
// 移除事件监听器
mTRTCCloud.setListener(null);
// 销毁 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);
    }
});

V2TIMManager.getInstance().createGroup(V2TIMManager.GROUP_TYPE_AVCHATROOM, groupID, groupName, new V2TIMValueCallback<String>() {
  @Override
  public void onSuccess(String s) {
      // 创建群组成功
  }
?
  @Override
  public void onError(int code, String desc) {
      // 创建群组失败
  }
});
?
// 监听群组创建通知
V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
  @Override
  public void onGroupCreated(String groupID) {
      // 群创建回调，groupID 为新创建群组的 ID
  }
});

V2TIMManager.getInstance().joinGroup(groupID, message, new V2TIMCallback() {
  @Override
  public void onSuccess() {
      // 加入群组成功
  }
?
  @Override
  public void onError(int code, String desc) {
      // 加入群组失败
  }
});
?
// 监听加入群组事件
V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
  @Override
  public void onMemberEnter(String groupID, List<V2TIMGroupMemberInfo> memberList) {
      // 有人加入群组
  }
});

private void enterRoom(String roomId, String userId) {
    TRTCCloudDef.TRTCParams params = new TRTCCloudDef.TRTCParams();
    // 以字符串房间号为例，建议和 IM 群组号保持一致
    params.strRoomId = roomId;
    params.userId = userId;
    // 从业务后台获取到的 UserSig
    params.userSig = getUserSig(userId);
    // 替换成您的 SDKAppID
    params.sdkAppId = SDKAppID;
    // 语聊互动场景进房需指定用户角色
    params.role = TRTCCloudDef.TRTCRoleAudience;
    // 以语聊互动进房场景为例
    mTRTCCloud.enterRoom(params, TRTCCloudDef.TRTC_APP_SCENE_VOICE_CHATROOM);
}
?
// 进房结果事件回调
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // result 代表加入房间所消耗的时间(毫秒)
        Log.d(TAG, "Enter room succeed");
    } else {
        // result 代表进房失败的错误码
        Log.d(TAG, "Enter room failed");
    }
}

V2TIMManager.getInstance().quitGroup(groupID, new V2TIMCallback() {
  @Override
  public void onSuccess() {
      // 退出群组成功
  }
?
  @Override
  public void onError(int code, String desc) {
      // 退出群组失败
  }
});
?
V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
  @Override
  public void onMemberLeave(String groupID, V2TIMGroupMemberInfo member) {
        // 群成员离开回调
  }
});

private void exitRoom() {
    mTRTCCloud.stopLocalAudio();
    mTRTCCloud.exitRoom();
}
?
// 离开房间事件回调
@Override
public void onExitRoom(int reason) {
    if (reason == 0) {
        Log.d(TAG, "主动调用 exitRoom 退出房间");
    } else if (reason == 1) {
        Log.d(TAG, "被服务器踢出当前房间");
    } else if (reason == 2) {
        Log.d(TAG, "当前房间整个被解散");
    }
}

V2TIMManager.getInstance().dismissGroup(groupID, new V2TIMCallback() {
  @Override
  public void onSuccess() {
      // 解散群组成功
  }
?
  @Override
  public void onError(int code, String desc) {
      // 解散群组失败
  }
});
?
V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
  @Override
  public void onGroupDismissed(String groupID, V2TIMGroupMemberInfo opUser) {
      // 群被解散回调
  }
});

public class SeatInfo implements Serializable {
    public static final transient int STATUS_UNUSED  = 0;
    public static final transient int STATUS_USED    = 1;
    public static final transient int STATUS_LOCKED  = 2;
?
    // 座位状态，对应三种状态
    public int status;
    // 座位是否禁言
    public boolean mute;
    // 座位占用时，存储用户信息
    public String userId;
?
    @Override
    public String toString() {
        return "TXSeatInfo{"
                + "status=" + status
                + ", mute=" + mute
                + ", user='" + userId + '\\''
                + '}';
    }
}

// 听众发送上麦请求，userId 为主播 ID，data 可传入标识信令的 json
private String sendInvitation(String userId, String data) {
    return V2TIMManager.getSignalingManager().invite(userId, data, true, null, 0, new V2TIMCallback() {
        @Override
        public void onError(int i, String s) {
            Log.e(TAG, "sendInvitation error " + i);
        }
?
        @Override
        public void onSuccess() {
            Log.i(TAG, "sendInvitation success ");
        }
    });
}
?
// 主播收到上麦请求, inviteID 为该条请求 ID，inviter 为请求者 ID
V2TIMManager.getSignalingManager().addSignalingListener(new V2TIMSignalingListener() {
    @Override
    public void onReceiveNewInvitation(String inviteID, String inviter,
                                       String groupId, List<String> inviteeList, String data) {
        Log.i(TAG, "received invitation: " + inviteID + " from " + inviter);
    }
});

// 同意上麦请求
private void acceptInvitation(String inviteID, String data) {
    V2TIMManager.getSignalingManager().accept(inviteID, data, new V2TIMCallback() {
        @Override
        public void onError(int i, String s) {
            Log.e(TAG, "acceptInvitation error " + i);
        }
?
        @Override
        public void onSuccess() {
            Log.i(TAG, "acceptInvitation success ");
        }
    });
}
?
// 拒绝上麦请求
private void rejectInvitation(String inviteID, String data) {
    V2TIMManager.getSignalingManager().reject(inviteID, data, new V2TIMCallback() {
        @Override
        public void onError(int i, String s) {
            Log.e(TAG, "rejectInvitation error " + i);
        }
?
        @Override
        public void onSuccess() {
            Log.i(TAG, "rejectInvitation success ");
        }
    });
}

// 本地保存的全量麦位信息列表
private List<SeatInfo> mSeatInfoList;
?
// 同意上麦请求的回调
V2TIMManager.getSignalingManager().addSignalingListener(new V2TIMSignalingListener() {
    @Override
    public void onInviteeAccepted(String inviteID, String invitee, String data) {
        Log.i(TAG, "received accept invitation: " + inviteID + " from " + invitee);
        takeSeat(seatIndex);
    }
});
?
// 听众开始上麦
private void takeSeat(int seatIndex) {
    // 创建麦位信息实例，存储修改后的麦位信息
    SeatInfo localInfo = mSeatInfoList.get(seatIndex);
    SeatInfo seatInfo = new SeatInfo();
    seatInfo.status = SeatInfo.STATUS_USED;
    seatInfo.mute = localInfo.mute;
    seatInfo.userId = mUserId;
    
    // 将麦位信息对象序列化为 JSON 格式
    Gson gson = new Gson();
    String json = gson.toJson(seatInfo, SeatInfo.class);
    HashMap<String, String> map = new HashMap<>();
    map.put("seat" + seatIndex, json);
    
    // 设置群属性，已有该群属性则更新其 value 值，没有该群属性则添加该属性
    V2TIMManager.getGroupManager().setGroupAttributes(groupId, map, new V2TIMCallback() {
        @Override
        public void onError(int code, String message) {
            // 修改群属性失败，上麦失败
        }
?
        @Override
        public void onSuccess() {
            // 修改群属性成功，切换 TRTC 角色并开始推流
            mTRTCCloud.switchRole(TRTCCloudDef.TRTCRoleAnchor);
            mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_DEFAULT);
        }
    });
}

// 本地保存的全量麦位信息列表
private List<SeatInfo> mSeatInfoList;
?
// 主播端调用该接口修改群属性保存的麦位信息
private void pickSeat(String userId, int seatIndex) {
    // 创建麦位信息实例，存储修改后的麦位信息
    SeatInfo localInfo = mSeatInfoList.get(seatIndex);
    SeatInfo seatInfo = new SeatInfo();
    seatInfo.status = SeatInfo.STATUS_USED;
    seatInfo.mute = localInfo.mute;
    seatInfo.userId = userId;
    
    // 将麦位信息对象序列化为 JSON 格式
    Gson gson = new Gson();
    String json = gson.toJson(seatInfo, SeatInfo.class);
    HashMap<String, String> map = new HashMap<>();
    map.put("seat" + seatIndex, json);
    
    // 设置群属性，已有该群属性则更新其 value 值，没有该群属性则添加该属性
    V2TIMManager.getGroupManager().setGroupAttributes(groupId, map, new V2TIMCallback() {
        @Override
        public void onError(int code, String message) {
            // 修改群属性失败，抱麦失败
        }
?
        @Override
        public void onSuccess() {
            // 修改群属性成功，触发 onGroupAttributeChanged 回调
        }
    });
}
?
// 听众端收到群属性变更回调，匹配自身信息成功后开始推流
V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
    @Override
    public void onGroupAttributeChanged(String groupID, Map<String, String> groupAttributeMap) {
        // 上一次本地保存的全量麦位信息列表
        final List<SeatInfo> oldSeatInfoList = mSeatInfoList;
        // 最新从 groupAttributeMap 中解析的全量麦位信息列表
        final List<SeatInfo> newSeatInfoList = getSeatListFromAttr(groupAttributeMap, seatSize);
        // 遍历全量麦位信息列表，对比新旧麦位信息
        for (int i = 0; i < seatSize; i++) {
            SeatInfo oldInfo = oldSeatInfoList.get(i);
            SeatInfo newInfo = newSeatInfoList.get(i);
            if (oldInfo.status != newInfo.status && newInfo.status == SeatInfo.STATUS_USED) {
                if (newInfo.userId.equals(mUserId)) {
                    // 匹配自身信息成功，切换 TRTC 角色并开始推流
                    mTRTCCloud.switchRole(TRTCCloudDef.TRTCRoleAnchor);
                    mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_DEFAULT);
                } else {
                    // 更新本地麦位列表，渲染本地麦位视图
                }
            }
        }
    }
});