基于Spring的RPC通訊模型的使用與比較

/**
   * 服務(wù)端：
   * <p>
   * 1、默認(rèn)情況下，RmiServiceExporter 會(huì)嘗試綁定到本地機(jī)器1099端口上的RMI注冊(cè)表。
   * 2、如果在這個(gè)端口沒有發(fā)現(xiàn)RMI注冊(cè)表，RmiServiceExporter 將會(huì)啟動(dòng)一個(gè)注冊(cè)表。
   * 3、可重寫注冊(cè)表的路徑和端口，這個(gè)是個(gè)大坑，當(dāng)你設(shè)置了registryHost屬性的時(shí)候，源碼中就不創(chuàng)建Registry，而是直接去獲取，可是我們自己也沒有創(chuàng)建，所以就會(huì)報(bào)連接不上。
   *
   * @param userService
   * @return
   */
  @Bean(name = "rmiServiceExporter")
  public RmiExporter rmiServiceExporter(UserService userService, Environment environment) {
    String registryHost = environment.getProperty("registryHost");
    int registryPort = environment.getProperty("registryPort", Integer.class);
    RmiExporter rmiExporter = new RmiExporter();
    rmiExporter.setService(userService); //要把該bean(即rmiServiceImpl)發(fā)布為一個(gè)RMI服務(wù)
    rmiExporter.setServiceName("RmiService"); //命名RMI 服務(wù)
    rmiExporter.setServiceInterface(UserService.class); //指定服務(wù)所實(shí)現(xiàn)的接口
    rmiExporter.setRegistryHost(registryHost);
    rmiExporter.setRegistryPort(registryPort);
    return rmiExporter;
  }

/**
 * Created by XiuYin.Cui on 2018/5/14.
 * 
 * 解決設(shè)置 registryHost 后，報(bào)連接拒絕的問題。
 */
public class RmiExporter extends RmiServiceExporter {

  @Override
  protected Registry getRegistry(String registryHost, int registryPort, RMIClientSocketFactory clientSocketFactory,
                  RMIServerSocketFactory serverSocketFactory) throws RemoteException {


    if (registryHost != null) {
      try {
        if (logger.isInfoEnabled()) {
          logger.info("Looking for RMI registry at port '" + registryPort + "' of host [" + registryHost + "]");
        }
        //把spring源代碼中這里try起來，報(bào)異常就創(chuàng)建一個(gè)
        Registry reg = LocateRegistry.getRegistry(registryHost, registryPort, clientSocketFactory);
        testRegistry(reg);
        return reg;
      } catch (RemoteException ex) {
        LocateRegistry.createRegistry(registryPort);
        Registry reg = LocateRegistry.getRegistry(registryHost, registryPort, clientSocketFactory);
        testRegistry(reg);
        return reg;
      }
    } else {
      return getRegistry(registryPort, clientSocketFactory, serverSocketFactory);
    }
  }
}

@Bean(name = "rmiUserServiceClient")
  public RmiProxyFactoryBean RmiUserServiceClient(){
    RmiProxyFactoryBean rmiProxyFactoryBean = new RmiProxyFactoryBean();
    rmiProxyFactoryBean.setServiceUrl("rmi://127.0.0.1:9999/RmiService");
    rmiProxyFactoryBean.setServiceInterface(UserService.class);
    rmiProxyFactoryBean.setLookupStubOnStartup(false);//不在容器啟動(dòng)后創(chuàng)建與Server端的連接
    rmiProxyFactoryBean.setRefreshStubOnConnectFailure(true);//連接出錯(cuò)的時(shí)候自動(dòng)重連
    rmiProxyFactoryBean.afterPropertiesSet();
    return rmiProxyFactoryBean;
  }

 @Resource(name="rmiUserServiceClient")
  private UserService userService;

/**
   * hessian沒有注冊(cè)表，不需要設(shè)置 serviceName
   */
  @Bean(name = "hessianServiceExporter")
  public HessianServiceExporter hessianServiceExporter(UserService userService) {
    HessianServiceExporter hessianServiceExporter = new HessianServiceExporter();
    hessianServiceExporter.setService(userService);
    hessianServiceExporter.setServiceInterface(UserService.class);
    return hessianServiceExporter;
  }
  /**
   * 需要配置一個(gè)URL映射來確保DispatcherServlet把請(qǐng)求轉(zhuǎn)給HessianServiceExporter
   */
  @Bean(name = "handlerMapping")
  public HandlerMapping handlerMapping() {
    SimpleUrlHandlerMapping handlerMapping = new SimpleUrlHandlerMapping();
    Properties mappings = new Properties();
    mappings.setProperty("/user.service", "hessianServiceExporter");
    handlerMapping.setMappings(mappings);
    return handlerMapping;
  }

@Bean(name = "hessianUserServiceClient")
  public HessianProxyFactoryBean hessianUserServiceClient(){
    HessianProxyFactoryBean proxy = new HessianProxyFactoryBean();
    proxy.setServiceUrl("http://127.0.0.1:8080/user.service");
    proxy.setServiceInterface(UserService.class);
    return proxy;
  }

  @Resource(name="hessianUserServiceClient")
  private UserService userService; 

/*Http Invoker*/
  @Bean(name = "httpInvokerServiceExporter")
  public HttpInvokerServiceExporter httpInvokerServiceExporter(UserService userService){
    HttpInvokerServiceExporter httpInvokerServiceExporter = new HttpInvokerServiceExporter();
    httpInvokerServiceExporter.setService(userService);
    httpInvokerServiceExporter.setServiceInterface(UserService.class);
    return httpInvokerServiceExporter;
  }
  /**
   * 需要配置一個(gè)URL映射來確保DispatcherServlet把請(qǐng)求轉(zhuǎn)給HessianServiceExporter
   */
  @Bean(name = "handlerMapping")
  public HandlerMapping handlerMapping() {
    SimpleUrlHandlerMapping handlerMapping = new SimpleUrlHandlerMapping();
    Properties mappings = new Properties();
    mappings.setProperty("/user.service", "hessianServiceExporter");
    mappings.setProperty("/userInvoker.service", "httpInvokerServiceExporter");
    handlerMapping.setMappings(mappings);
    return handlerMapping;
  }

@Bean(name = "httpInvokerUserServiceClient")
  public HttpInvokerProxyFactoryBean httpInvokerUserServiceClient(){
    HttpInvokerProxyFactoryBean proxy = new HttpInvokerProxyFactoryBean();
    proxy.setServiceUrl("http://127.0.0.1:8080//userInvoker.service");
    proxy.setServiceInterface(UserService.class);
    return proxy;
  }