Spring原生Rpc六種的正確打開方式實現示例

Posted on by

前言

在java生態圈談到Rpc，很多人可能就會想到Dubbo、Motan、Grpc等框架。但是你知道嗎？作為Java編程全傢桶的Spring已經內置瞭多種RPC的實現方式，可以直接使用。存在即合理，有些場景下其實並不需要Dubbo，Grpc等重量級的RPC組件，那麼Spring的輕量封裝就可以派上用場瞭。下面就來探索下Spring中的RPC的實現方式以及如何使用的。

文中代碼地址：https://gitee.com/kailing/spring-rpc

什麼是Rpc？

Rpc（Remote Procedure Call）: 封裝瞭內部實現的遠程調用過程就是rpc，rpc主要為瞭簡化遠程服務調用，通俗的講就是調用遠程服務（跨主機，跨進程）就像調用本地方法一樣。Spring Cloud體系中的Fegin 技術也可以認為是采用http協議傳輸數據的一種Rpc技術。

Spring中的Rpc

Spring中內置瞭六種不同數據傳輸方式的原生的Rpc實現，分別是WebService、Jms、Rmi、Http、Hessian（http）、Amqp。熟悉Rpc的知道，在Java中，主要是通過生成服務接口的代理來實現Rpc服務的調用，Dubbo、Motan這樣，Spring的實現也是這樣。在Rpc服務調用中，有兩個角色，分別是服務的提供者和調用者（消費者）。一方面服務調用者通過代理，在服務調用時會傳輸服務定義的接口名+方法參數給到提供者。另一方面服務提供者拿到接口信息找到本地服務生成調用結果返回給調用者。所以下面所述六種Rpc實現都會有一個公共的服務接口定義，以及各自的代理實現配置。

定義服務接口

/**
 * @WebService 註解隻用於ws 提供的RPC服務
 */ @WebService public interface AccountService { Account getAccount(String name);
     
     class Account implements Serializable { private String name; public String getName(){ return name;
          } public void setName(String name) { this.name = name;
          }
     }
}

公共的api，在Rpc的提供者和消費者中都會使用到，提供者中會實現這個接口提供服務，消費者會通過代理，生成這個接口的代理實現 ，然後通過底層封裝發送具體的消息。和使用dubbo和motan類似

調用服務代碼

@SpringBootApplication public class WsConsumerApplication { @Autowired private AccountService accountService; @PostConstruct public void callRpcService(){
		System.out.println("RPC遠程訪問開始！");
		System.err.println(accountService.getAccount("kl").getName());
		System.out.println("RPC遠程訪問結束！");
	} public static void main(String[] args) {
		SpringApplication.run(WsConsumerApplication.class, args);
	}
}

每個Rpc實現都一樣，都是通過註入AccountService 接口的代理實現來調用服務。不過每個Rpc的代理的配置方式會略有不同，主要體現在不同的傳輸技術會用到不同的配置。總的來說，連接url（http://127.0.0.1、tcp://172.0.0.1、rmi://127.0.0.1），端口、代理接口信息等都是共同需要的。

WEBSERVICE的RPC實現

服務提供者

服務實現

@WebService(serviceName="AccountService",endpointInterface = "com.spring.rpc.api.AccountService") @Service public class AccountServiceImpl extends SpringBeanAutowiringSupport implements AccountService { Logger logger = LoggerFactory.getLogger(getClass()); @Override @WebMethod public Account getAccount(String name) {
        logger.info("{} 請求獲取賬號！", name);
        Account account = new Account();
        account.setName(name + "的賬號"); return account;
    }
}

和其他服務實現不一樣，WebService定義服務時，需要使用@WebService和@WebMethod註解標記

服務暴露

@Configuration public class WsConfig { private String ipList = "127.0.0.1"; private String userName = "admin"; private String passWord = "sasa"; @Bean public SimpleHttpServerJaxWsServiceExporter rmiServiceExporter(Authenticator authenticator) {
        SimpleHttpServerJaxWsServiceExporter exporter = new SimpleHttpServerJaxWsServiceExporter();
        exporter.setHostname("127.0.0.1");
        exporter.setPort(8083);
        exporter.setAuthenticator(authenticator); return exporter;
    } @Bean public Authenticator authenticator(){
        Authenticator authenticator = new Authenticator();
        authenticator.setIpList(ipList);
        authenticator.setUserName(userName);
        authenticator.setPassWord(passWord); return authenticator;
    }
}

