RpcClientStart.java 827 B

123456789101112131415161718192021
  1. package cn.hhj;
  2. import cn.hhj.config.SpringConfig;
  3. import cn.hhj.proxy.RpcProxyClient;
  4. import cn.hhj.service.IHelloService;
  5. import cn.hhj.version.Version;
  6. import org.springframework.context.ApplicationContext;
  7. import org.springframework.context.annotation.AnnotationConfigApplicationContext;
  8. public class RpcClientStart {
  9. public static void main( String[] args ) throws InterruptedException {
  10. ApplicationContext context = new AnnotationConfigApplicationContext(SpringConfig.class);
  11. RpcProxyClient rpcProxyClient = context.getBean(RpcProxyClient.class);
  12. IHelloService iHelloService = rpcProxyClient.getClientProxy(IHelloService.class, Version.V2);
  13. for (int i = 0; i < 100; i++) {
  14. Thread.sleep(2000);
  15. System.out.println(iHelloService.sayHello(i));
  16. }
  17. }
  18. }