消息从rabbitmq通道传递到java NIO通道

我正在为一个应用程序构建一个聊天组件（保存所有讨论），并且我计划将一个长轮询服务器作为客户端机器和rabbitmq服务器之间的接口，它将解析格式并排入队列中的消息在rabbitmq上），由芹菜处理，然后芹菜会通过检查数据库中的某些信息等来检查是否允许发布，将消息保存到数据库中，然后再次将它们排入rabbitmq，这段时间将被长期使用，轮询服务器被推送到客户机。

我计划从兔子服务器到包含许多通道的长轮询服务器之间建立一个连接，每个连接对应一个客户端机器在另一端监听的nio套接字通道。

长轮询服务器将使用Java Nio库编写。 我的问题是，将消息从AMQP通道发送到套接字通道并将其推送到客户端的有效方式是什么？

从我对NIO的理解中，唯一需要为OP_WRITE注册一个选择键的时候，是以前尝试write（）调用返回0的时候。在这种情况下，我有兴趣在相应的AMQP中存在信息时写入套接字通道渠道。 一旦数据进入其相应的amqp通道后，我怎么能通知套接字通道，以便我可以通过套接字通道将数据发送到客户端？

---

只需调用write（）！ 不需要'告诉'SocketChannel什么。 然后，如果write（）返回零，请执行OP_WRITE。

链接地址: http://www.djcxy.com/p/5831.html

上一篇: Message passing from rabbitmq channel to java NIO channel

下一篇: Is there a JMS API/Client that works with all AMQP brokers?