Java 实现阿里云直播推流在线列表查询

阿里云直播推流在线列表可以通过 API 的方式进行查询获取

更多精彩

• 更多技术博客，请移步 asing1elife’s blog

官网

查询推流在线列表

初始化配置

1. Constants.ALI_ACCESS_KEY_ID 是阿里云服务密钥 id ，所有服务共用
2. Constants.ALI_ACCESS_SECRET 是阿里云服务密钥，所有服务共用
3. 将客户端的初始化放置在静态块中可以保证配置只初始化一次

private static IAcsClient iAcsClient;

static {
    // 初始化配置
    String regionId = "cn-shanghai";
    DefaultProfile profile = DefaultProfile.getProfile(regionId, Constants.ALI_ACCESS_KEY_ID, Constants.ALI_ACCESS_SECRET);

    iAcsClient = new DefaultAcsClient(profile);

    // 本地调试
    // System.setProperty("http.proxyHost", "127.0.0.1");
    // System.setProperty("http.proxyPort", "8080");
}

查询推流在线列表

1. Constants.ALI_LIVE_PULL_URL 是阿里云直播的推流地址
2. Constants.ALI_LIVE_APP_NAME 是阿流云直播的应用名称
   • 如果不指定，则会查询出所有的应用的推流列表
   • 只能是单纯的应用名称，和阿里云直播控制台设置的保持一直
3. 获取到推流在线列表后，只需要进行流名称的匹配即可

public Boolean checkLiveBegin(String streamName) {
    // 查询推流在线列表
    DescribeLiveStreamsOnlineListRequest listRequest = new DescribeLiveStreamsOnlineListRequest();
    listRequest.setDomainName(Constants.ALI_LIVE_PULL_URL);
    listRequest.setAppName(Constants.ALI_LIVE_APP_NAME.replace("/", ""));

    try {
        DescribeLiveStreamsOnlineListResponse response = iAcsClient.getAcsResponse(listRequest);

        // 获取当前推流列表
        List<LiveStreamOnlineInfo> onlineInfos = response.getOnlineInfo();

        for (LiveStreamOnlineInfo onlineInfo : onlineInfos) {
            if (onlineInfo.getStreamName().equals(streamName)) {
                return true;
            }
        }

    } catch (ClientException e) {
        logger.error("获取拉流信息失败！", e);
    }

    return false;
}