Imdroid/security-monitor
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

1、增加ntrip proxy服务

Browse Source
This commit is contained in:
weidong 2024-06-06 15:00:17 +08:00
parent 4ffc6e732d
commit e2f95ff358
3 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
sec-ntrip-proxy/src/main/java/com/imdroid/ntripproxy/executor/D331RtcmMessageExecutor.java
View File

@ -28,7 +28,7 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
// 推送基站数据 // 推送基站数据
byte[] srcData = new byte[message.getSrcBuf().readableBytes()]; byte[] srcData = new byte[message.getSrcBuf().readableBytes()];
message.getSrcBuf().getBytes(0,srcData); message.getSrcBuf().getBytes(0,srcData);
rtcmClient.sendMessage(srcData); rtcmClient.send(srcData);
return null; return null;
} }

4
sec-ntrip-proxy/src/main/java/com/imdroid/ntripproxy/executor/D341GgaMessageExecutor.java
View File

@ -35,9 +35,9 @@ public class D341GgaMessageExecutor implements Executor<D341GgaMessage, Void> {
message.getSrcBuf().getBytes(0, srcData); message.getSrcBuf().getBytes(0, srcData);
// send to ntrip server // send to ntrip server
ntripClient.sendMessage(transData); ntripClient.sendWithDebug(transData);
// send to rtcm server // send to rtcm server
rtcmClient.sendMessage(srcData); rtcmClient.send(srcData);
} }
catch (Exception e){ catch (Exception e){
logger.error("Exception {}",e); logger.error("Exception {}",e);

13
sec-ntrip-proxy/src/main/java/com/imdroid/ntripproxy/service/UDPClient.java
View File

@ -1,5 +1,6 @@
package com.imdroid.ntripproxy.service; package com.imdroid.ntripproxy.service;
import com.imdroid.common.util.DataTypeUtil;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import java.net.DatagramPacket; import java.net.DatagramPacket;
@ -29,15 +30,19 @@ public class UDPClient {
} }
} }
public void sendMessage(byte[] data) { public void send(byte[] data) {
try { try {
/*if (logger.isDebugEnabled()) {
logger.debug("推送udp {}: {}", port, DataTypeUtil.getHexString(data));
}*/
DatagramPacket packet = new DatagramPacket(data, data.length, inetAddress, port); DatagramPacket packet = new DatagramPacket(data, data.length, inetAddress, port);
socket.send(packet); socket.send(packet);
} catch (Exception e) { } catch (Exception e) {
logger.error("推送异常:", e); logger.error("推送异常:", e);
} }
} }
public void sendWithDebug(byte[] data) {
if (logger.isDebugEnabled()) {
logger.debug("推送udp {}: {}", port, DataTypeUtil.getHexString(data));
}
send(data);
}
} }