From 3c061abe43acec0cb66f58ee683c155646444cd1 Mon Sep 17 00:00:00 2001
From: Wxx <2563806166@qq.com>
Date: Sat, 8 Mar 2025 01:36:27 +0800
Subject: [PATCH] step4:snowflake

---
 .../main/java/common/trace/TraceContext.java  |   1 -
 .../classes/common/message/RequestType.class  | Bin 0 -> 1196 bytes
 .../RpcRequest$RpcRequestBuilder.class        | Bin 2248 -> 2527 bytes
 .../classes/common/message/RpcRequest.class   | Bin 3779 -> 4670 bytes
 .../java/com/kama/trace/TraceIdGenerator.java |  65 +++++++++++++++++-
 .../kama/client/netty/HeartbeatHandler.class  | Bin 1369 -> 1564 bytes
 .../client/netty/NettyClientHandler.class     | Bin 2135 -> 2114 bytes
 .../kama/server/netty/HeartbeatHandler.class  | Bin 2150 -> 2267 bytes
 .../server/netty/NettyServerInitializer.class | Bin 1995 -> 1995 bytes
 ...raceIdGenerator$SnowflakeIdGenerator.class | Bin 0 -> 1385 bytes
 .../com/kama/trace/TraceIdGenerator.class     | Bin 908 -> 1342 bytes
 11 files changed, 64 insertions(+), 2 deletions(-)
 create mode 100644 version6/krpc-common/target/classes/common/message/RequestType.class
 create mode 100644 version6/krpc-core/target/classes/com/kama/trace/TraceIdGenerator$SnowflakeIdGenerator.class

diff --git a/version6/krpc-common/src/main/java/common/trace/TraceContext.java b/version6/krpc-common/src/main/java/common/trace/TraceContext.java
index 22c83e3..8b4bdb5 100644
--- a/version6/krpc-common/src/main/java/common/trace/TraceContext.java
+++ b/version6/krpc-common/src/main/java/common/trace/TraceContext.java
@@ -47,7 +47,6 @@ public class TraceContext {
     }
     public static void clone(Map<String,String> context){
         for(Map.Entry<String,String> entry:context.entrySet()){
-            System.out.println(entry.getKey()+":"+entry.getValue());
             MDC.put(entry.getKey(),entry.getValue());
         }
     }
