观看直播

刺骨的言语ヽ痛彻心扉 2022-12-21 10:53 161阅读 0赞

/**
         * 观看直播
         * @param userId  学员id
         * @param classId 课程id
         * @param layId   课程编排ID
         * @return
         */
        @PostMapping("/lookLive")
        public ResultBean lookLive(String userId,String classId,String layId){
            String data = "$"+ DateUtils.dateTimeNow()+"$"+"live/"+layId+"$3";
            // 随机生成的16位数字和字母组合
            String sixth = StringUtils.getItemID(16);
            byte[] ivBytes = sixth.getBytes();
            String msg = LiveConfig.aesCbcEncrypt(data, ivBytes, LiveConfig.getKey().getBytes());
            String auth_info = "";
            try {
                auth_info = URLEncoder.encode(msg, "UTF-8") + "." + LiveConfig.bytesToHexString(ivBytes);
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
            Map<String, Object> map = new HashMap<>();
            // 返回推流地址
            map.put("PUSHURL",LiveConfig.getPUSHURL()+layId);
            // 返回播流地址
            map.put("PULLURL",LiveConfig.getPULLURL()+layId+"?auth_info="+auth_info);  // 加鉴权
            return ResultBean.successOrFail("200","操作成功",map);
        }

package com.fandemi.config.HuaWeiLive;
    
    import javax.crypto.Cipher;
    import javax.crypto.spec.IvParameterSpec;
    import javax.crypto.spec.SecretKeySpec;
    
    import java.io.UnsupportedEncodingException;
    import java.net.URLEncoder;
    
    
    public class LiveConfig {
    
        //推流URL(返回给前端推流用)
        private static String PUSHURL = "rtmp://tui.yehe8848.com/live/";
        //播放URL(返回给前端播放用)
        private static String PULLURL = "rtmp://app.yehe8848.com/live/";
        //在直播控制台配置的Key值(播放鉴权 key 值)
        private static String key = "ZAkiWz0qLZrRgNqy";
    
        public static void main(String[] args) {
            // data="$"+<Timestamp>+"$"+<LiveID>+"$"+<CheckLevel>，具体请参见“鉴权方式C”
            String data = "$20201023110000$live/stream01$3";
            // 随机生成的16位数字和字母组合I33632I6ZLKO5213
            byte[] ivBytes = "yCmE666N3YAq30SN".getBytes();
            //在直播控制台配置的Key值
            byte[] key = "ZAkiWz0qLZrRgNqy".getBytes();
            String msg = aesCbcEncrypt(data, ivBytes, key);
            try {
                System.out.println(URLEncoder.encode(msg, "UTF-8") + "." + bytesToHexString(ivBytes));
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
        }
    
        public static String aesCbcEncrypt(String data, byte[] ivBytes, byte[] key) {
            try {
                SecretKeySpec sk = new SecretKeySpec(key, "AES");
                Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");
    
                if (ivBytes != null) {
                    cipher.init(Cipher.ENCRYPT_MODE, sk, new IvParameterSpec(ivBytes));
                } else {
                    cipher.init(Cipher.ENCRYPT_MODE, sk);
                }
    
                return Base64.encode(cipher.doFinal(data.getBytes("UTF-8")));
            } catch (Exception e) {
                return null;
            }
        }
    
        public static String bytesToHexString(byte[] src) {
            StringBuilder stringBuilder = new StringBuilder("");
            if ((src == null) || (src.length <= 0)) {
                return null;
            }
    
            for (int i = 0; i < src.length; i++) {
                int v = src[i] & 0xFF;
                String hv = Integer.toHexString(v);
                if (hv.length() < 2) {
                    stringBuilder.append(0);
                }
                stringBuilder.append(hv);
            }
            return stringBuilder.toString();
        }
    
        public static String getPUSHURL() {
            return PUSHURL;
        }
    
        public static void setPUSHURL(String PUSHURL) {
            LiveConfig.PUSHURL = PUSHURL;
        }
    
        public static String getPULLURL() {
            return PULLURL;
        }
    
        public static void setPULLURL(String PULLURL) {
            LiveConfig.PULLURL = PULLURL;
        }
    
        public static String getKey() {
            return key;
        }
    
        public static void setKey(String key) {
            LiveConfig.key = key;
        }
    }