我正在使用 Java 中的 Netty NIO 开发客户端和服务器通信系统。我的代码可以找到in the following repository .目前我有一台服务器和两个客户端，我正在将信息从服务器发送到客户端，反之亦然。

我想弄清楚的是，当我从第一个客户端接收到服务器的消息时，我如何将该消息发送到第二个客户端(以及从客户端 2 到客户端 1 的相反方向)。如何向特定客户端发送消息？

我注意到我的问题是由于我尝试从服务器发送消息的方式引起的。我在 serverHandler 中的代码如下:

for (Channel ch : channels1) {
    responseData.setIntValue(channels1.size());
    remoteAddr.add(ch.remoteAddress().toString());
    future = ch.writeAndFlush(responseData);
    //future.addListener(ChannelFutureListener.CLOSE);
    System.out.println("the requested data from the clients are: "+requestData);
    responseData1.setStringValue(requestData.toString());
    future = ch.writeAndFlush(responseData1);
    System.out.println(future);
}

默认情况下，我发送有关连接数的消息，但当我从客户端 1 或 2 收到消息时，我想将其发送回 2 和 1。所以我想执行两者之间的通信组件。如何从服务器发送到特定客户端？我不确定如何将消息发送回客户端。

最佳答案

一般方法

让我们描述解决问题的方法。

在服务器端接收数据时，使用 channel 的远程地址( java.net.SocketAddress Channel.remoteAddress() method)来标识客户端。

这样的识别可以使用像这样的 map 来完成:Map<SocketAddress, Client> , 其中Client类或接口(interface)应包含适当的客户端连接( channel )关联上下文，包括其 Channel .确保 map 保持最新:适当处理 «client connected» 和 «client disconnected» 事件。

识别客户端后，您可以使用客户端连接( channel )映射向客户端(当前发送客户端除外)发送适当的消息。

此外，我想建议您使用 Netty 找到一个很好的聊天应用程序实现并看一看。

Netty 特定的解决方案

让我们考虑服务器端的实现，特别是 ProcessingHandler 的实现类。

它已经通过将 Activity channel 表示为 channel 组来管理它们:

static final ChannelGroup channels1 =
    new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

使 channel 组保持最新状态

当前的实现处理 «channel becomes active» 事件以使 channel 组保持最新:

@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
    channels1.add(ctx.channel());
    // ...
}

但这只是一半:还需要对称地处理 «channel becomes inactive» 事件。实现应如下所示:

@Override
public void channelInactive(final ChannelHandlerContext ctx) throws Exception {
    channels1.remove(ctx.channel());
}

广播:将接收到的消息发送到除当前 channel 之外的所有 channel

要实现所需的行为，只需通过引入适当的检查来更新实现，如下所示:

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    // ...

    for (Channel ch : channels1) {
        // Does `ch` represent the channel of the current sending client?
        if (ch.equals(ctx.channel())) {
            // Skip.
            continue;
        }

        // Send the message to the `ch` channel.
        // ...
    }

    // ...
}

发送和接收字符串问题

Currently ，围绕 ResponseData 的功能类不存在(未实现)。

要使客户端和服务器都能正常工作，需要进行以下草稿更改。

1. ResponseData类别:getStringValue和 toString方法应该更正:

   String getStringValue() {
       return this.strValue;
   }
   
   @Override
   public String toString() {
       return intValue + ";" + strValue;
   }
   

2. ResponseDataEncoder类:它应该使用字符串值:

   private final Charset charset = Charset.forName("UTF-8");
   
   @Override
   protected void encode(final ChannelHandlerContext ctx, final ResponseData msg, final ByteBuf out) throws Exception {
       out.writeInt(msg.getIntValue());
       out.writeInt(msg.getStringValue().length());
       out.writeCharSequence(msg.getStringValue(), charset);
   }
   

3. ResponseDataDecoder类:它应该使用字符串值:

   private final Charset charset = Charset.forName("UTF-8");
   
   @Override
   protected void decode(final ChannelHandlerContext ctx, final ByteBuf in, final List<Object> out) throws Exception {
       ResponseData data = new ResponseData();
       data.setIntValue(in.readInt());
       int strLen = in.readInt();
       data.setStringValue(in.readCharSequence(strLen, charset).toString());
       out.add(data);
   }
   

4. ClientHandler类:它应该正确接收和处理消息:

   @Override
   public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
       final ResponseData responseData = (ResponseData) msg;
       System.out.println("The message sent from the server " + responseData);
       update.accept(responseData.getIntValue());
   }
   

其他引用资料

1. «SecureChat ‐ an TLS-based chat server, derived from the Telnet example», Netty Documentation .特别是 SecureChatServerHandler class 的实现.
2. «Netty in Action», Norman Maurer, Marvin Allen Wolfthal (ISBN-13: 978-1617291470) , «第 3 部分 — 网络协议(protocol)»，«12.2 我们的示例 WebSocket 应用程序» 子章。涵盖“基于浏览器的聊天应用程序”的实现。

关于java - 网络 NIO : Read received messages，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47269633/