zhubaomin
2025-04-03 c6beb89b7170115eada78526f87406381c931229
pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/tcp/TcpUnit.java
@@ -30,16 +30,21 @@
   public static TcpUnit getInstance(){
      return instance ;
   }
   /**
    * 把IoSession会话的ID属性设置到IoSession属性中
    * 把IoSession会话的ID属性及协议名称版本号设置到IoSession属性中
    * @param session
    * @param rtuAddr
    * @param protocolName
    * @param protocolVersion
    * @throws Exception
    */
   public void setIoSessionArrId(IoSession session, String id) throws Exception {
      session.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrIdKey, id) ;
   public void setIoSessionArrs(IoSession session, String rtuAddr, String protocolName, Short protocolVersion) throws Exception {
      session.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrRtuAddr, rtuAddr) ;
      session.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolName, protocolName) ;
      session.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolVersion, protocolVersion) ;
   }
   @Override
   public void setAdapter(UnitAdapterInterface adapter) throws Exception {
      if(adapter == null){