贝博粮情解析2

CZT

2023-09-27 3a97ed3e03c8969aef34d172bf46116596683bd3

 igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grainv1/client/ClientHandler.java

文件名从 igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/client/ClientHandler.java 修改
@@ -1,13 +1,12 @@
package com.ld.igds.protocol.beibo.grain.client;
package com.ld.igds.protocol.beibo.grainv1.client;

import com.ld.igds.protocol.beibo.grain.analysis.AnalysisService;
import com.ld.igds.protocol.beibo.grainv1.analysis.AnalysisService;
import com.ld.igds.util.BytesUtil;
import com.ld.igds.util.SpringUtil;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.util.internal.logging.InternalLogger;
import io.netty.util.internal.logging.InternalLoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;

import java.net.InetSocketAddress;

@@ -25,7 +24,7 @@
   public void channelActive(ChannelHandlerContext ctx) {
      InetSocketAddress insocket = (InetSocketAddress) ctx.channel()
            .remoteAddress();
      log.info("璐濆崥绮儏鍒嗘満鎴愬姛杩炴帴锛孖P={},port={}", insocket.getAddress()
      log.info("鍒嗘満鎴愬姛杩炴帴锛孖P={},port={}", insocket.getAddress()
            .getHostAddress(), insocket.getPort());
   }

@@ -36,7 +35,7 @@
      InetSocketAddress insocket = (InetSocketAddress) ctx.channel()
            .remoteAddress();

      log.info("璐濆崥绮儏鍒嗘満鏂紑杩炴帴锛孖P={},port={}", insocket.getAddress(),insocket.getPort());
      log.info("鍒嗘満鏂紑杩炴帴锛孖P={},port={}", insocket.getAddress(),insocket.getPort());
   }

   @Override
@@ -44,15 +43,15 @@
         throws Exception {
      byte[] bytes = (byte[]) msg;
      String result = BytesUtil.bytesToString(bytes);
      log.info("璐濆崥绮儏鍒嗘満杩斿洖淇℃伅=" + result);
      log.info("鍒嗘満杩斿洖淇℃伅=" + result);

      InetSocketAddress insocket = (InetSocketAddress) ctx.channel().remoteAddress();
//      InetSocketAddress insocket = (InetSocketAddress) ctx.channel().remoteAddress();

      //瑙ｆ瀽
      if (null == analysisService) {
         analysisService = (AnalysisService) SpringUtil.getBean(AnalysisService.BEAN_ID);
      }
      analysisService.analysis(result);
//      analysisService.analysis(result);
   }

   @Override