阅读本文,您可以获取 Java SDK 拉流回源的接口调用示例,实现快速开发。
说明
本文的调用示例包含接口的部分参数。由于参数间可能存在互斥关系,在调用时,请您参考注释,进行调整。
调用接口前,请先完成 Java SDK 的安装及初始化操作。
本节为您介绍拉流回源相关接口的功能和调用示例。
您可以调用 UpdateRelaySourceV3 接口添加或更新播放触发回源配置。详细的参数说明可参见 UpdateRelaySourceV3 接口文档。
接口调用示例如下所示。
package com.volcengine.live.demo; import com.volcengine.model.live.v20230101.*; import com.volcengine.service.live.v20230101.LiveService; import java.util.ArrayList; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; public class UpdateRelaySourceV3Demo { public static void main(String[] args) { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里,否则可能导致 AccessKey 泄露,威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY,来实现 API 访问的身份验证。运行代码示例前,请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY LiveService service = LiveService.getInstance(); service.setAccessKey(System.getenv("VOLC_ACCESSKEY")); service.setSecretKey(System.getenv("VOLC_SECRETKEY")); UpdateRelaySourceV3Body body = new UpdateRelaySourceV3Body(); // 域名空间,即直播流地址的域名所属的域名空间。您可以调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口或在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面,查看直播流使用的域名所属的域名空间。 body.setVhost("push.example.com"); // 应用名称,即直播流地址的 AppName 字段取值,默认为空,表示为当前域名空间的全局播放触发回源配置。支持由大小写字母(A - Z、a - z)、数字(0 - 9)、下划线(_)、短横线(-)和句点(.)组成,长度为 1 到 30 个字符。 body.setApp("live"); // 回源组配置详情。 List<UpdateRelaySourceV3BodyGroupDetailsItem> GroupDetails = new ArrayList<>(); UpdateRelaySourceV3BodyGroupDetailsItem GroupDetails1 = new UpdateRelaySourceV3BodyGroupDetailsItem(); // 回源组名称。 GroupDetails1.setGroup("relay1"); // 回源服务器配置列表。 List<UpdateRelaySourceV3BodyGroupDetailsItemServersItem> Servers = new ArrayList<>(); UpdateRelaySourceV3BodyGroupDetailsItemServersItem Servers1 = new UpdateRelaySourceV3BodyGroupDetailsItemServersItem(); // 回源协议,支持两种回源协议。 // <li> rtmp:RTMP 回源协议; </li> // <li> flv:FLV 回源协议。 </li> Servers1.setRelaySourceProtocol("rtmp"); // 直播源服务器的地址,支持填写回源服务的域名或 IP 地址。 // note: // <li> 当源站使用了非默认端口时,支持在回源地址中以域名:端口或 IP:端口的形式配置端口。 </li> // <li> 最多支持添加 10 个回源地址,回源失败时,将按照您添加的地址顺序轮循尝试。 </li> Servers1.setRelaySourceDomain("example.org"); // 自定义回源参数,缺省情况下为空。格式为 "Key":"Value",例如,"domain":"live.push.net"。 Map<String, String> RelaySourceParams = new LinkedHashMap<>(); RelaySourceParams.put("key1", "value1"); RelaySourceParams.put("key2", "value2"); Servers1.setRelaySourceParams(RelaySourceParams); Servers.add(Servers1); GroupDetails1.setServers(Servers); GroupDetails.add(GroupDetails1); body.setGroupDetails(GroupDetails); try { UpdateRelaySourceV3Res resp = service.updateRelaySourceV3(body); System.out.println(resp); } catch (Exception e) { e.printStackTrace(); } } }
您可以调用 DeleteRelaySourceV3 接口删除播放触发回源配置。详细的参数说明可参见 DeleteRelaySourceV3 接口文档。
接口调用示例如下所示。
package com.volcengine.live.demo; import com.volcengine.model.live.v20230101.*; import com.volcengine.service.live.v20230101.LiveService; public class DeleteRelaySourceV3Demo { public static void main(String[] args) { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里,否则可能导致 AccessKey 泄露,威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY,来实现 API 访问的身份验证。运行代码示例前,请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY LiveService service = LiveService.getInstance(); service.setAccessKey(System.getenv("VOLC_ACCESSKEY")); service.setSecretKey(System.getenv("VOLC_SECRETKEY")); DeleteRelaySourceV3Body body = new DeleteRelaySourceV3Body(); // 直播流使用的域名所属的域名空间,您可以调用 [DescribeRelaySourceV3](https://www.volcengine.com/docs/6469/1126874) 接口获取待删除配置的 Vhost 取值。 body.setVhost("push.example.com"); // 应用名称,您可以调用 [DescribeRelaySourceV3](https://www.volcengine.com/docs/6469/1126874) 接口获取待删除配置的 App 取值。 body.setApp("live"); // 回源组名称。 body.setGroup("relay1"); try { DeleteRelaySourceV3Res resp = service.deleteRelaySourceV3(body); System.out.println(resp); } catch (Exception e) { e.printStackTrace(); } } }
您可以调用 DescribeRelaySourceV3 接口查询播放触发回源配置。详细的参数说明可参见 DescribeRelaySourceV3 接口文档。
接口调用示例如下所示。
package com.volcengine.live.demo; import com.volcengine.model.live.v20230101.*; import com.volcengine.service.live.v20230101.LiveService; public class DescribeRelaySourceV3Demo { public static void main(String[] args) { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里,否则可能导致 AccessKey 泄露,威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY,来实现 API 访问的身份验证。运行代码示例前,请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY LiveService service = LiveService.getInstance(); service.setAccessKey(System.getenv("VOLC_ACCESSKEY")); service.setSecretKey(System.getenv("VOLC_SECRETKEY")); DescribeRelaySourceV3Body body = new DescribeRelaySourceV3Body(); // 直播流使用的域名所属的域名空间。您可以调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口或在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面,查看直播流使用的域名。所属的域名空间。 body.setVhost("push.example.com"); // 应用名称,即直播流地址的 AppName 字段取值,默认为空,表示查询当前域名空间下所有播放触发回源配置。支持由大小写字母(A - Z、a - z)、数字(0 - 9)、下划线(_)、短横线(-)和句点(.)组成,长度为 1 到 30 个字符。 body.setApp("live"); // 回源组名称。 body.setGroup("relay1"); try { DescribeRelaySourceV3Res resp = service.describeRelaySourceV3(body); System.out.println(resp); } catch (Exception e) { e.printStackTrace(); } } }
您可以调用 CreateRelaySourceV4 接口添加固定触发回源配置。详细的参数说明可参见 CreateRelaySourceV4 接口文档。
接口调用示例如下所示。
package com.volcengine.live.demo; import com.volcengine.model.live.v20230101.*; import com.volcengine.service.live.v20230101.LiveService; import java.util.ArrayList; import java.util.List; public class CreateRelaySourceV4Demo { public static void main(String[] args) { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里,否则可能导致 AccessKey 泄露,威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY,来实现 API 访问的身份验证。运行代码示例前,请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY LiveService service = LiveService.getInstance(); service.setAccessKey(System.getenv("VOLC_ACCESSKEY")); service.setSecretKey(System.getenv("VOLC_SECRETKEY")); CreateRelaySourceV4Body body = new CreateRelaySourceV4Body(); // 域名空间。 // 通过以下任一方式,获取域名空间: // <li> 调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口,通过返回参数 Vhost 获取。 </li> // <li> 在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面,通过**域名空间**字段获取。 </li> body.setVhost("pull.example.com"); // 视频直播播放地址中的 AppName。例如播放地址为 rtmp://pull.example.com/live/test?authinfo,则 AppName 为 live。 // 支持由大小写字母(A - Z、a - z)、数字(0 - 9)、下划线(_)、短横线(-)和句点(.)组成,长度为 1 到 30 个字符。 // note: // 同一 App 不能同时配置播放触发和固定触发的回源配置。您可调用 [DescribeRelaySourceV3](https://docs.volcengine.com/docs/6469/1126874?lang=zh) 查询已有播放触发回源配置的 App 取值。 body.setApp("live"); // 视频直播播放地址中的 StreamName。例如播放地址为 rtmp://pull.example.com/live/test?authinfo,则 StreamName 为 test。 // 支持由大小写字母(A - Z、a - z)、数字(0 - 9)、下划线(_)和短横线(-)组成,长度为 1 到 100 个字符。 // note: // App 和 Stream 的组合不能与已有固定触发回源配置重复。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 查询已有固定触发回源配置的 App 和 Stream 取值。 body.setStream("example_stream"); // 回源地址列表,即视频直播从源站拉取直播流时访问的地址列表。支持 RTMP、RTMPS、FLV 或 HLS 协议。 // 通常包含协议、源站的域名或 IP 地址,以及源站直播流的 AppName 和 StreamName。如果源站要求回源请求携带额外参数,还需包含查询参数。例如 rtmp://192.*.*.10/live01/test01?token=abc。 // note: // <li> 支持配置自有源站或第三方源站的回源地址。触发回源后,视频直播会访问您配置的回源地址,从源站拉取直播流。 </li> // <li> 如果源站使用非默认端口,需在源站的域名或 IP 地址后填写端口,例如 rtmp://192.*.*.10:1936/live01/test01?token=abc,否则系统可能按默认端口访问源站,导致回源失败。 </li> // <li> 最多支持传入 10 个回源地址。系统会按照回源地址在数组中的排列顺序依次尝试回源,数组中越靠前的地址优先级越高。如果当前回源地址回源失败,系统会再尝试下一个回源地址。 </li> List<String> SrcAddrS = new ArrayList<>(); SrcAddrS.add("rtmp://live.example.com/live01/test01"); body.setSrcAddrS(SrcAddrS); // 回源开始时间。Unix 时间戳,单位为秒。 // note: // <li> StartTime 和 EndTime 的时间间隔不可超过 7 天。 </li> // <li> StartTime 和 EndTime 需同时传入或同时不传。传入时,表示添加固定回源类型的回源配置。不传时,表示添加永久回源类型的回源配置。 </li> body.setStartTime(1785923506); // 回源结束时间。Unix 时间戳,单位为秒。 // note: // <li> StartTime 和 EndTime 的时间间隔不可超过 7 天。 </li> // <li> StartTime 和 EndTime 需同时传入或同时不传。传入时,表示添加固定回源类型的回源配置。不传时,表示添加永久回源类型的回源配置。 </li> body.setEndTime(1785953506); try { CreateRelaySourceV4Res resp = service.createRelaySourceV4(body); System.out.println(resp); } catch (Exception e) { e.printStackTrace(); } } }
您可以调用 DeleteRelaySourceV4 接口删除固定触发回源配置。详细的参数说明可参见 DeleteRelaySourceV4 接口文档。
接口调用示例如下所示。
package com.volcengine.live.demo; import com.volcengine.model.live.v20230101.*; import com.volcengine.service.live.v20230101.LiveService; public class DeleteRelaySourceV4Demo { public static void main(String[] args) { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里,否则可能导致 AccessKey 泄露,威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY,来实现 API 访问的身份验证。运行代码示例前,请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY LiveService service = LiveService.getInstance(); service.setAccessKey(System.getenv("VOLC_ACCESSKEY")); service.setSecretKey(System.getenv("VOLC_SECRETKEY")); DeleteRelaySourceV4Body body = new DeleteRelaySourceV4Body(); // 域名空间。 // 通过以下任一方式,获取域名空间: // <li> 调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口,通过返回参数 Vhost 获取。 </li> // <li> 在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面,通过**域名空间**字段获取。 </li> body.setVhost("pull.example.com"); // 视频直播播放地址中的 AppName。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 并根据返回参数 App 获取固定触发回源配置的 AppName。 body.setApp("live"); // 视频直播播放地址中的 StreamName。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 并根据返回参数 Stream 获取固定触发回源配置的 StreamName。 body.setStream("example_stream"); try { DeleteRelaySourceV4Res resp = service.deleteRelaySourceV4(body); System.out.println(resp); } catch (Exception e) { e.printStackTrace(); } } }
您可以调用 UpdateRelaySourceV4 接口更新固定触发回源配置。详细的参数说明可参见 UpdateRelaySourceV4 接口文档。
接口调用示例如下所示。
package com.volcengine.live.demo; import com.volcengine.model.live.v20230101.*; import com.volcengine.service.live.v20230101.LiveService; import java.util.ArrayList; import java.util.List; public class UpdateRelaySourceV4Demo { public static void main(String[] args) { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里,否则可能导致 AccessKey 泄露,威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY,来实现 API 访问的身份验证。运行代码示例前,请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY LiveService service = LiveService.getInstance(); service.setAccessKey(System.getenv("VOLC_ACCESSKEY")); service.setSecretKey(System.getenv("VOLC_SECRETKEY")); UpdateRelaySourceV4Body body = new UpdateRelaySourceV4Body(); // 域名空间。 // 通过以下任一方式,获取域名空间: // <li> 调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口,通过返回参数 Vhost 获取。 </li> // <li> 在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面,通过**域名空间**字段获取。 </li> body.setVhost("pull.example.com"); // 视频直播播放地址中的 AppName。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 并根据返回参数 App 获取固定触发回源配置的 AppName。 body.setApp("live"); // 视频直播播放地址中的 StreamName。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 并根据返回参数 Stream 获取固定触发回源配置的 StreamName。 body.setStream("example_stream"); // 回源地址列表,即视频直播从源站拉取直播流时访问的地址列表。支持 RTMP、RTMPS、FLV 或 HLS 协议。 // 通常包含协议、源站的域名或 IP 地址,以及源站直播流的 AppName 和 StreamName。如果源站要求回源请求携带额外参数,还需包含查询参数。例如 rtmp://192.*.*.10/live01/test01?token=abc。 // note: // <li> 支持配置自有源站或第三方源站的回源地址。触发回源后,视频直播会访问您配置的回源地址,从源站拉取直播流。 </li> // <li> 如果源站使用非默认端口,需在源站的域名或 IP 地址后填写端口,例如 rtmp://192.*.*.10:1936/live01/test01?token=abc,否则系统可能按默认端口访问源站,导致回源失败。 </li> // <li> 最多支持传入 10 个回源地址。系统会按照回源地址在数组中的排列顺序依次尝试回源,数组中越靠前的地址优先级越高。如果当前回源地址回源失败,系统会再尝试下一个回源地址。 </li> List<String> SrcAddrS = new ArrayList<>(); SrcAddrS.add("rtmp://live.example.com/live01/test01"); body.setSrcAddrS(SrcAddrS); // 回源开始时间。Unix 时间戳,单位为秒。 // note: // <li> StartTime 和 EndTime 的时间间隔不可超过 7 天。 </li> // <li> StartTime 和 EndTime 需同时传入或同时不传。传入时,表示更新固定回源类型的回源时间,或将永久回源类型变更为固定回源类型并设置回源时间。不传时,表示更新为永久回源类型。 </li> body.setStartTime(1785923506); // 回源结束时间。Unix 时间戳,单位为秒。 // note: // <li> StartTime 和 EndTime 的时间间隔不可超过 7 天。 </li> // <li> StartTime 和 EndTime 需同时传入或同时不传。传入时,表示更新固定回源类型的回源时间,或将永久回源类型变更为固定回源类型并设置回源时间。不传时,表示更新为永久回源类型。 </li> body.setEndTime(1785953506); try { UpdateRelaySourceV4Res resp = service.updateRelaySourceV4(body); System.out.println(resp); } catch (Exception e) { e.printStackTrace(); } } }
您可以调用 ListRelaySourceV4 接口查询固定触发回源配置列表。详细的参数说明可参见 ListRelaySourceV4 接口文档。
接口调用示例如下所示。
package com.volcengine.live.demo; import com.volcengine.model.live.v20230101.*; import com.volcengine.service.live.v20230101.LiveService; public class ListRelaySourceV4Demo { public static void main(String[] args) { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里,否则可能导致 AccessKey 泄露,威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY,来实现 API 访问的身份验证。运行代码示例前,请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY LiveService service = LiveService.getInstance(); service.setAccessKey(System.getenv("VOLC_ACCESSKEY")); service.setSecretKey(System.getenv("VOLC_SECRETKEY")); ListRelaySourceV4Body body = new ListRelaySourceV4Body(); // 域名空间。 // 通过以下任一方式,获取域名空间: // <li> 调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口,通过返回参数 Vhost 获取。 </li> // <li> 在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面,通过**域名空间**字段获取。 </li> body.setVhost("pull.example.com"); // 查询数据的页码,默认值为 1,表示查询第一页的数据。 body.setPage(1); // 每页显示的数据条数,默认值为 20,最大值为 500。 body.setSize(20); try { ListRelaySourceV4Res resp = service.listRelaySourceV4(body); System.out.println(resp); } catch (Exception e) { e.printStackTrace(); } } }