3

我有一个运行各种本机 javascript 客户端连接的 netty Web 套接字服务器。现在我想做的是从客户端获取数据请求,并根据每个客户端的请求传回数据。有一种class A实际需要根据请求向客户端异步发送连续的数据(即:不是简单的请求回复模型)。

问题是 - 在 A 类,我有我需要发送的所有数据,但是如何确定哪些数据必须发送到哪个客户端(必须根据客户端请求),即:我如何映射客户端请求,要从 A 类发送的数据以及需要从 A 类发送数据的通道。(我将所有通道存储在 a 中shared ChannelGroup)。

4

1 回答 1

4

你可能想试试这个。

  1. 实例化 DefaultChannelGroupDefaultChannelGroup myChannels = new DefaultChannelGroup("myChannels")

  2. 建立 Web 套接字连接后,将其添加到通道组:myChannels.add()

  3. 将频道 ID 和您的请求 ID 添加到哈希图中

  4. 当您有数据要写入时,我假设您有请求 ID。使用它在哈希图中查找您的频道 ID

  5. 然后从频道组中获取频道:myCahnnels.find(channelId)

  6. 最后,将数据写入通道。

希望这可以帮助。

于 2012-07-22T05:00:33.503 回答