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

添加 deviceProxy 配置

Browse Source
This commit is contained in:
shikong 2023-09-14 16:53:02 +08:00
parent bfc5db85ae
commit 8c874a8886
5 changed files with 85 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/config/sip/DeviceProxyConfig.java Normal file
View File

@ -0,0 +1,12 @@
package cn.skcks.docking.gb28181.mocking.config.sip;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
@Data
@Configuration
@ConfigurationProperties(prefix = "proxy.device")
public class DeviceProxyConfig {
private String url;
}

45
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/core/sip/message/processor/invite/request/InviteRequestProcessor.java
View File

@ -4,11 +4,12 @@ import cn.hutool.core.date.DateUtil;
import cn.skcks.docking.gb28181.core.sip.gb28181.sdp.GB28181Description;
import cn.skcks.docking.gb28181.core.sip.listener.SipListener;
import cn.skcks.docking.gb28181.core.sip.message.processor.MessageProcessor;
import cn.skcks.docking.gb28181.core.sip.utils.SipUtil;
import cn.skcks.docking.gb28181.mocking.core.sip.gb28181.sdp.GB28181DescriptionParser;
import cn.skcks.docking.gb28181.mocking.core.sip.response.SipResponseBuilder;
import cn.skcks.docking.gb28181.mocking.core.sip.sender.SipSender;
import cn.skcks.docking.gb28181.mocking.orm.mybatis.dynamic.mapper.MockingDeviceMapper;
import cn.skcks.docking.gb28181.mocking.orm.mybatis.dynamic.model.MockingDevice;
import cn.skcks.docking.gb28181.mocking.service.device.DeviceProxyService;
import cn.skcks.docking.gb28181.mocking.service.device.DeviceService;
import gov.nist.javax.sdp.TimeDescriptionImpl;
import gov.nist.javax.sdp.fields.TimeField;
import gov.nist.javax.sip.message.SIPRequest;
@ -24,9 +25,9 @@ import javax.sdp.MediaDescription;
import javax.sdp.SdpParseException;
import javax.sdp.SessionName;
import javax.sip.RequestEvent;
import javax.sip.header.CallIdHeader;
import javax.sip.message.Request;
import javax.sip.message.Response;
import java.util.Date;
import java.util.EventObject;
import java.util.Vector;
@ -38,7 +39,9 @@ public class InviteRequestProcessor implements MessageProcessor {
private final SipSender sender;
private final MockingDeviceMapper mockingDeviceMapper;
private final DeviceProxyService deviceProxyService;
private final DeviceService deviceService;
@PostConstruct
@Override
@ -52,13 +55,18 @@ public class InviteRequestProcessor implements MessageProcessor {
public void process(EventObject eventObject) {
RequestEvent requestEvent = (RequestEvent) eventObject;
SIPRequest request = (SIPRequest)requestEvent.getRequest();
String deviceId = SipUtil.getUserIdFromFromHeader(request);
CallIdHeader callIdHeader = request.getCallIdHeader();
String senderIp = request.getLocalAddress().getHostAddress();
String transport = request.getTopmostViaHeader().getTransport();
String content = new String(request.getRawContent());
GB28181Description gb28181Description = new GB28181DescriptionParser(content).parse();
log.info("解析的 sdp信息: \n{}", gb28181Description);
String id = gb28181Description.getOrigin().getUsername();
MockingDevice device = deviceService.getDeviceByGbChannelId(id).orElse(null);
if(device == null){
log.error("未能找到 deviceId: {} 的相关信息", id);
sender.sendResponse(senderIp, transport, notFound(request));
return;
}
Vector<?> mediaDescriptions = gb28181Description.getMediaDescriptions(true);
log.info("mediaDescriptions {}",mediaDescriptions);
mediaDescriptions.stream().filter(item->{
@ -79,9 +87,9 @@ public class InviteRequestProcessor implements MessageProcessor {
if(StringUtils.equalsAnyIgnoreCase(type,"Play","PlayBack")){
log.info("点播/回放请求");
if(StringUtils.equalsIgnoreCase(type,"Play")){
play(gb28181Description, (MediaDescription) item);
play(device, gb28181Description, (MediaDescription) item);
} else {
playback(gb28181Description, (MediaDescription) item);
playback(device, gb28181Description, (MediaDescription) item);
}
} else if(StringUtils.equalsIgnoreCase(type,"Download")){
log.info("下载请求");
@ -98,6 +106,11 @@ public class InviteRequestProcessor implements MessageProcessor {
});
}
private SipSender.SendResponse notFound(SIPRequest request) {
return (provider, ip, port) -> SipResponseBuilder.response(request, Response.NOT_FOUND,
"Not Found");
}
private SipSender.SendResponse unsupported(SIPRequest request) {
return (provider, ip, port) -> SipResponseBuilder.response(request, Response.UNSUPPORTED_MEDIA_TYPE,
"Unsupported Media Type");
@ -109,11 +122,11 @@ public class InviteRequestProcessor implements MessageProcessor {
* @param mediaDescription 媒体描述符
*/
@SneakyThrows
private void play(GB28181Description gb28181Description, MediaDescription mediaDescription){
private void play(MockingDevice device,GB28181Description gb28181Description, MediaDescription mediaDescription){
TimeField time = new TimeField();
time.setStart(DateUtil.offsetMinute(DateUtil.date(), -15));
time.setStop(DateUtil.date());
playback(gb28181Description, mediaDescription, time);
playback(device, gb28181Description, mediaDescription, time);
}
/**
@ -122,15 +135,17 @@ public class InviteRequestProcessor implements MessageProcessor {
* @param mediaDescription 媒体描述符
*/
@SneakyThrows
private void playback(GB28181Description gb28181Description, MediaDescription mediaDescription) {
private void playback(MockingDevice device,GB28181Description gb28181Description, MediaDescription mediaDescription) {
TimeDescriptionImpl timeDescription = (TimeDescriptionImpl) gb28181Description.getTimeDescriptions(true).get(0);
TimeField time = (TimeField) timeDescription.getTime();
playback(gb28181Description, mediaDescription, time);
playback(device, gb28181Description, mediaDescription, time);
}
@SneakyThrows
private void playback(GB28181Description gb28181Description, MediaDescription mediaDescription, TimeField time){
log.info("{} ~ {}", time.getStart(), time.getStop());
private void playback(MockingDevice device,GB28181Description gb28181Description, MediaDescription mediaDescription, TimeField time){
Date start = time.getStart();
Date stop = time.getStop();
log.info("{} ~ {}", start, time.getStop());
String channelId = gb28181Description.getOrigin().getUsername();
log.info("通道id: {}", channelId);
String address = gb28181Description.getOrigin().getAddress();
@ -138,6 +153,8 @@ public class InviteRequestProcessor implements MessageProcessor {
Media media = mediaDescription.getMedia();
int port = media.getMediaPort();
log.info("目标端口号: {}", port);
deviceProxyService.proxyVideo2Rtp(device,start,stop);
// TODO 推流 && 关流事件订阅
}
}

36
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java Normal file
View File

@ -0,0 +1,36 @@
package cn.skcks.docking.gb28181.mocking.service.device;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.URLUtil;
import cn.skcks.docking.gb28181.mocking.config.sip.DeviceProxyConfig;
import cn.skcks.docking.gb28181.mocking.orm.mybatis.dynamic.model.MockingDevice;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.util.HashMap;
@Slf4j
@Service
@RequiredArgsConstructor
public class DeviceProxyService {
private final DeviceService deviceService;
private final DeviceProxyConfig proxyConfig;
public void proxyVideo2Rtp(MockingDevice device, Date startTime, Date endTime){
String url = URLUtil.completeUrl(proxyConfig.getUrl(), "/video");
HashMap<String, String> map = new HashMap<>(3);
String deviceCode = device.getDeviceCode();
map.put("device_id", deviceCode);
map.put("begin_time", DateUtil.format(startTime, DatePattern.PURE_DATETIME_FORMAT));
map.put("end_time", DateUtil.format(endTime, DatePattern.PURE_DATETIME_FORMAT));
String query = URLUtil.buildQuery(map, StandardCharsets.UTF_8);
url = StringUtils.joinWith("?",url,query);
log.info("设备: {} 视频 url: {}", deviceCode, url);
}
}

3
gb28181-mocking-starter/src/main/resources/application-local.yml
View File

@ -69,3 +69,6 @@ media:
id: amrWMKmbKqoBjRQ9
# secret: 035c73f7-bb6b-4889-a715-d9eb2d1925cc
secret: 4155cca6-2f9f-11ee-85e6-8de4ce2e7333
proxy:
device:
url: http://192.168.2.3:18183

3
gb28181-mocking-starter/src/main/resources/application.yml
View File

@ -67,3 +67,6 @@ media:
id: amrWMKmbKqoBjRQ9
# secret: 035c73f7-bb6b-4889-a715-d9eb2d1925cc
secret: 4155cca6-2f9f-11ee-85e6-8de4ce2e7333
proxy:
device:
url: http://192.168.2.3:18183