前言

业务服务器主要是跟七牛云直播平台进行交互，做流的管理，可以理解为用代码实现七牛云直播管理平台。
业务服务器主要处理的就是创建流、查看流状态、获取流、禁用流、启用流、保存直播回放、查询直播历史、获取到URL。当然这部分是七牛提供的SDK，我们也可以在业务服务器上加上我们的东西，比如用户管理，流绑定，礼物系统，聊天系统等等。本文主要用于对API的解释说明，如有不对，请指正！

引入模块

var Pili = require('piliv2');

配置模块

配置AK/SK

var ACCESS_KEY = 'QiniuAccessKey';
var SECRET_KEY = 'QiniuSecretKey';
var credentials = new Pili.Credentials(ACCESS_KEY, SECRET_KEY);

配置HUB

配置这个之前必须要在七牛云平台创建直播空间。

var HUB = 'HubName';
var hub = new Pili.Hub(credentials, HUB);

流管理

这里基本上都是对流进行操作，比如创建流、查询流、流列表、启动流、禁用流等。

创建流

相当于在云平台上通过可视化进行创建流。（streamKey是每个流的标示是唯一的，我是这样处理这个的，每个主播有一个固定的streamKey，这个值是在用户注册的时候UID）

hub.createStream(streamKey, function(err, stream) {
  if (!err) {
      console.log(stream);
  } else {
    // Log error
    console.log(err, err.errorCode, err.httpCode);
  }
});

获取流

获取到流的一些信息如：创建时间、更新时间、结束时间、是否可用等

var stream = hub.newStream(streamKey);
stream.loadInfo(function(err) {
    if (!err) {
        console.log(stream);
    } else {
        console.log(err + 'error code: ' + err.errorCode + 'http code: ' + err.httpCode);
    }
})

返回值：

{
    "credentials":{
        "accessKey":"AK",
        "secretKey":"SK"
    },
    "key":"posttest",
    "hub":"HubName",
    "createdAt":1478569976,
    "updatedAt":1479782576,
    "expireAt":1482547376,
    "disabledTill":0
}

获取直播信息

获取到正在直播流的信息：直播的IP、开始的时间戳、fps

var stream = hub.newStream(streamKey);
stream.liveInfo(function(err, status) {
    if (!err) {
            console.log(status);
        } else {
            console.log(err + 'error code: ' + err.errorCode + 'http code: ' + err.httpCode);
        }
});

返回值：

{
    "startAt":1480575012,
    "clientIP":"xxxxxxxxxxxxxx",
    "bps":900192,
    "fps":{
        "audio":40,
        "video":20,
        "data":0
    }
}

列出流

查询所有流和正在直播的流就靠liveonly这个值

var listOptions = {'liveonly': false,'prefix': '','limit': 2,};
var listCallBack = function(err, marker, streams) {
    if (!err) {
        streams.forEach(function(stream) {
            console.log(stream);
        });
        if (marker) {
            listOptions.marker = marker;
            hub.listStreams(listOptions, listCallBack);
        }
    } else {
         console.log(err + 'error code: ' + err.errorCode + 'http code: ' + err.httpCode);
    }
}
hub.listStreams(listOptions, listCallBack);

禁用流

用户想关闭直播业务的时候可以调用，管理员也可以对用户进行禁播。

var stream = hub.newStream(streamKey);
stream.disable(-1, function(err) {
    console.log(stream.disabledTill);
});

启用流

开启直播业务

var stream = hub.newStream(streamKey);
stream.enable(function(err) {
    console.log(stream.disabledTill);
});

获取流历史

需要设定起始时间戳、结束时间戳

var stream = hub.newStream(streamKey);
var publishHistoryOptions = {
   start : null,    // optional, in second, unix timestamp
   end   : null,    // optional, in second, unix timestamp
};
stream.publishHistory(publishHistoryOptions, function(err, history) {
    if (!err) {
        console.log(history);
    } else {
            console.log(err + 'error code: ' + err.errorCode + 'http code: ' + err.httpCode);
    }
})

保存直播视频

也是要配置初始时间戳、结束时间戳

var stream = hub.newStream(streamKey);
var savePlaybackOptions = {
   start : null,    // optional, in second, unix timestamp
   end   : null,    // optional, in second, unix timestamp
};

stream.savePlayback(savePlaybackOptions, function(err, m3u8Name) {

    if (!err) {
            console.log(m3u8Name);
        } else {
            console.log(err + 'error code: ' + err.errorCode + 'http code: ' + err.httpCode);
        }
});

URL相关

获取推流地址

    //获取推流地址
   var pu = Pili.publishURL(credentials, 'pili-publish.xxxx.top', HUB, streamkey, 60);
    //获取RTMP拉流地址
    var rtmpURL = Pili.rtmpPlayURL('pili-live-rtmp.xxxx.top', HUB, streamkey);
    //获取HDL拉流地址
    var hdlURL = Pili.hdlPlayURL('pili-live-hdl.xxxx.top', HUB, streamkey);
    //获取HLS拉流地址
    var hlsURL = Pili.hlsPlayURL('pili-live-hls.xxxx.top', HUB, streamkey);
    //获取实时截图地址
    var snapURL = Pili.snapshotPlayURL('pili-live-snapshot.xxxx.top', HUB, streamkey);

后记

本文只是列出常用的API，以及做了一些解释，代码只是调用SDK中的方法，具体业务需要写在路由中，有相应的网络请求的时候调用相应的代码。业务服务器端的开发还是挺简单的，主要把流与用户进行绑定，后期还有聊天室的绑定。