基于TIM + CCL 实现点播/直播弹幕解决方案

原创

良人

修改于 2022-04-02 10:36:28

1.4K0

修改于 2022-04-02 10:36:28

文章被收录于专栏：IM、TRTC直播点播相关讨论 IM、TRTC直播点播相关讨论IM、TRTC直播点播相关讨论

说明

本demo采用TIM进行弹幕消息管理，CCL(CommentCoreLibrary)进行页面弹幕展示，采用Tcplayer进行点播播放

效果展示

Demo线上地址

Demo代码库

思维导图

相关问题点设计思路

关于TIM用户，demo用的是固定的userID，在实际使用中建议还是和业务的userID进行关联，不建议固定userID
（服务端）关于弹幕条数，demo默认一个视频最多拉200条历史弹幕，这个可以根据实际情况调整（实时弹幕不计）

let getMessageList = async (GroupId, ReqMsgSeq) => {
    const reqData = {
        GroupId,
        ReqMsgNumber: 20
    }
    if (ReqMsgSeq) { // 默认拉的是最新消息，续拉的话需要填
        reqData.ReqMsgSeq = ReqMsgSeq
    }

    // 服务端拉取消息 
    const { data } = await axios({
        method: 'post',
        url: `https://console.tim.qq.com/v4/group_open_http_svc/group_msg_get_simple?usersig=${adminSig}&identifier=administrator&sdkappid=${SDKAPPID}&contenttype=json`,
        data: reqData
    })
    if (data.ActionStatus === 'OK' && data.RspMsgList.length) { // 获取到消息进行深拷贝保存
        const len = data.RspMsgList.length;
        const msgSeqFirst = data.RspMsgList[0].MsgSeq
        const msgSeqLast = data.RspMsgList[len - 1].MsgSeq
        const isFinished = data.IsFinished
        messageList = messageList.concat(data.RspMsgList)
        if (isFinished === 1 && messageList.length < 200 && msgSeqFirst > 20) { // 当弹幕消息小于200尝试续拉（条件是当前的消息IsFinished 是正常拉完了）
            await getMessageList(GroupId, msgSeqLast)
        }
    }
    return messageList
}

3. （服务端）在1的基础上，关于用户和群组的关系，需要判断用户是否在群中，如果不在的话，可以调restapi把该用户添加到群组，这样才能发送弹幕消息(鉴于时间和精力，本demo未做相关判断)

4. 关于视频内容和弹幕消息同步，所有弹幕消息都是通过自定义消息来实现，在发消息时记录下当前播放时间，然后装弹幕时用这个播放时间就能同步弹幕消息和视频内容了。

         let sendMessage = function () {
            const inputDom = $('message')
            const text = inputDom.value
            const time = player.currentTime()
            const messageObj = { text, time }
            if (isSDKReady) {
                // 通过发送自定义消息记录当前时间使消息和视频内容同步
                let message = tim.createCustomMessage({
                    to: groupID,
                    conversationType: TIM.TYPES.CONV_GROUP,
                    payload: {
                        data: 'vodBarrageMessage', // 用于标识该消息是弹幕消息
                        description: JSON.stringify(messageObj), // 弹幕消息体
                        extension: ''
                    }
                });
                // 2. 发送消息
                let promise = tim.sendMessage(message);
                promise.then(function (imResponse) {
                    hanldeLiveMessageToBarage(text, 0x7c8f2d)
                    inputDom.value = ''
                }).catch(function (imError) {
                    // 发送失败
                    console.warn('sendMessage error:', imError);
                });
            } else {
                alert("您还未登录，请稍后再试")
            }
        }
        
                // 拼装弹幕消息
        function handleCustomMessaageToBarrage(item) {
            const barrage = {
                "mode": 1,
                "text": item.text,
                "stime": Math.floor(item.time * 1000),
                "size": 25,
                "color": 0xFFFFFF
            }
            barrageList.push(barrage)
        }

5. (前端) 关于弹幕的样式可以根据实际情况进行调整,如下面发送实时弹幕的样式是这样的

        function hanldeLiveMessageToBarage(text) {
            const barrage = {
                "mode": 1,
                "text": text,
                "stime": 0,
                "size": 25,
                "color": 0x7c8f2d
            }
            cm.send(barrage)
        }

6. TIM群类型，建议使用加群简单能存储历史消息的类型

跑通Demo

已经有TIM应用，如果没有的话可以去腾讯云控制台创建个免费体验版应用，详情参考官网文档。
因为有和后端交互，和本demo相关的服务端相关代码在cloudFunctions目录下仅供参考。
基于1，只要后台能返回需要数据或者前端用mock数据也可以

  function getDataFromCloudBase() {
            app
                .callFunction({
                    name: "getVideoBarrageInfo",
                    data: { userID, fileID },
                })
                .then((res) => {
                    const { result } = res; //云函数执行结果
                    if (result.status === 'ok') { // 返回了我们想要的结果
                        userSig = result.userSig  // 用户签名
                        groupID = result.groupID  // TIM 群
                        handleTIMInitAndLogin()
                        handleMessageArr(result.messageArr) // ["消息1", "消息2", "消息3"] 这个数据可以用mock数据
                    }
                });
        }

4. 在vscode Live Server 上直接Open With Live Server