| | |
|---|
| | | int result = -1; |
|---|
| | | // 查询此rtp server 是否已经存在 |
|---|
| | | JSONObject rtpInfo = zlmresTfulUtils.getRtpInfo(mediaServerItem, streamId); |
|---|
| | | if (rtpInfo != null && rtpInfo.getInteger("code") == 0 && rtpInfo.getBoolean("exist")) { |
|---|
| | | result = rtpInfo.getInteger("local_port"); |
|---|
| | | if(rtpInfo.getInteger("code") == 0){ |
|---|
| | | if (rtpInfo.getBoolean("exist")) { |
|---|
| | | result = rtpInfo.getInteger("local_port"); |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | }else if(rtpInfo.getInteger("code") == -2){ |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | |
|---|
| | | Map<String, Object> param = new HashMap<>(); |
|---|
| | | // 推流端口设置0则使用随机端口 |
|---|
| | | param.put("enable_tcp", 1); |
|---|
| | |
|---|
| | | */ |
|---|
| | | public int totalReaderCount(MediaServerItem mediaServerItem, String app, String streamId) { |
|---|
| | | JSONObject mediaInfo = zlmresTfulUtils.getMediaInfo(mediaServerItem, app, "rtmp", streamId); |
|---|
| | | Integer code = mediaInfo.getInteger("code"); |
|---|
| | | if (mediaInfo == null) { |
|---|
| | | return 0; |
|---|
| | | } |
|---|
| | | Integer code = mediaInfo.getInteger("code"); |
|---|
| | | if ( code < 0) { |
|---|
| | | logger.warn("查询流({}/{})是否有其它观看者时得到： {}", app, streamId, mediaInfo.getString("msg")); |
|---|
| | | return -1; |
|---|
