Shikong/gb28181-docking-platform
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

InviteResponseBuilder

Browse Source
This commit is contained in:
shikong 2023-09-30 04:01:41 +08:00
parent 84cd2110f4
commit f47fe2b10a
3 changed files with 77 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
gb28181-sip/src/main/java/cn/skcks/docking/gb28181/sip/method/invite/response/InviteResponseBuilder.java Normal file
View File

@ -0,0 +1,57 @@
package cn.skcks.docking.gb28181.sip.method.invite.response;
import cn.skcks.docking.gb28181.sdp.GB28181Description;
import cn.skcks.docking.gb28181.sdp.GB28181SDPBuilder;
import cn.skcks.docking.gb28181.sdp.parser.GB28181DescriptionParser;
import cn.skcks.docking.gb28181.sip.generic.SipBuilder;
import cn.skcks.docking.gb28181.sip.generic.SipContentType;
import cn.skcks.docking.gb28181.sip.generic.SipResponseBuilder;
import cn.skcks.docking.gb28181.sip.method.invite.InviteBuilder;
import gov.nist.javax.sip.message.SIPRequest;
import gov.nist.javax.sip.message.SIPResponse;
import lombok.Data;
import lombok.SneakyThrows;
import lombok.ToString;
import lombok.experimental.SuperBuilder;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import javax.sip.message.Request;
import javax.sip.message.Response;
@Slf4j
@Data
@SuperBuilder
@ToString(callSuper = true)
public class InviteResponseBuilder implements InviteBuilder {
@SneakyThrows
public Response createInviteResponse(Request request, GB28181Description gb28181Description, String toTag){
Response response = SipResponseBuilder.createResponse(Response.OK, request, SipContentType.SDP, gb28181Description);
return addHeader(response, toTag);
}
@SneakyThrows
public Response createInviteResponse(Request request, String rtpIp, int rtpPort){
return createInviteResponse(request, rtpIp, rtpPort, "");
}
@SneakyThrows
public Response createInviteResponse(Request request, String rtpIp, int rtpPort, String toTag){
SIPRequest sipRequest = (SIPRequest) request;
GB28181DescriptionParser receive = new GB28181DescriptionParser(new String(sipRequest.getRawContent()));
GB28181Description gb28181Description = GB28181SDPBuilder.Sender.build(receive.parse(), rtpIp, rtpPort);
Response response = SipResponseBuilder.createResponse(Response.OK, request, SipContentType.SDP, gb28181Description);
return addHeader(response, toTag);
}
@SneakyThrows
private Response addHeader(Response response, String toTag){
SIPResponse sipResponse = (SIPResponse) response;
if (StringUtils.isNotBlank(toTag)) {
sipResponse.getToHeader().setTag(toTag);
}
return SipBuilder.addHeaders(
response,
SipBuilder.createContactHeader(sipResponse.getFromHeader().getAddress()));
}
}

6
gb28181-sip/src/test/java/cn/skcks/docking/gb28181/sip/SipTest.java
View File

@ -1,14 +1,12 @@
package cn.skcks.docking.gb28181.sip;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
import cn.skcks.docking.gb28181.constant.GB28181Constant;
import cn.skcks.docking.gb28181.sip.generic.SipBuilder;
import cn.skcks.docking.gb28181.sip.generic.SipRequestBuilder;
import cn.skcks.docking.gb28181.sip.generic.SipResponseBuilder;
import cn.skcks.docking.gb28181.sip.header.GBDateHeader;
import cn.skcks.docking.gb28181.sip.header.XGBVerHeader;
import cn.skcks.docking.gb28181.sip.header.impl.XGBVerHeaderImpl;
import cn.skcks.docking.gb28181.sip.generic.SipRequestBuilder;
import cn.skcks.docking.gb28181.sip.generic.SipResponseBuilder;
import cn.skcks.docking.gb28181.sip.parser.GbStringMsgParserFactory;
import cn.skcks.docking.gb28181.sip.property.DefaultProperties;
import cn.skcks.docking.gb28181.sip.utils.SipUtil;

23
gb28181-sip/src/test/java/cn/skcks/docking/gb28181/sip/process/RequestTest.java
View File

