Êþº¾ 4º chushihua/lunxun java/lang/Object isRunning Z isPaused
|
shouldStop +Ljava/util/concurrent/atomic/AtomicBoolean; pollingThread Ljava/lang/Thread; pollingInterval I MIN_SLOT ConstantValue MAX_SLOT < SERIAL_CHECK_INTERVAL lastSerialCheckTime J serialConnected queryCommandCache Ljava/util/Map; Signature 6Ljava/util/Map<Ljava/lang/Integer;Ljava/lang/String;>; DEBUG_ENABLED <clinit> ()V Code ! # % )java/util/concurrent/atomic/AtomicBoolean
|
$ ' ( ) <init> (Z)V + - / 1 3 &java/util/concurrent/ConcurrentHashMap
|
2 5 ( 7 9 LineNumberTable LocalVariableTable
|
5 this Lchushihua/lunxun; checkSerialConnection ()Z
|
B D C java/lang/System E F currentTimeMillis ()J
|
J L K chuankou/Sendmsg M @
|
isPortOpen B O P Q out Ljava/io/PrintStream; S 串å£è¿æ¥æ£å¸¸
|
U W V java/io/PrintStream X Y println (Ljava/lang/String;)V B [ \ Q err ^ $串å£è¿æ¥å¤±è´¥ - 串å£æªæå¼ ` java/lang/StringBuilder b 串å£è¿æ¥æ£æ¥å¼å¸¸:
|
_ d ( Y
|
f h g java/lang/Exception i j
|
getMessage ()Ljava/lang/String;
|
_ l m n append -(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
_ p q j toString currentTime result e Ljava/lang/Exception; StackMapTable checkSerialConnectionWithRetry
|
y ? @ è
|
} ~ java/lang/Thread sleep (J)V
|
}
currentThread ()Ljava/lang/Thread;
|
} interrupt java/lang/InterruptedException i Ljava/lang/InterruptedException; startPolling 轮询æ¥è¯¢å·²ç»å¨è¿è¡ä¸
|
w @ *串å£æªè¿æ¥ï¼æ æ³å¯å¨è½®è¯¢æ¥è¯¢
|
loadPollingIntervalFromConfig
|
$ ) set chushihua/lunxun$PollingTask
|
( !(Lchushihua/lunxun$PollingTask;)V CardSlot-Polling-Thread
|
} ¢ ( £ )(Ljava/lang/Runnable;Ljava/lang/String;)V ¥
|
|
} § ¨ ) setDaemon
|
} ª « start 轮询æ¥è¯¢å·²å¯å¨ï¼é´é:
|
_ ¯ m ° (I)Ljava/lang/StringBuilder; ² ms ´ )å¯å¨è½®è¯¢æ¥è¯¢çº¿ç¨æ¶åçå¼å¸¸: stopPolling · 轮询æ¥è¯¢æªå¨è¿è¡ ¸
|
} » ¼ join
|
} ¾ ¿ @ isAlive Á @轮询线ç¨æªå¨3ç§å
åæ¢ï¼æ 记为å®æ¤çº¿ç¨å¹¶å¿½ç¥ à åæ¢è½®è¯¢æ¥è¯¢æ¶è¢«ä¸æ:
|
h Æ #åæ¢è½®è¯¢çº¿ç¨æ¶åçå¼å¸¸: È è½®è¯¢æ¥è¯¢å·²åæ¢ Ê java/lang/Throwable pausePolling Í '轮询æ¥è¯¢æªå¨è¿è¡ï¼æ æ³æå Ï $轮询æ¥è¯¢å·²ç»å¤äºæåç¶æ Ñ è½®è¯¢æ¥è¯¢å·²æå resumePolling Ô '轮询æ¥è¯¢æªå¨è¿è¡ï¼æ æ³æ¢å¤ Ö !轮询æ¥è¯¢æªå¤äºæåç¶æ Ø *串å£æªè¿æ¥ï¼æ æ³æ¢å¤è½®è¯¢æ¥è¯¢
|
Ú Û notifyAll Ý è½®è¯¢æ¥è¯¢å·²æ¢å¤ ß java/lang/Class isPolling isSerialConnected setPollingInterval (I)V å 轮询é´éä¸è½å°äº10ms ç 轮询é´é已设置为:
|
é ê @ restartPolling interval getPollingInterval ()I
|
ï µ @ È
|
ó @
|
õ ÷ ö chushihua/Chushihua ø ù getInstance ()Lchushihua/Chushihua;
|
õ û ü @ isInitialized
|
õ þ ÿ getMachineConfig ()Lhome/MachineConfig;
|
home/MachineConfig ì í ä»é
ç½®å 载轮询é´é: 5é
置系ç»æªåå§åï¼ä½¿ç¨é»è®¤è½®è¯¢é´é:
|
å 载轮询é´éé
置失败: 使ç¨é»è®¤è½®è¯¢é´é: configSystem Lchushihua/Chushihua; machineConfig Lhome/MachineConfig; getCachedQueryCommand (I)Ljava/lang/String;
|
java/lang/Integer valueOf (I)Ljava/lang/Integer; apply ()Ljava/util/function/Function; java/util/Map !" computeIfAbsent C(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object;$ java/lang/String
|
slotNumber clearQueryCache ( ) clear+ æ¥è¯¢æ令ç¼åå·²æ¸
空 sendImmediateQuery (I)Z/ å¡æ§½ç¼å·å¿
é¡»å¨1-60ä¹é´1 *串å£æªè¿æ¥ï¼æ æ³åéæ¥è¯¢æ令
|
3
|
#5 6 j trim
|
#8 9 @ isEmpty
|
J; <= sendMessage (Ljava/lang/String;)Z? ç«å³æ¥è¯¢æå - å¡æ§½ A +ç«å³æ¥è¯¢å¤±è´¥ - åéæ令å°å¡æ§½ C 失败E ;ç«å³æ¥è¯¢å¤±è´¥ - çæçæ¥è¯¢æ令为空ï¼å¡æ§½: G ç«å³æ¥è¯¢å¡æ§½ I æ¶åçå¼å¸¸: queryCommand Ljava/lang/String;
|
sendResult sendImmediateQueryToAllO 0串å£æªè¿æ¥ï¼æ æ³åéæ¹éæ¥è¯¢æ令Q !å¼å§æ¹éæ¥è¯¢ææå¡æ§½...
|
$S T @ get
|
VXW java/lang/Math YZ min (II)I
|
\ ,- 2` #æ¹éæ¥è¯¢å®æï¼æååé: b / successCount batchSize
|
totalSlots
|
batchStart batchEnd slot setSerialConnectedk )串å£è¿æ¥ç¶æ已设置为: å·²è¿æ¥m )串å£è¿æ¥ç¶æ已设置为: æªè¿æ¥
|
o Ë @ connected getPollingStatuss å·²åæ¢u å·²æåw è¿è¡ä¸y å·²è¿æ¥{ æªè¿æ¥ } ~ í size Q轮询ç¶æ: %s, 串å£: %s, é´é: %dms, æ令ç¼å: %d, å¡æ§½èå´: %d-%d
|
# format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; status serialStatus cacheSize setPollingPaused (Z)Z 3轮询æ¥è¯¢æªå¨è¿è¡ï¼æ æ³è®¾ç½®æåç¶æ '轮询æ¥è¯¢å·²éè¿å¤é¨è°ç¨æå '轮询æ¥è¯¢å·²éè¿å¤é¨è°ç¨æ¢å¤ paused getPerformanceStats 0æ¥è¯¢æ令ç¼å大å°: %d, 轮询é´é: %dms isDEBUG_ENABLED setDEBUG_ENABLED dEBUG_ENABLED access$0 access$1 -()Ljava/util/concurrent/atomic/AtomicBoolean; access$2 access$3 access$4 access$5 access$6
|
SourceFile lunxun.java BootstrapMethods
|
£¥¤ "java/lang/invoke/LambdaMetafactory ¦§ metafactory Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;¢ &(Ljava/lang/Object;)Ljava/lang/Object;©
|
¬® publicway/QueryData ¯ queryData« '(Ljava/lang/Integer;)Ljava/lang/String;± InnerClasses PollingTask¶ %java/lang/invoke/MethodHandles$Lookup¸ java/lang/invoke/MethodHandles Lookup ! J J
|
|
|
|
|
k /³ ³ "» $Y· &³ *d³ , ³ .³ 0» 2Y· 4³ 6³ 8± : " # * & ; ( / *· <± : ; = > ? @ f¸ A? ² .e G ² 0¬ ³ .¸ I= ² 8 ² NR¶ T³ 0§ 0² Z]¶ T³ 0§ !M² Z» _Ya· c,¶ e¶ k¶ o¶ T³ 0² 0¬ A D f : B . / 0 3 7 9 : & ; . = 2 > 5 ? = @ A B E C ^ D b G ; b r % s E t u v ü ü ÿ f
|
w @ );§ ¸ x ¬ z¸ |§ L¸ ¶ ¬ ¡ÿᬠ: & N O P S T U V N ' Y ; % t v ü H @ 2 ² ² N¶ T¬¸ ² Z¶ T¬¸ ³ ³ "² *¶ » }Y» Y· · ¡³ ¤² ¤¶ ¦² ¤¶ ©² 8 ² N» _Y¬· c² ,¶ ®±¶ k¶ o¶ T¬K² Z» _Y³· c*¶ e¶ k¶ o¶ T³ ² *¶ ¬ 2 v x f : V a b c g h i m # o ' p + q 2 t F u M v S w Y x v z x { y | } ~ ; y & t u v û UA f µ @ ³² ² N¶¶ T¬² *¶ ³ ³ "² ¤Æ ² ¤¶ ² ¤ ¸¶ º² ¤¶ ½ d² ZÀ¶ T² ¤¶ ¦§ RK² Z» _Y· c*¶ Ķ k¶ o¶ T¸ ¶ ³ ¤§ /K² Z» _YÅ· c*¶ e¶ k¶ o¶ T³ ¤§ L³ ¤+¿³ ¤² *¶ ² NǶ T¬ + L O + L v f + o v : j % + 4 = E L P i o ¡ v w ¡ ¡ ¢ ¡ ¢ ¥ © ¦ ± § ; P t w t u v ~ f f` É Ë @ :² ² 8 ² N̶ T¬² " ² 8 ² Nζ T¬³ "² Nж T¬ : . ¯ ° ± ³ ¶ · " ¸ * º , ½ 0 ¾ 8 ¿ ; v Ò @ Ó P² ² NÓ¶ T¬² " ² NÕ¶ T¬¸ ² Z׶ T¬³ "YK¶ Ù*ç *ÿ² Nܶ T¬ 9 @ C C E C : > Ç È É Ì Í Î Ò & Ó . Ô 0 × 4 Ø 9 Ù > Ø F Û N Ü ; v ÿ Þ Éú à @ $ ² ¬ : ä ; @ $ ² "¬ : ì ; á @ $ ² 0¬ : ô ; â ã 9
|
¢ ² Zä¶ T±³ ,² N» _Yæ· c¶ ®±¶ k¶ o¶ T² ¸ èW± : " ü ý þ . 4 8 ; 9 ë v ( ì í $ ² ,¬ : ; ê @ g ¸ îW ð¸ |§
|
K¸ ¶ ¸ ò¬
|
:
|
; t v M
|
¸ ôK*¶ ú 0*¶ ýL+¶³ ,² N» _Y· c² ,¶ ®±¶ k¶ o¶ T§ ]² N» _Y· c² ,¶ ®±¶ k¶ o¶ T§ <K² Z» _Y · c*¶ e¶ k¶ o¶ T² N» _Y · c² ,¶ ®±¶ k¶ o¶ T± V Y f : . ( ) * + , 5- 8. V0 Z1 t2 4 ; R % Z 8 t u v ü 8 õÿ f8
|
? ² 6¸º ¹ À#° : : ; % & : ² 6¹' ² N*¶ T± : A B C ; ,- Á¡ <¤ ² Z.¶ T¬¸ ² Z0¶ T¬¸2L+Æ T+¶4¶7 J+¸:= "² 8 ² N» _Y>· c¶ ®¶ o¶ T¬² Z» _Y@· c¶ ®B¶ k¶ o¶ T¬² Z» _YD· c¶ ®¶ o¶ T¬L² Z» _YF· c¶ ®H¶ k+¶ e¶ k¶ o¶ T¬ ' ` f b f f : R Ü Ý Þ â ã %ä 'é ,ë :í ?ï Cð Iñ `ó bõ ö ù ú ý þ ¿ÿ ; * Á% , nJK ? BL & t u v
|
ý 8#ú ÿ f M í ¡¸ ² ZN¶ T¬;<<=² NP¶ T>§ U² *¶R § O `d<¸U6 6§ ¸[ ¤ÿî<¢ ]¸ |§ :¸ ¶ § `> <¤ÿ«² N» _Y_· c¶ ®a¶ k ¶ ®¶ o¶ T¬ ` f i : ^
|
! & / 2 > D L O Y# `% f& k' q( t ~- . ; H c d e # [f > 6g A h k t v ,
|
ÿ ý
|
ÿ ú
|
ú i ) 4³ 0¸ A³ . ² Nj¶ T§ ² Zl¶ T² ² " ¸nW± : & 6 7
|
9 : ; < #> /? 3B ; 4p v q j ù j²
|
rK§ ² "
|
tK§ vK² 0 x§ zL² 6¹| =½ Y*SY+SY² ,¸SY ¸SY¸SY<¸S¸° : . J K
|
L M N O R .S 7U AV fU ; 4
|
K
K L
K . <K 7 3 v ü # B# ! u² ² N¶ T¬ "² " ³ "² N¶ T¬² Nζ T¬² " 4¸ ² Z׶ T¬³ "YL¶ Ù+ç +ÿ² N¶ T¬² NÕ¶ T¬ S Z ] ] _ ] : Z _ ` a d f g h (i *k 2l 4p :r @s Ht Jw Nx Sy Xx `{ i| k~ s ; u v ÿ Þ Éú
|
j J "½ Y² 6¹| ¸SY² ,¸S¸° : ; @ $ ² 8¬ : ; ) 3 ³ 8± :
|
; @ $ ² ¬ : ; $ ² *° : ; @ $ ² "¬ : ; @ $ ¸ ¬ : M ; í $ ² ,¬ : ; % ¸2° : 9 ; ) % ³ 0± : ; ¡ ¨ ª°²³ ´
|
µ·¹
|
