这是本身搭建直播服务器、开发直播平台系列的文章，前面两篇文章分别为：php

这篇文章是在上面多频道输入输出和权限控制的基础上进行的。html

1、目标

一、实现直播状态的更改：

（直播状态的更改主要是为了显示，在前端刷新列表的时候，用于判断那些直播间在直播，哪些不在。）：前端

  • 用户开始推流以后，操做数据库，更改直播状态，显示直播间已经开始直播。
  • 用户推流结束或者关闭软件后，操做数据库，更改直播状态。

二、实现简单的人数统计（暂用）：

这里实现人数统计是基于数据库的（rtmp-nginx-module自己是有一个模块的，能够实现当前视频流观看人数的统计），这里只是简单的实现自增和自减数据库。nginx

  • 用户观看打开页面开始观看直播，数据库字段自增1
  • 用户关闭页面后，链接断掉，数据库字段自减1

2、rtmp服务器的配置

在 实现nginx-rtmp-module多频道输入输出与权限控制 这篇文章里，咱们配置了 on_publish 这个参数。git

主要实现多频道和权限控制，用户在正式推流到服务器以前首先去配置的url中验证一下权限（具体的能够看上篇文章）。github

目前咱们须要配置更多的参数：thinkphp

application myapp{ live on; # live on表示开启直播模式 on_publish http://192.168.124.125/on_publish.html; on_publish_done http://192.168.124.125/on_publish_done.html; on_play http://192.168.124.125/on_play.html; on_play_done http://192.168.124.125/on_play_done.html; }

能够看到，除了 on_publish ，咱们还配置了 on_publish_done、on_play、on_play_done 三个参数，后面也是一个url。数据库

这三个参数也是很是容易理解的，分别对应以下：json

  • on_publish_done —— 推流结束
  • on_play —— 客户端播放
  • on_play_done —— 客户端播放结束

对上面三个参数的具体解释和用法能够看rtmp的文档：bash

r.jpg

通过上面的配置，用户推送或者推送结束、或者用户播放和播放结束都可以触发URL，同时操做数据库便可。

3、程序部分注意问题

配置好了URL，就须要进行操做，可是会发现一个问题：

  • 不知道用户观看的是哪一个流、或者不知道推送结束的是哪一个流

上面问题能够看 实现nginx-rtmp-module多频道输入输出与权限控制 这篇文章里面接收的 name参数 ,上面的配置中全部的推送都会携带一个name参数，而这个name是不可变的，用于标识当前流名称。

用我写的简单举个例子：

  • 下面是基于thinkphp5框架写的。
  • url与函数不匹配是由于我作了route。

能够看到，每次的操做都会得到一个name的参数，固然，除了name以外每一个不一样的配置有不一样的参数能够获取，具体能够去 文档 了解一下

/** * 用户直播结束的回调事件 * - 用户直播结束后，将status设置成0，标注该房间未在推流 * @param Request $request */ function onPublishDone(Request $request){ // 得到stream name $name=trim($request->param('name')); // 关闭直播 设置status 为 0 Db::name('room')->where(['guid'=>$name])->setField('status',0); return json('')->code(200)->header(['关闭直播']); } /** * 用户观看直播的回调事件 */ function onPlay(Request $request){ // 得到视频流地址 $name=trim($request->param('name')); // 有人加入观看，设置people +1 Db::name('room')->where(['guid'=>$name])->setInc('people'); } /** * 用户结束观看直播的回调事件 * @param Request $request */ function onPlayDone(Request $request){ // 得到视频流地址 $name=trim($request->param('name')); // 有人加入观看，设置people -1 Db::name('room')->where(['guid'=>$name])->setDec('people'); }