@ -5,12 +5,14 @@ import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.RandomUtil;
import cn.skcks.docking.gb28181.constant.CmdType;
import cn.skcks.docking.gb28181.sdp.media.MediaStreamMode;
import cn.skcks.docking.gb28181.sip.generic.SipBuilder;
import cn.skcks.docking.gb28181.sip.manscdp.catalog.query.CatalogQueryDTO;
import cn.skcks.docking.gb28181.sip.manscdp.catalog.response.CatalogDeviceListDTO;
import cn.skcks.docking.gb28181.sip.manscdp.catalog.response.CatalogResponseDTO;
import cn.skcks.docking.gb28181.sip.manscdp.catalog.response.CatalogSubscribeResponseDTO;
import cn.skcks.docking.gb28181.sip.manscdp.keepalive.notify.KeepaliveNotifyDTO;
import cn.skcks.docking.gb28181.sip.method.invite.request.InviteRequestBuilder;
import cn.skcks.docking.gb28181.sip.method.invite.response.InviteResponseBuilder;
import cn.skcks.docking.gb28181.sip.method.message.request.MessageRequestBuilder;
import cn.skcks.docking.gb28181.sip.method.message.response.MessageResponseBuilder;
import cn.skcks.docking.gb28181.sip.method.notify.request.NotifyRequestBuilder;
@ -45,8 +47,11 @@ public class RequestTest {
public static final String domain = "4405010000";
public static final String rtpIp = "10.10.10.200";
public static int rtpPort = RandomUtil.randomInt(30000,50000);
public static final String receiveRtp = "10.10.10.200";
public static int receiveRtpPort = RandomUtil.randomInt(30000,40000);
public static final String senderRtp = "10.10.10.200";
public static int senderRtpPort = RandomUtil.randomInt(40000,50000);
@Test
void inviteTest(){
@ -69,20 +74,28 @@ public class RequestTest {
String playSsrc = "0" + ssrc;
// 1 开头的为历史
String playBackSsrc = "1" + ssrc;
InviteResponseBuilder inviteResponseBuilder = InviteResponseBuilder.builder().build();
// 实时点播请求
Request playInviteRequest = inviteRequestBuilder.createPlayInviteRequest(callId, 1, localId, rtpIp, rtpPort, playSsrc, MediaStreamMode.TCP_ACTIVE);
Request playInviteRequest = inviteRequestBuilder.createPlayInviteRequest(callId, 1, localId, receiveRtp, receiveRtpPort, playSsrc, MediaStreamMode.TCP_ACTIVE);
log.info("\n{}", playInviteRequest);
Response inviteResponse = inviteResponseBuilder.createInviteResponse(playInviteRequest, senderRtp, senderRtpPort, SipUtil.nanoId());
log.info("\n{}", inviteResponse);
Date now = DateUtil.date();
Date startTime = DateUtil.beginOfDay(DateUtil.offsetDay(now,-1));
Date endTime = DateUtil.endOfDay(DateUtil.offsetDay(now,-1));
// 回放请求
Request playbackInviteRequest = inviteRequestBuilder.createPlaybackInviteRequest(callId, 1, localId, rtpIp, rtpPort, playBackSsrc, MediaStreamMode.TCP_ACTIVE,startTime,endTime);
Request playbackInviteRequest = inviteRequestBuilder.createPlaybackInviteRequest(callId, 1, localId, receiveRtp, receiveRtpPort, playBackSsrc, MediaStreamMode.TCP_ACTIVE,startTime,endTime);
log.info("\n{}", playbackInviteRequest);
inviteResponse = inviteResponseBuilder.createInviteResponse(playbackInviteRequest, senderRtp, senderRtpPort, SipUtil.nanoId());
log.info("\n{}", inviteResponse);
// 下载请求
Request downloadInviteRequest = inviteRequestBuilder.createDownloadInviteRequest(callId, 1, localId, rtpIp, rtpPort, playBackSsrc, MediaStreamMode.TCP_ACTIVE,startTime,endTime,4.0);
Request downloadInviteRequest = inviteRequestBuilder.createDownloadInviteRequest(callId, 1, localId, receiveRtp, receiveRtpPort, playBackSsrc, MediaStreamMode.TCP_ACTIVE,startTime,endTime,4.0);
log.info("\n{}", downloadInviteRequest);
inviteResponse = inviteResponseBuilder.createInviteResponse(downloadInviteRequest, senderRtp, senderRtpPort, SipUtil.nanoId());
log.info("\n{}", inviteResponse);
}