Êþº¾ 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 '串å£æ°æ®å
å¤ç线ç¨ç»æè¿è¡
|
;=< chuankou/SerialPortService > getReceivedDataCount
|
@BA publicway/ProtocolParser01 CD parseDDCC01Data ,([B)Lpublicway/ProtocolParser01$ParseResult;
|
FHG &publicway/ProtocolParser01$ParseResult I * fuzhi
|
K LM
|
bytesToHex ([B)Ljava/lang/String;
|
OQP publicway/ProtocolParser51 RS parse (Ljava/lang/String;)IU #åè½ç 0x51 - å¼é¨æ§å¶æåW 5åè½ç 0x51 - å¼é¨æ§å¶å¤±è´¥ææ¥æä¸åæ³Y åè½ç 0x52 - LED亮度æ§å¶[ #åè½ç 0x80 - å·¥å¡å级使è½] )åè½ç 0x81 - å·¥ä½å¡å级æ°æ®å
_ #åè½ç 0x82 - åæ¿å级使è½a &åè½ç 0x83 - åæ¿å级æ°æ®å
c æªç¥åè½ç : 0x
|
egf java/lang/Integer hi toHexString (I)Ljava/lang/String;k 解ææ°æ®å
æ¶åçé误: hostAddress slotAddress functionCode returnValueLength returnValue rst (Lpublicway/ProtocolParser01$ParseResult; hexPacket Ljava/lang/String; resultw java/lang/String
|
Jy z ; setLength| %02X
|
~ java/lang/Byte valueOf (B)Ljava/lang/Byte;
|
v
format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; bytes b hexStringToBytes (Ljava/lang/String;)[B
|
v trim
|
v ½ \s
|
v
|
replaceAll 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
|
v length "java/lang/IllegalArgumentException #HEXå符串é¿åº¦å¿
须为å¶æ°:
|
ù
|
v ¡¢ substring (II)Ljava/lang/String;
|
e¤ ¥¦ 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
|
e½ ¾ (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 2 5 8 . : 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 E F I L N & O 0 Q 4 R > S D V K W R Y \ Z ` [ f ] k a t b } c e f / O P 4 ª « ` ª « j ¨Z ¨ # ¬ + / *´ H¬ . l / O P ® + 0*´ H ² R¯¶ Z±+Æ +¾ ±*´ >+¹ ± ² µ¸¶ Z± . " s t u x y } ' ~ / / 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 - ® + ¶
|
E¸:W+3=+3>+36+3 ÿ~x+3 ÿ~6d6: ¼:+¸ Ó« ¼ ÿÿÿ ÿÿÿ ÿÿÿ ¤ÿÿÿ ° A Q T R Æ º+¸?:¶E§ ¬*+·J:¸N6 ² RT¶ Z§ ² RV¶ Z§ ² RX¶ Z§ t² RZ¶ Z§ h² R\¶ Z§ \² R^¶ Z§ P² R`¶ Z§ D² µ» JYb· ø ÿ~¸d¶¶¶ Z§ "M² µ» JYj· ø,¶¶¶¶ Z,¶2± "% . % & , /! 4" :# E' ) + , / 2 ¢3 ©4 ¯5 ¸6 »7 Ä9 Ç; Ð< Ó> Ü? ßA èB ëD ôE ÷G HJ"N&O@PDR / z E O P E! l m n & ü , öo / óp qr ¢ %st © u & ª" ; ÿ E Ò Ò û Bý vù ÿ ! Ò LM + C*´ M¶x+Y:¾6>§ $ 3=*´ M{½ Y ¸}S¸¶W ¡ÿÜ*´ M¶° . X Y Z 2Y ;\ / C O P C ÿ Ò Ò + X *Æ *¶¶ ¼°*¶L+¶p »Y» JY· ø+¶¶·¿+¶l¼M>§ >+ `¶:, l¸£T§ !:»Y» JY§· ø¶¶·©¿ +¶¡ÿÀ,° W d g¬ . 6 ` a e h &i ?l Hn Mo Wq dr is
n w / > ®t u¯t H Ju J F$ W .°t i ª± , ü ,vý Òÿ vv Òv ¬ú ² + ã n³½ Y*´ H µ§ ·SY*´ <¹¹ ¸¼SY*´ <¹¿ *´ <¹¹ `¸¼SY*´ >¹¹ ¸¼SY*´ >¹¿ *´ >¹¹ `¸¼S¸° . ~ + D S j~ / n O P - ÿ vÂÂÿ vÂÂv Ä ; + 5 ± . / O P Å ÆÇ Î ÏÒÓÎ Ô×ØÙ ÚÜÞ F@ß
|
