RpcServer server = new RpcServer("127.0.0.1",1234);
  HelloServiceImpl impl = new HelloServiceImpl();
  server.export(HelloService.class, impl);

  RpcClient client = new RpcClient("127.0.0.1",1234);
  HelloService service = client.refer(HelloService.class);
  //同步调用
  System.out.println(service.hello("test rpc"));

  RpcClient client = new RpcClient("127.0.0.1",1234);
  HelloService service = client.refer(HelloService.class);
  RpcContext ctx = RpcContext.getContext();
  ctx.setAsync(true);
  String obj=service.hello("test rpc");
  System.out.println(obj==null);
  Future<String> f =ctx.getFuture();
  System.out.println(f.get());

  RpcClient client = new RpcClient("127.0.0.1",1234);
  HelloService service = client.refer(HelloService.class);
  RpcContext ctx = RpcContext.getContext();
  ctx.setAsync(true);
  ctx.setCallback(new Callback() {
			
		@Override
		public void onSuccess(Object result) {
			System.out.println("success  "+ result);
		}
		@Override
		public void onError(Throwable thr) {
		       System.out.println("error");
		       thr.printStackTrace();
		}
		});
  String obj=service.hello("test rpc");
  System.out.println(obj==null);

//单向调用
  RpcContext ctx = RpcContext.getContext();
  ctx.setOneway(true);
  System.out.println(service.hello("test rpc")==null);

     RpcServer server = new RpcServer("127.0.0.1",1234,60);//60 weight WeightRoute时起作用
     server.setRegistry(true);          //设置向注册中心注册
     HelloServiceImpl impl = new HelloServiceImpl();
     server.export(HelloService.class, impl);

	//负载均衡设置
//	Cluster cluster = new Cluster(WeightRoute.class);
//	Cluster cluster = new Cluster(RandomRoute.class);
	Cluster cluster = new Cluster(RoundRobinRoute.class);
	HelloService service = cluster.refer(HelloService.class);
		
	for (int i = 0; i < 10; i++) {			
		System.out.println(service.hello("test rpc"));
	}