| | |
| | | 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){ |