Просмотр исходного кода

修改到docker外运行环境

tags/v1.0.0^2
林万龙 4 лет назад
Родитель
Сommit
f63310cb98
1 измененных файлов: 18 добавлений и 6 удалений
  1. +18
    -6
      src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java

+ 18
- 6
src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java Просмотреть файл

@@ -58,10 +58,17 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
//通知客户端链接建立成功
// 默认返回取得时间成功
String ackAckCheckRef = "233E0101020004020A1D";
if (Integer.parseInt(nettyServerConfig.getPosAsycServerPort()) == channel.localAddress().getPort()) {
// if (Integer.parseInt(nettyServerConfig.getPosAsycServerPort()) == channel.localAddress().getPort()) {
// ackAckCheckRef = "233E010102000401091C";
// }
// if (Integer.parseInt(nettyServerConfig.getStarsAsycServerPort()) == channel.localAddress().getPort()) {
// ackAckCheckRef = "233E010102000421293C";
// }

if (9013 == channel.localAddress().getPort()) {
ackAckCheckRef = "233E010102000401091C";
}
if (Integer.parseInt(nettyServerConfig.getStarsAsycServerPort()) == channel.localAddress().getPort()) {
if (9012 == channel.localAddress().getPort()) {
ackAckCheckRef = "233E010102000421293C";
}
//String str = "通知客户端链接建立成功" + " " + LocalDateTime.now() + " " + channel.localAddress().getHostString() +
@@ -107,11 +114,16 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
// if (Integer.parseInt(posAsycServerPort) == channel.localAddress().getPort()) {

if (AST_POS_CMD.equals(recvmg)) {
// channelAns = dipperAstPosAsyncTaskService.pushAstPos(ipAddress,
// positionConfig.getCenterProvinceFilePath(),
// positionConfig.getCenterProvince(),
// positionConfig.getIpPositionRequestPath(),
// positionConfig.getIpPositionRequestKey());
channelAns = dipperAstPosAsyncTaskService.pushAstPos(ipAddress,
positionConfig.getCenterProvinceFilePath(),
positionConfig.getCenterProvince(),
positionConfig.getIpPositionRequestPath(),
positionConfig.getIpPositionRequestKey());
"/csv/provinceLonAlt.csv",
"湖北省",
"https://restapi.amap.com/v3/ip",
"65e794b0a1a4b87eeec86f93fea05411");
buf = Unpooled.buffer(channelAns.getBytes().length);
}



Загрузка…
Отмена
Сохранить