在Netty处理程序中管理CompletionStage

Question

在调用从 Netty 处理程序内部返回CompletionStage的服务时，如何最好地处理异常。

在我看来，有两种类型的异常需要处理：

在

1. 被调用服务内生成CompletionStage时发生的异常
2. 评估返回CompletionStage的内容时发生的异常

这是否足以涵盖两种情况：

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
try {
myService.call(arg1).whenComplete((response, throwable) -> {
if (throwable != null) {
ctx.fireExceptionCaught(throwable);
} else {
ctx.writeAndFlush(response);
}
} catch(Exception e) {
if (e.getCause() instanceof DecoderException) {
throw e;
} else {
throw new DecoderException(e.getCause());
}
}

Answer 1

是的，您在代码中显示的内容应该正确涵盖两者。