基于netty的服务器推送设计

Question

关于netty的第二个问题。我们只是从它开始。我们有一个设计，我们需要使用 <罢工> 具有长轮询的HTTP HTTP流。我们估计5k-50k连接的用户打开连接。我们知道tomcat不会处理，所以我们看着netty完成任务。

设计应该足够简单，但我们不能使用websocket（我们希望在netty上使用hornetQ，并提供websocket/stomp支持），但我们不能。

因此，基本上，我们将在连接的客户机中设置服务器推送事件（我们甚至可以使用JS SSE来实现）。

客户机将基于url订阅endpoint（就像JMS上的队列，但要简单得多）

因此，我们将在服务器端有一个进程来生成事件并通知感兴趣的频道（我们为此使用了一个简单的观察者模式）。

因此，通道订阅这些进程，然后从中接收事件。

我今天的问题是，考虑到netty的架构，我们使用的设计方法是否正确。

public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
    service.subscribe(this);
    this.context = ctx;
    ctx.sendUpstream(e);
}

//this method gets called by the service when a server event happens
public void onUpdate(String message) {
  ChannelBuffer buffer = Channels.buffer(message.getBytes().length());
  buffer.writeBytes(message.getBytes());
  ChannelFuture future = Channels.future(this.context.getChannel());
  future.addListener(ChannelFutureListener.CLOSE);
  Channels.write(this.context,future,buffer);
}

当做

Answer 1

看起来不错，但是没有太多。您如何处理长轮询启动和可能的后续超时？（或者你完全擅长于此……这不是西班牙宗教法庭）

根据你的“URL队列”的数量和流行程度，你可以考虑的一件事是使用通道组作为订阅该URL队列的所有通道的容器。这样，您就可以将消息写入组。另外，当频道关闭时，它们将被从组中弹出，因此有一些代码简化。

另外，您考虑过HTTP Streaming吗？在我看来，不如网络套接字好，但比长轮询好。

我不是110%有信心所有的实现都是完美的，但是我已经整理了一个测试项目，演示了使用netty进行长轮询、网络套接字和超文本传输协议的JSON推送。还有一个javascript客户端，它适应您选择的推送类型。你可能会发现它很有用（我很高兴得到任何反馈......）