| | |
|---|
| | | import com.genersoft.iot.vmp.media.zlm.ZLMRTPServerFactory;
|
|---|
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
|
|---|
| | |
|
|---|
| | | import org.apache.log4j.Logger;
|
|---|
| | |
|
|---|
| | | import java.text.ParseException;
|
|---|
| | | import java.util.HashMap;
|
|---|
| | | import java.util.Map;
|
|---|
| | |
|---|
| | | String platformGbId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(FromHeader.NAME)).getAddress().getURI()).getUser();
|
|---|
| | | String channelId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(ToHeader.NAME)).getAddress().getURI()).getUser();
|
|---|
| | | SendRtpItem sendRtpItem = redisCatchStorage.querySendRTPServer(platformGbId, channelId);
|
|---|
| | | if (sendRtpItem == null) return;
|
|---|
| | | String streamId = sendRtpItem.getStreamId();
|
|---|
| | | Map<String, Object> param = new HashMap<>();
|
|---|
| | | param.put("vhost","__defaultVhost__");
|
|---|
| | | param.put("app","rtp");
|
|---|
| | | param.put("app",sendRtpItem.getApp());
|
|---|
| | | param.put("stream",streamId);
|
|---|
| | | System.out.println("停止向上级推流：" + streamId);
|
|---|
| | | zlmrtpServerFactory.stopSendRtpStream(param);
|
|---|
| | | redisCatchStorage.deleteSendRTPServer(platformGbId, channelId);
|
|---|
| | | if (zlmrtpServerFactory.totalReaderCount(streamId) == 0) {
|
|---|
| | | if (zlmrtpServerFactory.totalReaderCount(sendRtpItem.getApp(), streamId) == 0) {
|
|---|
| | | System.out.println(streamId + "无其它观看者，通知设备停止推流");
|
|---|
| | | cmder.streamByeCmd(streamId);
|
|---|
| | | cmder.streamByeCmd(sendRtpItem.getDeviceId(), channelId);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } catch (SipException e) {
|
|---|
