简单的RPC(未用动态代理)

package app01;

import java.io.Serializable;

public class Didi implements Serializable{

public String name;
public int age;

public Didi() {
super();
}

public Didi(String name, int age) {
super();
this.name = name;
this.age = age;
}

@Override
public String toString() {
return "Didi [name=" + name + ", age=" + age + "]";
}

public String getRpc(){
return "RPC的调用";
}

public String getAddress(String s){
return s;
}

public String getAddress(String s, int num){
return s + "  地铁: " + num;
}

}

package app01;

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.List;

public class Server {

public static void main(String[] args) throws IOException, ClassNotFoundException, NoSuchMethodException, IllegalAccessException, IllegalArgumentException, InstantiationException {
ServerSocket server = new ServerSocket();
server.bind(new InetSocketAddress(8089));
while(true){
Socket socket = server.accept();
InputStream is = socket.getInputStream();
ObjectInputStream ois = new ObjectInputStream(is);

String className = ois.readUTF();
Class c = Class.forName(className);
String methodName = ois.readUTF();
Class[] ps = (Class[]) ois.readObject();//参数类型
Method method = c.getMethod(methodName, ps);
Object[] arguments  =  (Object[]) ois.readObject();//参数

String ms = null;
try {
ms = (String) method.invoke(c.newInstance(), arguments);
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
oos.writeObject(ms);
oos.flush();
oos.close();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}

}

}

package app01;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

public class Client <T>{

public static void main(String[] args) throws ClassNotFoundException, IOException, InstantiationException, IllegalAccessException, NoSuchMethodException, SecurityException, IllegalArgumentException, InvocationTargetException  {
RpcGetMes("app01.Didi", "getAddress", new Class[]{String.class, int.class}, new Object[]{"回龙观东大街", 8});
}

static void RpcGetMes(String className, String methodName, Class[] ps, Object[] paras)throws IOException, ClassNotFoundException{
Socket socket = new Socket();
socket.connect(new InetSocketAddress("localhost", 8089));
OutputStream os = socket.getOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(os);
oos.writeUTF(className);
oos.writeUTF(methodName);
oos.writeObject(ps);
oos.writeObject(paras);
oos.flush();
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
String reMes = (String) ois.readObject();
System.out.println("客户端收到数据: " + reMes);
oos.close();
}

}