七牛云直播 接口测试

参考：

1. 名词解释 直播空间： 类似直播间的分类 直播流： 类似直播间 直播域名： 直播以及观看直播，直播封面等url域名 直播推流：主播开启直播间 推流地址：主播开播连接的地址 直播拉流：观众获取直播间 播放地址：观众获取直播间的地址
2. 快速入门 略 有详细讲解
3. SDK 七牛云坑来了 GetHub先下好 慢慢看md 然后直接看接口
4. 进入正题 添加七牛云依赖

<dependency>
	<groupId>com.qiniu</groupId>
	<artifactId>qiniu-java-sdk</artifactId>
	<version>[7.2.0, 7.2.99]</version>
</dependency>

上工具类

@RequestMapping("/activeuser")
    public ResPonObject activeuser(HttpSession session, HttpServletRequest request,
                                   @RequestParam(value="groupId",required=false,defaultValue="") String  groupId){
          
   
        System.out.println(request.getHeader("Authorization"));
        System.out.println("==========获取正在推流的用户
 groupId:"+groupId);
        String[] list = QiNiu.listRoom(false, "test", null);
        List<ActiveUser> activeUserList = new ArrayList<>();
        for(String s: list){
          
   
            ActiveUser activeUser = new ActiveUser();
//            activeUser.setAvatarUrl("http://pili-snapshot.mokesv.com/"+s+"/"+s+".jpg");
            activeUser.setAvatarUrl("http://img4.imgtn.bdimg.com/it/u=3347054600,86785670&fm=26&gp=0.jpg");
            activeUser.setLiveTitle(s+"直播间");
            activeUser.setNickName(s+"主播");
            activeUser.setUserId(s);
            activeUserList.add(activeUser);
        }
        ResPonObject resPonObject = new ResPonObject();
        resPonObject.setData(activeUserList);
        return resPonObject;
    }

· 获取RTMP的推流或者播放地址

/**
     * 获取推流地址 （直播）
     * @param session
     * @param request
     * @return
     */
    @RequestMapping("/publish")
    public ResPonObject publish(HttpSession session, HttpServletRequest request){
          
   
        System.out.println("获取推流地址:"+request.getHeader("Authorization"));
        String urlRtmp = QiNiu.urlPublish("test-003",5*60);
        System.out.println("推流地址："+urlRtmp);
        Map<String,String> param = new HashMap<>();
        param.put("url",urlRtmp);
        param.get("url");
        ResPonObject resPonObject = new ResPonObject();
        resPonObject.setData(param);
        return resPonObject;
    }

    /**
     * 获取拉流地址 （看直播）
     * @param request authToken
     * @param userId 直播流名
     * @return
     */
    @RequestMapping("/play")
    public ResPonObject play(HttpSession session, HttpServletRequest request,
                             @RequestParam(value="userId",required=false,defaultValue="") String  userId){
          
   
        System.out.println("获取拉流地址:"+request.getHeader("Authorization"));
        String urlRtmp = QiNiu.urlPlay(userId);
        System.out.println("拉流地址："+urlRtmp);
        Map<String,String> param = new HashMap<>();
        param.put("url",urlRtmp);
        ResPonObject resPonObject = new ResPonObject();
        resPonObject.setData(param);
        return resPonObject;
    }

返回数据对象封装