直播带货全链路技术方案：从零搭建高并发实时互动系统

一、系统架构设计

直播带货系统核心由四个模块构成：推流端、流媒体服务器、业务服务器和播放端。推流端负责采集主播的音视频流并编码推送到服务器；流媒体服务器负责接收、转码、分发直播流；业务服务器处理商品信息、弹幕、点赞、订单等业务逻辑；播放端则拉取流进行播放并展示互动信息。

1.1 技术选型与资源准备

你需要准备以下资源：

• 服务器：至少2台云服务器（建议4核8G以上配置），一台部署流媒体服务，一台部署业务服务。推荐使用阿里云ECS或腾讯云CVM。
• 域名与备案：一个已备案的域名，用于HTTPS访问。
• 推流与播放工具：OBS Studio（推流端）、VLC media player（测试播放）。

核心软件采用开源方案：

• 流媒体服务器：SRS（Simple RTMP Server），性能稳定，配置简单。
• 业务服务器：Node.js + Socket.IO，用于处理实时弹幕和信令。
• 前端播放：video.js 配合 videojs-contrib-hls 插件，支持HLS协议。

二、流媒体服务部署与配置

这是保证直播流畅不卡顿的基础。

2.1 安装与启动SRS

登录你的流媒体服务器（假设系统为CentOS 7），执行以下命令：

``` 1. 安装依赖 yum install -y git gcc gcc-c++ make 2. 克隆SRS源码 cd /home && git clone https://gitee.com/ossrs/srs.git 3. 切换到稳定分支并编译 cd srs/trunk && git checkout 4.0release ./configure && make 4. 启动SRS（使用默认配置） ./objs/srs -c conf/srs.conf ```

执行后，如果看到“[2023-...] [trace] start success”类似日志，说明服务已启动。默认监听1935（RTMP）、8080（HTTP API）端口。

2.2 配置SRS支持HLS与HTTPS

默认配置不支持HLS（用于网页播放）和HTTPS。创建并编辑配置文件 /home/srs/trunk/conf/live.conf：

``` listen 1935; max_connections 1000; daemon on; srs_log_tank file; srs_log_file /home/srs/trunk/objs/srs.log; http_server { enabled on; listen 8080; dir ./objs/nginx/html; } http_api { enabled on; listen 1985; } vhost __defaultVhost__ { hls { enabled on; hls_path ./objs/nginx/html/hls; HLS切片文件存储路径 hls_fragment 3; 每个TS切片时长（秒） hls_window 60; HLS播放列表时长（秒） } } ```

使用此配置重启SRS：./objs/srs -c conf/live.conf

配置HTTPS（必须，否则微信等环境无法播放）：

``` 在http_server配置块内添加 https { enabled on; listen 8088; ssl_certificate /path/to/your/domain.crt; 你的SSL证书路径 ssl_certificate_key /path/to/your/domain.key; 你的SSL私钥路径 } ```

配置后需将推流和播放地址的端口改为8088，协议改为https。

2.3 推流测试

在安装了OBS的主播电脑上，进行推流设置：

• 进入OBS设置 -> “推流”选项卡。
• 服务：选择“自定义”。
• 服务器：填写 rtmp://你的服务器IP:1935/live （如果配置了HTTPS并希望使用RTMPS，则填 rtmps://你的域名:1935/live，但需SRS支持并开放相应端口）。
• 串流密钥：填写一个唯一的流ID，例如 test_stream_123。

点击“确定”后，在OBS主界面点击“开始推流”。在服务器上查看日志 tail -f /home/srs/trunk/objs/srs.log，应能看到客户端连接和流发布日志。

三、业务服务器与实时互动实现

此部分处理商品推送、弹幕、点赞等业务逻辑。

3.1 搭建Node.js服务

在你的业务服务器上操作：

``` 1. 安装Node.js（以v16.x为例） curl -fsSL https://rpm.nodesource.com/setup_16.x | bash - yum install -y nodejs 2. 创建项目目录并初始化 mkdir -p /home/live-commerce && cd /home/live-commerce npm init -y npm install express socket.io 3. 创建主文件 app.js ```

编辑 /home/live-commerce/app.js 文件：

``` const express = require('express'); const http = require('http'); const socketIo = require('socket.io'); const app = express(); const server = http.createServer(app); const io = socketIo(server, { cors: { origin: "", // 生产环境应替换为你的前端域名 methods: ["GET", "POST"] } }); // 存储在线房间和用户 let liveRooms = {}; io.on('connection', (socket) => { console.log('新用户连接:', socket.id); // 加入直播间 socket.on('join_room', (roomId, userInfo) => { socket.join(roomId); if (!liveRooms[roomId]) { liveRooms[roomId] = { users: [], goodsList: [] }; } liveRooms[roomId].users.push({ socketId: socket.id, ...userInfo }); // 通知房间内其他人有新用户加入 socket.to(roomId).emit('user_joined', userInfo); // 给刚加入的用户发送当前房间的商品列表 socket.emit('current_goods', liveRooms[roomId].goodsList); }); // 接收弹幕 socket.on('send_comment', (roomId, commentData) => { // 广播给房间内除发送者外的所有人 socket.to(roomId).emit('new_comment', commentData); }); // 主播端：推送商品 socket.on('push_goods', (roomId, goodsItem) => { if (!liveRooms[roomId]) return; liveRooms[roomId].goodsList.push(goodsItem); // 广播给房间内所有人 io.to(roomId).emit('new_goods', goodsItem); }); // 处理断开连接 socket.on('disconnect', () => { for (let roomId in liveRooms) { liveRooms[roomId].users = liveRooms[roomId].users.filter(user => user.socketId !== socket.id); } console.log('用户断开:', socket.id); }); }); const PORT = process.env.PORT || 3000; server.listen(PORT, () => { console.log(`业务服务器运行在端口 ${PORT}`); }); ```

启动服务：node app.js。服务将在3000端口运行。

3.2 前端播放与互动页面集成

创建一个简单的HTML页面 index.html，部署在Nginx或你的业务服务器静态目录下。

```

直播间

```

将代码中的“你的域名”和“你的业务服务器IP”替换为你的实际地址。

四、全链路测试与上线检查清单

按照以下顺序测试，确保每个环节通畅。

1. 推流测试：使用OBS向rtmp://服务器IP:1935/live/your_stream_key推流。在服务器执行ffmpeg -i rtmp://localhost:1935/live/your_stream_key，能正常输出流信息即成功。
2. 拉流播放测试：用VLC播放器打开https://你的域名:8088/live/your_stream_key.m3u8，能正常播放画面和声音。
3. 业务服务器测试：打开两个浏览器窗口，都访问你的index.html页面。在一个窗口的浏览器控制台（F12）里执行socket.emit('push_goods', 'live_room_001', {name:'测试商品', price:99, link:''})，观察两个窗口的商品列表是否都更新了。
4. 弹幕测试：在两个窗口分别发送弹幕，观察是否都能实时收到。

上线前安全检查清单：

• 所有服务器端口（1935, 8080/8088, 3000）已在安全组/防火墙中正确放行。
• SRS的HLS输出目录（./objs/nginx/html/hls）有足够的磁盘空间。
• 业务服务器代码中Socket.IO的CORS设置，在生产环境已将origin: ""改为具体的前端域名。
• 已配置Nginx反向代理，将业务服务器的3000端口通过域名（如api.yourdomain.com）以HTTPS方式暴露，避免直接暴露IP和端口。
• 建立日志轮转机制，定期清理SRS和Node.js的日志文件，防止磁盘占满。