1. JAVA中三種常用的RPC框架

        共 7162字,需瀏覽 15分鐘

         ·

        2021-08-13 08:32

        點擊上方 Java學(xué)習(xí)之道,選擇 設(shè)為星標

        每天18:30點,干貨準時奉上!

        來源: blog.csdn.net/zhaowen25/article/details/45443951
        作者: vince_zw

        RPC是遠程過程調(diào)用的簡稱,廣泛應(yīng)用在大規(guī)模分布式應(yīng)用中,作用是有助于系統(tǒng)的垂直拆分,使系統(tǒng)更易拓展。Java中的RPC框架比較多,各有特色,廣泛使用的有RMI、Hessian、Dubbo等。RPC還有一個特點就是能夠跨語言,本文只以JAVA語言里的RPC為例。

        對于RPC有一個邏輯關(guān)系圖,以RMI為例:

        其他的框架結(jié)構(gòu)也類似,區(qū)別在于對象的序列化方法,傳輸對象的通訊協(xié)議,以及注冊中心的管理與failover設(shè)計(利用zookeeper)。

        客戶端和服務(wù)端可以運行在不同的JVM中,Client只需要引入接口,接口的實現(xiàn)以及運行時需要的數(shù)據(jù)都在Server端,RPC的主要依賴技術(shù)是序列化、反序列化和傳輸協(xié)議,JAVA里對應(yīng)的就是對象的序列化、反序列化以及序列化后數(shù)據(jù)的傳輸。RMI的序列化和反序列化是JAVA自帶的,Hessian里的序列化和反序列化是私有的,傳輸協(xié)議則是HTTP,Dubbo的序列化可以多種選擇,一般使用Hessian的序列化協(xié)議,傳輸則是TCP協(xié)議,使用了高性能的NIO框架Netty。對于序列化,我還了解一些,像Google的ProBuffer、JBoss Marshalling和Apache Thrift等,之前有寫一篇介紹ProBuffer的博文

        Part1RMI(遠程方法調(diào)用)

        JAVA自帶的遠程方法調(diào)用工具,不過有一定的局限性,畢竟是JAVA語言最開始時的設(shè)計,后來很多框架的原理都基于RMI,RMI的使用如下:

        對外接口

        public interface IService extends Remote {

           public String queryName(String no) throws RemoteException;

        }

        服務(wù)實現(xiàn)

        import java.rmi.RemoteException;
        import java.rmi.server.UnicastRemoteObject;

        // 服務(wù)實現(xiàn)
        public class ServiceImpl extends UnicastRemoteObject implements IService {

           /**
            */

           private static final long serialVersionUID = 682805210518738166L;

           /**
            * @throws RemoteException
            */

           protected ServiceImpl() throws RemoteException {
               super();
           }

           /* (non-Javadoc)
            *
            */

           @Override
           public String queryName(String no) throws RemoteException {
               // 方法的具體實現(xiàn)
               System.out.println("hello" + no);
               return String.valueOf(System.currentTimeMillis());
           }
           
        }

        RMI客戶端

        import java.rmi.AccessException;
        import java.rmi.NotBoundException;
        import java.rmi.RemoteException;
        import java.rmi.registry.LocateRegistry;
        import java.rmi.registry.Registry;

        // RMI客戶端
        public class Client {

           public static void main(String[] args) {
               // 注冊管理器
               Registry registry = null;
               try {
                   // 獲取服務(wù)注冊管理器
                   registry = LocateRegistry.getRegistry("127.0.0.1",8088);
                   // 列出所有注冊的服務(wù)
                   String[] list = registry.list();
                   for(String s : list){
                       System.out.println(s);
                   }
               } catch (RemoteException e) {
                   
               }
               try {
                   // 根據(jù)命名獲取服務(wù)
                   IService server = (IService) registry.lookup("vince");
                   // 調(diào)用遠程方法
                   String result = server.queryName("ha ha ha ha");
                   // 輸出調(diào)用結(jié)果
                   System.out.println("result from remote : " + result);
               } catch (AccessException e) {
                   
               } catch (RemoteException e) {
                   
               } catch (NotBoundException e) {
                   
               }
           }
        }

        RMI服務(wù)端

        import java.rmi.RemoteException;
        import java.rmi.registry.LocateRegistry;
        import java.rmi.registry.Registry;

        // RMI服務(wù)端
        public class Server {

           public static void main(String[] args) {
               // 注冊管理器
               Registry registry = null;
               try {
                   // 創(chuàng)建一個服務(wù)注冊管理器
                   registry = LocateRegistry.createRegistry(8088);

               } catch (RemoteException e) {
                   
               }
               try {
                   // 創(chuàng)建一個服務(wù)
                   ServiceImpl server = new ServiceImpl();
                   // 將服務(wù)綁定命名
                   registry.rebind("vince", server);
                   
                   System.out.println("bind server");
               } catch (RemoteException e) {
                   
               }
           }
        }

        服務(wù)注冊管理器寫在了Server里,當然也可以抽出來單獨作為一個服務(wù),在其他一些框架中,往往用Zookeeper充當注冊管理角色。

        Part2Hessian(基于HTTP的遠程方法調(diào)用)

        基于HTTP協(xié)議傳輸,在性能方面還不夠完美,負載均衡和失效轉(zhuǎn)移依賴于應(yīng)用的負載均衡器,Hessian的使用則與RMI類似,區(qū)別在于淡化了Registry的角色,通過顯示的地址調(diào)用,利用HessianProxyFactory根據(jù)配置的地址create一個代理對象,另外還要引入Hessian的Jar包。

        Part3Dubbo(淘寶開源的基于TCP的RPC框架)

        基于Netty的高性能RPC框架,是阿里巴巴開源的,總體原理如下:

        在了解Dubbo之前,要先對Zookeeper有深入的理解,當理解了zookeeper后,Dubbo也就了無秘密了。

        Dubbo的詳細說明在淘寶開源里說的非常詳細,在工作中很多生產(chǎn)項目都用了Dubbo,過程中也發(fā)現(xiàn)了很多需要注意的地方,尤其是那繁多的配置,設(shè)置不當都會讓人煩腦,最好能再基于現(xiàn)有開源的Dubbo再定制優(yōu)化一下。

        -- END --

         | 更多精彩文章 -



        加我微信,交個朋友
        長按/掃碼添加↑↑↑

        瀏覽 45
        點贊
        評論
        收藏
        分享

        手機掃一掃分享

        分享
        舉報
        評論
        圖片
        表情
        推薦
        點贊
        評論
        收藏
        分享

        手機掃一掃分享

        分享
        舉報
          
          

            1. 91精品国产情侣高潮露脸仙踪林 | 国产女人18毛片水真多18精品 | 摩的司机的男男激情 | 国产91精品久久久久久久网曝门 | 无码人妻 一区二区三区 |