// 视频流 func Feed(ctx *gin.Context) { var tokenId int64 // current 表示获取当前截止时间之前的视频 currentTime, err := strconv.ParseInt(ctx.Query("latest_time"), 10, 64) if err != nil || currentTime == int64(0) { currentTime = utils.GetCurrentTime() } // t...-Go服务器开发

这段代码是一个名为Feed的函数，用于处理视频流的请求。以下是对每行代码进行详细注释：

func Feed(ctx *gin.Context) {
    var tokenId int64
    currentTime, err := strconv.ParseInt(ctx.Query("latest_time"), 10, 64)
    if err != nil || currentTime == int64(0) {
        currentTime = utils.GetCurrentTime()
    }
    userId, _ := ctx.Get("UserId")
    tokenId = userId.(int64)

    feedListResponse, err := utils.GetVideoSvrClient().GetFeedList(ctx, &pb.GetFeedListRequest{
        CurrentTime: currentTime,
        TokenUserId: tokenId,
    })

    var resp = &DouyinFeedResponse{VideoList: make([]*Video, 0), NextTime: feedListResponse.NextTime}

    var userIdList = make([]int64, 0)
    var followUintList = make([]*pb.FollowUint, 0)
    var favoriteUnitList = make([]*pb.FavoriteUnit, 0)
    
	// 遍历视频列表，获取作者ID并构建相应的请求结构体
	for _, video := range feedListResponse.VideoList {
        userIdList = append(userIdList, video.AuthorId)
        followUintList = append(followUintList, &pb.FollowUint{
            SelfUserId: tokenId,
            UserIdList: video.AuthorId,
        })
        favoriteUnitList = append(favoriteUnitList, &pb.FavoriteUnit{
            UserId:  tokenId,
            VideoId: video.Id,
        })
    }
    
	// 调用远程方法获取视频作者信息（一次性）
	getUserInfoRsp, err := utils.GetUserSvrClient().GetUserInfoDict(ctx, &pb.GetUserInfoDictRequest{
        UserIdList: userIdList,
    })
    
	if err != nil {
        log.Errorf("GetUserSvrClient GetUserInfoDict err %v", err.Error())
        response.Fail(ctx, fmt.Sprintf("GetUserSvrClient GetUserInfoDict err %v", err.Error()), nil)
        return
    }
    
	isFollowedRsp, err := utils.GetRelationSvrClient().IsFollowDict(ctx, &pb.IsFollowDictReq{
        FollowUintList: followUintList,
    })
    
	if err != nil {
        log.Errorf("GetRelationSvrClient IsFollowDict err %v", err.Error())
        response.Fail(ctx, fmt.Sprintf("GetRelationSvrClient IsFollowDict err %v", err.Error()), nil)
        return
    }
    
	isFavoriteVideoRsp, err := utils.GetFavoriteSvrClient().IsFavoriteVideoDict(ctx, &pb.IsFavoriteVideoDictReq{
        FavoriteUnitList: favoriteUnitList,
    })
	log.Infof("IsFavoriteVideoDict isFavoriteVideoRsp %+v", isFavoriteVideoRsp)

	if err != nil {
        log.Errorf("GetFavoriteSvrClient IsFavoriteVideoDict err %v", err.Error())
        response.Fail(ctx, fmt.Sprintf("GetFavoriteSvrClient IsFavoriteVideoDict err %v", err.Error()), nil)
        return
    }

	for _, video := range feedListResponse.VideoList {
		videoRsp := &Video{
            Id:            video.Id,
            PlayUrl:       video.PlayUrl,
            CoverUrl:      video.CoverUrl,
            FavoriteCount: video.FavoriteCount,
            CommentCount:  video.CommentCount,
            IsFavorite:    video.IsFavorite,
            Title:         video.Title,
		}
		
		videoRsp.Author = getUserInfoRsp.UserInfoDict[video.AuthorId]
        
		var followUint = strconv.FormatInt(tokenId, 10) + "_" + strconv.FormatInt(videoRsp.Author.Id, 10)
		videoRsp.Author.IsFollow = isFollowedRsp.IsFollowDict[followUint]

        var favoriteUint = strconv.FormatInt(tokenId, 10) + "_" + strconv.FormatInt(videoRsp.Id, 10)
		videoRsp.IsFavorite = isFavoriteVideoRsp.IsFavoriteDict[favoriteUint]
		
        resp.VideoList = append(resp.VideoList, videoRsp)
	}

    response.Success(ctx, "success", resp)
}

