dubbo源碼解析（三十一）遠(yuǎn)程調(diào)用——rmi協(xié)議

atinosun 發(fā)布于2019-08-19 11:32 / 2000人閱讀

摘要：關(guān)于協(xié)議的介紹可以參考官方文檔。必須與特定遠(yuǎn)程處理提供程序的規(guī)則兼容。后記該部分相關(guān)的源碼解析地址該文章講解了遠(yuǎn)程調(diào)用中關(guān)于協(xié)議實(shí)現(xiàn)的部分，邏輯比較簡(jiǎn)單。

遠(yuǎn)程調(diào)用——rmi協(xié)議

目標(biāo)：介紹rmi協(xié)議的設(shè)計(jì)和實(shí)現(xiàn)，介紹dubbo-rpc-rmi的源碼。

前言

dubbo支持rmi協(xié)議，主要基于spring封裝的org.springframework.remoting.rmi包來(lái)實(shí)現(xiàn)，當(dāng)然最原始還是依賴 JDK 標(biāo)準(zhǔn)的java.rmi.*包，采用阻塞式短連接和 JDK 標(biāo)準(zhǔn)序列化方式。關(guān)于rmi協(xié)議的介紹可以參考dubbo官方文檔。

地址：http://dubbo.apache.org/zh-cn...

源碼分析 （一）RmiRemoteInvocation

該類繼承了RemoteInvocation，主要是在RemoteInvocation的基礎(chǔ)上新增dubbo自身所需的附加值，避免這些附加值沒(méi)有被傳遞，為了做一些驗(yàn)證處理。

public class RmiRemoteInvocation extends RemoteInvocation {
    private static final long serialVersionUID = 1L;
    private static final String dubboAttachmentsAttrName = "dubbo.attachments";

    /**
     * executed on consumer side
     */
    public RmiRemoteInvocation(MethodInvocation methodInvocation) {
        super(methodInvocation);
        // 添加dubbo附加值的屬性
        addAttribute(dubboAttachmentsAttrName, new HashMap(RpcContext.getContext().getAttachments()));
    }

    /**
     * Need to restore context on provider side (Though context will be overridden by Invocation"s attachment
     * when ContextFilter gets executed, we will restore the attachment when Invocation is constructed, check more
     * 需要在提供者端恢復(fù)上下文（盡管上下文將被Invocation的附件覆蓋
     * 當(dāng)ContextFilter執(zhí)行時(shí)，我們將在構(gòu)造Invocation時(shí)恢復(fù)附件，檢查更多
     * from {@link com.alibaba.dubbo.rpc.proxy.InvokerInvocationHandler}
     */
    @SuppressWarnings("unchecked")
    @Override
    public Object invoke(Object targetObject) throws NoSuchMethodException, IllegalAccessException,
            InvocationTargetException {
        // 獲得上下文
        RpcContext context = RpcContext.getContext();
        // 設(shè)置參數(shù)
        context.setAttachments((Map) getAttribute(dubboAttachmentsAttrName));
        try {
            return super.invoke(targetObject);
        } finally {
            // 清空參數(shù)
            context.setAttachments(null);
        }
    }
}

（二）RmiProtocol

該類繼承了AbstractProxyProtocol類，是rmi協(xié)議實(shí)現(xiàn)的核心，跟其他協(xié)議一樣，也實(shí)現(xiàn)了自己的服務(wù)暴露和服務(wù)引用方法。

1.doExport

@Override
protected  Runnable doExport(final T impl, Class type, URL url) throws RpcException {
    // rmi暴露者
    final RmiServiceExporter rmiServiceExporter = new RmiServiceExporter();
    // 設(shè)置端口
    rmiServiceExporter.setRegistryPort(url.getPort());
    // 設(shè)置服務(wù)名稱
    rmiServiceExporter.setServiceName(url.getPath());
    // 設(shè)置接口
    rmiServiceExporter.setServiceInterface(type);
    // 設(shè)置服務(wù)實(shí)現(xiàn)
    rmiServiceExporter.setService(impl);
    try {
        // 初始化bean的時(shí)候執(zhí)行
        rmiServiceExporter.afterPropertiesSet();
    } catch (RemoteException e) {
        throw new RpcException(e.getMessage(), e);
    }
    return new Runnable() {
        @Override
        public void run() {
            try {
                // 銷毀
                rmiServiceExporter.destroy();
            } catch (Throwable e) {
                logger.warn(e.getMessage(), e);
            }
        }
    };
}

該方法是服務(wù)暴露的邏輯實(shí)現(xiàn)。

2.doRefer

