什么原因导致阻塞操作 Netty 4 中的异常？

Question

最近，我在我的netty4项目中找到了一些BlockingOperationException。

有人说在使用start netty的ServerBootstrap的sync()方法时会导致死锁，因为sync()会调用await()方法，而await()中有一个叫‘check deadlock’的方法。

但我不这么认为。ServerBootstrap使用名为boosGroup的EventLoopGroup，Channel使用workerGroup来操作IO，我认为它们不会相互影响，它们有不同的EventExector。

在我的实践中，死锁异常不会出现在Netty启动过程中，大多数发生在等待writeAndFlush的Channel之后。

分析源代码、checkDeadLock、 exception在当前线程和执行器线程相同时引发异常。

我的项目代码是吹：

private void channelWrite(T message) {
    boolean success = true;
    boolean sent = true;
    int timeout = 60;
    try {
        ChannelFuture cf = cxt.write(message);
        cxt.flush();
        if (sent) {
            success = cf.await(timeout);
        }
        if (cf.isSuccess()) {
            logger.debug("send success.");
        }
        Throwable cause = cf.cause();
        if (cause != null) {
            this.fireError(new PushException(cause));
        }
    } catch (LostConnectException e) {
        this.fireError(new PushException(e));
    } catch (Exception e) {
        this.fireError(new PushException(e));
    } catch (Throwable e) {
        this.fireError(new PushException("Failed to send message“, e));
    }
    if (!success) {
        this.fireError(new PushException("Failed to send message"));
    }
}

我知道Netty官方建议不要使用sync()或await()方法，但是我想知道什么情况会导致进程死锁，当前线程和执行线程的执行是一样的。

我更改了我的项目代码。

private void pushMessage0(T message) {
    try {
        ChannelFuture cf = cxt.writeAndFlush(message);
        cf.addListener(new ChannelFutureListener() {
            @Override
            public void operationComplete(ChannelFuture future) throws PushException {
                if (future.isSuccess()) {
                    logger.debug("send success.");
                } else {
                    throw new PushException("Failed to send message.");
                }
                Throwable cause = future.cause();
                if (cause != null) {
                    throw new PushException(cause);
                }
            }
        });
    } catch (LostConnectException e) {
        this.fireError(new PushException(e));
    } catch (Exception e) {
        this.fireError(new PushException(e));
    } catch (Throwable e) {
        this.fireError(new PushException(e));
    }
}

但是我面临一个新问题，我无法从ChannelHandlerListener获取pushException。

Answer 1

不能在IO线程中调用await是可以理解的。但是，有2点。1.如果您在通道处理程序中调用以下代码，将不会报告异常，因为大多数情况下，await中的isDone检查返回true，因为您在IO线程中，而IO线程正在同步写入数据。调用await时，数据已经写入。

ChannelPromise p = ctx.writeAndFlush(msg);
p.await()

Answer 2

如果您在事件加速器正在使用的同一线程中调用“同步”或“等待”，则 Netty 将引发“同步”或“等待”，而“事件”演示者正在使用并绑定到该线程。这通常是频道本身使用的事件循环。