前言

Dubbo不只提供了堵塞式的的同步調(diào)用，同時(shí)提供了異步調(diào)用的方式。這種方式主要應(yīng)用于提供者接口響應(yīng)耗時(shí)明顯，消費(fèi)者端可以利用調(diào)用接口的時(shí)間去做一些其他的接口調(diào)用,利用Future 模式來異步等待和獲取結(jié)果即可。這種方式可以大大的提升消費(fèi)者端的利用率。 目前這種方式可以通過XML的方式進(jìn)行引入。

1、異步調(diào)用實(shí)現(xiàn)

（1）為了能夠模擬等待，通過 int timeToWait參數(shù)，標(biāo)明需要休眠多少毫秒后才會(huì)進(jìn)行返回。

String sayHello(String name, int timeToWait);

（2）接口實(shí)現(xiàn) 為了模擬調(diào)用耗時(shí) 可以讓線程等待一段時(shí)間

（3）在消費(fèi)者端，配置異步調(diào)用 注意消費(fèi)端默認(rèn)超時(shí)時(shí)間1000毫秒 如果提供端耗時(shí)大于1000毫秒會(huì)出現(xiàn)超時(shí)

可以通過改變消費(fèi)端的超時(shí)時(shí)間 通過timeout屬性設(shè)置即可單位毫秒

<dubbo:reference id="helloService" interface="com.lagou.service.HelloService">
        <!--添加異步調(diào)用方式，注解方式不支持-->
        <dubbo:method name="sayHello" async="true" />
</dubbo:reference>

（4）測(cè)試，我們休眠100毫秒，然后再去進(jìn)行獲取結(jié)果。方法在同步調(diào)用時(shí)的返回值是空，我們可以通過RpcContext.getContext().getFuture() 來進(jìn)行獲取Future對(duì)象來進(jìn)行后續(xù)的結(jié)果等待操作。

package com.lagou;
import com.lagou.bean.ConsumerComponent;
import com.lagou.service.HelloService;
import com.sun.org.apache.xpath.internal.functions.FuncTrue;
import org.apache.dubbo.rpc.RpcContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.io.IOException;
import java.util.concurrent.Future;
public class XMLConsumerMain {
    public static void main(String[] args) throws IOException, InterruptedException {
        ClassPathXmlApplicationContext   app  = new ClassPathXmlApplicationContext("consumer.xml");
        HelloService  service = app.getBean(HelloService.class);
        while (true) {
            System.in.read();
            try {
                String hello = service.sayHello("world", 100);
                // 利用Future 模式來獲取
                Future<Object>  future  = RpcContext.getContext().getFuture();
                System.out.println("result :" + hello);
                System.out.println("future result:"+future.get());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

2、異步調(diào)用特殊說明

需要特別說明的是，該方式的使用，請(qǐng)確保dubbo的版本在2.5.4及以后的版本使用。 原因在于在2.5.3及之前的版本使用的時(shí)候，會(huì)出現(xiàn)異步狀態(tài)傳遞問題。

比如我們的服務(wù)調(diào)用關(guān)系是A -> B -> C , 這時(shí)候如果A向B發(fā)起了異步請(qǐng)求，在錯(cuò)誤的版本時(shí)，B向C發(fā)起的請(qǐng)求也會(huì)連帶的產(chǎn)生異步請(qǐng)求。這是因?yàn)樵诘讓訉?shí)現(xiàn)層面，他是通過RPCContext 中的attachment 實(shí)現(xiàn)的。在A向B發(fā)起異步請(qǐng)求時(shí)，會(huì)在attachment 中增加一個(gè)異步標(biāo)示字段來表明異步等待結(jié)果。B在接受到A中的請(qǐng)求時(shí)，會(huì)通過該字段來判斷是否是異步處理。但是由于值傳遞問題，B向C發(fā)起時(shí)同樣會(huì)將該值進(jìn)行傳遞，導(dǎo)致C誤以為需要異步結(jié)果，導(dǎo)致返回空。這個(gè)問題在2.5.4及以后的版本進(jìn)行了修正。

到此這篇關(guān)于Dubbo異步調(diào)用的實(shí)現(xiàn)介紹的文章就介紹到這了,更多相關(guān)Dubbo異步調(diào)用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！