随时向客户端发送消息 Netty Io答案

【问题标题】：Send message to client any moment Netty Io随时向客户端发送消息 Netty Io
【发布时间】：2017-10-26 19:34:34
【问题描述】：

我有一个基于微服务的架构，netty io 运行在 spring boot 应用程序上，当我想向客户端发送消息时，我必须等待来自客户端的消息才能将回复发送给我想要的人发送。我怎么能不等他和我沟通就给他发消息呢？这一步我迷路了。

【问题讨论】：

【解决方案1】：

你可以这样处理：

除了等待 HelloMessage 之外，您还可以捕获 channelActive 事件，但每次有人连接到您侦听的端口时都会触发它，即使不是您的客户端之一。这就是为什么我更喜欢使用“Hello Message”

现在，您在频道上有一个参考，您可以随时致电channel.writeAndFlush() 发送消息

【讨论】：

但是我的一个疑问是，我怎么能使用这个从另一个微服务打开的通道？我可以将它放入一个变量中并将其封装以从异步方法中使用？
不，你不能，可能你需要定义一个不同的工作流程，例如使用一个微服务来接收/传递消息（如发布-订阅模式），我们没有太多有关您的架构和代码的信息
这个想法是让端点接收应该发送给客户端的命令，接收该命令并通过 RabbitMQ 中的队列将其发送到所有 Socket 服务器节点，看看客户端是什么并通过消费者从队列中发送消息
但是我看到 channel.write() 或 channel.writeAndFlush() 不是线程安全的 [stackoverflow.com/questions/11095044/…，所以我最终将所有写请求发布到一个环形缓冲区以由单处理线。对此有任何想法吗？主动向客户端发送消息，或者客户端之间的对话是很常见的场景，需要解决。