提交到Gitblit

克 刘

2020-03-16 549148d90d41a3320bd36d469fd690354c78de58

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


1qr
q    .s    .t
.u    .vw
qx
y
z
{|}
~€|‚
~ƒ
~„Š
‹Œ
Ž|‘
“
”•
‹–    .—˜™    š›d
œž
Ÿ 
Ÿ{
¡    ¢£
¤¥
¦§¨
©ª
«¬­®
log
Lorg/slf4j/Logger;
 redisTemplate
3Lorg/springframework/data/redis/core/RedisTemplate;
    Signature
YLorg/springframework/data/redis/core/RedisTemplate<Ljava/lang/String;Ljava/lang/Object;>;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
lockFlag
Ljava/lang/ThreadLocal;
+Ljava/lang/ThreadLocal<Ljava/lang/String;>;

UNLOCK_LUA
Ljava/lang/String;
<init>
6(Lorg/springframework/data/redis/core/RedisTemplate;)V
Code
LineNumberTable
LocalVariableTable
this
-Lcom/kidgrow/redis/lock/RedisDistributedLock;
LocalVariableTypeTable
\(Lorg/springframework/data/redis/core/RedisTemplate<Ljava/lang/String;Ljava/lang/Object;>;)V
lock
(Ljava/lang/String;JIJ)Z

e
 Ljava/lang/InterruptedException;
key
expire

J

retryTimes

I
sleepMillis
result

Z
 StackMapTable€
setRedis
(Ljava/lang/String;J)Z
status
Ljava/lang/Exception;
releaseLock
(Ljava/lang/String;)Z
Ljava/lang/Boolean;¯
lambda$releaseLock$1
b(Ljava/lang/String;Lorg/springframework/data/redis/connection/RedisConnection;)Ljava/lang/Boolean;

connection
;Lorg/springframework/data/redis/connection/RedisConnection;

scriptByte
[B

Exceptions°
lambda$setRedis$0
c(Ljava/lang/String;JLorg/springframework/data/redis/connection/RedisConnection;)Ljava/lang/Boolean;
uuid
keyByte
uuidByte
<clinit>
()V

SourceFile
RedisDistributedLock.java
*Lorg/springframework/stereotype/Component;?m
java/lang/ThreadLocal:;45VW23
java/lang/StringBuilder
+get redisDistributeLock failed, retrying...±²±³´µ¶·¸¹º»
java/lang/InterruptedException
Interrupted!¼½¾¿Àm
BootstrapMethodsÁÂÃÄÅÆÇÈÉ
java/lang/BooleanÊË
java/lang/Exception
,set redisDistributeLock occured an exception̽ÍÅÎÏm
0release redisDistributeLock occured an exceptionÐÑ=>ÒÓÔÕÖ×ØÙÚÛÜÝÞßàáâãäåæçéìíàîïð
+com/kidgrow/redis/lock/RedisDistributedLockñòó
hif redis.call("get",KEYS[1]) == ARGV[1] then     return redis.call("del",KEYS[1]) else     return 0 end 
/com/kidgrow/common/lock/AbstractDistributedLock
java/lang/Throwable
+org/springframework/dao/DataAccessException
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
(I)Ljava/lang/StringBuilder;
toString
()Ljava/lang/String;
org/slf4j/Logger
debug
(Ljava/lang/String;)V
java/lang/Thread
sleep
(J)V
warn
*(Ljava/lang/String;Ljava/lang/Throwable;)V
 currentThread
()Ljava/lang/Thread;
    interrupt
ôõ
O(Lorg/springframework/data/redis/connection/RedisConnection;)Ljava/lang/Object;
.ö
P(Lorg/springframework/data/redis/connection/RedisConnection;)Ljava/lang/Boolean;
    doInRedis
u(Lcom/kidgrow/redis/lock/RedisDistributedLock;Ljava/lang/String;J)Lorg/springframework/data/redis/core/RedisCallback;
1org/springframework/data/redis/core/RedisTemplate
execute
G(Lorg/springframework/data/redis/core/RedisCallback;)Ljava/lang/Object;
booleanValue
()Z
error
.÷
t(Lcom/kidgrow/redis/lock/RedisDistributedLock;Ljava/lang/String;)Lorg/springframework/data/redis/core/RedisCallback;
remove
getStringSerializer
=()Lorg/springframework/data/redis/serializer/RedisSerializer;
9org/springframework/data/redis/serializer/RedisSerializer
    serialize
(Ljava/lang/Object;)[B
4org/springframework/data/redis/connection/ReturnType
BOOLEAN
6Lorg/springframework/data/redis/connection/ReturnType;
get
()Ljava/lang/Object;
9org/springframework/data/redis/connection/RedisConnection
eval
P([BLorg/springframework/data/redis/connection/ReturnType;I[[B)Ljava/lang/Object;
java/util/UUID

randomUUID
()Ljava/util/UUID;
set
(Ljava/lang/Object;)V
java/util/concurrent/TimeUnit
MILLISECONDS
Ljava/util/concurrent/TimeUnit;
4org/springframework/data/redis/core/types/Expiration
from
X(JLjava/util/concurrent/TimeUnit;)Lorg/springframework/data/redis/core/types/Expiration;ø
Gorg/springframework/data/redis/connection/RedisStringCommands$SetOption
    SetOption
InnerClasses
ifAbsent
K()Lorg/springframework/data/redis/connection/RedisStringCommands$SetOption;
˜([B[BLorg/springframework/data/redis/core/types/Expiration;Lorg/springframework/data/redis/connection/RedisStringCommands$SetOption;)Ljava/lang/Boolean;
valueOf
(Z)Ljava/lang/Boolean;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;ùúýgh_`
=org/springframework/data/redis/connection/RedisStringCommands
"java/lang/invoke/LambdaMetafactory
metafactoryÿ
Lookup
Ì(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;

%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!.12345678
9:;
6<=>
?@Ag*·
*»Y·µ*+µ±B/01CDE45
F
47
6G
HI
Aÿ    [*+ ·6šN„ÿžF²»Y·    
¶¶¶ ¹¸§:²¹¸¶*+ ·6§ÿ³¬
69B*
5791:6>9;;<G=M?XACH;JK[DE[L>
[MN[OP[QNSRSTü
pU
VW
A **´*+ º¶À¶6¬:²¹¬
BFNOP(RC4XSJY*DE*L>
*MNT
ZZ
[\
AåD*´*+º¶ÀM,¶>*´¶¬M²,¹*´¶§:*´¶¿¬ 6 ,6686B.[aea b!c,e3f6e?fBgC*R]!JYDDEDL>
T`ZU^_`A¡    I*´¶² ¹!N,-²"½#Y*´¶+¹!SY*´¶*´¶$¹!S¹%À°B\] ^0_@]C*IDEIL>
Iab9cde
fghAÔ    P¸&¶':*´¶(*´¶+¹!:*´¶¹!: ²)¸*¸+¹,¶6¸-°BGHI J0KJLCRPDEPL>
PMNPabHi> 0jd0 kdJRSe
flm
A.
.¸/³0³ ±
B& ,no8
pë¦èê@ûþü…†‡ˆ‰†‡’‰