完成如上代碼，其實我們已經構建瞭一個完整的WebService服務，而且還加上瞭用戶、密碼和ip白名單等接口權限認證，訪問：http://127.0.0.1:8083/AccountServiceImpl?WSDL 就可以看到服務的定義，如下：

服務消費者

@Configuration public class WsConfig { @Bean("accountService") public JaxWsPortProxyFactoryBean accountService()throws Exception{
        JaxWsPortProxyFactoryBean factoryBean = new JaxWsPortProxyFactoryBean();
        factoryBean.setServiceName("AccountService");
        factoryBean.setPortName("AccountServiceImplPort");
        factoryBean.setNamespaceUri("http://provider.ws.rpc.spring.com/");
        URL wsdlDocumentUrl = new URL("http://127.0.0.1:8083/AccountServiceImpl?WSDL");
        factoryBean.setWsdlDocumentUrl(wsdlDocumentUrl);
        factoryBean.setServiceInterface(AccountService.class);
        factoryBean.setUsername("admin");
        factoryBean.setPassword("sasa"); return factoryBean;
    }
}

通過聲明JaxWsPortProxyFactoryBean來獲得AccountService.class的代理實例。當註入服務調用方法時，實際上是觸發瞭一次WebService的遠程調用

HTTP的RPC實現

服務提供者

服務實現

@Service public class AccountServiceImpl implements AccountService { Logger logger = LoggerFactory.getLogger(getClass()); @Override public Account getAccount(String name) {
        logger.info("{} 請求獲取賬號！", name);
        Account account = new Account();
        account.setName(name + "的賬號"); return account;
    }
}

服務暴露

@Configuration public class HttpConfig { @Bean("/AccountService") public HttpInvokerServiceExporter rmiServiceExporter(AccountServiceImpl accountService){
        HttpInvokerServiceExporter exporter = new HttpInvokerServiceExporter();
        exporter.setService(accountService);
        exporter.setServiceInterface(AccountService.class); return exporter;
    } @Bean public ServletRegistrationBean servletRegistrationBean(DispatcherServlet dispatcherServlet) {
        ServletRegistrationBean servlet = new ServletRegistrationBean();
        servlet.setServlet(dispatcherServlet);
        servlet.setName("remoting");
        servlet.setLoadOnStartup(1);
        servlet.addUrlMappings("/remoting/*"); return servlet;
    }
}

服務消費者

@Configuration public class HttpConfig { @Bean("accountService") public HttpInvokerProxyFactoryBean accountService(){
        HttpInvokerProxyFactoryBean factoryBean = new HttpInvokerProxyFactoryBean();
        factoryBean.setHttpInvokerRequestExecutor(new HttpComponentsHttpInvokerRequestExecutor());
        factoryBean.setServiceUrl("http://127.0.0.1:8081/remoting/AccountService");
        factoryBean.setServiceInterface(AccountService.class); return factoryBean;
    }
}

可以看到，在配置Http實現的Rpc服務消費者時，和WebService是類似的，定義一個FactoryBean就ok瞭。其實其他的四種Rpc實現也都大同小異。後面就不一一列舉瞭

文末結語

博文起草構思的時候本來打算將Spring中內置六種Rpc實現都詳細描述下，後面看著看著就覺得使用起來真的很類似。隻不過像Amqp和Jms以及WebService等實現需要有這方面技術經驗的人才能看的明白。但單就Rpc使用和實現來說基本差不多，所以後面就沒有一一列出占用篇幅。但是上面提到的WebService、Jms、Rmi、Http、Hessian、Amqp這六種實現在上面的git倉庫中都有詳細的實例程序。感興趣的不妨下載下來跑一跑，看下每個實現的代理工廠類都是如何實現的，非常有助於你真正理解Rpc的調用過程，以及實現自己的Rpc輪子。

以上就是Spring原生Rpc六種的正確打開方式實現示例的詳細內容，更多關於Spring原生Rpc打開方式的資料請關註WalkonNet其它相關文章！

推薦閱讀：