有关如何创建参数化流API的任何想法?

我想创建参数化的流式api,如http://dev.twitter.com/pages/streaming_api_methods#statuses-filter

我看到的直截了当的方式如下:

  1. 为消息创建redis频道(如twitter状态)。
  2. 每个连接的套接字都在此通道上订阅。
  3. 在redis内部回调每个套接字检查当前消息是否适合提供的参数(参数可以设置为单独的套接字消息)

你觉得伙计们怎么样?

你可能想看看nats