java原生序列化 Socket短连接 动态代理 反射 

服务提供者 负责提供服务接口定义和服务实现类
服务发布者 负责将本地服务发布成远程服务 
本地服务代理，运行RPC客户端，通过代理调用远程服务提供者，然后将结果进行封装返回给本地消费者


HelloService
HelloServiceImpl
RpcExporter  服务发布
RpcImporter  服务导入  
RpcTest



关键代码


RpcExporter

ObjectInputStream inputStream = new ObjectInputStream(client.getInputStream());
String interfaceName = inputStream.readUTF();
Class<?> service = Class.forName(interfaceName);
String methodName = inputStream.readUTF();
Class<?> [] parameterTypes = (Class<?> [])inputStream.readObject();
Object [] arguments = (Object [])inputStream.readObject();
Method method = service.getMethod(methodName,parameterTypes);
Object result = method.invoke(service.newInstance(),arguments);
ObjectOutputStream outputStream = new ObjectOutputStream(client.getOutputStream());
outputStream.writeObject(result);
                
RpcImporter
public S importer(final Class<?> serviceClass, final InetSocketAddress address) {
      return (S) Proxy.newProxyInstance(serviceClass.getClassLoader(), new Class<?>[]{serviceClass.getInterfaces()[0]},
      new InvocationHandler() {
           public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
                        
               Socket socket = new Socket();
               socket.connect(address);
               ObjectOutputStream outputStream = new ObjectOutputStream(socket.getOutputStream());
               outputStream.writeUTF(serviceClass.getName());
               outputStream.writeUTF(method.getName());
               outputStream.writeObject(method.getParameterTypes());
               outputStream.writeObject(args);
               ObjectInputStream inputStream = new ObjectInputStream(socket.getInputStream());
               return inputStream.readObject();

              
RpcTest


final int port = 8083;
System.out.println("port="+port);

new Thread(new Runnable() {
    public void run() {
      try {
          RpcExporter.exporter("localhost", port);
       } catch (Exception e) {
                    e.printStackTrace();
       }
     }
     }).start();

RpcImporter<HelloService> importer = new RpcImporter<HelloService>();
HelloService hello = importer.importer(HelloServiceImpl.class, new InetSocketAddress("localhost", port));
        
System.out.println(hello.sayHello("tiger"));
System.out.println(hello.sayHello("cat"));
            


完整代码
https://gitee.com/dyyx/demos/tree/master/playrpc


 springcloud核心组件 feign ribbon 独立使用例子