aliyun-go-live-sdk
博客专区 > Cbping 的博客 > 博客详情
aliyun-go-live-sdk
Cbping 发表于10个月前
aliyun-go-live-sdk
  • 发表于 10个月前
  • 阅读 23
  • 收藏 1
  • 点赞 0
  • 评论 0

腾讯云 技术升级10大核心产品年终让利>>>   

摘要: 个人开源的阿里云直播go语言版本SDK。 提供 https://help.aliyun.com/document_detail/27191.html?spm=0.0.0.0.60u2Ny 文档上的相应接口

详细信息请看

github:https://github.com/BPing/aliyun-live-go-sdk

Build Status Coverage Status Go Report Card

阿里云直播 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

文档

Example

直播(Live)

    方法名以"WithApp"结尾代表可以更改请求中  "应用名字(AppName)",
    否则按默认的(初始化时设置的AppName)。
    如果为空,代表忽略参数AppName
    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 应用名 为空时,忽略此参数
    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)
    //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)

录制(请看文档)

截图(2017-01-18)

  • 添加截图配置
	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)

转码(2017-01-19)

  • 添加转码配置
	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)

混流(2017-01-19)

  • 开始混流操作
	err=liveM.StartMixStreamsService(...)
  • 结束混流操作
	err=liveM.StopMixStreamsService(...)

拉流(2017-10-12)

  • 添加拉流信息
	err=liveM.AddLivePullStreamInfoConfig(...)
  • 删除拉流信息
	err=liveM.DeleteLivePullStreamInfoConfig(...)
  • 查询域名下拉流配置信息
	err=liveM.DescribeLivePullStreamConfig(...)

连麦((2017-10-12)

  • 添加连麦配置
	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(...)

状态通知((2017-10-12)

  • 设置回调链接
	err=liveM.SetStreamsNotifyUrlConfig(...)
  • 删除推流回调配置
	err=liveM.DeleteLiveStreamsNotifyUrlConfig(...)
  • 查询推流回调配置
	err=liveM.StreamsNotifyUrlConfig(...)

流(Stream)

  //如果 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)

License

采用 Apache License, Version 2.0许可证授权原则。

标签: rtmp aliyun golang go gopher
共有 人打赏支持
粉丝 3
博文 11
码字总数 5190
×
Cbping
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: