socket 在远程方法调用中使用反射机制

socket 在远程方法调用中运用反射机制

反射,客户端服务器.

接口实现类 (传递的中间类)

public interface HelloService

public class HelloServiceImpl implements HelloService

public class Call implements Serializable

public class SimpleServer {
private Map remoteObj ects=new HashMap(); //存放远程对象的缓存

        /** 把一个远程对象放到缓存中*/
        public void register(String className,Object remoteObj ect){
                  remoteObj ects.put( className,remoteObj ect);
         }

       public void service()throws Exception{
                ServerSocket serverSocket = new ServerSocket(8000);
                System.out.println("服务器启动.");
                while(true){
                        Socket socket=serverSocket.accept();
                        InputStream in=socket.getInputStream();
                        Obj ectInputStream ois=new Obj ectInputStream(in);
                        OutputStream out=socket.getOutputStream();
                        Obj ectOutputStream oos=new Obj ectOutputStream(out);

                         Call call=(Call)ois.readObj ect();            //接收客户发送的Call 对象
                         System.out.println(call);
                         call=invoke(call);                            //调用相关对象的方法
                         oos.writeObj ect(call);                       // 向客户发送包含了执行结果的Call 对象

                         ois.close();
                         oos.close();
                         socket.close();
                }
          }

public Call invoke(Call call){

                    Obj ect result=null;
                    try{
                          String className=call.getClassName();
                          String methodName=call.getMethodName();
                          Obj ect[] params=call.getParams();
                          Class classType=Class.forName(className);
                           Class[] paramTypes=call.getParamTypes();
                           Method method=classType.getMethod(methodName,paramTypes);
                          Obj ect remoteObj ect=remoteObj ects.get(className);                   //从缓存中取出相关的远程对象
                           if(remoteObj ect==null){
                                     throw new Exception(className+"的远程对象不存 ");
                            }else{
                                     result=method.invoke(remoteObject,params);
                             }
                        }catch(Exception e){result=e;}

                  call.setResult(result);                                                  //设置方法执行结果
                   return call;
              }

              public static void main(String args[])throws Exception {
                         SimpleServer server=new SimpleServer();
                         //把事先创建的HelloServiceImpl 对象加入到服务器的缓存中
                         server.register("remotecall.HelloService",new HelloServiceImpl());
                         server.service();
               }

              public class SimpleClient {
                         public void invoke()throws Exception{
                         Socket socket = new Socket("localhost",8000);
                         OutputStream out=socket.getOutputStream();
                         Obj ectOutputStream oos=new Obj ectOutputStream(out);
                         InputStream in=socket.getInputStream();
                         Obj ectInputStream ois=new Obj ectInputStream(in);

                         //Call call=new Call("remotecall.HelloService","getTime",
                                                             new Class[]{},new Obj ect[]{});
                          Call call=new Call("remotecall.HelloService","echo",
                                                                           new Class[]{String.class},new Obj ect[]{"Hello"});
                          oos.writeObject(call);                                                  // 向服务器发送Call 对象
                          call=(Call)ois.readObj ect();                                       //接收包含了方法执行结果的Call 对象
                          System.out.println(call.getResult());

                          ois.close();
                          oos.close();
                          socket.close();
                       }

public static void main(String args[])throws Exception {

                               new SimpleClient().invoke();
                          }
                  }

socket 在远程方法调用中使用反射机制

相关推荐