long polling netty nio framework 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);