短视频网站开发中的异步任务与实时互动设计
核心关键词：短视频网站开发、消息队列、WebSocket
短视频网站开发的工程难点不在于页面开发，而在于异步任务的处理与实时互动的支撑。视频从上传到可播放，中间涉及合并、转码、截图、审核等多个耗时步骤，这些步骤若同步执行，用户将面临不可接受的长等待。
消息队列是异步任务的核心基础设施。RabbitMQ与Kafka是两种主流选择。RabbitMQ适合任务分发场景（转码任务、通知推送），其消息确认机制与死信队列可以保证任务不丢失；Kafka适合事件流场景（用户行为日志、播放统计），其高吞吐与分区特性支持大规模数据管道。实践中，转码任务通常使用RabbitMQ，用户行为事件使用Kafka。
转码Worker的稳定性直接影响视频上线的时效性。Worker进程需要具备：失败重试机制（FFmpeg进程崩溃时自动重启）、进度上报（便于运营后台监控）、以及资源隔离（多个转码任务不应争抢CPU导致整体延迟）。使用Docker容器化Worker，配合Kubernetes的Job或Deployment进行调度，是现代短视频网站开发的推荐实践。
实时互动功能（点赞通知、评论提醒、新粉丝提醒）依赖WebSocket长连接。架构上，WebSocket服务独立于HTTP API服务部署，通过Redis Pub/Sub实现多实例间的消息广播。用户连接时进行JWT鉴权，鉴权通过后加入对应的用户频道。当互动发生时，后端发布消息到Redis频道，所有WebSocket实例订阅该频道并将消息推送给对应连接的用户。
一个容易被忽视的性能瓶颈是“写扩散”问题。当一个大V用户发布视频时，需要向所有粉丝推送通知。若粉丝数达百万级，同步写入所有粉丝的通知队列将造成数据库压力激增。解决方案是采用“拉模式”或混合模式：普通用户的通知走写扩散，大V用户的通知走拉模式（粉丝主动拉取），或仅推送至在线粉丝，离线粉丝登录后聚合拉取。
