提交 34407b7e 编写于 作者: S shuang.kou

[v3.0]refractor package structure

上级 e6746a46
package github.javaguide; package github.javaguide;
import github.javaguide.transport.ClientTransport; import github.javaguide.remoting.transport.ClientTransport;
import github.javaguide.proxy.RpcClientProxy; import github.javaguide.proxy.RpcClientProxy;
import github.javaguide.transport.netty.client.NettyClientClientTransport; import github.javaguide.remoting.transport.netty.client.NettyClientClientTransport;
/** /**
* @author shuang.kou * @author shuang.kou
......
package github.javaguide; package github.javaguide;
import github.javaguide.transport.ClientTransport; import github.javaguide.remoting.transport.ClientTransport;
import github.javaguide.proxy.RpcClientProxy; import github.javaguide.proxy.RpcClientProxy;
import github.javaguide.transport.socket.SocketRpcClient; import github.javaguide.remoting.transport.socket.SocketRpcClient;
/** /**
* @author shuang.kou * @author shuang.kou
......
package github.javaguide; package github.javaguide;
import github.javaguide.transport.netty.server.NettyServer; import github.javaguide.remoting.transport.netty.server.NettyServer;
/** /**
* @author shuang.kou * @author shuang.kou
......
package github.javaguide; package github.javaguide;
import github.javaguide.transport.socket.SocketRpcServer; import github.javaguide.remoting.transport.socket.SocketRpcServer;
/** /**
* @author shuang.kou * @author shuang.kou
......
package github.javaguide.handler; package github.javaguide.handler;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
import github.javaguide.dto.RpcResponse; import github.javaguide.remoting.dto.RpcResponse;
import github.javaguide.enumeration.RpcResponseCode; import github.javaguide.enumeration.RpcResponseCode;
import github.javaguide.exception.RpcException; import github.javaguide.exception.RpcException;
import github.javaguide.provider.ServiceProvider; import github.javaguide.provider.ServiceProvider;
......
package github.javaguide.proxy; package github.javaguide.proxy;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
import github.javaguide.transport.ClientTransport; import github.javaguide.remoting.transport.ClientTransport;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import java.lang.reflect.InvocationHandler; import java.lang.reflect.InvocationHandler;
......
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.RpcErrorMessageEnum;
import github.javaguide.enumeration.RpcResponseCode; import github.javaguide.enumeration.RpcResponseCode;
import github.javaguide.exception.RpcException; import github.javaguide.exception.RpcException;
......
package github.javaguide.dto; package github.javaguide.remoting.dto;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;
......
package github.javaguide.dto; package github.javaguide.remoting.dto;
import github.javaguide.enumeration.RpcResponseCode; import github.javaguide.enumeration.RpcResponseCode;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
......
package github.javaguide.transport; package github.javaguide.remoting.transport;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
/** /**
* 传输 RpcRequest。 * 传输 RpcRequest。
......
package github.javaguide.transport.netty.client; package github.javaguide.remoting.transport.netty.client;
import github.javaguide.enumeration.RpcErrorMessageEnum; import github.javaguide.enumeration.RpcErrorMessageEnum;
import github.javaguide.exception.RpcException; import github.javaguide.exception.RpcException;
......
package github.javaguide.transport.netty.client; package github.javaguide.remoting.transport.netty.client;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
import github.javaguide.dto.RpcResponse; import github.javaguide.remoting.dto.RpcResponse;
import github.javaguide.serialize.kyro.KryoSerializer; import github.javaguide.serialize.kyro.KryoSerializer;
import github.javaguide.transport.netty.codec.kyro.NettyKryoDecoder; import github.javaguide.remoting.transport.netty.codec.kyro.NettyKryoDecoder;
import github.javaguide.transport.netty.codec.kyro.NettyKryoEncoder; import github.javaguide.remoting.transport.netty.codec.kyro.NettyKryoEncoder;
import io.netty.bootstrap.Bootstrap; import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption; import io.netty.channel.ChannelOption;
......
package github.javaguide.transport.netty.client; package github.javaguide.remoting.transport.netty.client;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
import github.javaguide.dto.RpcResponse; import github.javaguide.remoting.dto.RpcResponse;
import github.javaguide.registry.ServiceDiscovery; import github.javaguide.registry.ServiceDiscovery;
import github.javaguide.registry.ZkServiceDiscovery; import github.javaguide.registry.ZkServiceDiscovery;
import github.javaguide.transport.ClientTransport; import github.javaguide.remoting.transport.ClientTransport;
import github.javaguide.utils.checker.RpcMessageChecker; import github.javaguide.remoting.dto.RpcMessageChecker;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import io.netty.channel.ChannelFutureListener; import io.netty.channel.ChannelFutureListener;
import io.netty.util.AttributeKey; import io.netty.util.AttributeKey;
......
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.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.channel.SimpleChannelInboundHandler; import io.netty.channel.SimpleChannelInboundHandler;
......
package github.javaguide.transport.netty.codec.kyro; package github.javaguide.remoting.transport.netty.codec.kyro;
import github.javaguide.serialize.Serializer; import github.javaguide.serialize.Serializer;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
......
package github.javaguide.transport.netty.codec.kyro; package github.javaguide.remoting.transport.netty.codec.kyro;
import github.javaguide.serialize.Serializer; import github.javaguide.serialize.Serializer;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
......
package github.javaguide.transport.netty.server; package github.javaguide.remoting.transport.netty.server;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
import github.javaguide.dto.RpcResponse; import github.javaguide.remoting.dto.RpcResponse;
import github.javaguide.provider.ServiceProvider; import github.javaguide.provider.ServiceProvider;
import github.javaguide.provider.ServiceProviderImpl; import github.javaguide.provider.ServiceProviderImpl;
import github.javaguide.registry.ServiceRegistry; import github.javaguide.registry.ServiceRegistry;
import github.javaguide.registry.ZkServiceRegistry; import github.javaguide.registry.ZkServiceRegistry;
import github.javaguide.serialize.kyro.KryoSerializer; import github.javaguide.serialize.kyro.KryoSerializer;
import github.javaguide.transport.netty.codec.kyro.NettyKryoDecoder; import github.javaguide.remoting.transport.netty.codec.kyro.NettyKryoDecoder;
import github.javaguide.transport.netty.codec.kyro.NettyKryoEncoder; import github.javaguide.remoting.transport.netty.codec.kyro.NettyKryoEncoder;
import io.netty.bootstrap.ServerBootstrap; import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelInitializer;
......
package github.javaguide.transport.netty.server; package github.javaguide.remoting.transport.netty.server;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
import github.javaguide.dto.RpcResponse; import github.javaguide.remoting.dto.RpcResponse;
import github.javaguide.handler.RpcRequestHandler; import github.javaguide.handler.RpcRequestHandler;
import github.javaguide.utils.concurrent.ThreadPoolFactory; import github.javaguide.utils.concurrent.ThreadPoolFactory;
import github.javaguide.utils.factory.SingletonFactory; import github.javaguide.utils.factory.SingletonFactory;
......
package github.javaguide.transport.socket; package github.javaguide.remoting.transport.socket;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
import github.javaguide.dto.RpcResponse; import github.javaguide.remoting.dto.RpcResponse;
import github.javaguide.exception.RpcException; import github.javaguide.exception.RpcException;
import github.javaguide.registry.ServiceDiscovery; import github.javaguide.registry.ServiceDiscovery;
import github.javaguide.registry.ZkServiceDiscovery; import github.javaguide.registry.ZkServiceDiscovery;
import github.javaguide.transport.ClientTransport; import github.javaguide.remoting.transport.ClientTransport;
import github.javaguide.utils.checker.RpcMessageChecker; import github.javaguide.remoting.dto.RpcMessageChecker;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
......
package github.javaguide.transport.socket; package github.javaguide.remoting.transport.socket;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
import github.javaguide.dto.RpcResponse; import github.javaguide.remoting.dto.RpcResponse;
import github.javaguide.handler.RpcRequestHandler; import github.javaguide.handler.RpcRequestHandler;
import github.javaguide.utils.factory.SingletonFactory; import github.javaguide.utils.factory.SingletonFactory;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
......
package github.javaguide.transport.socket; package github.javaguide.remoting.transport.socket;
import github.javaguide.provider.ServiceProvider; import github.javaguide.provider.ServiceProvider;
import github.javaguide.provider.ServiceProviderImpl; import github.javaguide.provider.ServiceProviderImpl;
......
...@@ -3,8 +3,8 @@ package github.javaguide.serialize.kyro; ...@@ -3,8 +3,8 @@ package github.javaguide.serialize.kyro;
import com.esotericsoftware.kryo.Kryo; import com.esotericsoftware.kryo.Kryo;
import com.esotericsoftware.kryo.io.Input; import com.esotericsoftware.kryo.io.Input;
import com.esotericsoftware.kryo.io.Output; import com.esotericsoftware.kryo.io.Output;
import github.javaguide.dto.RpcRequest; import github.javaguide.remoting.dto.RpcRequest;
import github.javaguide.dto.RpcResponse; import github.javaguide.remoting.dto.RpcResponse;
import github.javaguide.exception.SerializeException; import github.javaguide.exception.SerializeException;
import github.javaguide.serialize.Serializer; import github.javaguide.serialize.Serializer;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册