| | |
| | | |
| | | @Resource |
| | | private RedisTemplate redisTemplate; |
| | | |
| | | @Resource |
| | | private DOWNConnectRspService downConnectRspService; |
| | | |
| | | |
| | | /** |
| | |
| | | */ |
| | | public void linkTest(ChannelHandlerContext ctx, OuterPacket out) { |
| | | if (!redisTemplate.hasKey("login:" + out.getGnsscenterId())) { |
| | | log.error("链路还未登录校验,拒绝连接"); |
| | | log.error("链路还未登录校验,拒绝连接:{}", out.getGnsscenterId()); |
| | | ctx.close(); |
| | | return; |
| | | } |
| | | int gnsscenterId = out.getGnsscenterId(); |
| | | //保存链路 |
| | | ChannelMap.addServerChannel(gnsscenterId, ctx.channel()); |
| | | OuterPacket rep = new OuterPacket(DataType.UP_LINKTEST_RSP.getCode(), null); |
| | | OuterPacket rep = new OuterPacket(DataType.UP_LINKTEST_RSP.getCode(), gnsscenterId, null); |
| | | rep.setGnsscenterId(gnsscenterId); |
| | | log.info("主链路连接保持应答({}):{}", DataType.UP_LINKTEST_RSP.getCode(), JSON.toJSONString(rep)); |
| | | ctx.writeAndFlush(rep); |
| | | //从链路保持请求 |
| | | downConnectRspService.downLinkTest(gnsscenterId); |
| | | } |
| | | } |