| | |
|---|
| | | import gov.nist.javax.sdp.fields.TimeField; |
|---|
| | | import gov.nist.javax.sip.address.AddressImpl; |
|---|
| | | import gov.nist.javax.sip.address.SipUri; |
|---|
| | | import gov.nist.javax.sip.header.Subject; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import org.springframework.beans.factory.InitializingBean; |
|---|
| | |
|---|
| | | import javax.sip.address.SipURI; |
|---|
| | | import javax.sip.header.CallIdHeader; |
|---|
| | | import javax.sip.header.FromHeader; |
|---|
| | | import javax.sip.header.Header; |
|---|
| | | import javax.sip.message.Request; |
|---|
| | | import javax.sip.message.Response; |
|---|
| | | import java.text.ParseException; |
|---|
| | |
|---|
| | | try { |
|---|
| | | Request request = evt.getRequest(); |
|---|
| | | SipURI sipURI = (SipURI) request.getRequestURI(); |
|---|
| | | String channelId = sipURI.getUser(); |
|---|
| | | //从subject读取channelId,不再从request-line读取。 有些平台request-line是平台国标编码，不是设备国标编码。 |
|---|
| | | //String channelId = sipURI.getUser(); |
|---|
| | | String channelId = SipUtils.getChannelIdFromHeader(request); |
|---|
| | | String requesterId = SipUtils.getUserIdFromFromHeader(request); |
|---|
| | | CallIdHeader callIdHeader = (CallIdHeader)request.getHeader(CallIdHeader.NAME); |
|---|
| | | if (requesterId == null || channelId == null) { |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (playTransaction == null) { |
|---|
| | | SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, null, true); |
|---|
| | | String streamId = null; |
|---|
| | | if (mediaServerItem.isRtpEnable()) { |
|---|
| | | sendRtpItem.setStreamId(String.format("%s_%s", device.getDeviceId(), channelId)); |
|---|
| | | }else { |
|---|
| | | sendRtpItem.setStreamId(ssrcInfo.getStream()); |
|---|
| | | streamId = String.format("%s_%s", device.getDeviceId(), channelId); |
|---|
| | | } |
|---|
| | | SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, streamId, true); |
|---|
| | | sendRtpItem.setStreamId(ssrcInfo.getStream()); |
|---|
| | | // 写入redis， 超时时回复 |
|---|
| | | redisCatchStorage.updateSendRTPSever(sendRtpItem); |
|---|
| | | playService.play(mediaServerItem, ssrcInfo, device, channelId, hookEvent, errorEvent, (code, msg)->{ |
|---|
