Êþº¾ 3 Å
|
1 y z
|
{ | } ~
|
y
|
|
|
y
|
|
|
|
|
|
|
% y ¡
|
% ¢
|
% £ ¤ ¥
|
¦ § ¨ ©
|
/ y ª logger Lorg/slf4j/Logger; currentLocal Ljava/lang/ThreadLocal; Signature GLjava/lang/ThreadLocal<Lcom/codingapi/tx/aop/bean/TxTransactionLocal;>; groupId Ljava/lang/String;
|
maxTimeOut I cacheModelInfo Ljava/util/Map; 5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
|
hasIsGroup Z hasStart hasConnection kid type readOnly <init> ()V Code LineNumberTable LocalVariableTable this .Lcom/codingapi/tx/aop/bean/TxTransactionLocal; isHasIsGroup ()Z setHasIsGroup (Z)V getKid ()Ljava/lang/String; setKid (Ljava/lang/String;)V
|
isHasStart setHasStart
|
getGroupId
|
setGroupId isHasConnection setHasConnection getMaxTimeOut ()I setMaxTimeOut (I)V current 0()Lcom/codingapi/tx/aop/bean/TxTransactionLocal;
|
setCurrent 1(Lcom/codingapi/tx/aop/bean/TxTransactionLocal;)V putLoadBalance '(Ljava/lang/String;Ljava/lang/String;)V key data
|
jsonObject !Lcom/alibaba/fastjson/JSONObject; request Lcom/codingapi/tx/model/Request; getLoadBalance &(Ljava/lang/String;)Ljava/lang/String; json old StackMapTable setType getType
|
isReadOnly setReadOnly clear <clinit>
|
SourceFile TxTransactionLocal.java F G ,com/codingapi/tx/aop/bean/TxTransactionLocal « ¬ 2 3 &java/util/concurrent/ConcurrentHashMap < = ? @ A @ B @ E @ C 9 8 9 : ; 4 5 ® ¯ ° ± ² ³ ´ µ com/alibaba/fastjson/JSONObject g W R ´ ¶ k d putLoadBalance--> start · ¸ T com/codingapi/tx/model/Request plb ¹ R F d º » ¼ ½ ¾ putLoadBalance--> end ¯ ¿ java/lang/String java/lang/StringBuilder cacheModelInfo-> À Á getLoadBalance--> start glb getLoadBalance--> end ,res - > Â Ã Ä D 9 java/lang/InheritableThreadLocal java/lang/Object org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; java/lang/ThreadLocal get ()Ljava/lang/Object; set (Ljava/lang/Object;)V java/util/Map put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; 8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object; org/slf4j/Logger debug toString .com/codingapi/tx/framework/utils/SocketManager getInstance 2()Lcom/codingapi/tx/framework/utils/SocketManager; sendMsg 4(Lcom/codingapi/tx/model/Request;)Ljava/lang/String; &(Ljava/lang/Object;)Ljava/lang/Object; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; #org/apache/commons/lang/StringUtils
|
isNotEmpty (Ljava/lang/String;)Z ! 1 2 3 4 5 6 7 8 9 : ; < = 6 > ? @ A @ B @ C 9 D 9 E @ F G H o -*· *¸ µ *» Y· µ *µ *µ *µ
|
*µ ± I % " * ' 1 J - K L M N H / *´ ¬ I 4 J K L O P H > *µ ± I
|
8 9 J K L ? @ Q R H / *´ ° I < J K L S T H > *+µ ± I
|
@ A J K L C 9 U N H / *´ ¬ I D J K L V P H > *µ ± I
|
H I J K L A @ W R H / *´ ° I L J K L X T H > *+µ ± I
|
P Q J K L 8 9 Y N H / *´
|
¬ I T J K L Z P H > *µ
|
± I
|
X Y J K L B @ [ \ H / *´ ¬ I ] J K L ] ^ H > *µ ± I
|
a b J K L : ; _ ` H "
|
² ¶ À ° I f a b H 6 ² *¶ ± I
|
j k J _ L c d H Ô ^*´ +,¹ W» Y· N-*¶ ¶ W-+¶ W-,¶ W*´ ¹ » Y -¶ · :¸ ¶ !W*´ "¹ ± I *
|
o q r s ' t / u : v I w R x ] y J 4 ^ K L ^ e 9 ^ f 9 J g h I i j k l H 1 *´ +¹ # À $M*´ » %Y· &'¶ (,¶ (¶ )¹ ,Ç j*´ *¹ » Y· N-*¶ ¶ W-+¶ W» Y+-¶ · :¸ ¶ !:*´ » %Y· &,¶ (¶ (¶ )¹ ¸ - °,° I 6 } ~ * . 9 A L T
c m J > A T g h c 2 i j m ( m 9 K L e 9 n 9 o ü p q T H > *+µ .± I
|
J K L D 9 r R H / *´ .° I J K L s N H / *´ ¬ I J K L t P H > *µ ± I
|
J K L E @ u G H $ ² ¶ ± I
|
¡ ¢ v G H # » /Y· 0³ ± I w x
|
