添加被忽略的文件

zhubaomin

2025-04-07 39bf16fdaa41ea3ab9a8962e00bae7342904483e

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
Êþº¾@õ

java/lang/Object
<init>
()V
    

java/lang/Integer
valueOf
(I)Ljava/lang/Integer;    
*com/dy/rtuMw/server/forTcp/TcpSessionCache
map
Ljava/util/HashMap;

java/util/HashMap
size
()I

values
()Ljava/util/Collection; !"
java/util/Collection
iterator
()Ljava/util/Iterator;$%&'(
java/util/Iterator
hasNext
()Z$*+,
next
()Ljava/lang/Object;.
%com/dy/rtuMw/server/forTcp/TcpSession    -012
    ioSession
(Lorg/apache/mina/core/session/IoSession;4567(
&org/apache/mina/core/session/IoSession
isConnected
9:
intValue4<=>
closeNow
+()Lorg/apache/mina/core/future/CloseFuture;
@A
clear
CDE
get
&(Ljava/lang/Object;)Ljava/lang/Object;
-
HIJ
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
LMNOP
java/lang/String
equals
(Ljava/lang/Object;)Z
RST
putNewTcpSession
=(Ljava/lang/String;Lorg/apache/mina/core/session/IoSession;)V
VWE
removeY
8com/dy/common/mw/channel/tcp/TcpIoSessionAttrIdIsRtuAddr[
    key_pName4]^E
getAttribute`
key_pVerson
bcd
entrySet
()Ljava/util/Set;fg
 java/util/Seti
java/util/Map$Entryhkl,
getValue
hop,
getKey
rstu
java/lang/Boolean
(Z)Ljava/lang/Boolean;4wxy
write
=(Ljava/lang/Object;)Lorg/apache/mina/core/future/WriteFuture;{
java/lang/Exception}
Rtu连接已经关闭!
z€
(Ljava/lang/String;)V‚
Rtu未曾上线!
„…†‡
java/lang/Long
(J)Ljava/lang/Long;    -‰Š‹
lastDownComTime
Ljava/lang/Long;
Ž‘
java/lang/System
currentTimeMillis
()J    -“”‹
lastUpDataTime    -–—‹
lastUpDataTimeForOnlineCtrl
„™š‘
    longValue    œžŸ‹
$com/dy/rtuMw/server/ServerProperties
lastUpDataTimeLive    œ¡¢‹
disconnectedByNoUpDataMinutes¤
6因较长时间未收上行数据，认为设备离线
¦§¨©ª
'com/dy/rtuMw/server/forTcp/RtuLogDealer
log
'(Ljava/lang/String;Ljava/lang/String;)V
    Signature
NLjava/util/HashMap<Ljava/lang/String;Lcom/dy/rtuMw/server/forTcp/TcpSession;>;
Code
LineNumberTable
LocalVariableTable
this
,Lcom/dy/rtuMw/server/forTcp/TcpSessionCache;
info
()[Ljava/lang/Integer;
se
'Lcom/dy/rtuMw/server/forTcp/TcpSession;
col
Ljava/util/Collection;
rtuTotalConnect
Ljava/lang/Integer;
rtuTotalOnLine
rtuTotalOffLine
LocalVariableTypeTable
?Ljava/util/Collection<Lcom/dy/rtuMw/server/forTcp/TcpSession;>;
 StackMapTableÀ
java/lang/Throwable
closeAllSessions
tcpSe
rtuAddr
Ljava/lang/String;
MethodParameters
 changeRtuAddr
O(Ljava/lang/String;Ljava/lang/String;Lorg/apache/mina/core/session/IoSession;)V

oldRtuAddr

newRtuAddr
 getTcpSession
;(Ljava/lang/String;)Lcom/dy/rtuMw/server/forTcp/TcpSession;
getTcpProtocolNameVersion
'(Ljava/lang/String;)[Ljava/lang/Object;
allOnLineStateStatistics
arr
[Ljava/lang/Integer;
it
Ljava/util/Iterator;
entry
Ljava/util/Map$Entry;
fLjava/util/Iterator<Ljava/util/Map$Entry<Ljava/lang/String;Lcom/dy/rtuMw/server/forTcp/TcpSession;>;>;
PLjava/util/Map$Entry<Ljava/lang/String;Lcom/dy/rtuMw/server/forTcp/TcpSession;>;Ð
    allOnLine
()Ljava/util/HashMap;
:Ljava/util/HashMap<Ljava/lang/String;Ljava/lang/Boolean;>;
<()Ljava/util/HashMap<Ljava/lang/String;Ljava/lang/Boolean;>;

partOnLine
(([Ljava/lang/String;)Ljava/util/HashMap;
 rtuAddrArrGrp
[Ljava/lang/String;ß
O([Ljava/lang/String;)Ljava/util/HashMap<Ljava/lang/String;Ljava/lang/Boolean;>;
    isConnect
'(Ljava/lang/String;)Ljava/lang/Boolean;
(Ljava/lang/String;[B)V
data
[B

Exceptions

whenUpData
updateRtuStatus
(Ljava/lang/Long;)V
Ljava/util/Set;
now
aLjava/util/Set<Ljava/util/Map$Entry<Ljava/lang/String;Lcom/dy/rtuMw/server/forTcp/TcpSession;>;>;
<clinit>

SourceFile
TcpSessionCache.java
InnerClassesó
 java/util/Map
Entry!


«¬

­/

*·
±®
¯
°±    ²³
­
n    –¸K¸L¸M² YN² ¶¸K² ¶:¹
:¹#
™B¹)
À-:´/¹3
™+:+¶8`¸LW§,:,¶8`¸MW§ÿº-ç
:-ÿ½Y*SY+SY,S°{~~‚~®6  
!"#$'%F&S'f)v+y,…-¯4F0´µ'R¶·‘¸¹
Œº¹
‡»¹¼
'R¶½¾.ÿ0$ü5-úùD¿ú    Á
­àG² YK² ¶L+¹
M,¹#
™,¹)
À-N-´/¹;
W§ÿã² ¶?*ç
:*ÿ±<??C?®"45 6'71849::F;¯'
´µ -¶·
¼
 -¶½
¾!þ$úÿ


¿ú    ST­É@² YM² *¶BÀ-N-Ç»-Y·FN-+µ/² *-¶GW§-+µ/,ç
:,ÿ±588<8®&    DEFGJ"K.M3O?P¯ "µ@ÃÄ@12
¾ý.-úD¿úÅ    Ã1    ÆÇ­áN*ÆL+ÆH*+¶Kš@² YN² *¶BÀ-:Ç+,¸Q§² *¶UW² +¶GW-ç
:-ÿ±CFFJF®&    Z[\"]'^/`7aAcMe¯*"µNÈÄNÉÄ
N12¾ý/-úD¿úÅ ÈÉ1    ÊË­5
² *¶BÀ-°®
m¯
ÃÄÅ
à   ÌÍ­Œ2² *¶BÀ-L+Æ$½Y+´/Z¹\SY+´/_¹\S°
°®vwxy)z/x0|¯2ÃÄ'µ
¾
ü0-Å
à   Î³
­
U—² YK½Y¸SY¸SL² ¶a¹e
M
N,¹#
™_,¹)
ÀhN-¹j
À-´/¹3
™"+:2:2¶8`¸SW§ÿ½+:2:2¶8`¸SW§ÿž+*ð:*ÿ”®.†‡ˆ%‰'Š0‹:ŒNmŒ’“¯ wÏÐ
%kÑÒ'iÓÔ¼%kÑÕ'iÓÖ¾&ÿ'×$hûEÿ

