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

createByeRequest, createByeResponse

Browse Source
This commit is contained in:
shikong 2023-09-30 17:00:20 +08:00
parent 563fb03ea3
commit fde9332d9b
3 changed files with 21 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
gb28181-sip/src/main/java/cn/skcks/docking/gb28181/sip/method/invite/request/InviteRequestBuilder.java
View File

@ -24,7 +24,7 @@ import java.util.Date;
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true) @ToString(callSuper = true)
public class InviteRequestBuilder extends RequestBuilder implements InviteBuilder { public class InviteRequestBuilder extends RequestBuilder implements InviteBuilder {
private SubjectHeader createSubject(String senderId, String senderStreamId, String receiveId, String receiveStreamId){ private SubjectHeader createSubject(String senderId, String senderStreamId, String receiveId, String receiveStreamId) {
String subject = StringUtils.joinWith(",", String subject = StringUtils.joinWith(",",
// 发送者 channelId:流序号 // 发送者 channelId:流序号
StringUtils.joinWith(":", senderId, senderStreamId), StringUtils.joinWith(":", senderId, senderStreamId),
@ -33,8 +33,8 @@ public class InviteRequestBuilder extends RequestBuilder implements InviteBuilde
return SipBuilder.createSubjectHeader(subject); return SipBuilder.createSubjectHeader(subject);
} }
public Request createPlayInviteRequest(String callId, long cSeq, String channelId, String rtpIp, int rtpPort, String ssrc, MediaStreamMode mediaStreamMode, String receiveId){ public Request createPlayInviteRequest(String callId, long cSeq, String channelId, String rtpIp, int rtpPort, String ssrc, MediaStreamMode mediaStreamMode, String receiveId) {
GB28181Description description = GB28181SDPBuilder.Receiver.play(getTargetId(), channelId, Connection.IP4,rtpIp,rtpPort,ssrc,mediaStreamMode); GB28181Description description = GB28181SDPBuilder.Receiver.play(getTargetId(), channelId, Connection.IP4, rtpIp, rtpPort, ssrc, mediaStreamMode);
SIPRequest request = (SIPRequest) createRequest(METHOD, callId, cSeq, description); SIPRequest request = (SIPRequest) createRequest(METHOD, callId, cSeq, description);
Address address = request.getFrom().getAddress(); Address address = request.getFrom().getAddress();
@ -64,7 +64,7 @@ public class InviteRequestBuilder extends RequestBuilder implements InviteBuilde
} }
public Request createDownloadInviteRequest(String callId, long cSeq, String channelId, String rtpIp, int rtpPort, String ssrc, MediaStreamMode mediaStreamMode, String receiveId, Date startTime, Date endTime, Double downloadSpeed) { public Request createDownloadInviteRequest(String callId, long cSeq, String channelId, String rtpIp, int rtpPort, String ssrc, MediaStreamMode mediaStreamMode, String receiveId, Date startTime, Date endTime, Double downloadSpeed) {
GB28181Description description = GB28181SDPBuilder.Receiver.download(getTargetId(), channelId, Connection.IP4, rtpIp, rtpPort, ssrc, mediaStreamMode, startTime, endTime,downloadSpeed); GB28181Description description = GB28181SDPBuilder.Receiver.download(getTargetId(), channelId, Connection.IP4, rtpIp, rtpPort, ssrc, mediaStreamMode, startTime, endTime, downloadSpeed);
SIPRequest request = (SIPRequest) createRequest(METHOD, callId, cSeq, description); SIPRequest request = (SIPRequest) createRequest(METHOD, callId, cSeq, description);
Address address = request.getFrom().getAddress(); Address address = request.getFrom().getAddress();
@ -77,4 +77,8 @@ public class InviteRequestBuilder extends RequestBuilder implements InviteBuilde
public Request createDownloadInviteRequest(String callId, long cSeq, String channelId, String rtpIp, int rtpPort, String ssrc, MediaStreamMode mediaStreamMode, Date startTime, Date endTime, Double downloadSpeed) { public Request createDownloadInviteRequest(String callId, long cSeq, String channelId, String rtpIp, int rtpPort, String ssrc, MediaStreamMode mediaStreamMode, Date startTime, Date endTime, Double downloadSpeed) {
return createDownloadInviteRequest(callId, cSeq, channelId, rtpIp, rtpPort, ssrc, mediaStreamMode, String.valueOf(0), startTime, endTime, downloadSpeed); return createDownloadInviteRequest(callId, cSeq, channelId, rtpIp, rtpPort, ssrc, mediaStreamMode, String.valueOf(0), startTime, endTime, downloadSpeed);
} }
public Request createByeRequest(String callId, long cSeq) {
return createRequest(Request.BYE, callId, cSeq);
}
} }

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

@ -58,4 +58,12 @@ public class InviteResponseBuilder implements InviteBuilder {
public Response createTryingInviteResponse(Request request){ public Response createTryingInviteResponse(Request request){
return SipResponseBuilder.createResponse(Response.TRYING,request); return SipResponseBuilder.createResponse(Response.TRYING,request);
} }
public Response createByeResponse(Request request){
return createByeResponse(request, "");
}
public Response createByeResponse(Request request, String toTag){
return addHeader(SipResponseBuilder.createResponse(Response.OK,request), toTag);
}
} }

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

@ -98,6 +98,11 @@ public class RequestTest {
log.info("\n{}", tryingInviteResponse); log.info("\n{}", tryingInviteResponse);
inviteResponse = inviteResponseBuilder.createInviteResponse(downloadInviteRequest, senderRtp, senderRtpPort, SipUtil.nanoId()); inviteResponse = inviteResponseBuilder.createInviteResponse(downloadInviteRequest, senderRtp, senderRtpPort, SipUtil.nanoId());
log.info("\n{}", inviteResponse); log.info("\n{}", inviteResponse);
Request byeRequest = inviteRequestBuilder.createByeRequest(callId, 2);
log.info("\n{}", byeRequest);
Response byeResponse = inviteResponseBuilder.createByeResponse(byeRequest, SipUtil.nanoId());
log.info("\n{}", byeResponse);
} }