为什么 Netty 不执行我的计划任务？

Question

使用 Java 8 和 Netty 4.1.1.Final，我原以为下面的测试用例会成功，但它超时了。我不理解 wrt nettys 事件循环和任务调度是怎么回事？

public class SchedulerTest {


CountDownLatch latch;

TimerHandler handler;

static class TimerHandler extends ChannelInboundHandlerAdapter {

    ChannelHandlerContext ctx;

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        super.channelActive(ctx);
        this.ctx = ctx;
    }

    private void timeout(final long ms) {
        ctx.executor().schedule(() -> {
            ctx.fireUserEventTriggered(ms);
        }, ms, TimeUnit.MILLISECONDS);
    }

}

static class TimeoutReactor extends ChannelInboundHandlerAdapter {
    CountDownLatch latch;

    public TimeoutReactor(CountDownLatch latch) {
        super();
        this.latch = latch;
    }

    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        System.out.println("userEventTriggered");
        latch.countDown();
        super.userEventTriggered(ctx, evt);
    }

}

@Before
public void setUp() throws Exception {
    latch = new CountDownLatch(2);
    handler = new TimerHandler();
    TimeoutReactor reactor = new TimeoutReactor(latch);
    new EmbeddedChannel(handler, reactor);
}

@Test(timeout = 1000)
public void test() throws InterruptedException {

    handler.timeout(30);
    handler.timeout(20);
    latch.await();
}

}

Answer 1

这是因为 EmbeddedChannel 不是“真正的” Channel 实现，主要用于测试和嵌入式 ChannelHandlers。您需要在给定的时间范围后调用“runPendingTasks()”才能运行它。如果您使用“真正的” Channel 实现，它将无需任何额外的方法调用即可工作。