Spring原生Rpc六種的正確打開方式實現示例
前言
在java生態(tài)圈談到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的提供者和消費者中都會使用到，提供者中會實現這個接口提供服務，消費者會通過代理，生成這個接口的代理實現 ，然后通過底層封裝發(fā)送具體的消息。和使用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的代理的配置方式會略有不同，主要體現在不同的傳輸技術會用到不同的配置?？偟膩碚f，連接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的代理實例。當注入服務調用方法時，實際上是觸發(fā)了一次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打開方式的資料請關注腳本之家其它相關文章！
相關文章
這篇文章主要介紹了Spring?Boot如何自定義監(jiān)控指標?,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-03-03
SpringBoot中如何解決讀取properties文件讀取問題
這篇文章主要介紹了SpringBoot中如何解決讀取properties文件讀取問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-07-07
這篇文章主要介紹了Mybatis如何根據List批量查詢List結果，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
這篇文章主要介紹了Spring基于XML配置AOP詳解,Spring 的 AOP 功能是基于 AspectJ 實現的,支持使用 XML 方式定義 AOP 切面,Spring 項目使用 AOP 功能需要定義三個部分：切面、切點和通知,需要的朋友可以參考下2023-09-09
Java使用@Autowired注解獲取對象為null的幾種情況及解決方法
這篇文章主要給大家介紹了使用@Autowired注解獲取對象為null的幾種情況以及?解決方法,文中有詳細的代碼示例講解,具有一定的參考價值,需要的朋友可以參考下2023-09-09
本篇文章介紹了，在Java中輸入輸出流的使用詳細分析。需要的朋友參考下2013-04-04
時間處理是常見的需求，本文將講述Java語言如何進行時間處理，感興趣的朋友可以了解下2021-05-05
在jmeter中,可以利用正則表達式提取器來幫助我們完成這一動作，本文就詳細的介紹一下應該如何使用，感興趣的可以了解一下2021-11-11
這篇文章主要介紹了java數據庫連接、查詢、更新等,需要的朋友可以參考下2018-05-05
這篇文章主要介紹了java解析jwt中的payload的用法,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2025-04-04