前言：

近年来，直播兴起，各家直播平台的火爆，支持演唱会的直播、主播、明星直播和带货直播等等等，TRTC提供了简便快捷完整的直播互动解决方案，这次我们来一起学习如何在android端使用TRTC完成互动直播的基本流程

实现步骤

第一步：集成SDK

音视频通话组件 TRTCCalling 依赖 TRTC SDK 和 IM SDK，可以参考官方提供的集成指引，完成集成 TRTC集成文档 和 IM集成文档

DEMO主要文件

第二步：配置对应权限和混淆规则

<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.WRITE_EXTERNAL_STORAGE" />
<uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE" />
<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-permission android:name="android.permission.READ_PHONE_STATE" />
<uses-feature android:name="android.hardware.camera"/>
<uses-feature android:name="android.hardware.camera.autofocus" />

在 proguard-rules.pro 文件，将 SDK 相关类加入不混淆名单：

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

第三步：在GenerateTestUserSig.java中配置SDKID和SECRETKEY

SDKAPPID：在音视频控制台中对应创建的应用的ID

SECRETKEY：音视频控制台对应的计算密钥，点击查看密钥获得

第四步：初始化SDK和登录

1:调用TrtcLiveRoom初始化

TRTCLiveRoom.sharedInstance(this); 

2:初始化IM

V2TIMManager.getInstance().login(userId, userSig,callback) 

3:LiveRoom组件登录

和以往音频和视频通话不同的是新增TRTCLiveRoomConfig参数,属性如下：

全局配置信息，在登录时初始化，登录之后不可变更。

• useCDNFirst 属性：用于设置观众观看方式。true 表示普通观众通过 CDN 观看，计费便宜但延时较高。false 表示普通观众通过低延时观看，计费价格介于 CDN 和连麦之间，但延迟可控制在1s以内。
• CDNPlayDomain 属性：在 useCDNFirst 设置为 true 时才会生效，用于指定 CDN 观看的播放域名，您可以登录直播控制台 >【域名管理】页面中进行设置。

TRTCLiveRoom mLiveRoom = TRTCLiveRoom.sharedInstance(this);
//useCDNFirst：true 表示普通观众通过 CDN 观看，false 表示普通观众通过低延时观看
//yourCDNPlayDomain：表示 CDN 观看时配置的播放域名
TRTCLiveRoomDef.TRTCLiveRoomConfig config = 
 new TRTCLiveRoomDef.TRTCLiveRoomConfig(useCDNFirst, yourCDNPlayDomain);
mLiveRoom.login(SDKAPPID, userId, userSig, config, 
 new TRTCLiveRoomCallback.ActionCallback() {
         @Override
         public void onCallback(int code, String msg) {
             if (code == 0) {
                 //登录成功
             }
         }
});

第五步：房间列表

进入直播房间选择列表首先申请动态权限

if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) {
    PermissionUtils.permission(PermissionConstants.STORAGE, PermissionConstants.MICROPHONE, PermissionConstants.CAMERA)
            .request();
}

通过RoomManager获取房间列表

