smartboot / smart-socket Goto Github PK

for (EBasicInfo elevator : list) {
      if (elevatorSessionMap.get(elevator.getId())!=null)continue;
      AioQuickClient client = new AioQuickClient(elevator.getIpAddress(), elevator.getCanPort(), new ElevatorProtocol(), elevatorProcessor);
      client.setReadBufferSize(1000);
      try {
          AioSession session = client.start();
          session.setAttachment(elevator.getId());
          elevatorSessionMap.put(elevator.getId(),session);
      }
      catch (IOException e) {
          log.error("elevator 连接失败 elevatorId={}",elevator.getId());
          }
  }

 List<byte[]> canFrameList=new ArrayList<>();
  while ((readBuffer.remaining() >= CAN_LENGTH)) {
      readBuffer.mark();
      byte b1 = readBuffer.get();
      byte b2 = readBuffer.get();
      if (b1 == CAN_HEADER[0] && b2 == CAN_HEADER[1]) {
          readBuffer.reset();
          byte[] canFrame = new byte[CAN_LENGTH];
          readBuffer.get(canFrame);
          if (canValidate(canFrame)) {
              byte[] canId= Arrays.copyOfRange(canFrame,4,8);
              if ((Ints.fromByteArray(canId)==0x7d0)) {
                  if (Byte.toUnsignedInt(canFrame[8])==0xa0&&Byte.toUnsignedInt(canFrame[9])==0xa1) {
                      log.debug("canFrame:{}",Arrays.toString(ByteUtils.byteArrayTo0xStringArray(canFrame)));
                  }
              }
              canFrameList.add(canFrame);
          }else {
              log.debug("校验不通过");
          }
      }else {
          log.debug("不满足can header");
          readBuffer.reset();
          readBuffer.get();
      }
  }
  return canFrameList;

java.nio.channels.CancelledKeyException
        at sun.nio.ch.SelectionKeyImpl.ensureValid(SelectionKeyImpl.java:73)
        at sun.nio.ch.SelectionKeyImpl.interestOps(SelectionKeyImpl.java:77)
        at org.smartboot.socket.enhance.EnhanceAsynchronousChannelGroup.removeOps(EnhanceAsynchronousChannelGroup.java:122)
        at org.smartboot.socket.enhance.EnhanceAsynchronousServerChannel.doRead(EnhanceAsynchronousServerChannel.java:273)
        at org.smartboot.socket.enhance.EnhanceAsynchronousChannelGroup.lambda$new$0(EnhanceAsynchronousChannelGroup.java:76)
        at org.smartboot.socket.enhance.EnhanceAsynchronousChannelGroup$Worker.run(EnhanceAsynchronousChannelGroup.java:219)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)