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

1、修改ping应答的bug

Browse Source
This commit is contained in:
weidong 2025-08-31 18:11:01 +08:00
parent 6f01e78368
commit 8146ff1879
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D314PingMessageExecutor.java
View File

@ -5,6 +5,8 @@ import com.imdroid.sideslope.server.DeviceChannel;
import com.imdroid.sideslope.server.OnlineChannels; import com.imdroid.sideslope.server.OnlineChannels;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled; import io.netty.buffer.Unpooled;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
/** /**
@ -13,6 +15,7 @@ import org.springframework.stereotype.Component;
*/ */
@Component @Component
public class D314PingMessageExecutor implements Executor<D314PingMessage, Void> { public class D314PingMessageExecutor implements Executor<D314PingMessage, Void> {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
@Override @Override
public Void execute(D314PingMessage message) { public Void execute(D314PingMessage message) {
@ -24,6 +27,7 @@ public class D314PingMessageExecutor implements Executor<D314PingMessage, Void>
ByteBuf buf = Unpooled.buffer(); ByteBuf buf = Unpooled.buffer();
buf.writeBytes(forwardBytes); buf.writeBytes(forwardBytes);
deviceChannel.writeAndFlush(buf); deviceChannel.writeAndFlush(buf);
logger.info("{} ping ack",deviceId);
} }
return null; return null;