| | |
|---|
| | | 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(TcpIoSessionAttrKeys.sessionAttrRtuAddr, rtuAddr) ; |
|---|
| | | session.setAttribute(TcpIoSessionAttrKeys.sessionAttrProtocolName, protocolName) ; |
|---|
| | | session.setAttribute(TcpIoSessionAttrKeys.sessionAttrProtocolVersion, protocolVersion) ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void setAdapter(UnitAdapterInterface adapter) throws Exception { |
|---|
| | | if(adapter == null){ |
|---|
