diff --git a/example-client/src/main/java/github/javaguide/NettyClientMain.java b/example-client/src/main/java/github/javaguide/NettyClientMain.java index 3143b71f337296d14f16138862907290978bbb45..f6cd77d91d5dd7d26daa6602b8faedcb62996466 100644 --- a/example-client/src/main/java/github/javaguide/NettyClientMain.java +++ b/example-client/src/main/java/github/javaguide/NettyClientMain.java @@ -1,8 +1,8 @@ package github.javaguide; -import github.javaguide.transport.ClientTransport; +import github.javaguide.remoting.transport.ClientTransport; import github.javaguide.proxy.RpcClientProxy; -import github.javaguide.transport.netty.client.NettyClientClientTransport; +import github.javaguide.remoting.transport.netty.client.NettyClientClientTransport; /** * @author shuang.kou diff --git a/example-client/src/main/java/github/javaguide/RpcFrameworkSimpleClientMain.java b/example-client/src/main/java/github/javaguide/RpcFrameworkSimpleClientMain.java index d4f135768ec0a1e0e5a82858fd5c908b66f34ba5..d1e1aef9136b2efc23f71bba4ac17cb8e1940e73 100644 --- a/example-client/src/main/java/github/javaguide/RpcFrameworkSimpleClientMain.java +++ b/example-client/src/main/java/github/javaguide/RpcFrameworkSimpleClientMain.java @@ -1,8 +1,8 @@ package github.javaguide; -import github.javaguide.transport.ClientTransport; +import github.javaguide.remoting.transport.ClientTransport; import github.javaguide.proxy.RpcClientProxy; -import github.javaguide.transport.socket.SocketRpcClient; +import github.javaguide.remoting.transport.socket.SocketRpcClient; /** * @author shuang.kou diff --git a/example-server/src/main/java/github/javaguide/NettyServerMain.java b/example-server/src/main/java/github/javaguide/NettyServerMain.java index bfb017b3b8f117add045a26c22aa77cedd1a41a6..b7223161c09ee6365ac4dc73591408b2940acf41 100644 --- a/example-server/src/main/java/github/javaguide/NettyServerMain.java +++ b/example-server/src/main/java/github/javaguide/NettyServerMain.java @@ -1,6 +1,6 @@ package github.javaguide; -import github.javaguide.transport.netty.server.NettyServer; +import github.javaguide.remoting.transport.netty.server.NettyServer; /** * @author shuang.kou diff --git a/example-server/src/main/java/github/javaguide/RpcFrameworkSimpleServerMain.java b/example-server/src/main/java/github/javaguide/RpcFrameworkSimpleServerMain.java index 6e638d9641ae12c7c24baee05c78e687bb56c01d..ef0a340818804976cf812fc16a426661a96c0d80 100644 --- a/example-server/src/main/java/github/javaguide/RpcFrameworkSimpleServerMain.java +++ b/example-server/src/main/java/github/javaguide/RpcFrameworkSimpleServerMain.java @@ -1,6 +1,6 @@ package github.javaguide; -import github.javaguide.transport.socket.SocketRpcServer; +import github.javaguide.remoting.transport.socket.SocketRpcServer; /** * @author shuang.kou diff --git a/rpc-framework-simple/src/main/java/github/javaguide/handler/RpcRequestHandler.java b/rpc-framework-simple/src/main/java/github/javaguide/handler/RpcRequestHandler.java index da630e98e788149fdadc2d4da1fd6c1553369714..cea78b8b4679f4398c9cb8c3d0eba8da41b556fd 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/handler/RpcRequestHandler.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/handler/RpcRequestHandler.java @@ -1,7 +1,7 @@ package github.javaguide.handler; -import github.javaguide.dto.RpcRequest; -import github.javaguide.dto.RpcResponse; +import github.javaguide.remoting.dto.RpcRequest; +import github.javaguide.remoting.dto.RpcResponse; import github.javaguide.enumeration.RpcResponseCode; import github.javaguide.exception.RpcException; import github.javaguide.provider.ServiceProvider; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/proxy/RpcClientProxy.java b/rpc-framework-simple/src/main/java/github/javaguide/proxy/RpcClientProxy.java index 33c3f46c7102a84bad3e2ec0f166a1eeee5298ba..6f849580184a72a155d1726b1415e00c93c9664d 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/proxy/RpcClientProxy.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/proxy/RpcClientProxy.java @@ -1,7 +1,7 @@ package github.javaguide.proxy; -import github.javaguide.dto.RpcRequest; -import github.javaguide.transport.ClientTransport; +import github.javaguide.remoting.dto.RpcRequest; +import github.javaguide.remoting.transport.ClientTransport; import lombok.extern.slf4j.Slf4j; import java.lang.reflect.InvocationHandler; diff --git a/rpc-framework-common/src/main/java/github/javaguide/utils/checker/RpcMessageChecker.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/dto/RpcMessageChecker.java similarity index 90% rename from rpc-framework-common/src/main/java/github/javaguide/utils/checker/RpcMessageChecker.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/dto/RpcMessageChecker.java index 11cee5fde202feadf5c55204c8bda1d634c90eba..74297cdd43099498982918c3b87e8f7bcb41cf1b 100644 --- a/rpc-framework-common/src/main/java/github/javaguide/utils/checker/RpcMessageChecker.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/dto/RpcMessageChecker.java @@ -1,7 +1,6 @@ -package github.javaguide.utils.checker; +package github.javaguide.remoting.dto; + -import github.javaguide.dto.RpcRequest; -import github.javaguide.dto.RpcResponse; import github.javaguide.enumeration.RpcErrorMessageEnum; import github.javaguide.enumeration.RpcResponseCode; import github.javaguide.exception.RpcException; diff --git a/rpc-framework-common/src/main/java/github/javaguide/dto/RpcRequest.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/dto/RpcRequest.java similarity index 93% rename from rpc-framework-common/src/main/java/github/javaguide/dto/RpcRequest.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/dto/RpcRequest.java index fa5c48bb09696b06597e760853cb12c3508c0821..fba2cd977408e1ebd63e1d92822282e5d4e5a794 100644 --- a/rpc-framework-common/src/main/java/github/javaguide/dto/RpcRequest.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/dto/RpcRequest.java @@ -1,4 +1,4 @@ -package github.javaguide.dto; +package github.javaguide.remoting.dto; import lombok.AllArgsConstructor; import lombok.Builder; diff --git a/rpc-framework-common/src/main/java/github/javaguide/dto/RpcResponse.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/dto/RpcResponse.java similarity index 97% rename from rpc-framework-common/src/main/java/github/javaguide/dto/RpcResponse.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/dto/RpcResponse.java index 7f7cbd546e4dfe88032b8306cdbd826620108ed9..502934c7668bd761ab7c83e7aace957dbdc9c7e4 100644 --- a/rpc-framework-common/src/main/java/github/javaguide/dto/RpcResponse.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/dto/RpcResponse.java @@ -1,4 +1,4 @@ -package github.javaguide.dto; +package github.javaguide.remoting.dto; import github.javaguide.enumeration.RpcResponseCode; import lombok.AllArgsConstructor; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/ClientTransport.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/ClientTransport.java similarity index 77% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/ClientTransport.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/ClientTransport.java index 8d7f9601197e6b902f80568b4208341ee87dbb6a..6e57b5600556ca455704c74bf04a4296402777fc 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/ClientTransport.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/ClientTransport.java @@ -1,6 +1,6 @@ -package github.javaguide.transport; +package github.javaguide.remoting.transport; -import github.javaguide.dto.RpcRequest; +import github.javaguide.remoting.dto.RpcRequest; /** * 传输 RpcRequest。 diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/ChannelProvider.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/ChannelProvider.java similarity index 97% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/ChannelProvider.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/ChannelProvider.java index 50ece7cce6cdbb5ec9d775c2a82e5c245755439b..0f392ac4c3b44da6eadc317fcbf173e2957fd82b 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/ChannelProvider.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/ChannelProvider.java @@ -1,4 +1,4 @@ -package github.javaguide.transport.netty.client; +package github.javaguide.remoting.transport.netty.client; import github.javaguide.enumeration.RpcErrorMessageEnum; import github.javaguide.exception.RpcException; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/NettyClient.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyClient.java similarity index 88% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/NettyClient.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyClient.java index 5ce825f228077e49e06762bb15586ee6b81bbcd5..8ac973e7671d78a962499919151c71d45795eb74 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/NettyClient.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyClient.java @@ -1,10 +1,10 @@ -package github.javaguide.transport.netty.client; +package github.javaguide.remoting.transport.netty.client; -import github.javaguide.dto.RpcRequest; -import github.javaguide.dto.RpcResponse; +import github.javaguide.remoting.dto.RpcRequest; +import github.javaguide.remoting.dto.RpcResponse; import github.javaguide.serialize.kyro.KryoSerializer; -import github.javaguide.transport.netty.codec.kyro.NettyKryoDecoder; -import github.javaguide.transport.netty.codec.kyro.NettyKryoEncoder; +import github.javaguide.remoting.transport.netty.codec.kyro.NettyKryoDecoder; +import github.javaguide.remoting.transport.netty.codec.kyro.NettyKryoEncoder; import io.netty.bootstrap.Bootstrap; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelOption; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/NettyClientClientTransport.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyClientClientTransport.java similarity index 88% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/NettyClientClientTransport.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyClientClientTransport.java index 7d15e20498c923a58ac180e0c2638bc66f2b7c26..a695f72810f0c176263617ec7aec987af2b310de 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/NettyClientClientTransport.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyClientClientTransport.java @@ -1,11 +1,11 @@ -package github.javaguide.transport.netty.client; +package github.javaguide.remoting.transport.netty.client; -import github.javaguide.dto.RpcRequest; -import github.javaguide.dto.RpcResponse; +import github.javaguide.remoting.dto.RpcRequest; +import github.javaguide.remoting.dto.RpcResponse; import github.javaguide.registry.ServiceDiscovery; import github.javaguide.registry.ZkServiceDiscovery; -import github.javaguide.transport.ClientTransport; -import github.javaguide.utils.checker.RpcMessageChecker; +import github.javaguide.remoting.transport.ClientTransport; +import github.javaguide.remoting.dto.RpcMessageChecker; import io.netty.channel.Channel; import io.netty.channel.ChannelFutureListener; import io.netty.util.AttributeKey; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/NettyClientHandler.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyClientHandler.java similarity index 94% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/NettyClientHandler.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyClientHandler.java index b1f8fc190a3b40c3e18a845da3bb2de04f841992..063f80dca77b85184ab0d8ef0b78da3638ea8cdb 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/client/NettyClientHandler.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyClientHandler.java @@ -1,6 +1,6 @@ -package github.javaguide.transport.netty.client; +package github.javaguide.remoting.transport.netty.client; -import github.javaguide.dto.RpcResponse; +import github.javaguide.remoting.dto.RpcResponse; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.channel.SimpleChannelInboundHandler; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/codec/kyro/NettyKryoDecoder.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/kyro/NettyKryoDecoder.java similarity index 97% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/netty/codec/kyro/NettyKryoDecoder.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/kyro/NettyKryoDecoder.java index 5f38913000067b5f1fece7b271f3935b93eef3ed..817fe3e69f2281ca73e84b6eb94e05b676d3e7f8 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/codec/kyro/NettyKryoDecoder.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/kyro/NettyKryoDecoder.java @@ -1,4 +1,4 @@ -package github.javaguide.transport.netty.codec.kyro; +package github.javaguide.remoting.transport.netty.codec.kyro; import github.javaguide.serialize.Serializer; import io.netty.buffer.ByteBuf; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/codec/kyro/NettyKryoEncoder.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/kyro/NettyKryoEncoder.java similarity index 95% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/netty/codec/kyro/NettyKryoEncoder.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/kyro/NettyKryoEncoder.java index 6bc76f36f33ae7e2319a775989c9b291bf18e56b..20cec1ad684b76866082bf747accbc9d63e3bb7b 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/codec/kyro/NettyKryoEncoder.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/kyro/NettyKryoEncoder.java @@ -1,4 +1,4 @@ -package github.javaguide.transport.netty.codec.kyro; +package github.javaguide.remoting.transport.netty.codec.kyro; import github.javaguide.serialize.Serializer; import io.netty.buffer.ByteBuf; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/server/NettyServer.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyServer.java similarity index 92% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/netty/server/NettyServer.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyServer.java index 9d384713a23d6ea002b78da5839b439e1084a5e8..137b505d1a969a3ddb811e2ccfa01754cd200eaa 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/server/NettyServer.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyServer.java @@ -1,14 +1,14 @@ -package github.javaguide.transport.netty.server; +package github.javaguide.remoting.transport.netty.server; -import github.javaguide.dto.RpcRequest; -import github.javaguide.dto.RpcResponse; +import github.javaguide.remoting.dto.RpcRequest; +import github.javaguide.remoting.dto.RpcResponse; import github.javaguide.provider.ServiceProvider; import github.javaguide.provider.ServiceProviderImpl; import github.javaguide.registry.ServiceRegistry; import github.javaguide.registry.ZkServiceRegistry; import github.javaguide.serialize.kyro.KryoSerializer; -import github.javaguide.transport.netty.codec.kyro.NettyKryoDecoder; -import github.javaguide.transport.netty.codec.kyro.NettyKryoEncoder; +import github.javaguide.remoting.transport.netty.codec.kyro.NettyKryoDecoder; +import github.javaguide.remoting.transport.netty.codec.kyro.NettyKryoEncoder; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelInitializer; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/server/NettyServerHandler.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyServerHandler.java similarity index 94% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/netty/server/NettyServerHandler.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyServerHandler.java index 845a736f697f97840e4f712eb3921a06ec557d07..5d954982e15fccbf0aa4664aed7a5ab6594234d6 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/netty/server/NettyServerHandler.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyServerHandler.java @@ -1,7 +1,7 @@ -package github.javaguide.transport.netty.server; +package github.javaguide.remoting.transport.netty.server; -import github.javaguide.dto.RpcRequest; -import github.javaguide.dto.RpcResponse; +import github.javaguide.remoting.dto.RpcRequest; +import github.javaguide.remoting.dto.RpcResponse; import github.javaguide.handler.RpcRequestHandler; import github.javaguide.utils.concurrent.ThreadPoolFactory; import github.javaguide.utils.factory.SingletonFactory; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/socket/SocketRpcClient.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcClient.java similarity index 86% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/socket/SocketRpcClient.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcClient.java index cf0454abb29380c80e30fd60fb4e21b310006ab1..48bccfbe82e597ce16fd620e1b417125168f307c 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/socket/SocketRpcClient.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcClient.java @@ -1,12 +1,12 @@ -package github.javaguide.transport.socket; +package github.javaguide.remoting.transport.socket; -import github.javaguide.dto.RpcRequest; -import github.javaguide.dto.RpcResponse; +import github.javaguide.remoting.dto.RpcRequest; +import github.javaguide.remoting.dto.RpcResponse; import github.javaguide.exception.RpcException; import github.javaguide.registry.ServiceDiscovery; import github.javaguide.registry.ZkServiceDiscovery; -import github.javaguide.transport.ClientTransport; -import github.javaguide.utils.checker.RpcMessageChecker; +import github.javaguide.remoting.transport.ClientTransport; +import github.javaguide.remoting.dto.RpcMessageChecker; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/socket/SocketRpcRequestHandlerRunnable.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcRequestHandlerRunnable.java similarity index 90% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/socket/SocketRpcRequestHandlerRunnable.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcRequestHandlerRunnable.java index 7c1a0b93b9cbb253e645ffd9f76c2f775af09f27..935c0fd4a66828fe0b70f5f3fc29da77d814b64e 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/socket/SocketRpcRequestHandlerRunnable.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcRequestHandlerRunnable.java @@ -1,7 +1,7 @@ -package github.javaguide.transport.socket; +package github.javaguide.remoting.transport.socket; -import github.javaguide.dto.RpcRequest; -import github.javaguide.dto.RpcResponse; +import github.javaguide.remoting.dto.RpcRequest; +import github.javaguide.remoting.dto.RpcResponse; import github.javaguide.handler.RpcRequestHandler; import github.javaguide.utils.factory.SingletonFactory; import lombok.extern.slf4j.Slf4j; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/transport/socket/SocketRpcServer.java b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcServer.java similarity index 97% rename from rpc-framework-simple/src/main/java/github/javaguide/transport/socket/SocketRpcServer.java rename to rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcServer.java index 1176797cc341a5c291cdcca90b36815c8a14c6f8..7b1904db14a12686b8298a3cbb91cab4750dc995 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/transport/socket/SocketRpcServer.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcServer.java @@ -1,4 +1,4 @@ -package github.javaguide.transport.socket; +package github.javaguide.remoting.transport.socket; import github.javaguide.provider.ServiceProvider; import github.javaguide.provider.ServiceProviderImpl; diff --git a/rpc-framework-simple/src/main/java/github/javaguide/serialize/kyro/KryoSerializer.java b/rpc-framework-simple/src/main/java/github/javaguide/serialize/kyro/KryoSerializer.java index ca0beae4d6dd089af649e2c0147025fadefd1813..d81b2feb04157ce6ef541f6be6ecdfc3ebca9c9d 100644 --- a/rpc-framework-simple/src/main/java/github/javaguide/serialize/kyro/KryoSerializer.java +++ b/rpc-framework-simple/src/main/java/github/javaguide/serialize/kyro/KryoSerializer.java @@ -3,8 +3,8 @@ package github.javaguide.serialize.kyro; import com.esotericsoftware.kryo.Kryo; import com.esotericsoftware.kryo.io.Input; import com.esotericsoftware.kryo.io.Output; -import github.javaguide.dto.RpcRequest; -import github.javaguide.dto.RpcResponse; +import github.javaguide.remoting.dto.RpcRequest; +import github.javaguide.remoting.dto.RpcResponse; import github.javaguide.exception.SerializeException; import github.javaguide.serialize.Serializer; import lombok.extern.slf4j.Slf4j;