@Override
@SuppressWarnings("unchecked")
protected  T doRefer(final Class serviceType, final URL url) throws RpcException {
    // FactoryBean對(duì)于RMI代理，支持傳統(tǒng)的RMI服務(wù)和RMI調(diào)用者，創(chuàng)建RmiProxyFactoryBean對(duì)象
    final RmiProxyFactoryBean rmiProxyFactoryBean = new RmiProxyFactoryBean();
    // RMI needs extra parameter since it uses customized remote invocation object
    // 檢測(cè)版本
    if (url.getParameter(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion()).equals(Version.getProtocolVersion())) {
        // Check dubbo version on provider, this feature only support
        // 設(shè)置RemoteInvocationFactory以用于此訪問(wèn)器
        rmiProxyFactoryBean.setRemoteInvocationFactory(new RemoteInvocationFactory() {
            @Override
            public RemoteInvocation createRemoteInvocation(MethodInvocation methodInvocation) {
                // 自定義調(diào)用工廠可以向調(diào)用添加更多上下文信息
                return new RmiRemoteInvocation(methodInvocation);
            }
        });
    }
    // 設(shè)置此遠(yuǎn)程訪問(wèn)者的目標(biāo)服務(wù)的URL。URL必須與特定遠(yuǎn)程處理提供程序的規(guī)則兼容。
    rmiProxyFactoryBean.setServiceUrl(url.toIdentityString());
    // 設(shè)置要訪問(wèn)的服務(wù)的接口。界面必須適合特定的服務(wù)和遠(yuǎn)程處理策略
    rmiProxyFactoryBean.setServiceInterface(serviceType);
    // 設(shè)置是否在找到RMI存根后緩存它
    rmiProxyFactoryBean.setCacheStub(true);
    // 設(shè)置是否在啟動(dòng)時(shí)查找RMI存根
    rmiProxyFactoryBean.setLookupStubOnStartup(true);
    // 設(shè)置是否在連接失敗時(shí)刷新RMI存根
    rmiProxyFactoryBean.setRefreshStubOnConnectFailure(true);
    // // 初始化bean的時(shí)候執(zhí)行
    rmiProxyFactoryBean.afterPropertiesSet();
    return (T) rmiProxyFactoryBean.getObject();
}

該方法是服務(wù)引用的邏輯實(shí)現(xiàn)。

后記

該部分相關(guān)的源碼解析地址：https://github.com/CrazyHZM/i...

該文章講解了遠(yuǎn)程調(diào)用中關(guān)于rmi協(xié)議實(shí)現(xiàn)的部分，邏輯比較簡(jiǎn)單。接下來(lái)我將開(kāi)始對(duì)rpc模塊關(guān)于thrift協(xié)議部分進(jìn)行講解。

GPU云服務(wù)器云服務(wù)器三十一 dubbo源碼 js 調(diào)用tcp協(xié)議遠(yuǎn)程協(xié)議錯(cuò)誤

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/77386.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

atinosun

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

miniconda

閱讀 867·2023-04-26 00:11
GreenCloudVPS八周年活動(dòng),VPS年付五折起

閱讀 2667·2021-11-04 16:13
C經(jīng)典書籍筆記——C陷阱與缺陷③（語(yǔ)意陷阱）

閱讀 2116·2021-09-09 09:33
iON：兩周年慶，圣何塞CN2 GIA和新加坡CN2年付8折優(yōu)惠，KT旗下商家，網(wǎng)速快穩(wěn)定

閱讀 1484·2021-08-20 09:35
CloudIPLC：539元/月/1GB內(nèi)存/20GB空間/2TB流量/100Mbps端口/獨(dú)立IP

閱讀 3837·2021-08-09 13:42
（淘寶無(wú)限適配）手機(jī)端rem布局詳解（轉(zhuǎn)載非原創(chuàng)）

閱讀 3615·2019-08-30 15:55
css浮動(dòng)及其危害和解決方法

閱讀 1075·2019-08-30 15:55
css3動(dòng)畫整理

閱讀 2228·2019-08-30 13:55

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

dubbo源碼解析（三十一）遠(yuǎn)程調(diào)用——rmi協(xié)議

相關(guān)文章

dubbo源碼解析（四十八）異步化改造

dubbo源碼解析（四十六）消費(fèi)端發(fā)送請(qǐng)求過(guò)程

***dubbo源碼解析（一）Hello,Dubbo***

dubbo源碼解析（二十一）遠(yuǎn)程調(diào)用——Listener

dubbo源碼解析（四十七）服務(wù)端處理請(qǐng)求過(guò)程

發(fā)表評(píng)論

0條評(píng)論

atinosun

男|高級(jí)講師

TA的文章

miniconda

GreenCloudVPS八周年活動(dòng),VPS年付五折起

C經(jīng)典書籍筆記——C陷阱與缺陷③（語(yǔ)意陷阱）

iON：兩周年慶，圣何塞CN2 GIA和新加坡CN2年付8折優(yōu)惠，KT旗下商家，網(wǎng)速快穩(wěn)定

CloudIPLC：539元/月/1GB內(nèi)存/20GB空間/2TB流量/100Mbps端口/獨(dú)立IP

（淘寶無(wú)限適配）手機(jī)端rem布局詳解（轉(zhuǎn)載非原創(chuàng)）

css浮動(dòng)及其危害和解決方法

css3動(dòng)畫整理

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

dubbo源碼解析（三十一）遠(yuǎn)程調(diào)用——rmi協(xié)議

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！