向 Atmosphere 中的一部分订阅者广播

Question

我正在尝试做的事情： 能够让用户订阅多个不同的“聊天室”，并使用反向 AJAX/comet 将消息从聊天室发送给登录到该房间的每个人。 （有点复杂，但这是一个类似的用例）。

我在做什么： 将 Grails 与 JMS 和 Atmosphere 结合使用。发送消息时，我使用 JMS 发送消息对象，该对象由 Grails 服务接收，然后广播到气氛 URL（即气氛/消息）。

显然，JMS 在那里有点多余，但我虽然可以用它来帮助我过滤谁应该检索消息，尽管这看起来并不真正有效（假设订阅者基本上是单例服务......）。

无论如何，我需要做的只是向收听气氛/消息的正确子集的人发送消息。 RESTful 类型的 URL 在这里是完美的（即，atmosphere/messages/*，其中 * 是房间 ID），但是我不知道如何使用 Atmosphere 来做到这一点。

关于如何实现我想要的目标有什么想法/建议吗？这里没有什么是具体的，所以请随意提出几乎任何建议。我什至一直在思考（基于对另一个问题的回答），例如，我是否可以做一些事情，比如向 Node.js 服务器发送消息，并让它处理反向 AJAX/comet 部分。

Answer 1

如果我正确理解您的要求，以下应该可以工作（jax-rs + scala 代码）：

1）每个想要从聊天室获取消息的人都注册它：

@GET
@Path(choose/a/path)
def register(@QueryParam("chatroomId") chatroomId: Broadcaster) {
  // alternatively, the Suspend annotation can be used
  new SuspendResponse.SuspendResponseBuilder[String]()
          .resumeOnBroadcast(false).broadcaster(chatroomId).scope(SCOPE.REQUEST)
          .period(suspendTimeout, TimeUnit.MINUTES)
          .addListener(new AtmosphereEventsLogger()).build
}

2）要为所有注册用户广播消息，请调用以下命令方法：

@POST
@Broadcast
@Path(choose/a/path/{chatroomId})
def broadcast(@PathParam("chatroomId") id: String) {
  // first find your broadcaster with the BroadcasterFactory
  BroadcasterFactory.getDefault().lookupAll() // or maybe there is a find by id?
  broadcaster = ...
  broadcaster.broadcast(<your message>)
}

我还建议阅读atmosphere 白皮书，看看邮件列表 和 Jeanfrancois Arcand 的博客。

希望有帮助。

Answer 2

人们对彗星的概念存在误解。它只是另一个发布/订阅实现。如果您有多个聊天室，那么您需要有多个“主题”，即用户可以注册的多个频道。例如：

broadcaster['/atmosphere/chatRoom1'].broadcast('Hello world!')

broadcaster['/atmosphere/chatRoom2'].broadcast('Hello world!')

所以我建议您创建多个通道，并且不要手动过滤应该检索消息的用户集（这绝对不是应该这样做的方式）。您不需要在服务器端创建任何内容，因为用户只需注册特定频道并接收任何人放入其中的消息。

Answer 3

我建议您为一个 URL（如 /atmosphere/chat-room）创建一个 AtmosphereHandler，然后使用 AtmosphereResource 并与其绑定一个 BroadcastFilter，假设将其命名为 ChatRoomBroadcastFilter。

每当用户订阅新的聊天室时，就会向服务器发送一条消息（从客户端），告诉服务器有关订阅的信息。订阅后，维护用户列表>>聊天室绑定在服务器上的某个位置。

每当广播消息时，都将其与聊天室 ID 一起广播。仅当用户订阅了聊天室时，ChatRoomBroadcastFilter 中的（您可能需要将其设为 PerRequestBroacastFilter）才将消息传播给用户。我不确定这是否可以解决问题。如果您需要代码示例，请在评论中提及。我会把它放出来，但这需要一些时间，所以现在不放它；）。