¿    ØÙ­
_² YK»Y·mL² ¶a¹e
M
N,¹#
™2,¹)
ÀhN+-¹n
ÀL-¹j
À-´/¹3
¸q¶GW§ÿË+*ð:*ÿWXX\X®&    ›œžŸ% /¡T£X¤¯ J
>ÑÒ<ÓÔ¼ JÚ
>ÑÕ<ÓÖ¾#ÿ$h7ÿ

¿«Û    ÜÝ­
    [² YL»Y·mM*N-¾66¢5-2:² ¶BÀ-:Æ,´/¹3
¸q¶GW„
§ÿÊ,+ð:+ÿSTTXT®&    ­®¯$°1±6²J¯PµT¶¯*1µ$&ÃÄF[Þß¼
FÚ¾+ÿàà

2øÿà
¿Å
Þ«á    âã­l² *¶BÀ-L+Æ+´/¹3
¸q°
°®¿ÀÁïÃĵ
¾
ü-Å
à   xä­¤>² *¶BÀ-M,Æ',´/¹3
™,´/+¹vW§»zY|·~¿»zY·~¿±®ÍÎÏÐ)Ò3Õ=ׯ >ÃÄ>åæ
3µ¾
ü)-        ç
zÅ    Ãå    è€­‚,² *¶BÀ-L+Æ+    ¸ƒµˆ+¸Œ¸ƒµ’+¸Œ¸ƒµ•±®Þßàá!â+ä¯,ÃÄ!µ
¾
ü+-Å
à   éê­
¬·² YL² ¶aM,¹e
N-¹#
™-¹)
Àh:¹j
À-:´’Æ *¶˜´’¶˜e²›¶˜”ž    
µ’´•Æÿ¶´/Æÿ®´/¹3
™ÿ¡*¶˜´•¶˜e² ¶˜”žÿŠ´/¹;
W¹n
ÀL£¸¥§ÿm+ç
:+ÿ±¬¯¯³¯®Bìí îñò(ó4ô<õSöYùaúvûü˜ýª
¶
¯4 cë–ÑÒ(‚ÓÔ4vµ·ì‹¼  cí–ÑÕ(‚ÓÖ¾+þf$ýDh-ÿP„D¿úÅ
ìî
­#»Y·m³ ±
®
ïðñ

hòô