diff --git a/version6/krpc-common/target/classes/common/message/RequestType.class b/version6/krpc-common/target/classes/common/message/RequestType.class
new file mode 100644
index 0000000000000000000000000000000000000000..0430f78298587ca22434940dd38a1c0c612d4946
GIT binary patch
literal 1196
zcmaJ<?@!ZE6g_Y4HdYIaIhmWAD4?!G87TN`6F13>Boh)gNr<1iT4zbu>DH0>KlwpH
zg=jQ<_Kz~&+tn}u*AIQYujib5-g)=e?{7Z=JVGIifI!M<w_0r{-!i*hy=mq*&38Ss
z>(<}DH6sv^RRj?d2(52yJ}*}V($)VH3d|T$5n)E;S*5&Le^M#edH0+O6{7;-*{yQ*
zMWrT?c{xl;!8oE}jH;MGOdx33ZO0UdXSM2%zN_bL-D&1G8at-p78JyBA&f~C30xEy
zI|fvoUW<C}>UPiEcrCD;9bm88dbe8`*r>T3%V`z{JFtLvs+5XLNK+n0`xW^RYuxm*
ziYZ*7aEg{=xhn#bgZjSQnzl89ph6kUFnm@ZaTdyhMHqHNMHU)I<@xRkOl7s9VUdHs
zP<hq!H(s?IbG_GUn4P-bu*vbl8BMieHy{wJwhi6h(mNJQ_&Tzqw@5B_IyZ9MG~IrG
zDXXnfSneB(>_=)=)6v~thj?<94oX8(G;BXJg3`wPfF6fl9A<5$AfVLRy^di%wfJz+
zfvKJ6>n|-*kZ~Gwxs>Dq256<Rq@4g?BoIyUKvEr|{TwvH&rvl^D?iE}l&=^&!uUt3
z1a8th<o#0!pTI32zeIY>P+}r?i1SAfj1T;SpQjzw=jO3MmB1oy`wDqlSs|GFjO2$C
z<S35GLEP~VKvP65*lr0DWLnkST>1c+T;>aspH65fp2j3G*hXK2zc>a7OCEYTs_@YH
zmNZWjm<axW*p~Jn)wbn5glng>7{OiK^J$MMX?|wD6DxLAk`6Gv56P>p$+B044{?1T
X3VZB_s`$Rr;IF=$`*=YA19<ocMCa>e

literal 0
HcmV?d00001

diff --git a/version6/krpc-common/target/classes/common/message/RpcRequest$RpcRequestBuilder.class b/version6/krpc-common/target/classes/common/message/RpcRequest$RpcRequestBuilder.class
index f5d58a69d75848897a68fb8226767f3945e7e33c..649584d2ad88eae945e7db4e2bb9565dd294c9f9 100644
GIT binary patch
literal 2527
zcmbtW>uwWA6#mA!*l{;??htAq&`@j>F!bI!Nl8r808Wrdl&a#_#GWQg>|J+vjG8y;
zW3&<#6_xq`eW<G6>~8IK*0mDxV`t9Hob#RQoY}wsdHWZDH9X5Ag^@HyEsSAYVCtoO
zCCg3e9F?CPzEpKBFurO#wq6$)DHIPTkikS6SqtyM61Y=$TP@cqx0LV8BUOIhu0K~l
zb(F7{d*o)vZZ?!BFse`6N+4f5D;0|D^R!|Vyl)|gDS=7b(aQT#*43_TQE;Z#vu;m&
zwsRD)&sdl>?Aeym$8N*$8kBhp3%Er4+tQOQUtsn{Og{83kYBWL1s_m8WHe?_SDd-p
zl)hg{<Ep^oS=+lFXOYKs6UHTh<H9f>V`fBdBzNNKBU|HJp+&`mEN<e%G?p#g!bkt5
zucPf|dBgMMDZREDO11ahP?5mxLL4SSE++NQusjMDiYN(OYRMB-b)CA@-`o0_l&__u
z3I6jt`<c|7+!<h=z{H+?<VfA|n5_A@PeEu_OY0RDT-9yxI9IbBwcBYODsNvNHcfVG
zZe2DHq-UFTv^lDeZTfUKk-Bb*lSNG>Plv{!ctNy{!XW?ux9A31v^hA(7X#Vo1BvSG
zg3c`ThnW{E3iYETxXIW>gEe+&T8qHd!VpQOD5JaeKS$O?7vbICb30yLZP}(ea=qSl
z&+rmpmo07E_1O-mHeFZy+LP^_pxyYnacpF<iE0{;%!T<@V7aHkc3!zBsvKUw@D6Rs
zx^}%&fnVaeju=DGZRs?c%3rRz?n$RzNm?A+=@SfkXzVcRFY)^^;Lb-7RoQIr*;-XH
z_)g$OEDAj`YUTyg%GbooQeTTU8@(oMR$)u+QO3SCQDj?s>^RB`%1ZIlO(!&@@l@be
zB9MdPlg5s~wc)IM2f|?D2H%DhyW1E?K4PR&=D7)Gz9YfRha;HzE`YCGK(A2FNR4yn
zE~zqSVRlMyAbty2?r}87z&wvZ@PGmL@qjBqbsuvy!WAktMx;x3e&_Hj$rR3tFN7?S
zIGF=`jn*7K83Z(WZXn~Z0h%2QG<|L$6EOp{fKNFlT$?*LkO{c~x`NN>wgKAV+>O!Y
z0BGbKF$#0`IRV1(rwO@2;4q6{kopo|aWpEn7*ms?{GZ7GP<qWwyv8KIX?}D3F2BLG
z!MO>s^WD^b&6I|iPgo-cbBXeOcz@uAf#mcSw}D}}OA+oUR*972kJ@@L=kX2a4DlcG
W+rl<iGd$1m-{UbR@B}sNV)0*7+H))b

delta 827
zcma))&rcIU6vw}_?e3OkDA2;X)mBB2mgR>iq6jKb6_uzla5CzFz$ThN@CTes?BCGL
zP0!*{5+RzBc=BMldGX4fKf?H(*+v^;lx*I-_h#OH-kb04UiMqNxBIj91;7=|R=wrw
zMzN5VXoVE;R-&~ht4sG5R-z`P&@Pcdwz}W#bV~R*qOzhVnG?vV%|tHkA;2*S8+m~{
zCH28BsJCLc`8ZCvI4RMEQ|gDf@AOEVMz0#M^46ocs%B@Dw)fV%k8cv&B7NE8ELUAj
z>e4Co*#6p87MP!Vwm26(Uyoj{4gCqr>ra=Lq8BAK>pT=QYQqV|E%n_Q8BM}MGbHb2
z>B|_;>5b>?5Gb0s1ee~1!<{}g?fS)#xz2!2^mCOawlRP~W`fiqQ~TNtDhF$Qb_0oV
zt&a2zf=_Gw7EdQwW2(abZM1}&+_Lb0kiLWlWpIXTp8-`GNNtBEX&E%h$1po<(%r_9
zIt(arh>`q?5%Mevu}ChNC6Z%l&oLUod9J!gxh`t3gWy591(()BYom31!qLC$5Oagy
z;*a7&oi~FdUg@utZ-jkDLG$Qp=m!1;&DWtxTqMQ97%mwfV4Ob1HWRdITw|8ud5S;y
Nbu{4yZsIm_zW^&)U4;Mu

diff --git a/version6/krpc-common/target/classes/common/message/RpcRequest.class b/version6/krpc-common/target/classes/common/message/RpcRequest.class
index 6f245599a2b8a435d1f733773952a8cd023948f1..60d5f9622e2099badbeb68034325c361b98779ba 100644
GIT binary patch
literal 4670
zcmcgv`%@d&75=VRX@yuG#s*ssad3<a2(X&I3&t%FTu1=BK%K@(TQ6b_GD0g$D<@7L
zY0{+6r0<8DK7Oo!ac0^~A(?ch)Bcjq^lxhFerN9rt)wmEwlihW-h0pe&bjA)=iIY*
z|NhT+{|sOnzfB>AHWP-0I1&o!oV&a07PGrfrDAV6+0{~R)wx-9DxQM5QOy@Now7o9
zWOV7@0*C54vsz)Q9Z9sCNLlEBrEs!YSFf;syW}XeFU-%ZuFuZTtSbz(tWrl#rO<_L
z6FnA=pjTn6+311itqv&|p1;_WBZsZ<pKVh7IcA{`{R(lPDuss+Bg)^w2@7eQR7jl9
z7xUf)g|?B=D=7@%go%e0dT!Xa>}<g<Ze=fR+;DQ9Q2B_3LE$m6a%pvWW~rSad{kJl
zq&H;YEIy#nnJ;=y`MRBRR_tB!+PhRYwdR%c#Vv*<h7k*+0#EHa-nP3bSP_p|7{>&c
zDA{Fux1w<LnUKDA#n;bT_#hsmz6R<T_J+Z81-nw=USs&Mg^%E)3dx*ZoWEJM3krQB
zt!78B3i#s|K7mg%>$V(ETRjy)W<x#<V9LUISs_8WU8sni3l=_wPm@X7S!|@_7!9_N
zB094c=0vBHI?D&V$jrQji}(z)lrxtDYWhY-!}|@$NnsIBn0V5{5|(R$ta|xEcBWjm
zZ<Es0rsI@+9yk~siLenN(&SvSa2cP~4r(_vMch$Xr$+q%)-0^!bEJOTu58b_n@k8M
z+M+o5l!edZX$4E%SvZ*Pk8((BJY(Tmd?C<ScXc)?3`c6TGTh6`^Cb({U@IKowRfC3
zx0tiNr}7>>D^@(a=#h};4?UW#R{uLmL;{$|DID|jBJXC`oO0eS<X^Bi3R0Zb@>@mQ
ztCrdCYhn6)=E4*)+m2oKW*wU))6i6RFXfBQN_BU`DX(ioy-RM+E?lu`oQ4CT;ce%+
z^M_h$(m^Ss`R)Iim$2VKvW7)EX-2Oo^fx-miWxY%^MCO{=oB}OM<lhT+N{)S!y|`!
zBvyKeZ94xA#V4qV0_`NUe(V`hj%$ZK`d9=?;iK5sa2o2Qo@kZVHmcmlG93hmuM^kX
zmiKPEB*>6{b)|e+FzEFsnkxQLjcAf~`_Ou|Co>us7Im(9c5Y|cE(HOPUtV2Yo>x$d
ztgU6IQY|pK<H6!xLrqI`425kay@LvoT63%AoO3ZRXQ{h>PdF#1O`&6j_l#vnjtP%J
z&#dcu6|ZcUbSx^}3H&gHAK}L)ej?@LrwT*$@|`c<a(A4p4x_Fp7ww$qmTxQE3BP3m
zpf<W-7dHz|WoXHDcdDhSLyJg*qSV_6c=#X%;R~0Tz{H$gD6Hi@XDW%GD=gND7?Idc
ztMS1GMnzC(R7NHL)l=_@H`8jAC3&$}bjp6VIppw2-E?plGx3JP*%sQO*f8;Hg;R$^
znGTvdoaWnc016wtNXFzc!YUt=tBBw7j^VewRQN6L48(5weFwd0$942mvPH>R>d9Z{
zJ5X=I+(+j=j{cqk7C$}{Y=K9q!W(O#G8m{N|Aelm-^TG~bRTiNW(DX;qQ!=lc^eO9
z-omLpoc;sHG2gzt=0TSXoIqYs8jBm);YjQhh!97A!#2ToIAkX?Mq`=rJ)Fr*>~SV-
z>>-m$$M<kfmT2>r=wb^T^_S>iE6ZHarh;W?)aOv#9QIihr-tRO=Iaj2^^E!=6E5S}
zWna505{DAaZjmnYBE_e;oMkIE<C#C=w6LW2tT_$uH-4~R-ku_q&onEa43Sk=<~1rp
zdAM15AX1q(tqA2zv+}7(W!{g1FopMgu3337LRk~%a_tgs1|CSxNC*;sfa}?!nLFlN
z>DP#Z5GH~UDwI))vUBD^?Z`2bz<JSjh9A_9q>tFC;ufEh5DojvJg6N>KC$y0o)1V~
z3iA_6^~3qmWuTtA2|smfh2b_=;B{Vms;+W{c6$8gSmt+#8~4Wkir5>7x7{223u4RT
znSFf7AF}hYm2o~MjfuaZBW=8gBX?m<q>X({))3Q^aYCji6Y02M67Qk+E;`fkbRq<r
znKTKSnM|fl0VM;FnNEg4j}!9vJ6Nb$mZeu}W8)qj)@MFU#It%M2Z{0~Uci^R%|6`0
zS6F8F6^HNOtCY1NgKyw#>=`@^*YP5IaV+!g_jUFXEJZVTi9M4kHiehjOA-%;r^`(K
zgAc^sN56>y{wLM@@>MC__Hehmo5uNJrg`>Dg=BhM2p0dtB_f>YwNp+gy%ztKd}L@d
zYJqxE9NnI&^TxCvl!2b9ZH6S-Gj<o|#6DK9iF|s}kcqSr%p@gHdTM4e?oTmBzEUzB
z_oqZiP11hl+H^1==Q4;UTo+e2AiRyVy@FTisBGbz?8T5`$@~^K(S|epVEZ<E221i|
z41*9Zls<>VeH@2DN|hpqQ0hM6^)bcw8NzrCP{SCFq5zf%!Rp9nDZzB}y9ZVD2|6S7
zdr$}!^7xz4R9t0460W|BF9OYFPRC8Z9|i*&41CXz?rV6RtwFn8_&$3{_I|+M&+rS5
TdPz<fe|MO(zr?Tj(o6pfKW7Vn

literal 3779
zcmb_fTXz#x6#h;-xip#5&?_kw5ehVEOH}aI6tGl~Vq37SMJ@`{bZCbrnUI;F#oH@C
z!Q~H-7anviE-qZlr7yUaKgcH$zcXjjOqzkkgDlAGv(Mi9?EUS_IsEnS<KF-r!*?;X
z35*u(QpqmoN~Yr&Yi4etQdlr=)=bA8ZjdKyR&mv=CLo~ch#)EuowUl9dt9J>B(t1A
z99j$=0;wCuEhASn%4@lED>ux7+kqtX7&>+AK$k%JxyK1~T4mR)UN;Knyiqa*x@Q~4
z7Tu~<Udu~sJ9TtRQ;Cx4uG_0pR<e6_^r4@QRg9`pas+xV2lSOQp8hT!X$(?d2`+6`
z<XJ)C>7wB{`2>v)>39Wu1mXpweClS+C<^qAw3^LalEQm+yoP<mV9j)AnnURw$pp0g
zU?gh8Iu6JKqQu-NI?~J`9V60AC(X=lg(!EjIz}-j(7~Paew2M9nV{=_oCzF8E{4~2
zyn#3CS*f{JF*jAM8k<BXv1*zXFC;E9BOx|ISSrq=I^M$D%0cCZ!jM4*b?PX_@ve^d
zFhLa84QGAYUM1eFni=Wjq|QoY73tEQGh5sJVGb#c_jOF+q_44LD=Y;Lg=(~d-p$(o
zK*uSZ78ocQ8|JiKE*S0w%cW;!$2H0>0l5-PvY)P2TQ9>2$$JcE1bV&Nw(Q)ZS+$I!
zb=z1e5|@reYpra!wJPbp7BnZb$MXWQ71fRcIhNIP8>+Q`sjDgYyJoGjIbSQSnAIh9
zaQCcTFpA3touMN>Q*+lXqOtq=htTBgOJNm^#V^tzOBG9IS)jk!5q78V%(?&V90{X5
zY9ORw6~rm0rG=aN-Y*Ghq?4kJHf096t~Y0R8T(4X*6C}i-Ub-ETKRS7h21<MeNY7=
zw!3atxha!3yltlTc$?d~U7l!To^oO+xge`^(KQMib4JC_N96p%%-ksfF~jjyHJw_~
z71*)ebaFUoBkpcBY+})_RSV{6OO}0C<E}X@8$%#D&nsxoloiSfOr5lC*Kw;xMM3R!
zMR7BMDx4Tx+08Y9;l^!Ym2cS_W=>^EHTY?x;M&zqf$xK5<O?dJXN>Y{(R7AqZF{3u
z$-l6>n-t~v3lR_2x1XKhH1JJK8^z+H<(m08z7Uvd05Q^(x?^H&Zv#oWs(3d*gOXkx
z6B$m%nR3~zdPQUsyPXY_{yiSUR{{rG;0i+_hHnJ+yjYa!SCH}gOY%+=_z)V}<b}^+
z+a_;o@5}4i`||ds%#25$<z5Fq!Yny+<m{!q{1g8b;^HH;|3q3~p1)Ck!7H8x?$J^@
z$CczpvX2n^nM7Mav>WHh(Ukzs<72L*@&cu#^0)j(_#KqW+0h3`WXB#Ll^uV8o@`os
zfB|W-Jz%lNvv^c#`4*|~1uESb^g@*Z49d3%btNUk)v!of`64-I$x#3-(I>td_}d)N
zeI#V;!GLy!2E?~Qh;nMX@?fYkpA#X<J=>LsLY4Ul@S$wv;XVeoEAI(WR<VD=vzKwf
z_h5p?Bz93R7u&Ph>sjen5?k0uee4B34Y!keSv#^wWiegEr7(YbUe=DxyR>r|SA1}0
zgK@Rg)brv}P12~Es8==hw)u=F@ZG396%v&gk-IaR{SguE-sm4l{(wmPz0u#1oEytN
z#BOg%;??;v{!D1&e<GRIo?z!)=;LYaA@<iL4o*ZUa&RJ=j!2p46LjB2XF8IO281#c
z$^3%xy3!G@kJQ)NJ^B*t8x`Xj<>OZF?%;D=Wdwb2aE;yBhGDG2Ag>)+?yZp0I7+5a
zAQfSM<hg&9&2Q5FJ|tuDf3PEl<Wuy=5a-{xc#2($>=0dD)aK(|VZ;Zh;0YWR5*+DZ
zu(N_mh-^6+p<B{HAz!b)nZKzghsIJWKdBw_03Ax@*9m7lHF_7Z@rQWln&cmx(Bwv1
z^LOGBWNt|&w+UW;YeD4XA{;g~ZkBwn+6mNktkIhY8)BVQ8xkBR7Cmjpem?hakkUMe
zIAoq-K>o)pDFk7G5YH&oShq<=A0l;ux{TJ$q8QKH*qSq^X<v@JAsN05RmF3HA4YQG
zF{Xj-LqH*{2H=n%i-w|?hZ4&CN}B>UDS3lb`0p0J<f@wy@;QJ_-V?X+HOF@PKUd)?
A!~g&Q

diff --git a/version6/krpc-core/src/main/java/com/kama/trace/TraceIdGenerator.java b/version6/krpc-core/src/main/java/com/kama/trace/TraceIdGenerator.java
index 1050485..042b997 100644
--- a/version6/krpc-core/src/main/java/com/kama/trace/TraceIdGenerator.java
+++ b/version6/krpc-core/src/main/java/com/kama/trace/TraceIdGenerator.java
@@ -8,15 +8,78 @@ import java.util.UUID;
  * @create 2025/2/16 23:05
  */
 public class TraceIdGenerator {
+    //机器序列号默认为0，真实场景中从配置中心获取
+    private static final SnowflakeIdGenerator SNOWFLAKE =new SnowflakeIdGenerator(0L);
+
     public static  String generateTraceId() {
+        return Long.toHexString(SNOWFLAKE.nextId());
+    }
+    public static String generateTraceIdUUID(){
         UUID uuid = UUID.randomUUID();
         String uuidString = uuid.toString();
         // 去掉连字符
         String uuidWithoutHyphens = uuidString.replace("-", "");
         return uuidWithoutHyphens;
     }
-
     public static String generateSpanId() {
         return String.valueOf(System.currentTimeMillis());
     }
+    static class SnowflakeIdGenerator {
+        // 机器 ID（0~1023）
+        private final long workerId;
+
+        // 基准时间（2021-01-01 00:00:00）
+        private final long epoch = 1609459200000L;
+
+        // 序列号（0~4095）
+        private long sequence = 0L;
+
+        // 上一次生成 ID 的时间戳
+        private long lastTimestamp = -1L;
+
+        // 构造函数，传入机器 ID
+        public SnowflakeIdGenerator(long workerId) {
+            if (workerId < 0 || workerId > 1023) {
+                throw new IllegalArgumentException("Worker ID 必须在 0~1023 之间");
+            }
+            this.workerId = workerId;
+        }
+
+        // 生成下一个 ID
+        public synchronized long nextId() {
+            long timestamp = System.currentTimeMillis();
+
+            // 如果当前时间小于上一次生成 ID 的时间，说明时钟回拨
+            if (timestamp < lastTimestamp) {
+                throw new RuntimeException("时钟回拨！");
+            }
+
+            // 如果当前时间等于上一次生成 ID 的时间，递增序列号
+            if (timestamp == lastTimestamp) {
+                sequence = (sequence + 1) & 0xFFF; // 12 位序列号，最大 4095
+                if (sequence == 0) {
+                    // 如果序列号溢出，等待下一毫秒
+                    timestamp = waitNextMillis(lastTimestamp);
+                }
+            } else {
+                // 如果当前时间大于上一次生成 ID 的时间，重置序列号
+                sequence = 0L;
+            }
+
+            // 更新上一次生成 ID 的时间戳
+            lastTimestamp = timestamp;
+
+            // 生成 ID
+            return ((timestamp - epoch) << 22) | (workerId << 12) | sequence;
+        }
+
+        // 等待下一毫秒
+        private long waitNextMillis(long lastTimestamp) {
+            long timestamp = System.currentTimeMillis();
+            while (timestamp <= lastTimestamp) {
+                timestamp = System.currentTimeMillis();
+            }
+            return timestamp;
+        }
+    }
 }
diff --git a/version6/krpc-core/target/classes/com/kama/client/netty/HeartbeatHandler.class b/version6/krpc-core/target/classes/com/kama/client/netty/HeartbeatHandler.class
index 7d8d2797071f710065e3b275b7b5260f6caba067..a451e3870a748a9892097a8f124280092538dc4e 100644
GIT binary patch
delta 741
zcmZ{i&2G~`5Xb*(J2-I`2@={6nvgWKA&HZiLV(be0xc~RMI4GKNSs{DHK`K2*apF=
z;(&MnpO83%#H~T}g99H|-hemgQy|6(0#w9h=0Cf$Grt+_cjYx#zWw<43BYCC+ES8i
zRlzZg$Qb2F;W$IuaC$w*)_SJr>6WQ2Zy3wwqsOM_GsGU6y6exGI_Yew-2QKBD~=Nw
zlab-b;$(22x$!*4WfVA0VIp`gs70~sSPY4_<64^6U2CjsZO5`qw-rT^LEYbevH$sH
zGbpl&r8r6`%cyXus4^Tm_=G{~*lP~MNU6Q9Khd?WZd=+N-|g5|tGuE>K%GOwnLrWm
zK2UHL=VUZE&f@|@>R`1+-S8dv8BJ@M{*Z}b^6$#?UET9q<$uwGcfx9*i~YhPL-G&F
z!c)WC@H>vp5S=l)9lPVt1{JBanI|%U(XMDKq(ssY93p#>B8@yFAF1qsZIKYrBpY4>
z30xw}hY6TQiy{`zNLk_I4^%8dzFGYW`4wu_FOYB7wh^0_(o!FX-yo%K?jpH|w19hk
z<Pwv6I4$5UVimQzgId^795gH<MtT%7eGrZ`wH_nl3=wBhM-EfSQ_I2ts6kCR=^6T7
zB4uVUOI8X&enE!n3a*CWD<rRBj)><eAp)^3L~xy?M7Ilw;>Pb?j1L9{Vu}1NrrskL
S;;{kVa34o0x=CjOmVN@Dii?~8

delta 497
zcmZvZ$xZ@65QhJT!GUow$_^qfAnPD5xPi;n#3d#qdX)nq7#4%0i6>6R2bhzIiHR}Z
zAqJNimn(1J-2)F{jMaljFMm~cb^Tv;_m%u9Nu8hPR{*P6Z%TG%F~h+S{d&CBwhf^H
zsUI%5MR;U*;nNzdzUjw^h=7byj4=!z=1=pfa=uzj<<5@PLWRLtJ5d>&TY9BbOYPQ6
zRW+y93;9acj0uKhw|(AyyZA$FNC;t4L|8@yQ3m@zeGK9ecPUrNINEdWF;&_wW@CFI
z;@US$Xl3Jp_F~9s9pgP)(HeqByAi^T7z}hnkTRIiN1C8jiXx+Eia&rg^|C_B%YYS0
zQn_~kQ*;=VPh*Bmc=I(y6GcV&fOv_B@(yt)*@h(}c!d_McW@+Z_9r+E*l)BjY#VPQ
z$RS2>NB|<~5UGtI4pJ9<a3cs0+52^PngINnXE8@zHu``xslcIs1MzGg3;K`>7O_M_
VE$a-HK!y^5N?BMK{Vu=#+AoSzRzLs%

diff --git a/version6/krpc-core/target/classes/com/kama/client/netty/NettyClientHandler.class b/version6/krpc-core/target/classes/com/kama/client/netty/NettyClientHandler.class
index a6cecd45981413cbb45afa454f8b9348a1334d8f..43f66cb1c7d028c0ca2d4c9d22ae1044040b82cc 100644
GIT binary patch
delta 596
zcmYk2NlzO=5QV=UuZ#yY*at937*8O8ZI%#10$~kH*deR2ID*9`B2ogU9QX}r?)eYI
z5=#yUaYP)rapsR8s%J(6hpwuAUGKf>y0for^ZMcc1u#zK*t}KsbvV38&|%TZOSjEf
zP~GmXkxLaQCMa3-(&ru-D~$sduNYLswtxKmT~#=)ty<0bgZ+bF)%OX8+<POJbQrdH
z%R4t2*-DKf_?RV56Scj_U!~S+^|39r<6wxtqD4DO6_YwfT;inM`Xwuk7EV#eQW#80
z)X&h!v_#8q-~%&qi)usZ(&Rsqqmr}kO}zO~vm+k6K{7OnN|t6?J(Ysr8K?+{S>`<D
zEc1L6r8pTDSQPG(u(hj?EDN$CNK}wjIqPf${uO!APMLq?(}!K9b9y2a&*@i`pZ?-c
zlOshtY4YAQ?LIG@CKFDR;S--lKXkNb<;PzF$DzQ{EEG$ZyguPg=u-`rW<Oh+85o3O
kB>C#~>GkEk??YYMIb)<oUTdjm`?tmQn_vdtDSLVI5la+4eE<Le

delta 609
zcmYk3%Tg0T6o$X<NixY~O2<jb#S|5SB!*nLiHck_DBumbBey5uCCCG?oIOv#22({5
z7nbFc6+1RQ1W!P5re{dGnC{bm_xb+6d;WSio^y5g>o+jZ!MSs-oGd*Ixjbh$IMWR;
zLzx#g6_*jJib`;6RRUiRsCqE23)xY|Y{p$Cm<$f|N@B?7Rq#(2(q-PbO!GFdti$Xq
zb2jrX?|9!nvQCv+Yp0WkDqlv6v*K9@mntcBl9Y_i;5gOOS`aN<!4p2n=$bmoM;2w3
z2>C*2N_`@8LgtchUy@m^b$G03ba<+%cgSlZr9)A%doBkpLbz|5dc~xlK8Z0*-WXMl
z-YUgT!exnN<6hzupT#XjfiHX&&^G~v$s%P%l<%S>L|K(@osBr-zU)}Cllv(#YZ9wr
zg|S}7iL^=d$Q&t<WssIn(Zm^y`nqXy-84Bi*%E%&(OZ;P*^V8jVn?T1tN&r@g4f~I
wBcteDz5m|TiTPdD0%>;44`@nT(Oe%ge)*D_Hl>iIOy~!e=7-_$vS;S~dl7g*%>V!Z

diff --git a/version6/krpc-core/target/classes/com/kama/server/netty/HeartbeatHandler.class b/version6/krpc-core/target/classes/com/kama/server/netty/HeartbeatHandler.class
index a5f169298ab0b26a23c916b3a04c24ec5670e7b5..739f1edbb03468065f0ada5e7dbc47998dc6fbe8 100644
GIT binary patch
delta 1009
zcmZ8fNl#N@6g{^CkCsQlG8Sc~Kow{~L~Id}Nzn?*AP6YbT57R*kGvLxD-z=nV~m=o
z3lbA!G`KT>5dn=u;>urObY(&dYj-X*-WH<`n{%i0ecw6vy=eNk9mdbU*WLj*2>+t7
zgw#T<Ems?q{RFdHR{Zu*aH4+F?w0+2pP~-atBMqq!789!L<K4d>Dx&JT|k<U)h10(
zkpU*uh_J&<NEz(y>hI_s>uPs*m_aBKP^T{FvS-cEpk72V_7QBA?n%#Ok3Hy-{PvC+
zuWu?GkR_Kbq1zW$0+Qbqld)e!V@!kIrzo;wgcB|SO(J_~Cgf}v*6HzvW#tON;P-{M
z3=yoAWeIn;1wEk<zqb9T>uIN!O2|jZN?`xjN6>o1GX(WJ<*8q^Y3j7DF@=!a<P8R-
zK)6}`s&ko68!?C>0cT=fht*R3CvlWezqx#U^Zm_Qhx$WbGjfhly49$2grZANqK|Gx
zZp=j=E=2FVsPbO)NRlt;ETUwL6D*Nu*Ea6mSYNxn{$@FH_x{F%$C0;JBP%OJ5WASE
z#O?S(0=#Tg?a^D41h9t!P77uUNp4xbG(E*?GWipLzeyf)kjt5tb3Kw64{>GZNF4RM
zUxOAo(V&GfHU`pgm{Hs!pcQRg5!%tgEIv%TIO@44SAB#qhoPzu5V{#=g=H9=I*V=z
zsq-jWLdKp|SO{w<1XfY10oOLd;B#1Gr0RL(Cy*T5N#<^zR<B`iY|x;=VqDQE#!$<4
zT3A5?QW>)#Ae;5h=5m^ceC&jS(TM^UUx)$T#we_OtQ6z?i%BSt8*FB~B2J<cNBFud
z#-lJp#~c&7aEyCw@vr?@b{y`w02wFH%`52Pc?NX9;1nPTF#QapxK%){iSGp8Lo72H
zr~d7{IDQ&1m@`*!;3YC*d#8lGoA}9I?rG46evX-34=`gSj%VXI1`kh++&zyAn1JOE
DD6P~j

delta 798
zcmZuvOHUI~6#j0f?U-RiptNbD*7`sT^dUkkwmwiqsiH+t!FR?wsU_`{wAJWFRz?=$
z=ITNhCYrb~CI}|h*cgq8EB}IPDsiL!0rbo*ZCseioO92)=X~FHa_+a*YK!u9rScKL
zK3rK;wy;pkly*}KXEh@o9=}~I={W`|f1||U91%B}e0a2wF-qg5g0AIwj=c>k*oF=n
z+g0p<pTY5;ItF>#?8+KEVM&G+gb<doQ$-JUG5o`sygH?)h;2<NPYf9&&Cu@Wzb%e+
zZD8nAu^ADD0sjcU!`yB0nx>jsQO<u^+9esgc^B*EMQMf4S<^uoiMlLNI&>?gPnR-z
zgP|#PT{8?lJEm*bXwqCU&Hq^A&7%rVVNAxjNqCwM+rBiNW$0Zl-(CK6&){x*C^1QK
z^}&nk!}8MX!qWWn>g>DkuU=OlEmY^`e}1^{TLq5!Sio1$KJhUIH9>@h!K_v+>O~nB
z_)~kA^%8@ZKeK!J54-A!!a^GXBpTTUJK28TD!XEPC}&2%TExhz;%q}4dnsbH!~N9R
zPv@89ZRDeY&yXLZhikHPX8jvDy5GaYP{AgkjI9)PGE6K|r34e*3z=*iSqGsz>2qTv
zJhZM2h`=XU`v_S@Ck|kMx}20fNF7#_ZB>bRI)p)?E{ek#A~i=aBL<4#C{<eNZkYaK
z4aJj$CDDzmAu>=#u!3G8)Kq8@3KjC82j@hGP~)q0HJDuuW*3eN<~m<^m`X<k&<UI*
Y-%L<R5^+Y@37n&xLh*TA#ASH?0><N{od5s;

diff --git a/version6/krpc-core/target/classes/com/kama/server/netty/NettyServerInitializer.class b/version6/krpc-core/target/classes/com/kama/server/netty/NettyServerInitializer.class
index ecd2890f8652fb2bdbfb503b37b442faa43bcb08..588ac44e7982c392a1436752ead0bc2fd084079f 100644
GIT binary patch
delta 12
UcmX@jf0}>7HAaz**T1j<03@XavH$=8

delta 12
UcmX@jf0}>7HAbF|*T1j<03>|{ssI20

diff --git a/version6/krpc-core/target/classes/com/kama/trace/TraceIdGenerator$SnowflakeIdGenerator.class b/version6/krpc-core/target/classes/com/kama/trace/TraceIdGenerator$SnowflakeIdGenerator.class
new file mode 100644
index 0000000000000000000000000000000000000000..de725b3e997456a4925b8edfa4084480eab94840
GIT binary patch
literal 1385
zcmbW1&2Jl36vfZ8#~FJviCt%ss0HeA+NQQc<Fq9$kP`CImO4sOR7XZ#p_j=con$;?
z#^a{hfU;oK9kNu>mLgW|h6Pg706}C8e+Q|Q6+2cH=Dw-hgbE1>OMc&T@9&;>W`6tY
zr(XcPhf5kFh^kO@#L&TzTH!Z&(c$iL@#^A=umXmT3$|+q;|$SUz7hl2&F%3T64218
zLf6rSZicrkuUcH?RbC8yZi(W8Y)eZY2v_(#@ciRt*IWC<;j0H18DgU5SvMHijEtAk
zaYzP>*Tts|;aVcrYX9VJuZ}*s+vV_juwYk3J>b<E0m)yqrQ!&~z&?J-al|rrCjI3`
zRk*>WTb8H=w&%w2Iz#p&&tDb3S-NQM?tHQL?e^~dN9M?9r$^45HGlu{_THVx8V=*A
z6eYvZo15K_TMm5NT^`F<BvV$$KuEk6#w#spIF1u426dc7?jLfN*Xx0(G90oRzE421
zf;ro9?0Tr|jEVxok^MZ^8g4*G4sgH8kbHXQ$=;XW?B09u^!B4ae%{cK$I-R~$(BY$
zr*)jcS%&U4ZU^(?R`4Q+lAFoTkb2XeOTxK9g*y$wAeSrDO?yi;OU~M^m~T`Ug}=ZT
z9a>4xdKPyo+_&Yty{H5?B=))4|8whO1W^vSwK~UZ?RXt7ftHpS60+p*UKzBq*YGWI
z*_If+uNrDtDn(YAr{h<=dZ1#8A@d(R40_2WM^2N4>VhgT{>_#!NyiA8N<ms)FOAaD
z<sh5WI0BXaWYlm>mZUyPdohesdyZyb(UVc?M+;kE1q13P5{1Mjk~B_l!pJ0=_t2R!
z(BFK3u5BE?o_=i$Z|oE@n=ro*!=0yg0C8&b6wE{?jv<9X^rL_i7(x-J2xb^>(}}(i
zb`<a6U7Ata5Sn3(#@&dt=z)j|O#!{MSzJJ_jrl7fOHAtr9Gl1#9>ZwfmpJ+B>7gy0
z+IhZo7lQ@bOKRM}@aM7!nk1TcVaR3U2}UL!BL2KQ;y0))RiygXY12&U>l^a;#&?t^
z3RzTvv;|pIA<QmPtDm4vLLDZs^BBi8rf>z9F^AHD;;eRY3O=Tfmb?jBTpZD7=vRgm
z5`awKE^CEi%U7a@%9_e%nqNbcqlc|Ov-=onIt0v9dzFAbr0cvErZYoDdR}VTBfmKm
lSV1yO91Rnb0iHpjZ)TK;r6b<QMA%OfKPVu%7n8V%_}>m?F^vEK

literal 0
HcmV?d00001

diff --git a/version6/krpc-core/target/classes/com/kama/trace/TraceIdGenerator.class b/version6/krpc-core/target/classes/com/kama/trace/TraceIdGenerator.class
index 5bbe78752493bd2fed1cf63be214e1f214eecfa1..ed9fb11aa763fa8bf7ea897cbe43061f9e813e6c 100644
GIT binary patch
literal 1342
zcmbVM=}y}~5dIbdPK+CZNoeWCQQC&nJt#dwX=%6u0e*x-{Znai7GiL0>ev+Cs)qzo
zEA;{TP*rDhks>Oj%F^!4?A-H>fBpXc6ToY%sAxf}f{=zbv@^u^`4Km4?(7-sJNv@)
z8QP~U$MR<wT9d<D5rh#@plaxV#?WWFMdN@Mx#4@<6vl=;Gx<f~2#@=&#}LV_t#2=6
zXIJJKrm|P459J*9)2_`Anth~HMA4}rrlAWu!{q-sp)wqC>}T?oGL}`ukx<a1;W}<G
zM9-_vy3QU$hwm<l<DBnVl1n6)hqLD@RWYS?6SoxH)^G=R>plYCvW?Bn%p8O2aVPH<
ztBjtkd1xq9?E5tgV2~l~yY*o4x@KhvwOC;cF|hG49xy;f62l5cG>l^GuaVV#D4sa9
zX%Y-`$)?291@7g<$3QryNc~HGX{8e|6g<-KSPq~GBe|23FNzFZX5e|k@i(lZShZ~1
zD#;|DYM7MmRgSnFi1l4L$SDc5=L{k0=@wmSH&1DHW-Ujo1;riVZSWnNBzo30xxK|b
zOY${g$S+tWhJmYalp>FNRSb$6BpJFdNUDPg1%XANh*jHhJ{_8$e5rR-Z)#U<CX}Pp
z*tYzF8~95nhXvtKa?yI2+#z=)-on$SUE3fv=LViB7A#p|;^MMQNQe>k)<nr)6|xuP
zPRls7OKF>zN`lz<Wg9{m3ey?`j37ySNmLurw9s_EAkLthfP=P?Gq5j2wBRM3@>#;^
z6`fjD0Vzxq7olInAW5Y0V8u1*eT8z0Yh`qQCMj$3&`J6;4gC*jr4NXg(YrEoioWcq
zeow!DiifLX(y|&`M~G;7c9V62sGdq5{bU<L3~%t3-Xm1bEZ$Kxo$S&?wUBJC5v#A3
zn^MMj8BZ=I)=PbvZ**a(5|T>&f$00l8J>NEBAd}%ibmlVNY;WyEYTgJ*C;YXsTC@W
HWrY6#PZKWQ

delta 386
zcmYk2%T5A85JgYV06jE~;E0O&7!Z`V_+n-J0Ut5`fQcrulBK$I>Bg9t{t?|EaY0=3
zQO25(7<*Aw_jcV|m716rZKgk86X2Nso9Sf@0cnk~WU%g1^@D&pOOCvIRkdQMP~Cun
z0>cu^nxbWelAEeQW{q{th9#oxj=XwF;WwHmao?t;N=>03uJ7(|F9xooiYd*uB68ne
z<et5uGyaWx^s7%)*us;Iz(<iJC9y83Ct2o_Y<;3Wr0{4+jKAY;niB1-ffj8+X*%SE
ziN#l9=1VS&(Wk8u*|T;yA1;hoJny^<Kl2Jn3<X#cWJR7M6oc5fEaHUJU3LVe<v2Zd
j#X1z>o>ZQ2`+vhC!ST~$R>xFgfAw$If}jK8JPv;W15hVZ