Dubbo 的超时和重试

作者：爱好编程进阶

2022 年 5 月 09 日
本文字数：2325 字
阅读完需：约 8 分钟

<dubbo:consumer timeout="4000" > 全局配置

<dubbo:reference timeout="3000" ...> 接口类配置

<dubbo:method timeout="2000" ...> 方法配置

基于注解方式的超时配置
服务提供者注解方式配置

@Slf4j

@DubboService(timeout = 5000)

public class TestDubboTimeOutFacadeImpl implements TestDubboTimeOutFacade {

@Override

public void sendMessage(String param) {

try {

Thread.sleep(6000);

} catch (InterruptedException e) {

e.printStackTrace();

}

System.out.println("_________________服务提供者设置的超时时间是 5s");

}

《一线大厂 Java 面试题解析+后端开发学习笔记+最新架构讲解视频+实战项目源码讲义》无偿开源威信搜索公众号【编程进阶路】 服务消费者注解方式配置

@DubboReference(timeout = 3000)

private TestDubboTimeOutFacade testDubboTimeOutFacade;

[](()服务超时设置的代码实例

======================================================================

[](()场景一：服务消费者设置超时时间 3 秒，服务提供者设置超时时间 5 秒

服务提供者注解方式配置

@Slf4j

@DubboService(timeout = 5000)

public class TestDubboTimeOutFacadeImpl implements TestDubboTimeOutFacade {

@Override

public void sendMessage(String param) {

try {

Thread.sleep(6000);

} catch (InterruptedException e) {

e.printStackTrace();

}

System.out.println("_________________服务提供者设置的超时时间是 5s");

}

服务消费者注解方式配置

@DubboReference(timeout = 3000)

private TestDubboTimeOutFacade testDubboTimeOutFacade;

执行结果如下：

消费者端报错：

Caused by: java.util.concurrent.ExecutionException: org.apache.dubbo.remoting.TimeoutException: Waiting server-side response timeout by scan timer. start time: 2022-01-06 15:06:59.482, end time: 2022-01-06 15:07:02.513, client elapsed: 0 ms, server elapsed: 3031 ms, timeout: 3000 ms, request: Request [id=92, version=2.0.2, twoway=true, event=false, broken=false, data=null], channel: /127.0.0.1:50076 -> /127.0.0.1:7890

at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)

at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)

at org.apache.dubbo.rpc.AsyncRpcResult.get(AsyncRpcResult.java:181)

at org.apache.dubbo.rpc.protocol.AsyncToSyncInvoker.invoke(AsyncToSyncInvoker.java:61)

at org.apache.dubbo.rpc.listener.ListenerInvokerWrapper.invoke(ListenerInvokerWrapper.java:78)

at com.dahai.video.dubbotrace.DubboTransferTraceIdFilter.invoke(DubboTransferTraceIdFilter.java:43)