| | |
|---|
| | | */ |
|---|
| | | private static HashMap<String, TcpSession> sessionTable = new HashMap<String, TcpSession>() ; |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 得到信息 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public static Integer[] info(){ |
|---|
| | | Integer rtuTotalConnect = 0 ;//已经连接过中间件的RTU总数（包括在线与离线的） |
|---|
| | | Integer rtuTotalOnLine = 0 ;//在线RTU总数 |
|---|
| | | Integer rtuTotalOffLine = 0 ;//离线RTU总数 |
|---|
| | | synchronized (sessionTable){ |
|---|
| | | rtuTotalConnect = sessionTable.size() ; |
|---|
| | | Collection<TcpSession> col = sessionTable.values() ; |
|---|
| | | for(TcpSession se : col){ |
|---|
| | | if(se.ioSession.isConnected()){ |
|---|
| | | rtuTotalOnLine ++ ; |
|---|
| | | }else{ |
|---|
| | | rtuTotalOffLine ++ ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return new Integer[] {rtuTotalConnect, rtuTotalOnLine, rtuTotalOffLine} ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 关闭所有网络连接 |
|---|
| | | */ |
|---|
