视频直播生成推流地址和播放地址的程序示例(Java)

本文涉及的产品
视频直播,500GB 1个月
.cn 域名,1个 12个月
简介: 直播推流地址和播放地址本身没有API接口,需要在客户端自行拼接地址,然后使用推流工具或者播放器对其推流或播放。本文主要介绍如何生成直播的推流以及播放地址(Java示例代码)
import java.math.BigInteger;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import org.apache.commons.lang3.*;
public class Create_Live_Url {
 
 /**
  * 计算md5
  * @param param
  * @return
  */
 public static String md5(String param) {
  if(param == null || param.length() == 0) {
   return null;
  }
  try {
   MessageDigest md5 = MessageDigest.getInstance("MD5");
   md5.update(param.getBytes());
   byte[] byteArray = md5.digest();
   
   BigInteger bigInt = new BigInteger(1, byteArray);
                 // 参数16表示16进制
   String result = bigInt.toString(16);
                 // 不足32位高位补零
   while(result.length() < 32) {
    result = "0" + result;
   }
   return result;
  } catch (NoSuchAlgorithmException e) {
   e.printStackTrace();
  }
  return null;
 }
/**
     * 生成推流地址
     * @param pushDomain 推流域名
     * @param pushKey 推流域名配置的鉴权Key
     * @param appName 推流AppName
     * @param streamName 推流StreamName
     * @param expireTime 过期时间(单位是秒)
     */
 public static void generate_push_url(String pushDomain,String pushKey,String appName,String streamName,long expireTime) {
  String pushUrl = "";
  //推流域名未开启鉴权功能的情况下
  if(pushKey=="") {
   pushUrl = "rtmp://"+pushDomain+"/"+appName+"/"+streamName;
  }else {
   long timeStamp = System.currentTimeMillis()/1000L + expireTime;
   String stringToMd5 = "/"+appName+"/"+streamName+"-"+Long.toString(timeStamp)+"-0-0-"+pushKey;
   String authKey = md5(stringToMd5);
   pushUrl = "rtmp://"+pushDomain+"/"+appName+"/"+streamName+"?auth_key="+Long.toString(timeStamp)+"-0-0-"+authKey;
  }
  System.out.println("推流地址是: "+pushUrl);
 }
/**
  * 生成播放地址
  * @param pullDomain 播放域名
  * @param pullKey 播放鉴权Key
  * @param appName 播放appName(同推流appName)
  * @param streamName 播放streamName (同推流streamName)
  * @param expireTime 过期时间(单位是秒
  */
 public static void general_pull_url(String pullDomain,String pullKey,String appName,String streamName,long expireTime) {
  String rtmpUrl = ""; //rtmp的拉流地址
  String hlsUrl = "";  //m3u8的拉流地址
  String flvUrl = "";  //flv的拉流地址
  //播放域名未配置鉴权Key的情况下
  if(pullKey == "") {
   rtmpUrl = "rtmp://"+pullDomain+"/"+appName+"/"+streamName;
   hlsUrl = "http://"+pullDomain+"/"+appName+"/"+streamName+".m3u8";
   flvUrl = "http://"+pullDomain+"/"+appName+"/"+streamName+".flv";
  }else {
   long timeStamp = System.currentTimeMillis()/1000L + expireTime;
   String rtmpToMd5 = "/"+appName+"/"+streamName+"-"+Long.toString(timeStamp)+"-0-0-"+pullKey;
   String rtmpAuthKey = md5(rtmpToMd5);
   rtmpUrl = "rtmp://"+pullDomain+"/"+appName+"/"+streamName+"?auth_key="+Long.toString(timeStamp)+"-0-0-"+rtmpAuthKey;
   
   String hlsToMd5 = "/"+appName+"/"+streamName+".m3u8-"+Long.toString(timeStamp)+"-0-0-"+pullKey;
   String hlsAuthKey = md5(hlsToMd5);
   hlsUrl = "http://"+pullDomain+"/"+appName+"/"+streamName+".m3u8"+"?auth_key="+Long.toString(timeStamp)+"-0-0-"+hlsAuthKey;
   
   String flvToMd5 = "/"+appName+"/"+streamName+".flv-"+Long.toString(timeStamp)+"-0-0-"+pullKey;
   String flvAuthKey = md5(flvToMd5);
   flvUrl = "http://"+pullDomain+"/"+appName+"/"+streamName+".flv"+"?auth_key="+Long.toString(timeStamp)+"-0-0-"+flvAuthKey;
  }
  System.out.println("RTMP播放地址为: "+rtmpUrl);
  System.out.println("m3u8播放地址为: "+hlsUrl);
  System.out.println("flv播放地址为: "+flvUrl);
 }
public static void main(String[] args) {
  // TODO Auto-generated method stub
  //生成长度为5的随机字符串作为appName和streamName(字母和数字组合)
  String appName = RandomStringUtils.randomAlphanumeric(5);;
  String streamName = RandomStringUtils.randomAlphanumeric(5);;
  
  long expireTime = 3600L;
  String pullDomain = "mxl-pull.pier39.cn";
  String pullKey = "querty1234";
    
     String pushDomain = "mxl-push.pier39.cn";
  String pushKey = "querty123";
  Create_Live_Url.general_pull_url(pullDomain, pullKey, appName, streamName, expireTime);
  Create_Live_Url.generate_push_url(pushDomain, pushKey, appName, streamName, expireTime);
 }

}
相关文章
|
12天前
|
Java
Java开发实现图片URL地址检验,如何编码?
【10月更文挑战第14天】Java开发实现图片URL地址检验,如何编码?
42 4
|
21天前
|
Java 流计算
利用java8 的 CompletableFuture 优化 Flink 程序
本文探讨了Flink使用avatorscript脚本语言时遇到的性能瓶颈,并通过CompletableFuture优化代码,显著提升了Flink的QPS。文中详细介绍了avatorscript的使用方法,包括自定义函数、从Map中取值、使用Java工具类及AviatorScript函数等,帮助读者更好地理解和应用avatorscript。
利用java8 的 CompletableFuture 优化 Flink 程序
|
2月前
|
XML 存储 JSON
Java程序部署
Java程序部署
|
6天前
|
Web App开发 Java
使用java操作浏览器的工具selenium-java和webdriver下载地址
【10月更文挑战第12天】Selenium-java依赖包用于自动化Web测试,版本为3.141.59。ChromeDriver和EdgeDriver分别用于控制Chrome和Edge浏览器,需确保版本与浏览器匹配。示例代码展示了如何使用Selenium-java模拟登录CSDN,包括设置驱动路径、添加Cookies和获取页面源码。
|
11天前
|
Java Maven 数据安全/隐私保护
如何实现Java打包程序的加密代码混淆,避免被反编译?
【10月更文挑战第15天】如何实现Java打包程序的加密代码混淆,避免被反编译?
23 2
|
14天前
|
安全 Java Linux
java程序设置开机自启
java程序设置开机自启
|
17天前
|
运维 Java Linux
【运维基础知识】Linux服务器下手写启停Java程序脚本start.sh stop.sh及详细说明
### 启动Java程序脚本 `start.sh` 此脚本用于启动一个Java程序,设置JVM字符集为GBK,最大堆内存为3000M,并将程序的日志输出到`output.log`文件中,同时在后台运行。 ### 停止Java程序脚本 `stop.sh` 此脚本用于停止指定名称的服务(如`QuoteServer`),通过查找并终止该服务的Java进程,输出操作结果以确认是否成功。
24 1
|
2月前
|
消息中间件 分布式计算 Java
Linux环境下 java程序提交spark任务到Yarn报错
Linux环境下 java程序提交spark任务到Yarn报错
36 5
|
2月前
|
Java 编译器 数据库连接
探索Java中的异常处理:提升程序的鲁棒性
【9月更文挑战第25天】在Java的世界里,异常是那些不请自来、令人头疼的“客人”。它们悄无声息地潜入我们的代码,一旦出现,便可能导致程序崩溃或行为异常。但是,如果能够妥善管理这些异常,我们就能将潜在的灾难转变为增强程序鲁棒性和用户体验的机会。本文将通过深入浅出的方式,带领读者理解Java异常处理的重要性,并提供实用的策略来优雅地处理这些意外情况。让我们一起学习如何在Java中捕捉、处理和预防异常,确保我们的程序即使在面对不可预见的错误时也能保持稳健运行。
|
19天前
|
Java Python
如何通过Java程序调用python脚本
如何通过Java程序调用python脚本
13 0