java - 长轮询 netty nio 框架 java

Question

如何使用 netty 进行长轮询框架？比如说我获取 http://localhost/waitforx

但是 waitforx 是异步的，因为它必须等待一个事件？比如说它从阻塞队列中获取一些东西(只能在队列中获取数据时获取)。从队列中获取项目时，我想将数据发送回客户端。希望有人可以给我一些提示如何做到这一点。

非常感谢

Answer 1

你可以先写一个响应头，然后从其他线程发送正文(内容)。

void messageReceived(...) {
    HttpResponse res = new DefaultHttpResponse(...);
    res.setHeader(...);
    ...
    channel.write(res);
}

// In a different thread..
ChannelBuffer partialContent = ...;
channel.write(partialContent);