1、增加打印查找断点续传数据不连续的问题
This commit is contained in:
parent
f379f9d160
commit
37dba4ce37
@ -87,7 +87,7 @@ public class MultiLineGNSSCalcService {
|
|||||||
// 查找序号不连续的问题
|
// 查找序号不连续的问题
|
||||||
i++;
|
i++;
|
||||||
if(i==1) logger.info("d342: 1st d341 seq {}", message.getSeq());
|
if(i==1) logger.info("d342: 1st d341 seq {}", message.getSeq());
|
||||||
else if(i==d341Count) logger.info("d342: {}th d341 seq ",d341Count,message.getSeq());
|
else if(i==d341Count) logger.info("d342: {}th d341 seq {}",d341Count,message.getSeq());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else if(lastD342Time != null){
|
else if(lastD342Time != null){
|
||||||
|
|||||||
@ -2,6 +2,7 @@ package com.imdroid.sideslope.server.udp;
|
|||||||
|
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
||||||
|
import io.netty.channel.ChannelOption;
|
||||||
import io.netty.channel.EventLoopGroup;
|
import io.netty.channel.EventLoopGroup;
|
||||||
import io.netty.channel.nio.NioEventLoopGroup;
|
import io.netty.channel.nio.NioEventLoopGroup;
|
||||||
import io.netty.channel.socket.nio.NioDatagramChannel;
|
import io.netty.channel.socket.nio.NioDatagramChannel;
|
||||||
@ -43,8 +44,8 @@ public class RtcmUdpServer implements ApplicationRunner {
|
|||||||
Bootstrap bootstrap = new Bootstrap();
|
Bootstrap bootstrap = new Bootstrap();
|
||||||
bootstrap.group(group)
|
bootstrap.group(group)
|
||||||
.channel(NioDatagramChannel.class)
|
.channel(NioDatagramChannel.class)
|
||||||
//.option(ChannelOption.SO_SNDBUF, 512) //让系统自动设置
|
.option(ChannelOption.SO_SNDBUF, 1024*1024) //1M缓存,考虑1000个基站同时转发
|
||||||
//.option(ChannelOption.SO_RCVBUF, 512)
|
.option(ChannelOption.SO_RCVBUF, 1024*1024)//1M缓存,断点续传要大带宽
|
||||||
.handler(rtcmUdpHandler);
|
.handler(rtcmUdpHandler);
|
||||||
try {
|
try {
|
||||||
ChannelFuture future = bootstrap.bind(port).sync().channel().closeFuture();
|
ChannelFuture future = bootstrap.bind(port).sync().channel().closeFuture();
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user