使用MongoDB实现视频播放进度的保存与恢复(断点续播)_mongodb

一、业务场景说明

视频播放过程中通常存在以下需求：

用户播放视频过程中可能随时退出页面
再次进入视频页面时，需要从上次播放位置继续播放
播放器会 每隔一段时间（如 10 秒）自动保存播放进度
后端需要支持 高频写入 + 快速查询

二、为什么选择 mongodb 存储播放进度

原因	说明
写入频繁	每 5～10 秒保存一次进度
数据结构简单	用户 + 视频 + 秒数
不需要事务	单条数据即可
扩展性好	适合大用户量

mongodb 的 文档模型 + 高并发写入能力，非常适合播放进度这类数据。

三、mongodb 数据模型设计

1、播放进度实体类

@data
@document(collection = "user_video_play_process")
public class uservideoplayprocess {

    @id
    private string id;

    /** 用户id */
    private long userid;

    /** 视频id */
    private long videoid;

    /** 当前播放到的秒数 */
    private bigdecimal playsecond;

    /** 视频总时长（秒） */
    private bigdecimal duration;

    /** 是否播放完成：0-未完成，1-已完成 */
    private integer isfinished;

    /** 创建时间 */
    private date createtime;

    /** 更新时间 */
    private date updatetime;
}

2、索引设计

db.user_video_play_process.createindex(
  { userid: 1, videoid: 1 },
  { unique: true }
)

保证：

一个用户 + 一个视频 只有一条播放进度
查询和更新都非常快

四、获取视频播放进度（断点续播）

接口说明

用途：进入视频页面时，获取上次播放位置
返回值：秒数（用于前端 seek）

controller

@getmapping("/getplaysecond/{videoid}")
public result<bigdecimal> getplaysecond(@pathvariable long videoid) {
    long userid = authcontextholder.getuserid();
    return result.ok(
        videoplayprocessservice.getplaysecond(userid, videoid)
    );
}

service 实现

@override
public bigdecimal getplaysecond(long userid, long videoid) {

    query query = query.query(
        criteria.where("userid").is(userid)
                .and("videoid").is(videoid)
    );

    uservideoplayprocess process =
        mongotemplate.findone(query, uservideoplayprocess.class);

    return process == null ? bigdecimal.zero : process.getplaysecond();
}

五、更新视频播放进度

前端上报规则

播放过程中每 10 秒 上报一次
视频暂停 / 页面关闭 / 切换视频时强制上报
拖动进度条结束后上报

接收参数 vo

@data
public class videoplayprocessvo {

    private long videoid;

    private bigdecimal playsecond;

    private bigdecimal duration;
}

controller

@postmapping("/updateplayprocess")
public result updateplayprocess(
        @requestbody videoplayprocessvo vo) {

    long userid = authcontextholder.getuserid();
    videoplayprocessservice.updateplayprocess(userid, vo);
    return result.ok();
}

service 核心实现（upsert 思想）

@override
public void updateplayprocess(long userid, videoplayprocessvo vo) {

    query query = query.query(
        criteria.where("userid").is(userid)
                .and("videoid").is(vo.getvideoid())
    );

    boolean finished = vo.getplaysecond().compareto(
        vo.getduration().multiply(new bigdecimal("0.95"))
    ) >= 0;

    update update = new update()
            .set("playsecond", vo.getplaysecond())
            .set("duration", vo.getduration())
            .set("isfinished", finished ? 1 : 0)
            .set("updatetime", new date())
            .setoninsert("userid", userid)
            .setoninsert("videoid", vo.getvideoid())
            .setoninsert("createtime", new date());

    mongotemplate.upsert(
        query,
        update,
        uservideoplayprocess.class
    );
}

为什么用 upsert

存在即更新
不存在即插入
一条语句完成，避免并发问题
性能优于 find + save

六、前端播放流程说明（配合后端）

1. 进入视频页面
2. 调用 getplaysecond(videoid)
3. 播放器 seek 到返回的秒数
4. 播放过程中每 10 秒调用 updateplayprocess
5. 页面关闭 / 切视频时最后一次保存

七、常见问题与优化点

是否需要保存毫秒级？

❌ 不需要
✔ 秒级即可，节省存储 & 减少写入

如何降低 mongodb 写压力？

秒数变化 < 3 秒不更新
播放暂停时不上报
拖动结束才上报

是否需要按用户分集合？

❌ 不推荐
✔ 单集合 + 复合索引更稳妥

八、方案总结

使用 mongodb 存储视频播放进度，
通过 userid + videoid 唯一索引保证幂等，
利用 upsert 实现高效的断点续播功能。

该方案：

实现简单
性能稳定
易于扩展（学习进度、是否看完）

视频播放进度使用 mongodb 存储，
通过 upsert 保证高并发下的数据一致性，
实现视频的断点续播功能。

以上就是使用mongodb实现视频播放进度的保存与恢复(断点续播)的详细内容，更多关于mongodb视频播放进度保存与恢复的资料请关注代码网其它相关文章！

使用MongoDB实现视频播放进度的保存与恢复(断点续播)

2026年02月03日 • mongodb •我要评论