Êþº¾ 4Ü publicway/SerialProtocolParser java/lang/Object START_MARKER [B MIN_PACKET_LENGTH I ConstantValue FUNCTION_01 B FUNCTION_51 Q FUNCTION_52 R FUNCTION_80ÿÿÿ FUNCTION_81ÿÿÿ FUNCTION_82ÿÿÿ FUNCTION_83ÿÿÿ
|
dataBuffer bufferPosition dataQueue $Ljava/util/concurrent/BlockingQueue; Signature (Ljava/util/concurrent/BlockingQueue<[B>;
|
batchQueue batchExecutor /Ljava/util/concurrent/ScheduledExecutorService; isRunning Z processorThread Ljava/lang/Thread;
|
hexBuilder Ljava/lang/StringBuilder; <clinit> ()V Code - LineNumberTable LocalVariableTable <init>
|
2 0 * 4 6 8 'java/util/concurrent/ArrayBlockingQueue
|
7 : 0 ; (I)V = ?
|
A C B java/util/concurrent/Executors D E newSingleThreadScheduledExecutor 1()Ljava/util/concurrent/ScheduledExecutorService; G ! " I # $ K java/lang/StringBuilder
|
J : N ' ( this Lpublicway/SerialProtocolParser; start S U T java/lang/System V W out Ljava/io/PrintStream; Y '串å£å议解æå¨å·²ç»å¨è¿è¡ä¸
|
[ ] \ java/io/PrintStream ^ _ println (Ljava/lang/String;)V a b c run 6(Lpublicway/SerialProtocolParser;)Ljava/lang/Runnable; 2 g i h java/util/concurrent/TimeUnit j k MILLISECONDS Ljava/util/concurrent/TimeUnit; m o n -java/util/concurrent/ScheduledExecutorService p q scheduleAtFixedRate ](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; s java/lang/Thread a v Serial-Protocol-Parser
|
r x 0 y )(Ljava/lang/Runnable;Ljava/lang/String;)V { % &
|
r } ~ setDaemon (Z)V
|
r Q * 串å£å议解æå¨å·²å¯å¨ StackMapTable stop m * shutdown g k SECONDS m awaitTermination #(JLjava/util/concurrent/TimeUnit;)Z m shutdownNow ()Ljava/util/List;
|
r currentThread ()Ljava/lang/Thread;
|
r * interrupt è
|
r join (J)V ¢ ¤ £ "java/util/concurrent/BlockingQueue ¥ * clear § 串å£å议解æå¨å·²åæ¢ © java/lang/InterruptedException e Ljava/lang/InterruptedException; ()Z receiveData ([B)V ° >è¦å: 串å£å议解æå¨æªå¯å¨ï¼å¿½ç¥æ¥æ¶çæ°æ® ¢ ² ³ ´ offer (Ljava/lang/Object;)Z S ¶ · W err ¹ !æ¹ééå已满ï¼ä¸¢å¼æ°æ® rawData batchProcess ¢ ½ ¾ ¬ isEmpty À java/util/ArrayList
|
¿ : ¢ Ã Ä Å drainTo (Ljava/util/Collection;I)I Ç É È java/util/List Ê Ë iterator ()Ljava/util/Iterator; Í Ï Î java/util/Iterator Ð Ñ next ()Ljava/lang/Object;
|
S Ô Õ Ö arraycopy *(Ljava/lang/Object;ILjava/lang/Object;II)V
|
Ø Ù * processBuffer Í Û Ü ¬ hasNext
|
Þ ß * checkMemory batch Ljava/util/List; LocalVariableTypeTable Ljava/util/List<[B>;
|
å ç æ java/lang/Runtime è é
|
getRuntime ()Ljava/lang/Runtime;
|
å ë ì í totalMemory ()J
|
å ï ð í
|
freeMemory
|
å ò ó í maxMemory?é ÷ )å
å使ç¨çè¶
è¿80%ï¼å½å使ç¨:
|
J ù 0 _
|
J ý þ ÿ append (J)Ljava/lang/StringBuilder; MB
|
J þ -(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
J toString ()Ljava/lang/String; runtime Ljava/lang/Runtime; usedMem J maxMem
|
findStartMarker ()I
|
; compactBuffer $æ°æ®éå已满ï¼ä¸¢å¼æ°æ®å
#æ¾å
¥æ°æ®éåæ¶åçå¼å¸¸:
|
java/lang/Exception
|
getMessage
|
startIndex
|
dataLength totalPacketLength packet Ljava/lang/Exception; remaining i processPackets' '串å£æ°æ®å
å¤ç线ç¨å¼å§è¿è¡ ¢) * Ñ take
|
, - ® parsePacket/ $串å£æ°æ®å
å¤ç线ç¨è¢«ä¸æ1 å¤çæ°æ®å
æ¶åçå¼å¸¸:
|
3 4 * printStackTrace
|
r6 7 ¬ isInterrupted9 '串å£æ°æ®å
å¤ç线ç¨ç»æè¿è¡
|
;=< publicway/ProtocolParser01 >? parseDDCC01Data ,([B)Lpublicway/ProtocolParser01$ParseResult;
|
ACB &publicway/ProtocolParser01$ParseResult D * fuzhi
|
A
|
G HI
|
bytesToHex ([B)Ljava/lang/String;
|
KML publicway/ProtocolParser51 NO parse (Ljava/lang/String;)IQ #åè½ç 0x51 - å¼é¨æ§å¶æåS 5åè½ç 0x51 - å¼é¨æ§å¶å¤±è´¥ææ¥æä¸åæ³U åè½ç 0x52 - LED亮度æ§å¶W #åè½ç 0x80 - å·¥å¡å级使è½Y )åè½ç 0x81 - å·¥ä½å¡å级æ°æ®å
[ #åè½ç 0x82 - åæ¿å级使è½] &åè½ç 0x83 - åæ¿å级æ°æ®å
_ æªç¥åè½ç : 0x
|
acb java/lang/Integer de toHexString (I)Ljava/lang/String;g 解ææ°æ®å
æ¶åçé误: hostAddress slotAddress functionCode returnValueLength returnValue rst (Lpublicway/ProtocolParser01$ParseResult; hexPacket Ljava/lang/String; results java/lang/String
|
Ju v ; setLengthx %02X
|
z|{ java/lang/Byte }~ valueOf (B)Ljava/lang/Byte;
|
r format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; bytes b hexStringToBytes (Ljava/lang/String;)[B
|
r trim
|
r ½ \s
|
r
|
replaceAll 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
|
r length "java/lang/IllegalArgumentException #HEXå符串é¿åº¦å¿
须为å¶æ°:
|
ù
|
r substring (II)Ljava/lang/String;
|
a ¡¢ parseInt (Ljava/lang/String;I)I¤ æ æçHEXå符:
|
¦ 0§ *(Ljava/lang/String;Ljava/lang/Throwable;)V© java/lang/NumberFormatException hexString
|
cleanedHex byteStr !Ljava/lang/NumberFormatException; getStatusInfo° C串å£è§£æå¨ç¶æ: %s, éå大å°: %d/%d, æ¹ééå: %d/%d² è¿è¡ä¸´ å·²åæ¢ ¢¶ · size
|
a¹ }º (I)Ljava/lang/Integer; ¢¼ ½ remainingCapacity¿ [Ljava/lang/Object; setMaxRawDataPrintLength
|
SourceFile SerialProtocolParser.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;Ä *
|
Í » *Ì * *
|
Ò % *Ñ * InnerClasses× %java/lang/invoke/MethodHandles$LookupÙ java/lang/invoke/MethodHandles Lookup ParseResult !
|
! " B # $ % & ' ( ) * + 5 ¼YÝTYÌT³ ,± .
|
/ 0 * + H*· 1* ¼µ 3*µ 5*» 7Yd· 9µ <*» 7Yè· 9µ >*¸ @µ F*µ H*» JY · Lµ M± . *
|
|
- ! . " 4 % 9 ) G
|
/ H O P Q * + ° Y*´ H ² RX¶ Z±*µ H*´ F*º ` d d² f¹ l W*» rY*º t u· wµ z*´ z¶ |*´ z¶ ² R¶ Z± . *
|
/ 0 1 4 7 . 9 A : I ; P = X > / Y O P
* + 9 *´ H ±*µ H*´ F¹ *´ F
|
² ¹ !*´ F¹ W§ L*´ F¹ W¸ ¶ *´ zÆ #*´ z¶ *´ z ¶ §
|
L¸ ¶ *µ z*´ <¹ ¡ *´ >¹ ¡ *µ 5² R¦¶ Z± 0 3 ¨ R \ _ ¨ . R D E H K M & N 0 P 4 Q > R D U K V R X \ Y ` Z f \ k ` t a } b d e / O P 4 ª « ` ª « j ¨Z ¨ # ¬ + / *´ H¬ . k / O P ® + 0*´ H ² R¯¶ Z±+Æ +¾ ±*´ >+¹ ± ² µ¸¶ Z± . " r s t w x | ' } / / 0 O P 0 º » * + X *´ >¹ ¼ ±» ¿Yd· ÁL*´ >+d¹  W+¹ Æ N§ X-¹ Ì À ÒM*´ 5,¾`*´ 3¾¤ !*´ 3*´ 5,¾d*´ 3,¾¸ Ó*,¾µ 5§ ,*´ 3*´ 5,¾¸ Ó*Y´ 5,¾`µ 5*· ×-¹ Ú ÿ¥*· ݱ . >
$ 8 G \ b e t / O P z à á 8 K º â z à ã 9 ÿ Ç Í ÿ 6 Ç Ò Í ÿ Ç Í ß * + ² F¸ äL+¶ ê+¶ îeA+¶ ñ7 ôk '² R» JYö· ø úm úm¶ ü ¶¶¶ Z± . ¤ ¥ ¦ ¨ ! © E « / * F O P B
|
8 2
|
þ E å Ù * + Ñ Î§ Ä*·< *µ 5±`*´ 5¤ *·±*´ 3`3 ÿ~x*´ 3`3 ÿ~= ``> `*´ 5¤ *·± ¼:*´ 3 ¸ Ó*´ <¹ ± ,² µ¶ Z§ :² µ» JY· ø¶¶¶¶ Z*´ 5 `d6 *´ 3 `*´ 3¸ Ó*µ 5*´ 5 ¢ÿ9± g ~ . f ± ³ ´ ¶ · » ½ " ¾ #  @ à F Æ P È U É V Í [ Î g Ò u Ó ~ Õ Ö Ú ¨ Û Ü ¾ Þ Ä ± Í à / H Î O P ¼ @ F ~ [ i! ª" ¨ # / ü ý 2ÿ * Ò ü ÿ + 7<§ &*´ 33² ,3 *´ 3`3² ,3 ¬*´ 5² ,¾d¤ÿÓ¬ . æ ç # è % æ 5 ë / 7 O P 3$ ü ; + k " *´ 3*´ 3*´ 5d¸ Ó*Y´ 5dµ 5± . ò ó ô ! ö / " O P " ! % * + m² R&¶ Z§ J*´ <¹( À ÒL*+·+§ 5L² R.¶ Z¸ ¶ § 2L² µ» JY0· ø+¶¶¶¶ Z+¶2*´ H ¸ ¶5ÿ¬² R8¶ Z± ! ¨ 4 . : ü þ " + 1 4 5 O S þ c l / * m O P ! " ª « 5 ª" T ¨R - ® + ¸
|
G+3=+3>+36+3 ÿ~x+3 ÿ~6d6: ¼:+¸ Ó«  ÿÿÿ ÿÿÿ ÿÿÿ ªÿÿÿ ¶ A Q Z R Æ À+¸::¶@¶EW§ ¬*+·F:¸J6 ² RP¶ Z§ ² RR¶ Z§ ² RT¶ Z§ t² RV¶ Z§ h² RX¶ Z§ \² RZ¶ Z§ P² R\¶ Z§ D² µ» JY^· ø ÿ~¸`¶¶¶ Z§ "M² µ» JYf· ø,¶¶¶¶ Z,¶2± $' . % " ( + 0 6! A% ' ) * + - 0 ¤1 «2 ±3 º4 ½5 Æ7 É9 Ò: Õ< Þ= á? ê@ íB öC ùEFH$L(MBNFP / z G O P G! h i j " ( ük + ùl mn ¤ %op « q ( ª" ; ÿ A Ò Ò û Bý rù ÿ ! Ò HI + C*´ M¶t+Y:¾6>§ $ 3=*´ Mw½ Y ¸yS¸¶W ¡ÿÜ*´ M¶° . V W X 2W ;Z / C O P C ÿ Ò Ò
+ X *Æ *¶¶ ¼°*¶L+¶p »Y» JY· ø+¶¶·¿+¶l¼M>§ >+ `¶:, l¸T§ !:»Y» JY£· ø¶¶·¥¿ +¶¡ÿÀ,° W d g¨ . 6 ^ _ c f &g ?j Hl Mm Wo dp iq
l u / > ªp u«p H Jq J F$ W .¬p i ª , ü ,rý Òÿ rr Òr ¨ú ® + ã n¯½ Y*´ H ±§ ³SY*´ <¹µ ¸¸SY*´ <¹» *´ <¹µ `¸¸SY*´ >¹µ ¸¸SY*´ >¹» *´ >¹µ `¸¸S¸° . | } ~ + D S j| / n O P - ÿ r¾¾ÿ r¾¾r À ; + 5 ± . / O P Á ÂÃ Ê ËÎÏÊ ÐÓÔÕ ÖØÚ A;Û
|
