From 83b49f0365c4c213f5544425cd5bec7d79c5ebae Mon Sep 17 00:00:00 2001 From: Wxx <2563806166@qq.com> Date: Thu, 13 Feb 2025 16:39:06 +0800 Subject: [PATCH] =?UTF-8?q?version6:step1-=E5=BF=83=E8=B7=B3=E6=A3=80?= =?UTF-8?q?=E6=B5=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- version1/.idea/compiler.xml | 13 ++ version1/.idea/encodings.xml | 7 + version1/.idea/jarRepositories.xml | 20 +++ version1/.idea/misc.xml | 12 ++ version1/.idea/vcs.xml | 6 + version1/.idea/workspace.xml | 62 ++++++++ version4/.idea/.gitignore | 8 + version4/.idea/compiler.xml | 13 ++ version4/.idea/encodings.xml | 7 + version4/.idea/jarRepositories.xml | 20 +++ version4/.idea/misc.xml | 12 ++ version4/.idea/vcs.xml | 6 + version5/.idea/jarRepositories.xml | 5 + version5/.idea/vcs.xml | 4 +- .../com/kama/annotation/Retryable.class | Bin 0 -> 391 bytes .../serializer/myserializer/Serializer.class | Bin 1296 -> 1409 bytes .../com/kama/consumer/ConsumerTest.class | Bin 3941 -> 3967 bytes .../com/kama/client/rpcclient/RpcClient.class | Bin 207 -> 229 bytes .../classes/META-INF/application.properties | 0 version6/.idea/.gitignore | 8 + version6/.idea/compiler.xml | 18 +++ version6/.idea/encodings.xml | 17 ++ version6/.idea/jarRepositories.xml | 20 +++ version6/.idea/misc.xml | 14 ++ version6/.idea/vcs.xml | 6 + version6/krpc-api/pom.xml | 20 +++ .../java/com/kama/annotation/Retryable.java | 13 ++ .../src/main/java/com/kama/pojo/User.java | 26 +++ .../java/com/kama/service/UserService.java | 24 +++ .../com/kama/annotation/Retryable.class | Bin 0 -> 391 bytes .../com/kama/pojo/User$UserBuilder.class | Bin 0 -> 1701 bytes .../target/classes/com/kama/pojo/User.class | Bin 0 -> 3013 bytes .../com/kama/service/UserService.class | Bin 0 -> 343 bytes version6/krpc-common/pom.xml | 32 ++++ .../common/exception/SerializeException.java | 17 ++ .../main/java/common/message/MessageType.java | 13 ++ .../main/java/common/message/RpcRequest.java | 31 ++++ .../main/java/common/message/RpcResponse.java | 37 +++++ .../common/serializer/mycoder/MyDecoder.java | 58 +++++++ .../common/serializer/mycoder/MyEncoder.java | 50 ++++++ .../myserializer/HessianSerializer.java | 51 ++++++ .../myserializer/JsonSerializer.java | 78 +++++++++ .../myserializer/KryoSerializer.java | 80 ++++++++++ .../myserializer/ObjectSerializer.java | 60 +++++++ .../myserializer/ProtostuffSerializer.java | 83 ++++++++++ .../serializer/myserializer/Serializer.java | 38 +++++ .../src/main/java/common/spi/SpiLoader.java | 111 +++++++++++++ .../src/main/java/common/util/ConfigUtil.java | 48 ++++++ .../common/exception/SerializeException.class | Bin 0 -> 561 bytes .../classes/common/message/MessageType.class | Bin 0 -> 1196 bytes .../RpcRequest$RpcRequestBuilder.class | Bin 0 -> 2248 bytes .../classes/common/message/RpcRequest.class | Bin 0 -> 3779 bytes .../RpcResponse$RpcResponseBuilder.class | Bin 0 -> 2153 bytes .../classes/common/message/RpcResponse.class | Bin 0 -> 4218 bytes .../common/serializer/mycoder/MyDecoder.class | Bin 0 -> 3033 bytes .../common/serializer/mycoder/MyEncoder.class | Bin 0 -> 2549 bytes .../myserializer/HessianSerializer.class | Bin 0 -> 2191 bytes .../myserializer/JsonSerializer.class | Bin 0 -> 2802 bytes .../myserializer/KryoSerializer.class | Bin 0 -> 3569 bytes .../myserializer/ObjectSerializer.class | Bin 0 -> 1942 bytes .../myserializer/ProtostuffSerializer.class | Bin 0 -> 3186 bytes .../serializer/myserializer/Serializer.class | Bin 0 -> 1409 bytes .../target/classes/common/spi/SpiLoader.class | Bin 0 -> 5133 bytes .../classes/common/util/ConfigUtil.class | Bin 0 -> 2372 bytes version6/krpc-consumer/pom.xml | 50 ++++++ .../java/com/kama/consumer/ConsumerTest.java | 66 ++++++++ .../com/kama/consumer/ConsumerTestConfig.java | 20 +++ .../src/main/resources/application.properties | 7 + .../target/classes/application.properties | 7 + .../com/kama/consumer/ConsumerTest.class | Bin 0 -> 3967 bytes .../kama/consumer/ConsumerTestConfig.class | Bin 0 -> 781 bytes version6/krpc-core/pom.xml | 115 ++++++++++++++ .../main/java/com/kama/KRpcApplication.java | 48 ++++++ .../com/kama/client/cache/ServiceCache.java | 74 +++++++++ .../client/circuitbreaker/CircuitBreaker.java | 107 +++++++++++++ .../CircuitBreakerProvider.java | 28 ++++ .../kama/client/netty/HeartbeatHandler.java | 29 ++++ .../kama/client/netty/NettyClientHandler.java | 34 ++++ .../client/netty/NettyClientInitializer.java | 45 ++++++ .../com/kama/client/proxy/ClientProxy.java | 117 ++++++++++++++ .../com/kama/client/retry/GuavaRetry.java | 46 ++++++ .../com/kama/client/rpcclient/RpcClient.java | 18 +++ .../client/rpcclient/impl/NettyRpcClient.java | 97 ++++++++++++ .../rpcclient/impl/SimpleSocketRpcClient.java | 61 +++++++ .../client/servicecenter/ServiceCenter.java | 25 +++ .../client/servicecenter/ZKServiceCenter.java | 122 ++++++++++++++ .../servicecenter/ZKWatcher/watchZK.java | 98 ++++++++++++ .../servicecenter/balance/LoadBalance.java | 20 +++ .../balance/impl/ConsistencyHashBalance.java | 149 ++++++++++++++++++ .../balance/impl/RandomLoadBalance.java | 48 ++++++ .../balance/impl/RoundLoadBalance.java | 52 ++++++ .../main/java/com/kama/config/KRpcConfig.java | 37 +++++ .../java/com/kama/config/RpcConstant.java | 20 +++ .../kama/server/netty/HeartbeatHandler.java | 38 +++++ .../server/netty/NettyRpcServerHandler.java | 72 +++++++++ .../server/netty/NettyServerInitializer.java | 40 +++++ .../kama/server/provider/ServiceProvider.java | 58 +++++++ .../com/kama/server/ratelimit/RateLimit.java | 15 ++ .../impl/TokenBucketRateLimitImpl.java | 60 +++++++ .../ratelimit/provider/RateLimitProvider.java | 33 ++++ .../com/kama/server/server/RpcServer.java | 16 ++ .../server/server/impl/NettyRpcServer.java | 79 ++++++++++ .../server/server/impl/SimpleRpcServer.java | 68 ++++++++ .../kama/server/server/work/WorkThread.java | 61 +++++++ .../serviceRegister/ServiceRegister.java | 16 ++ .../impl/ZKServiceRegister.java | 106 +++++++++++++ .../balance/ConsistencyHashBalanceTest.java | 100 ++++++++++++ .../test/balance/RandomLoadBalanceTest.java | 76 +++++++++ .../test/balance/RoundLoadBalanceTest.java | 93 +++++++++++ .../serializer/HessianSerializerTest.java | 44 ++++++ .../test/serializer/KryoSerializerTest.java | 89 +++++++++++ .../serializer/ProtostuffSerializerTest.java | 89 +++++++++++ ....common.serializer.myserializer.Serializer | 5 + ....common.serializer.myserializer.Serializer | 5 + .../classes/com/kama/KRpcApplication.class | Bin 0 -> 1617 bytes .../com/kama/client/cache/ServiceCache.class | Bin 0 -> 3168 bytes .../circuitbreaker/CircuitBreaker$1.class | Bin 0 -> 889 bytes .../circuitbreaker/CircuitBreaker.class | Bin 0 -> 3249 bytes .../CircuitBreakerProvider.class | Bin 0 -> 2116 bytes .../circuitbreaker/CircuitBreakerState.class | Bin 0 -> 1229 bytes .../kama/client/netty/HeartbeatHandler.class | Bin 0 -> 1369 bytes .../client/netty/NettyClientHandler.class | Bin 0 -> 2135 bytes .../client/netty/NettyClientInitializer.class | Bin 0 -> 2486 bytes .../com/kama/client/proxy/ClientProxy.class | Bin 0 -> 6114 bytes .../com/kama/client/retry/GuavaRetry$1.class | Bin 0 -> 1343 bytes .../com/kama/client/retry/GuavaRetry.class | Bin 0 -> 4250 bytes .../com/kama/client/rpcclient/RpcClient.class | Bin 0 -> 229 bytes .../rpcclient/impl/NettyRpcClient.class | Bin 0 -> 4384 bytes .../impl/SimpleSocketRpcClient.class | Bin 0 -> 2995 bytes .../client/servicecenter/ServiceCenter.class | Bin 0 -> 319 bytes .../servicecenter/ZKServiceCenter.class | Bin 0 -> 6283 bytes .../servicecenter/ZKWatcher/watchZK$1.class | Bin 0 -> 3154 bytes .../servicecenter/ZKWatcher/watchZK.class | Bin 0 -> 2426 bytes .../servicecenter/balance/LoadBalance.class | Bin 0 -> 337 bytes .../balance/impl/ConsistencyHashBalance.class | Bin 0 -> 5355 bytes .../balance/impl/RandomLoadBalance.class | Bin 0 -> 2176 bytes .../balance/impl/RoundLoadBalance.class | Bin 0 -> 2805 bytes .../config/KRpcConfig$KRpcConfigBuilder.class | Bin 0 -> 2349 bytes .../classes/com/kama/config/KRpcConfig.class | Bin 0 -> 3648 bytes .../classes/com/kama/config/RpcConstant.class | Bin 0 -> 255 bytes .../kama/server/netty/HeartbeatHandler.class | Bin 0 -> 2150 bytes .../server/netty/NettyRpcServerHandler.class | Bin 0 -> 4648 bytes .../server/netty/NettyServerInitializer.class | Bin 0 -> 1984 bytes .../server/provider/ServiceProvider.class | Bin 0 -> 2272 bytes .../com/kama/server/ratelimit/RateLimit.class | Bin 0 -> 150 bytes .../impl/TokenBucketRateLimitImpl.class | Bin 0 -> 1290 bytes .../provider/RateLimitProvider.class | Bin 0 -> 2264 bytes .../com/kama/server/server/RpcServer.class | Bin 0 -> 166 bytes .../server/server/impl/NettyRpcServer.class | Bin 0 -> 3723 bytes .../server/server/impl/SimpleRpcServer.class | Bin 0 -> 2608 bytes .../kama/server/server/work/WorkThread.class | Bin 0 -> 2959 bytes .../serviceRegister/ServiceRegister.class | Bin 0 -> 287 bytes .../impl/ZKServiceRegister.class | Bin 0 -> 6833 bytes .../balance/ConsistencyHashBalanceTest.class | Bin 0 -> 4410 bytes .../test/balance/RandomLoadBalanceTest.class | Bin 0 -> 2086 bytes .../test/balance/RoundLoadBalanceTest.class | Bin 0 -> 2529 bytes .../serializer/HessianSerializerTest.class | Bin 0 -> 1784 bytes .../test/serializer/KryoSerializerTest.class | Bin 0 -> 3493 bytes .../serializer/ProtostuffSerializerTest.class | Bin 0 -> 3525 bytes version6/krpc-provider/pom.xml | 52 ++++++ .../java/com/kama/provider/ProviderTest.java | 37 +++++ .../kama/provider/impl/UserServiceImpl.java | 41 +++++ .../src/main/resources/application.properties | 7 + .../target/classes/application.properties | 7 + .../com/kama/provider/ProviderTest.class | Bin 0 -> 2194 bytes .../kama/provider/impl/UserServiceImpl.class | Bin 0 -> 1930 bytes version6/pom.xml | 97 ++++++++++++ 167 files changed, 4091 insertions(+), 1 deletion(-) create mode 100644 version1/.idea/compiler.xml create mode 100644 version1/.idea/encodings.xml create mode 100644 version1/.idea/jarRepositories.xml create mode 100644 version1/.idea/misc.xml create mode 100644 version1/.idea/vcs.xml create mode 100644 version1/.idea/workspace.xml create mode 100644 version4/.idea/.gitignore create mode 100644 version4/.idea/compiler.xml create mode 100644 version4/.idea/encodings.xml create mode 100644 version4/.idea/jarRepositories.xml create mode 100644 version4/.idea/misc.xml create mode 100644 version4/.idea/vcs.xml create mode 100644 version5/krpc-api/target/classes/com/kama/annotation/Retryable.class delete mode 100644 version5/krpc-provider/target/classes/META-INF/application.properties create mode 100644 version6/.idea/.gitignore create mode 100644 version6/.idea/compiler.xml create mode 100644 version6/.idea/encodings.xml create mode 100644 version6/.idea/jarRepositories.xml create mode 100644 version6/.idea/misc.xml create mode 100644 version6/.idea/vcs.xml create mode 100644 version6/krpc-api/pom.xml create mode 100644 version6/krpc-api/src/main/java/com/kama/annotation/Retryable.java create mode 100644 version6/krpc-api/src/main/java/com/kama/pojo/User.java create mode 100644 version6/krpc-api/src/main/java/com/kama/service/UserService.java create mode 100644 version6/krpc-api/target/classes/com/kama/annotation/Retryable.class create mode 100644 version6/krpc-api/target/classes/com/kama/pojo/User$UserBuilder.class create mode 100644 version6/krpc-api/target/classes/com/kama/pojo/User.class create mode 100644 version6/krpc-api/target/classes/com/kama/service/UserService.class create mode 100644 version6/krpc-common/pom.xml create mode 100644 version6/krpc-common/src/main/java/common/exception/SerializeException.java create mode 100644 version6/krpc-common/src/main/java/common/message/MessageType.java create mode 100644 version6/krpc-common/src/main/java/common/message/RpcRequest.java create mode 100644 version6/krpc-common/src/main/java/common/message/RpcResponse.java create mode 100644 version6/krpc-common/src/main/java/common/serializer/mycoder/MyDecoder.java create mode 100644 version6/krpc-common/src/main/java/common/serializer/mycoder/MyEncoder.java create mode 100644 version6/krpc-common/src/main/java/common/serializer/myserializer/HessianSerializer.java create mode 100644 version6/krpc-common/src/main/java/common/serializer/myserializer/JsonSerializer.java create mode 100644 version6/krpc-common/src/main/java/common/serializer/myserializer/KryoSerializer.java create mode 100644 version6/krpc-common/src/main/java/common/serializer/myserializer/ObjectSerializer.java create mode 100644 version6/krpc-common/src/main/java/common/serializer/myserializer/ProtostuffSerializer.java create mode 100644 version6/krpc-common/src/main/java/common/serializer/myserializer/Serializer.java create mode 100644 version6/krpc-common/src/main/java/common/spi/SpiLoader.java create mode 100644 version6/krpc-common/src/main/java/common/util/ConfigUtil.java create mode 100644 version6/krpc-common/target/classes/common/exception/SerializeException.class create mode 100644 version6/krpc-common/target/classes/common/message/MessageType.class create mode 100644 version6/krpc-common/target/classes/common/message/RpcRequest$RpcRequestBuilder.class create mode 100644 version6/krpc-common/target/classes/common/message/RpcRequest.class create mode 100644 version6/krpc-common/target/classes/common/message/RpcResponse$RpcResponseBuilder.class create mode 100644 version6/krpc-common/target/classes/common/message/RpcResponse.class create mode 100644 version6/krpc-common/target/classes/common/serializer/mycoder/MyDecoder.class create mode 100644 version6/krpc-common/target/classes/common/serializer/mycoder/MyEncoder.class create mode 100644 version6/krpc-common/target/classes/common/serializer/myserializer/HessianSerializer.class create mode 100644 version6/krpc-common/target/classes/common/serializer/myserializer/JsonSerializer.class create mode 100644 version6/krpc-common/target/classes/common/serializer/myserializer/KryoSerializer.class create mode 100644 version6/krpc-common/target/classes/common/serializer/myserializer/ObjectSerializer.class create mode 100644 version6/krpc-common/target/classes/common/serializer/myserializer/ProtostuffSerializer.class create mode 100644 version6/krpc-common/target/classes/common/serializer/myserializer/Serializer.class create mode 100644 version6/krpc-common/target/classes/common/spi/SpiLoader.class create mode 100644 version6/krpc-common/target/classes/common/util/ConfigUtil.class create mode 100644 version6/krpc-consumer/pom.xml create mode 100644 version6/krpc-consumer/src/main/java/com/kama/consumer/ConsumerTest.java create mode 100644 version6/krpc-consumer/src/main/java/com/kama/consumer/ConsumerTestConfig.java create mode 100644 version6/krpc-consumer/src/main/resources/application.properties create mode 100644 version6/krpc-consumer/target/classes/application.properties create mode 100644 version6/krpc-consumer/target/classes/com/kama/consumer/ConsumerTest.class create mode 100644 version6/krpc-consumer/target/classes/com/kama/consumer/ConsumerTestConfig.class create mode 100644 version6/krpc-core/pom.xml create mode 100644 version6/krpc-core/src/main/java/com/kama/KRpcApplication.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/cache/ServiceCache.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/circuitbreaker/CircuitBreaker.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/circuitbreaker/CircuitBreakerProvider.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/netty/HeartbeatHandler.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/netty/NettyClientHandler.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/netty/NettyClientInitializer.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/proxy/ClientProxy.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/retry/GuavaRetry.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/rpcclient/RpcClient.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/rpcclient/impl/NettyRpcClient.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/rpcclient/impl/SimpleSocketRpcClient.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/servicecenter/ServiceCenter.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/servicecenter/ZKServiceCenter.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/servicecenter/ZKWatcher/watchZK.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/servicecenter/balance/LoadBalance.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/servicecenter/balance/impl/ConsistencyHashBalance.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/servicecenter/balance/impl/RandomLoadBalance.java create mode 100644 version6/krpc-core/src/main/java/com/kama/client/servicecenter/balance/impl/RoundLoadBalance.java create mode 100644 version6/krpc-core/src/main/java/com/kama/config/KRpcConfig.java create mode 100644 version6/krpc-core/src/main/java/com/kama/config/RpcConstant.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/netty/HeartbeatHandler.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/netty/NettyRpcServerHandler.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/netty/NettyServerInitializer.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/provider/ServiceProvider.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/ratelimit/RateLimit.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/ratelimit/impl/TokenBucketRateLimitImpl.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/ratelimit/provider/RateLimitProvider.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/server/RpcServer.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/server/impl/NettyRpcServer.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/server/impl/SimpleRpcServer.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/server/work/WorkThread.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/serviceRegister/ServiceRegister.java create mode 100644 version6/krpc-core/src/main/java/com/kama/server/serviceRegister/impl/ZKServiceRegister.java create mode 100644 version6/krpc-core/src/main/java/com/kama/test/balance/ConsistencyHashBalanceTest.java create mode 100644 version6/krpc-core/src/main/java/com/kama/test/balance/RandomLoadBalanceTest.java create mode 100644 version6/krpc-core/src/main/java/com/kama/test/balance/RoundLoadBalanceTest.java create mode 100644 version6/krpc-core/src/main/java/com/kama/test/serializer/HessianSerializerTest.java create mode 100644 version6/krpc-core/src/main/java/com/kama/test/serializer/KryoSerializerTest.java create mode 100644 version6/krpc-core/src/main/java/com/kama/test/serializer/ProtostuffSerializerTest.java create mode 100644 version6/krpc-core/src/main/resources/META-INF/serializer/com.kama.common.serializer.myserializer.Serializer create mode 100644 version6/krpc-core/target/classes/META-INF/serializer/com.kama.common.serializer.myserializer.Serializer create mode 100644 version6/krpc-core/target/classes/com/kama/KRpcApplication.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/cache/ServiceCache.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/circuitbreaker/CircuitBreaker$1.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/circuitbreaker/CircuitBreaker.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/circuitbreaker/CircuitBreakerProvider.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/circuitbreaker/CircuitBreakerState.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/netty/HeartbeatHandler.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/netty/NettyClientHandler.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/netty/NettyClientInitializer.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/proxy/ClientProxy.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/retry/GuavaRetry$1.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/retry/GuavaRetry.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/rpcclient/RpcClient.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/rpcclient/impl/NettyRpcClient.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/rpcclient/impl/SimpleSocketRpcClient.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/servicecenter/ServiceCenter.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/servicecenter/ZKServiceCenter.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/servicecenter/ZKWatcher/watchZK$1.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/servicecenter/ZKWatcher/watchZK.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/servicecenter/balance/LoadBalance.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/servicecenter/balance/impl/ConsistencyHashBalance.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/servicecenter/balance/impl/RandomLoadBalance.class create mode 100644 version6/krpc-core/target/classes/com/kama/client/servicecenter/balance/impl/RoundLoadBalance.class create mode 100644 version6/krpc-core/target/classes/com/kama/config/KRpcConfig$KRpcConfigBuilder.class create mode 100644 version6/krpc-core/target/classes/com/kama/config/KRpcConfig.class create mode 100644 version6/krpc-core/target/classes/com/kama/config/RpcConstant.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/netty/HeartbeatHandler.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/netty/NettyRpcServerHandler.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/netty/NettyServerInitializer.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/provider/ServiceProvider.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/ratelimit/RateLimit.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/ratelimit/impl/TokenBucketRateLimitImpl.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/ratelimit/provider/RateLimitProvider.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/server/RpcServer.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/server/impl/NettyRpcServer.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/server/impl/SimpleRpcServer.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/server/work/WorkThread.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/serviceRegister/ServiceRegister.class create mode 100644 version6/krpc-core/target/classes/com/kama/server/serviceRegister/impl/ZKServiceRegister.class create mode 100644 version6/krpc-core/target/classes/com/kama/test/balance/ConsistencyHashBalanceTest.class create mode 100644 version6/krpc-core/target/classes/com/kama/test/balance/RandomLoadBalanceTest.class create mode 100644 version6/krpc-core/target/classes/com/kama/test/balance/RoundLoadBalanceTest.class create mode 100644 version6/krpc-core/target/classes/com/kama/test/serializer/HessianSerializerTest.class create mode 100644 version6/krpc-core/target/classes/com/kama/test/serializer/KryoSerializerTest.class create mode 100644 version6/krpc-core/target/classes/com/kama/test/serializer/ProtostuffSerializerTest.class create mode 100644 version6/krpc-provider/pom.xml create mode 100644 version6/krpc-provider/src/main/java/com/kama/provider/ProviderTest.java create mode 100644 version6/krpc-provider/src/main/java/com/kama/provider/impl/UserServiceImpl.java create mode 100644 version6/krpc-provider/src/main/resources/application.properties create mode 100644 version6/krpc-provider/target/classes/application.properties create mode 100644 version6/krpc-provider/target/classes/com/kama/provider/ProviderTest.class create mode 100644 version6/krpc-provider/target/classes/com/kama/provider/impl/UserServiceImpl.class create mode 100644 version6/pom.xml diff --git a/version1/.idea/compiler.xml b/version1/.idea/compiler.xml new file mode 100644 index 0000000..5593f45 --- /dev/null +++ b/version1/.idea/compiler.xml @@ -0,0 +1,13 @@ + + + + + + + + + + + + + \ No newline at end of file diff --git a/version1/.idea/encodings.xml b/version1/.idea/encodings.xml new file mode 100644 index 0000000..aa00ffa --- /dev/null +++ b/version1/.idea/encodings.xml @@ -0,0 +1,7 @@ + + + + + + + \ No newline at end of file diff --git a/version1/.idea/jarRepositories.xml b/version1/.idea/jarRepositories.xml new file mode 100644 index 0000000..abb532a --- /dev/null +++ b/version1/.idea/jarRepositories.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + \ No newline at end of file diff --git a/version1/.idea/misc.xml b/version1/.idea/misc.xml new file mode 100644 index 0000000..5372e92 --- /dev/null +++ b/version1/.idea/misc.xml @@ -0,0 +1,12 @@ + + + + + + + + \ No newline at end of file diff --git a/version1/.idea/vcs.xml b/version1/.idea/vcs.xml new file mode 100644 index 0000000..6c0b863 --- /dev/null +++ b/version1/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/version1/.idea/workspace.xml b/version1/.idea/workspace.xml new file mode 100644 index 0000000..60ff3f6 --- /dev/null +++ b/version1/.idea/workspace.xml @@ -0,0 +1,62 @@ + + + + + + + + + + + + + + + + + + + + + + 1736761843999 + + + + + + + + + \ No newline at end of file diff --git a/version4/.idea/.gitignore b/version4/.idea/.gitignore new file mode 100644 index 0000000..13566b8 --- /dev/null +++ b/version4/.idea/.gitignore @@ -0,0 +1,8 @@ +# Default ignored files +/shelf/ +/workspace.xml +# Editor-based HTTP Client requests +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/version4/.idea/compiler.xml b/version4/.idea/compiler.xml new file mode 100644 index 0000000..a49db56 --- /dev/null +++ b/version4/.idea/compiler.xml @@ -0,0 +1,13 @@ + + + + + + + + + + + + + \ No newline at end of file diff --git a/version4/.idea/encodings.xml b/version4/.idea/encodings.xml new file mode 100644 index 0000000..aa00ffa --- /dev/null +++ b/version4/.idea/encodings.xml @@ -0,0 +1,7 @@ + + + + + + + \ No newline at end of file diff --git a/version4/.idea/jarRepositories.xml b/version4/.idea/jarRepositories.xml new file mode 100644 index 0000000..abb532a --- /dev/null +++ b/version4/.idea/jarRepositories.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + \ No newline at end of file diff --git a/version4/.idea/misc.xml b/version4/.idea/misc.xml new file mode 100644 index 0000000..5372e92 --- /dev/null +++ b/version4/.idea/misc.xml @@ -0,0 +1,12 @@ + + + + + + + + \ No newline at end of file diff --git a/version4/.idea/vcs.xml b/version4/.idea/vcs.xml new file mode 100644 index 0000000..6c0b863 --- /dev/null +++ b/version4/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/version5/.idea/jarRepositories.xml b/version5/.idea/jarRepositories.xml index 5a2f139..c176f1e 100644 --- a/version5/.idea/jarRepositories.xml +++ b/version5/.idea/jarRepositories.xml @@ -16,5 +16,10 @@