请注意，这只是对代码的注释解释，并不包含完整的函数依赖关系和其他相关信息。如果你有进一步的问题，请继续提问。

内容由零声教学AI助手提供，问题来源于学员提问

// 视频流 func Feed(ctx *gin.Context) { var tokenId int64 // current 表示获取当前截止时间之前的视频 currentTime, err := strconv.ParseInt(ctx.Query("latest_time"), 10, 64) if err != nil || currentTime == int64(0) { currentTime = utils.GetCurrentTime() } // t...

golang云原生

diff --git a/mtk/package/kernel/wlan_driver/gen4m/mt6639_driver/os/linux/gl_kal.c b/mtk/package/kernel/wlan_driver/gen4m/mt6639_driver/os/linux/gl_kal.c 解释此命令

git 如何把更改提交到本地

执行什么命令可以输出 git diff 命令的输出片段，显示两个文件之间的差异

raco@ubuntu_2204:~/data/mtk_code/T830/T830/openwrt/build_dir/target-aarch64-openwrt-linux-musl_musl/linux-gem6xxx_evb6990_cpe_mt7992_emmc/hw_nat$ git diff hwnat_ioctl.c > temp_patch.patch raco@ubuntu_2204:~/data/mtk_code/T830/T830/openwrt/build_di...

PG主节点挂了，为什么备节点不会自动升主

git 拉取指定commit id的代码

WordPress自定义分享插件可以分享到微信朋友圈的那种我要自己写插件

如何在一个docker中运行多个程序

golang ipv6 地址转整数

Vue.prototype.zipMedia = async function(media) { const zip = new JSZip(); console.log("media.length: ", media.length); console.log("zipMedia_media: ", media); if (!media || media.length === 0) { return null; // 返回 null 表示没...

golang 布隆过滤器

golang + rdp 协议+tls，实现远程桌面服务端和客户端

git 拉取指定commit id的代码

golang为什么将method写在类外?

设置QScrollArea竖向滚动条悬浮在内容上

var modelPath: String? { switch self { case .pose_landmarker_lite: return Bundle.main.path( forResource: "pose_landmarker_lite", ofType: "task") case .pose_landmarker_full: return Bundle.main.path( forResour...

注册表怎么设置usb只能接入存储设备和打印机

// Execute executes the request // @return []SessionManagementSubscriptionData func (a SessionManagementSubscriptionDataRetrievalApiService) GetSmDataExecute(r ApiGetSmDataRequest) ([]SessionManagementSubscriptionData, http.Response, error) { ...

// 启动 ausf http2 server wg.Add(1) go func() { defer wg.Done() var h1s http.Server server.AusfH1s = &h1s errH1 := server.StarServer(common.UdmConfig.Sbi.Ausf.Ipv4Addr+":"+strconv.Itoa(common.UdmConfig.Sbi.Ausf.Port), &h1s) if errH1 != ...

用双向链表实现任意插入新的双向链表

#include #include int main() { intarr=(int)malloc(3*sizeof(int));//先分配3个整数 if(arr==NULL)return1; arr[0]=1;arr[1]=2;arr[2]=3; printf("Original array:"); for(int i=0;i

Qt 库的 QNetworkRequest 的 header(QNetworkRequest::ContentLengthHeader).toInt() 一直等于 69，可能原因？

go-zero 实现jwt 校验token 的api接口包含api文件

golang并发在哪些场景下没有增益

联系我们

// 视频流 func Feed(ctx *gin.Context) { var tokenId int64 // current 表示获取当前截止时间之前的视频 currentTime, err := strconv.ParseInt(ctx.Query("latest_time"), 10, 64) if err != nil || currentTime == int64(0) { currentTime = utils.GetCurrentTime() } // t...

相关推荐

git 拉取指定commit id的代码

WordPress自定义分享插件 可以分享到微信朋友圈的那种 我要自己写插件

如何在一个docker中运行多个程序

golang ipv6 地址转整数

Vue.prototype.zipMedia = async function(media) { const zip = new JSZip(); console.log("media.length: ", media.length); console.log("zipMedia_media: ", media); if (!media || media.length === 0) { return null; // 返回 null 表示没...

golang 布隆过滤器

golang + rdp 协议+tls，实现远程桌面服务端和客户端

git 拉取指定commit id的代码

golang为什么将method写在类外?

联系我们

登录

注册

WordPress自定义分享插件可以分享到微信朋友圈的那种我要自己写插件