Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Caster #536

Open
wants to merge 4 commits into
base: master
Choose a base branch
from
Open

Caster #536

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
b2f3090
添加导播台实现
iuaku Dec 21, 2021
6784e39
Merge branch 'master' into caster
iuaku Dec 21, 2021
370dc37
测试方法修改
iuaku Dec 27, 2021
0d058b3
Merge branch 'caster' of github.com:iLiuKun/java-sdk into caster
iuaku Dec 27, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
368 changes: 368 additions & 0 deletions src/main/java/com/qiniu/caster/CasterManager.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,368 @@
package com.qiniu.caster;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.JsonElement;
import com.qiniu.caster.model.CasterParams;
import com.qiniu.caster.model.Overlay;
import com.qiniu.caster.model.Text;
import com.qiniu.common.Constants;
import com.qiniu.common.QiniuException;
import com.qiniu.http.Client;
import com.qiniu.http.Response;
import com.qiniu.util.Auth;
import com.qiniu.util.Json;
import com.qiniu.util.StringMap;


public class CasterManager {
private final Auth auth;
private final String server;
private final Client client;

public CasterManager(Auth auth) {
this(auth, "http://pili-caster.qiniuapi.com");
}

private CasterManager(Auth auth, String server) {
this.auth = auth;
this.server = server;
this.client = new Client();
}

public CasterManager(Auth auth, String server, Client client) {
this.auth = auth;
this.server = server;
this.client = client;
}

/**
*
* 创建云导播
* @param name 导播台name
* @param casterParams 导播台参数
* @return
*/
public Response createCaster(String name, CasterParams casterParams) {
String url = server + "/v1/casters";
Gson gson = new GsonBuilder().setPrettyPrinting().create();
JsonElement jsonElement = gson.toJsonTree(casterParams);
jsonElement.getAsJsonObject().addProperty("name", name);
byte[] body = gson.toJson(jsonElement).getBytes(Constants.UTF_8);
String a = gson.toJson(jsonElement);
StringMap headers = auth.authorizationV2(url, "POST", body, Client.JsonMime);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 云导播列表
* @param name 云导播名称前缀匹配
* @param marker 如果上一次返回的结果超过了单次查询限制，则会返回marker表示上一次读取到哪条记录；这一次请求带上marker后，继续从该marker后开始读取,设置为null为从头开始
* @param limit 返回的最大数量，设置为-1默认为50
* @return
*/
public Response findCasters(String name, String marker, int limit) {
StringMap map = new StringMap().putNotEmpty("marker", marker)
.putNotEmpty("name", name).putWhen("limit", limit, limit > 0);
String queryString = map.formString();
if (map.size() > 0) {
queryString = "?" + queryString;
}
String url = String.format("%s/v1/casters/%s", server, queryString);
StringMap headers = auth.authorizationV2(url);
Response response = null;
try {
response = client.get(url, headers);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 云导播信息
* @param casterId 导播台id
* @return
*/
public Response getCasterInfo(String casterId) {
String url = String.format("%s/v1/casters/%s", server, casterId);
StringMap headers = auth.authorizationV2(url);
Response response = null;
try {
response = client.get(url, headers);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 开启云导播
* @param casterId 导播台id
* @param start 开启时间，设置为-1立即启动；导播台已开启时，禁止设置开启时间，规格为时间戳（秒级）
* @param hour 开启时长，设置为-1为默认为1小时；导播台已开启时，表示延长开启时长 [1.~]
* @return
*/
public Response startCaster(String casterId, int start, int hour) {
String url = String.format("%s/v1/casters/%s/start", server, casterId);
StringMap map = new StringMap().putWhen("start", start, start > 0)
.putWhen("hour", hour, hour > 0);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = auth.authorizationV2(url, "POST", body, Client.JsonMime);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 关闭云导播
* @param casterId 导播台id
* @return
*/
public Response stopCaster(String casterId) {
String url = String.format("%s/v1/casters/%s/stop", server, casterId);
StringMap map = new StringMap().putNotNull("CasterId", casterId);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = auth.authorizationV2(url, "POST", body, Client.JsonMime);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 删除云导播
* @param casterId 导播台id
* @return
*/
public Response deleteCaster(String casterId) {
String url = String.format("%s/v1/casters/%s", server, casterId);
StringMap map = new StringMap().putNotNull("CasterId", casterId);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = auth.authorizationV2(url, "DELETE", body, Client.JsonMime);
Response response = null;
try {
response = client.delete(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 更新云导播
* @param casterId 导播台id
* @param casterParams 导播台更新参数
* @return
*/
public Response update(String casterId, CasterParams casterParams) {
String url = String.format("%s/v1/casters/%s", server, casterId);
byte[] body = Json.encode(casterParams).getBytes(Constants.UTF_8);
StringMap headers = auth.authorizationV2(url, "POST", body, Client.JsonMime);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 更新PVW监视器频道
* @param casterId 导播台id
* @param channel 监视器频道 [0,7]
* @param staticKey 静态密钥
* @return
*/
public Response updatePvw(String casterId, int channel, String staticKey) {
String url = String.format("%s/v1/static/casters/%s/pvw", server, casterId);
StringMap map = new StringMap().putNotNull("CasterID", casterId)
.putWhen("channel", channel, channel >= 0);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = new StringMap().put("Authorization", staticKey);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 更新PGM监视器频道
* @param casterId 导播台id
* @param channel 监视器频道 [0,7]
* @param staticKey 静态密钥
* @return
*/
public Response updatePgm(String casterId, int channel, String staticKey) {
String url = String.format("%s/v1/static/casters/%s/pgm", server, casterId);
StringMap map = new StringMap().putNotNull("CasterID", casterId)
.putWhen("channel", channel, channel >= 0);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = new StringMap().put("Authorization", staticKey);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* PVW切换至PGM
* @param casterId 导播台id
* @param switchVol 是否同步切换音频
* @param staticKey 静态密钥
* @return
*/
public Response pvwSwitchToPgm(String casterId, boolean switchVol, String staticKey) {
String url = String.format("%s/v1/static/casters/%s/switch", server, casterId);
StringMap map = new StringMap().putNotNull("CasterID", casterId)
.putNotNull("switchVol", switchVol);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = new StringMap().put("Authorization", staticKey);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 更新监视器配置
* @param casterId 导播台id
* @param channel 监视器频道 [0,7]
* @param newUrl 监视器源流地址，支持直播流、静态视频、图片等
* @param vol 音量[0,300]
* @param muted 是否静音
* @param staticKey 静态密钥
* @return
*/
public Response updateMonitors(String casterId, int channel, String newUrl, int vol, boolean muted, String staticKey) {
String url = String.format("%s/v1/static/casters/%s/monitors", server, casterId);
StringMap map = new StringMap().putNotNull("CasterID", casterId)
.putWhen("channel", channel, channel >= 0)
.putNotNull("url", newUrl).putWhen("vol", vol, vol >= 0).putNotNull("muted", muted);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = new StringMap().put("Authorization", staticKey);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 更新输出配置
* @param casterId 导播台id
* @param newUrl PGM推流地址
* @param ab [64,512] 音频码率(Kbps)，默认值为64，-1为默认值
* @param vb [300,10240] 视频码率(Kbps)，默认值为1000，-1为默认值
* @param closed 关闭推流
* @param emergencyMode 紧急模式开关
* @param emergencyChannel 紧急模式监视器频道，取值范围是[0,7]，默认使用0频道 [0,7]
* @param delay [0，180] 延时播放，单位: 秒
* @param staticKey 静态密钥
* @return
*/
public Response updatePublish(String casterId, String newUrl, int ab, int vb, boolean closed, boolean emergencyMode, int emergencyChannel, int delay, String staticKey) {
String url = String.format("%s/v1/static/casters/%s/publish", server, casterId);
StringMap map = new StringMap().putNotNull("CasterID", casterId)
.putNotNull("url", newUrl).putWhen("vb", vb, vb >= 0)
.putWhen("ab", ab, ab >= 0)
.putNotNull("closed", closed).putNotNull("emergencyMode", emergencyMode)
.putWhen("emergencyChannel", emergencyChannel, emergencyChannel >= 0)
.putWhen("delay", delay, delay >= 0);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = new StringMap().put("Authorization", staticKey);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 更新PVW布局ID
* @param casterId 导播台id
* @param layout 布局ID，-1表示不使用布局
* @param staticKey 静态密钥
* @return
*/
public Response changeLayout(String casterId, int layout, String staticKey) {
String url = String.format("%s/v1/static/casters/%s/pvw/layouts", server, casterId);
StringMap map = new StringMap().putNotNull("CasterID", casterId)
.putWhen("layout", layout, layout >= 0);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = new StringMap().put("Authorization", staticKey);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}

/**
*
* 更新布局配置
* @param casterId 导播台ID
* @param layout [0,7] 布局ID
* @param title 布局标题，可留空
* @param overlay 画中画配置，key为对应的监视器频道，详细参数见画中画配置(overlay)详细参数
* @param text 文字水印配置，key为文字水印标题，详细参数见文字水印配置(text)详细参数
* @param staticKey 静态密钥
* @return
*/
public Response updateLayout(String casterId, int layout, String title, Overlay overlay, Text text, String staticKey) {
String url = String.format("%s/v1/static/casters/%s/layouts", server, casterId);
StringMap map = new StringMap().putNotNull("CasterID", casterId)
.putWhen("layout", layout, layout >= 0)
.putNotNull("title", title).putNotNull("overlay", overlay).putNotNull("text", text);
byte[] body = Json.encode(map).getBytes(Constants.UTF_8);
StringMap headers = new StringMap().put("Authorization", staticKey);
Response response = null;
try {
response = client.post(url, body, headers, Client.JsonMime);
} catch (QiniuException e) {
e.printStackTrace();
}
return response;
}
}
Loading