RpcServerHandler.java 文件源码

@Override
public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)
        throws Exception {
    Throwable te = e.getCause();
    if (te instanceof java.io.IOException) {// 网络异常，也有可能是soLinger参数引起
        return;
    }
    logger.error("Unexpected exception from downstream.{}", e.getCause());
    Channel c = e.getChannel();
    try {
        if (c.isWritable()) {
            RpcResponse res = new RpcResponse();
            res.setReturnFlag(RpcConst.ERR_CODE_SERVER_CHANNEL_EXCEPTION);
            res.setReturnMsg(logger.getStackTraceInfo(e.getCause()));
            c.write(res);
        }
    } finally {
        c.close();
    }
    // super.exceptionCaught(ctx, e);
}