RoomManager.getInstance().getRoomList(TCConstants.TYPE_LIVE_ROOM, new RoomManager.GetRoomListCallback() {
    @Override
    public void onSuccess(final List<String> roomIdList) {
        //绑定获取到的房间到页面上
    ｝
    @Override
    public void onFailed(int code, String msg) {
        //失败处理
    ｝
｝

绑定房间点击事件,判断房间是不是当前登录角色的USERID，如果是就创建房间，如果不是就以观众身份进入房间

RoomInfo info = mRoomInfoList.get(position);
if (info.anchorId.equals(mSelfUserId)) {
    createRoom();
} else {
    enterRoom(info);
}

第六步：主播创建房间和推流

登录成功后用户可以通过setProfile设置自身的昵称和头像

mTRTCLiveRoom.setSelfProfile(userName,avatarURL,callback) 
//用户名  用户头像图片URL地址  是否设置成功回调 

调用摄像头预览，设置美颜参数

//摄像头预览 
mLiveRoom.startCameraPreview(true, mTXCloudVideoView, null); 
//美颜参数设置 
mPanelBeautyControl.setBeautyManager(mLiveRoom.getBeautyManager()); 
//自定义控件初始化传入SDK的BeautyManager，封装了美颜的各个设置 

开启直播

设置好美颜后便可以开启直播

TRTCLiveRoomDef.TRTCCreateRoomParam param = new TRTCLiveRoomDef.TRTCCreateRoomParam();
param.roomName = "测试房间";
mLiveRoom.createRoom(123456789, param, new TRTCLiveRoomCallback.ActionCallback() {
    @Override
    public void onCallback(int code, String msg) {
        if (code == 0) {
            mLiveRoom.startPublish(mSelfUserId + "_stream", null);
        }
    }
});

下图是主播开播推流的流程图

第七步：观众观看流程

观众观看流程图

1. 登录成功后用户可以通过setProfile设置自身的昵称和头像

mTRTCLiveRoom.setSelfProfile(userName,avatarURL,callback) 
//用户名  用户头像图片URL地址  是否设置成功回调 

1. 获取房间列表

RoomManager.getInstance().getRoomList(TCConstants.TYPE_LIVE_ROOM,callBack) 

1. 选择其中一个房间调用enterRoom传入该房间的房间号进入房间
2. 调用startPlay并传入主播的 userId 开始播放。

• 若直播间列表已包含主播端的 userId 信息，观众端可直接调用startPlay并传入主播的 userId 即可开始播放。
• 若在进房前暂未获取主播的 userId，观众端在进房后会收到主播onAnchorEnter的事件回调，该回调中携带主播的 userId 信息，调用startPlay即可播放。

mLiveRoom.setDelegate(new TRTCLiveRoomDelegate() {     
    @Override     
    public void onAnchorEnter(final String userId) {           
        mLiveRoom.startPlay(userId, mTXCloudVideoView, null);     
    } 
}); 

第八步：弹幕交流和自定义信令

SDK提供了两个消息相关接口

1. liveRoom.sendRoomTextMsg()

// 发送端：发送文本消息
mLiveRoom.sendRoomTextMsg("Hello Word!", null);
// 接收端：监听文本消息
mLiveRoom.setDelegate(new TRTCLiveRoomDelegate() {
  @Override
  public void onRecvRoomTextMsg(String roomId, 
          String message, TRTCLiveRoomDef.TRTCLiveUserInfo userInfo) {
      Log.d(TAG, "收到来自" + userInfo.userName + "的消息:" + message);
  }
});

1. liveRoom.sendRoomCustomMsg()

// 发送端：您可以通过自定义 Cmd 来区分弹幕和点赞消息
// eg:"CMD_DANMU"表示弹幕消息，"CMD_LIKE"表示点赞消息
mLiveRoom.sendRoomCustomMsg("CMD_DANMU", "Hello world", null);
mLiveRoom.sendRoomCustomMsg("CMD_LIKE", "", null);
// 接收端：监听自定义消息
mLiveRoom.setDelegate(new TRTCLiveRoomDelegate() {
  @Override
  public void onRecvRoomCustomMsg(String roomId, String cmd, 
          String message, TRTCLiveRoomDef.TRTCLiveUserInfo userInfo) {
      if ("CMD_DANMU".equals(cmd)) {
          // 收到弹幕消息
          Log.d(TAG, "收到来自" + userInfo.userName + "的弹幕消息:" + message);
      } else if ("CMD_LIKE".equals(cmd)) {
          // 收到点赞消息
          Log.d(TAG, userInfo.userName + "给您点了个赞！");
      }
  }
});

第九步：连麦和PK

流程示意图

连麦和PK的流程大体相似，除了部分方法不同

连麦流程

1. 观众端调用requestJoinAnchor向主播端发起连麦请求。
2. 主播端会收到 TRTCLiveRoomDelegate#onRequestJoinAnchor（即有观众请求与您连麦）的事件通知。
3. 主播端可以通过调用responseJoinAnchor决定是否接受来自观众端的连麦请求。
4. 观众端会收到TRTCLiveRoomDelegate#responseCallback事件通知，该通知会携带来自主播端的处理结果。
5. 如果主播同意连麦请求，观众端可调用startCameraPreview开启本地摄像头，随后调用startPublish启动观众端的推流。
6. 主播端会在观众端启动通知后收到 TRTCLiveRoomDelegate#onAnchorEnter （即另一路音视频流已到来）通知，该通知会携带观众端的 userId。
7. 主播端调用startPlay即可看到连麦观众的画面。

// 1.观众端发起连麦请求
mLiveRoom.requestJoinAnchor(mSelfUserId + "请求和您连麦", 
    new TRTCLiveRoomCallback.ActionCallback() {
    @Override
    public void onCallback(int code, String msg) {
        if (code == 0) {
            // 4.主播接受了观众的请求
            TXCloudVideoView view = new TXCloudVideoView(context);
            parentView.add(view);
            // 5.观众启动预览，开启推流
            mLiveRoom.startCameraPreview(true, view, null);
            mLiveRoom.startPublish(mSelfUserId + "_stream", null);
        }
    }
});

// 2.主播端收到连麦请求
mLiveRoom.setDelegate(new TRTCLiveRoomDelegate() {
    @Override
    public void onRequestJoinAnchor(final TRTCLiveRoomDef.TRTCLiveUserInfo userInfo, 
            String reason, final int timeout) {
        // 3.同意对方的连麦请求
        mLiveRoom.responseJoinAnchor(userInfo.userId, true, "同意连麦");
    }

    @Override
    public void onAnchorEnter(final String userId) {
        // 6.主播收到连麦观众的上麦通知
        TXCloudVideoView view = new TXCloudVideoView(context);
        parentView.add(view);
        // 7.主播播放观众画面
        mLiveRoom.startPlay(userId, view, null);
    }
});

PK流程

1. 主播 A 调用requestRoomPK向主播 B 发起 PK 请求。
2. 主播 B 会收到TRTCLiveRoomDelegate onRequestRoomPK回调通知。
3. 主播 B 调用responseRoomPK决定是否接受主播 A 的 PK 请求。
4. 主播 B 接受主播 A 的要求，等待TRTCLiveRoomDelegate onAnchorEnter通知，调用startPlay显示主播 A。
5. 主播 A 收到responseCallback回调通知，PK 请求是否被同意。
6. 主播 A 请求被同意，等待TRTCLiveRoomDelegate onAnchorEnter通知，调用startPlay显示主播 B。

// 主播 A 创建12345的房间
mLiveRoom.createRoom(12345, param, null);

mLiveRoom.setDelegate(new TRTCLiveRoomDelegate() {
    @Override
    public void onAnchorEnter(final String userId) {
        // 6.收到 B 进房的通知
        mLiveRoom.startPlay(userId, mTXCloudVideoView, null);
    }
});

// 1.主播 A 向主播 B 发起 PK 请求
mLiveRoom.requestRoomPK(54321, "B", 
    new TRTCLiveRoomCallback.ActionCallback() {
    @Override
    public void onCallback(int code, String msg) {  
        // 5.收到是否同意的回调
        if (code == 0) {
            // 用户接受
        } else {
            // 用户拒绝
        }
    }
});

// 主播 B：
// 主播 B 创建54321的房间
mLiveRoom.createRoom(54321, param, null);

// 2.主播 B 收到主播 A 的消息
mLiveRoom.setDelegate(new TRTCLiveRoomDelegate() {
    @Override
    public void onRequestRoomPK(
       final TRTCLiveRoomDef.TRTCLiveUserInfo userInfo, final int timeout) {
        // 3.主播 B 回复主播 A 接受请求
        mLiveRoom.responseRoomPK(userInfo.userId, true, "");
    }
    @Override
    public void onAnchorEnter(final String userId) {
        // 4.主播 B 收到主播 A 进房的通知，播放主播 A 的画面
        mLiveRoom.startPlay(userId, mTXCloudVideoView, null);
    }
});