阿里云直播 golang SDK
package main
import (
"github.com/BPing/aliyun-live-go-sdk/aliyun"
"github.com/BPing/aliyun-live-go-sdk/device/live"
"github.com/BPing/aliyun-live-go-sdk/util"
"time"
"fmt"
)
const (
AccessKeyId = "<Yours' Id>"
AccessKeySecret = "<...>"
)
func main() {
cert := aliyun.NewCredentials(AccessKeyId, AccessKeySecret)
live := live.NewLive(cert, "<Yours' CDN>", "app-name",nil).SetDebug(true)
resp := make(map[string]interface{})
live.StreamsPublishList(time.Now().Add(-time.Hour * 12), time.Now(), &resp)
fmt.Println(resp)
}go get:
go get github.com/BPing/aliyun-live-go-sdk- Sdk:https://godoc.org/github.com/BPing/aliyun-live-go-sdk
- CDN:https://godoc.org/github.com/BPing/aliyun-live-go-sdk/device/cdn
- Live:https://godoc.org/github.com/BPing/aliyun-live-go-sdk/device/live
（v0.5,v0.5-）
方法名以"WithApp"结尾代表可以更改请求中 "应用名字（AppName）"，
否则按默认的(初始化时设置的AppName)。
如果为空，代表忽略参数AppName
（v0.6+）
移除以"WithApp"为后缀方法。
cert := client.NewCredentials(AccessKeyId, AccessKeySecret)
liveM := live.NewLive(cert, DomainName, AppName, nil).SetDebug(true)- 获取流列表
resp := make(map[string]interface{})
liveM.StreamsPublishList(time.Now().Add(-time.Hour * 12), time.Now(), &resp)
fmt.Println(resp)
// @appname 应用名 为空时，忽略此参数
resp := make(map[string]interface{})
liveM.StreamsPublishListWithApp(AppName,time.Now().Add(-time.Hour * 12), time.Now(), &resp)
fmt.Println(resp)- 获取黑名单
resp = make(map[string]interface{})
err = liveM.StreamsBlockList(&resp)
fmt.Println(err, resp)- 获取流的在线人数
resp1 := live.OnlineInfoResponse{}
err := liveM.StreamOnlineUserNum("video-name", &resp1)
fmt.Println(err, resp1)
// @appname 应用名 为空时，忽略此参数 （v0.5,v0.5-）
resp1 := live.OnlineInfoResponse{}
err := liveM.StreamOnlineUserNumWithApp(AppName,"video-name", &resp1)
fmt.Println(err, resp1) - 获取控制历史
resp = make(map[string]interface{})
err = liveM.StreamsControlHistory(time.Now().Add(-time.Hour * 12), time.Now(), &resp)
// （v0.5,v0.5-）
//err = liveM.StreamsControlHistoryWithApp(AppName,time.Now().Add(-time.Hour * 12), time.Now(), &resp)
fmt.Println(err, resp)- 禁止
resp = make(map[string]interface{})
err = liveM.ForbidLiveStreamWithPublisher("video-name", nil, &resp)
fmt.Println(err, resp)- 恢复
resp = make(map[string]interface{})
err = liveM.ResumeLiveStreamWithPublisher("video-name", &resp)
fmt.Println(err, resp)- 添加截图配置
oss := live.OssInfo{
OssBucket: OssBucket,
OssEndpoint: OssEndpoint,
OssObject: OssObject,
OssObjectPrefix: OssObjectPrefix,
}
config:=live.SnapshotConfig{
OssInfo:oss,
TimeInterval : 5,
OverwriteOssObject : "{AppName}/{StreamName}.jpg",
}
resp := make(map[string]interface{})
err:=liveM.AddLiveAppSnapshotConfig(config,&resp)
fmt.Println(err, resp)- 更新截图配置
config.SequenceOssObject="{AppName}/{StreamName}.jpg"
resp = make(map[string]interface{})
err=liveM.UpdateLiveAppSnapshotConfig(config,&resp)
fmt.Println(err, resp)- 查询域名截图配置
param:=live.LiveSnapshotParam{
PageNum:1,
PageSize:10,
Order:"asc",
}
resp = make(map[string]interface{})
err=liveM.LiveSnapshotConfig(param,&resp)
fmt.Println(err, resp)- 查询截图信息
resp = make(map[string]interface{})
err=liveM.LiveStreamSnapshotInfo("test-video-name1",time.Now().Add(-time.Hour*24*20), time.Now(),10,&resp)
fmt.Println(err, resp)- 删除截图配置
resp = make(map[string]interface{})
err=liveM.DeleteLiveAppSnapshotConfig(&resp)
fmt.Println(err, resp)- 添加转码配置
resp := make(map[string]interface{})
err:=liveM.AddLiveStreamTranscode("a","no","no",&resp)
fmt.Println(err, resp)- 查询转码配置信息
resp = make(map[string]interface{})
err=liveM.LiveStreamTranscodeInfo(&resp)
fmt.Println(err, resp))- 删除转码配置
resp = make(map[string]interface{})
err=liveM.DeleteLiveStreamTranscode("a",&resp)
fmt.Println(err, resp)- 开始混流操作
err=liveM.StartMixStreamsService(...)- 结束混流操作
err=liveM.StopMixStreamsService(...)- 添加拉流信息
err=liveM.AddLivePullStreamInfoConfig(...)- 删除拉流信息
err=liveM.DeleteLivePullStreamInfoConfig(...)- 查询域名下拉流配置信息
err=liveM.DescribeLivePullStreamConfig(...)- 添加连麦配置
err=liveM.AddLiveMixConfig(...)- 查询连麦配置
err=liveM.DescribeLiveMixConfig(...)- 删除连麦配置
err=liveM.DeleteLiveMixConfig(...)- 开启多人连麦服务
err=liveM.StartMultipleStreamMixService(...)- 停止多人连麦服务
err=liveM.StopMultipleStreamMixService(...)- 往主流添加一路流
err=liveM.AddMultipleStreamMixService(...)- 从主流移除一路流
err=liveM.RemoveMultipleStreamMixService(...)- 添加连麦回调配置
err=liveM.AddLiveMixNotifyConfig(...)- 查询连麦回调配置
err=liveM.DescribeLiveMixNotifyConfig(...)- 删除连麦回调配置
err=liveM.DeleteLiveMixNotifyConfig(...)- 更新连麦回调配置
err=liveM.UpdateLiveMixNotifyConfig(...)- 设置回调链接
err=liveM.SetStreamsNotifyUrlConfig(...)- 删除推流回调配置
err=liveM.DeleteLiveStreamsNotifyUrlConfig(...)- 查询推流回调配置
err=liveM.StreamsNotifyUrlConfig(...)- 增加直播录制转点播配置
err=liveM.AddLiveRecordVodConfig(...)- 删除直播录制转点播配置
err=liveM.DeleteLiveRecordVodConfig(...)- 查询直转点配置列表
err=liveM.DescribeLiveRecordVodConfigs(...)- 查询直播域名的网络带宽监控数据
err=liveM.DescribeLiveDomainBpsData(...)- 查询直播域名录制时长数据
err=liveM.DescribeLiveDomainRecordData(...)- 查询直播域名截图张数数据
err=liveM.DescribeLiveDomainSnapshotData(...)- 查询直播域名网络流量监控数据
err=liveM.DescribeLiveDomainTrafficData(...)- 查询直播域名转码时长数据
err=liveM.DescribeLiveDomainTranscodeData(...)- 查询直播流历史在线人数
err=liveM.DescribeLiveStreamHistoryUserNum(...)- 查询审核配置
err=liveM.DescribeLiveSnapshotDetectPornConfig(...)- 添加审核配置
err=liveM.AddLiveSnapshotDetectPornConfig(...)- 更新审核回调
err=liveM.UpdateLiveSnapshotDetectPornConfig(...)- 删除审核回调
err=liveM.DeleteLiveSnapshotDetectPornConfig(...)- 查询审核回调
err=liveM.DescribeLiveDetectNotifyConfig(...)- 添加回调通知
err=liveM.AddLiveDetectNotifyConfig(...)- 更新回调通知
err=liveM.UpdateLiveDetectNotifyConfig(...)- 删除审核回调
err=liveM.DeleteLiveDetectNotifyConfig(...) //如果 streamCert 为空的话，则代表不开启直播流鉴权
cert := client.NewCredentials(AccessKeyId, AccessKeySecret)
streamCert := live.NewStreamCredentials(PrivateKey, live.DefaultStreamTimeout)
liveM := live.NewLive(cert, DomainName, AppName, streamCert)
// GetStream 获取直播流
// @describe 每一次都生成新的流实例，不检查流名的唯一性，并且同一个名字会生成不同的实例的，
// 所以，使用时候，请自行确保流名的唯一性
stream := liveM.GetStream("video-name")- 获取RTMP推流地址
// RTMP 推流地址
// 如果开启了直播流鉴权，签名失效后，会重新生成新的有效的推流地址
stream.RtmpPublishUrl()- RTMP 直播播放地址
url:=stream.RtmpLiveUrls()- HLS 直播播放地址
url:=stream.HlsLiveUrls()- FLV 直播播放地址
url:=stream.HttpFlvLiveUrls()- 获取在线人数
num:=stream.OnlineUserNum()- 是否在线
isOnline:=stream.Online()- 是否被禁止
isBlocked:=stream.Blocked()- 获取直播流的帧率和码率
// type FrameRateAndBitRateInfos struct {
// FrameRateAndBitRateInfo []FrameRateAndBitRateInfo
//}
//
//// 各直播流的帧率/码率信息
//type FrameRateAndBitRateInfo struct {
// StreamUrl string // 直播流的URL
// VideoFrameRate int // 直播流的视频帧率
// AudioFrameRate int // 直播流的音频帧率
// BitRate int // 直播流的码率
//}
frameRateAndBitRateInfo,err:=stream.FrameRateAndBitRateData()- 获取截图信息
// 查询截图信息
// type StreamSnapshotInfoResponse struct {
// client.Response
// LiveStreamSnapshotInfoList struct {
// StreamSnapshotInfo []StreamSnapshotInfo `json:"StreamSnapshotInfo" xml:"StreamSnapshotInfo"`
// } `json:"LiveStreamSnapshotInfoList" xml:"LiveStreamSnapshotInfoList"` //截图内容列表，没有则返回空数组
// NextStartTime string //
// }
streamSnapshotInfo,err:=stream.SnapshotInfo(time.Now().Add(-time.Hour * 12), time.Now(), 10)github.com/BPing/go-toolkit/http-client
- cbping(452775680@qq.com)
采用 Apache License, Version 2.0许可证授权原则。