项目以go-zero微服务框架为核心构建，核心推拉流部分采用了开源框架 live-go
live
├─ main.go // 创建数据库
├─ utils // 工具类
├─ servers
│ ├─ user_sever
│ │ └─ user_api // 用户api服务
│ ├─ rank_server
│ │ └─ rank_api // 排行榜api服务
│ ├─ log_sever
│ │ └─ log_api.api // 日志api服务
│ ├─ live_sever
│ │ └─ live_api // 直播api服务
│ ├─ interact_server
│ │ └─ interact_api // 互动api服务
│ ├─ gateway_sever
│ │ ├─ gateway.go // 网关服务
│ │ └─ settings.yaml
│ ├─ file_sever
│ │ └─ file_api // 文件api服务
│ └─ auth_sever
│ └─ auth_api // 认证api服务
├─ rtmp
│ ├─ utils // 工具类
│ ├─ stream // 流管理
│ ├─ session // 会话管理
│ ├─ server // 启动服务
│ ├─ protocol // 处理 RTMP 协议的相关操作
│ └─ common // 公共模块
├─ models // 数据库模型
├─ core // 初始化服务
└─ common // 公共模块
├─ response // 响应封装
├─ models // 数据库公共模型
├─ middleware
│ └─ log_middleware.go // 全局日志中间件
└─ etcd
└─ delivery_address.go // 上送服务地址
服务共被分为8大板块
所有请求同一从网关转发，在网关层中进行了认证处理，限流、熔断的判断
认证服务中提供四个api接口：登录，登出，注册，认证
用户服务中提供两个api接口：获取当前登陆人信息，关注
直播服务中提供四个api接口，一个websocket连接：创建/结束直播，进入/离开直播间，ws链接用于实时获取当前直播间在线人数、处理WebRTC Offer、交换ICE候选
创建直播法一创建直播间后返回类似于：rtmp://localhost:1935/live/rfBd56ti2SMtYvSgD5xAV0YU99zampta7Z7S575KLkIZ9PYk的推流地址，之后用户可以使用ffmpeg相关命令或者 OBS软件进行推流
创建直播法二(需要前端配合，无法测试到底对不对(╥﹏╥)
- 前端获取媒体流：用户授权并获取摄像头和麦克风流。
- 前端请求创建直播：前端通过HTTP请求后端API创建直播会话。
- 前端建立WebRTC连接：前端创建
RTCPeerConnection并添加媒体流。 - 前端建立WebSocket连接：前端连接到后端WebSocket服务器。
- 后端处理WebSocket连接：后端接受并管理WebSocket连接。
- 前端创建和发送Offer：前端创建WebRTC Offer并发送到后端。
- 后端处理Offer并生成Answer：后端处理Offer并返回Answer。
- ICE候选交换：前端和后端通过WebSocket交换ICE候选。
- 推流到RTMP服务器：后端使用
ffmpeg将WebRTC媒体流推送到RTMP服务器。
互动服务中提供五个api接口，一个websocket连接：发起/参与抽奖、查看抽奖结果、送礼物、展示礼物列表，ws连接用于直播间内实时聊天
排行服务中提供三个api接口，两个websocket连接：直播间观众数/主播粉丝数/直播间收益排行榜，一个websocket实时获取三大排行榜信息，另一个实时获取直播间内高能用户榜一大哥排行榜
待完成...
处理头像，视频等文件上传的服务
待完成...
接口文档详情请看VCR 上链接！apifox接口文档
自己写了一部分RTMP服务，因为时间（人菜）的关系，只有一个架子，后续可能会继续完善
写了的部分： 流管理、会话管理、启动服务、处理 RTMP 协议的相关操作
emmmmmm
......未完待续