| | |
| | | Map<String, Object> param = new HashMap<>(); |
| | | int newPort = getPortFromUdpPortRange(); |
| | | param.put("port", newPort); |
| | | param.put("enable_tcp", 0); |
| | | param.put("enable_tcp", 1); |
| | | param.put("stream_id", streamId); |
| | | JSONObject jsonObject = zlmresTfulUtils.openRtpServer(param); |
| | | if (jsonObject.getInteger("code") == 0) { |
| | | System.out.println(11111111); |
| | | System.out.println(streamId); |
| | | System.out.println(ssrc); |
| | | System.out.println(newPort); |
| | | System.out.println(jsonObject.toJSONString()); |
| | | return newPort; |
| | | }else { |
| | | return getNewRTPPort(streamId); |
| | | } else { |
| | | return getNewRTPPort(ssrc); |
| | | } |
| | | } |
| | | |
| | |
| | | udpPortRangeArray[1] = Integer.parseInt(udpPortRangeStrArray[1]); |
| | | } |
| | | |
| | | if (currentPort == 0 || currentPort ++ > udpPortRangeArray[1]) { |
| | | if (currentPort == 0 || currentPort++ > udpPortRangeArray[1]) { |
| | | currentPort = udpPortRangeArray[0]; |
| | | return udpPortRangeArray[0]; |
| | | }else { |
| | | return currentPort ++; |
| | | } else { |
| | | if (currentPort % 2 == 1) { |
| | | currentPort++; |
| | | } |
| | | return currentPort++; |
| | | } |
| | | } |
| | | } |