1

zj

2024-06-13 8eea5be3b36875bd4ffe70e6c3a5bb07b1d829bf

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
41
Êþº¾4

*nop
q
r    <stuv
wxy
 
n
wz{
|}
~
~€
<
~‚"ƒ"x"„Š
‹ŒŽ‘’“”“•–
—
˜™š
›œ
žŸu     <¡¢£¤¥
¦§u¨“à
©ª«¬
0­u®¯
°±
°²
4³    4´
4µ
4¶
4—·
¸¹º
log
Lorg/slf4j/Logger;
 dataDBService
4Lcom/yami/trading/huobi/data/internal/DataDBService;
RuntimeVisibleAnnotations
Ljavax/annotation/Resource;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
4Lcom/yami/trading/huobi/data/job/SaveRealtimeServer;
start
run
item
,Lcom/yami/trading/bean/data/domain/Realtime;

i

I

J
partList
Ljava/util/List;
realtimePartition
Ljava/util/Map;
size
list

e
Ljava/lang/Throwable;
LocalVariableTypeTable
>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
bLjava/util/Map<Ljava/lang/Integer;Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;>;
 StackMapTableš»·«
mod
(Ljava/lang/String;)I
str
Ljava/lang/String;
bigInt
Ljava/math/BigInteger;
<clinit>

SourceFile
SaveRealtimeServer.java
*Lorg/springframework/stereotype/Component;EF
java/lang/Thread
SaveRealtimeServerE¼LF?@
启动SaveRealtimeServer！½¾¿ÀWÁ
java/util/ArrayListÂÃ
java/lang/StringÄÅÆÇÈ¿ÉÊdeËÌÍÎÏÐ
BootstrapMethodsÑÒÓÔÕÖ×ØÙÚÛÜ
 java/util/MapÝÞßàá»âãäå
java/lang/IntegeræÁçèéÒ
java/util/Listêëìíîï
入庫realtime_{} å¼€å§‹¾ðABñòó
7入庫realtime_{} ç»“束，入库 {}条， è€—æ—¶:{} ms
java/lang/Objectôçõ¾ö÷øù
java/lang/Throwable
 SaveRealtimeServer run fail ->{}úÊûð
java/math/BigIntegerüýþÿ
E


id



2com/yami/trading/huobi/data/job/SaveRealtimeServer



java/lang/Runnable
java/util/Iterator
)(Ljava/lang/Runnable;Ljava/lang/String;)V
org/slf4j/Logger
info
(Ljava/lang/String;)V
-com/yami/trading/huobi/data/job/RealtimeQueue
()I
poll
.()Lcom/yami/trading/bean/data/domain/Realtime;
,com/yami/trading/common/util/ApplicationUtil
getCurrentTimeUUID
'([Ljava/lang/String;)Ljava/lang/String;
*com/yami/trading/bean/data/domain/Realtime
setUuid
    getSymbol
()Ljava/lang/String;
 setTableIndex
(I)V
add
(Ljava/lang/Object;)Z
stream
()Ljava/util/stream/Stream;

    


&(Ljava/lang/Object;)Ljava/lang/Object;
~

A(Lcom/yami/trading/bean/data/domain/Realtime;)Ljava/lang/Integer;
apply
()Ljava/util/function/Function;
java/util/stream/Collectors

groupingBy
;(Ljava/util/function/Function;)Ljava/util/stream/Collector;
java/util/stream/Stream
collect
0(Ljava/util/stream/Collector;)Ljava/lang/Object;
keySet
()Ljava/util/Set;
 java/util/Set
iterator
()Ljava/util/Iterator;
hasNext
()Z
next
()Ljava/lang/Object;
intValue
valueOf
(I)Ljava/lang/Integer;
get
(cn/hutool/core/collection/CollectionUtil

isNotEmpty
(Ljava/util/Collection;)Z
java/lang/System
currentTimeMillis
()J
'(Ljava/lang/String;Ljava/lang/Object;)V
2com/yami/trading/huobi/data/internal/DataDBService
    saveBatch
(Ljava/util/List;)V
java/lang/Long
(J)Ljava/lang/Long;
((Ljava/lang/String;[Ljava/lang/Object;)V
(com/yami/trading/common/util/ThreadUtils
sleep
(J)V

getMessage
error
cn/hutool/crypto/digest/MD5
create
()Lcn/hutool/crypto/digest/MD5;
digest
(Ljava/lang/String;)[B
(I[B)V
TEN
.(Ljava/math/BigInteger;)Ljava/math/BigInteger;
abs
()Ljava/math/BigInteger;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;

 

Á
"java/lang/invoke/LambdaMetafactory
metafactory

Lookup
InnerClasses
Ì(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;
 getTableIndex

%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!<*
>?@AB
C
D
EF
G/

*·
±H
I
JK
LF
GJ
»Y*·¶²¹±H I
JK
MF
G    

¸    <»
Y·M>¢0¸:½ ¸¶¶¸¶,¹W„
§ÿÑ,¹
ž©,¹
º¸¹ÀN-¹
¹
:¹
™{¹
À¶6-¸ ¹!À":¸#™Q¸$7²%¸ ¹&*´'¹(²)½*Y¸ SY¹
¸ SY¸$e¸+S¹,§ÿ-¸/§&L²1+¶2¹3-¸/§:    -¸/    ¿§þåïø0ï
ø




Hj#$%&'$(1):%@,I-`.†/–0ž1£2²3½4ì6ï;õ<ø8ù9
;
 <
;
<If
"NO2PQ£ILR–VST†fPQ`UVëWQ
ãXTùYZ

JK[ –VS\`U]ãX\^-    þ 
_
ú1ý,`aû~ÿ
bHcWc
    de
GV»4Y¸5*¶6·7L+²8¶9¶:¶;¬H
ABIfghi
jF
G!
    <¸=³±
H
klC
m





…
†‡ˆ‰