| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void closeRTPServer(String deviceId, String channelId, String stream) { |
|---|
| | | String mediaServerId = streamSession.getMediaServerId(deviceId, channelId, stream); |
|---|
| | | String ssrc = streamSession.getSSRC(deviceId, channelId, stream); |
|---|
| | | MediaServerItem mediaServerItem = this.getOne(mediaServerId); |
|---|
| | | if (mediaServerItem != null) { |
|---|
| | | String streamId = String.format("%s_%s", deviceId, channelId); |
|---|
| | | zlmrtpServerFactory.closeRTPServer(mediaServerItem, streamId); |
|---|
| | | releaseSsrc(mediaServerItem.getId(), ssrc); |
|---|
| | | public void closeRTPServer(MediaServerItem mediaServerItem, String streamId) { |
|---|
| | | if (mediaServerItem == null) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | streamSession.remove(deviceId, channelId, stream); |
|---|
| | | zlmrtpServerFactory.closeRTPServer(mediaServerItem, streamId); |
|---|
| | | releaseSsrc(mediaServerItem.getId(), streamId); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void closeRTPServer(String mediaServerId, String streamId) { |
|---|
| | | MediaServerItem mediaServerItem = this.getOne(mediaServerId); |
|---|
| | | closeRTPServer(mediaServerItem, streamId); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | |
|---|
| | | Map<String, Object> param = new HashMap<>(); |
|---|
| | | param.put("api.secret",mediaServerItem.getSecret()); // -profile:v Baseline |
|---|
| | | param.put("ffmpeg.cmd","%s -fflags nobuffer -i %s -c:a aac -strict -2 -ar 44100 -ab 48k -c:v libx264 -f flv %s"); |
|---|
| | | param.put("hook.enable","1"); |
|---|
| | | param.put("hook.on_flow_report",String.format("%s/on_flow_report", hookPrex)); |
|---|
| | | param.put("hook.on_play",String.format("%s/on_play", hookPrex)); |
|---|
