Netty、字符串和冲洗

Question

我正在尝试调整示例 Netty 代理，使其在途中修改一些内容。

我在 FTP 客户端和服务器之间进行代理，因此行以 CRLF 结尾——这很重要。我还没有对 FTP 数据端口做任何事情，所以这不是一个因素。

我从这个示例代码开始：https://netty.io/4.0/xref/io/netty/example/proxy/package-summary.html

... 设置如下管道：

ch.pipeline().addLast(
      new LoggingHandler(LogLevel.INFO),
      new HexDumpProxyFrontendHandler(remoteHost, remotePort));

...而且效果很好。

如果我添加一个new LineBasedFrameDecoder(maxLen) ftp 客户端挂起等待服务器，因为代理已经剥离了CRLF，而服务器仍在等待。我可以通过告诉帧解码器不要删除定界符来解决这个问题：new LineBasedFrameDecoder(maxLen, false, false).

ch.pipeline().addLast(
      new LoggingHandler(LogLevel.INFO),
      new LineBasedFrameDecoder(maxLen, false, false),
      new HexDumpProxyFrontendHandler(remoteHost, remotePort));

到目前为止，还不错。但是如果我添加一个 String 解码器，我会得到相同的挂起症状，这次是因为未调用 StringDecoder 之后的管道步骤。

ch.pipeline().addLast(
      new LoggingHandler(LogLevel.INFO),
      new LineBasedFrameDecoder(maxLen, false, false),
      new StringDecoder(StandardCharsets.UTF_8),
      // aim is for my own string rewriter to go here
      new StringEncoder(StandardCharsets.UTF_8),
      new HexDumpProxyFrontendHandler(remoteHost, remotePort));

在调试器中，StringEncoder.encode() 中的断点不会触发。

如何告诉Netty解码后处理字符串？

Answer 1

StringEncoder 是一个出站通道适配器。它的目的是在写入时从 String 转换为 ByteBuf，所以我不希望对入站数据调用编码。

为了让您的代码正常工作，您需要将 StringEncoder 替换为入站通道适配器，该适配器在读取时从 String 转换为 ByteBuf。我怀疑 Netty 库中是否存在任何此类编解码器，因为解码器通常会从较低级别的格式转换为较高级别的格式，而不是相反。

由于 LineBasedFrameDecoder 发出 ByteBuf 而 HexDumpProxyFrontendHandler 消耗 ByteBuf，我建议您删除 StringDecoder 和 StringEncoder 并插入您的客户重写器。但是.. 使它成为 ByteBuf 到 ByteBuf 解码器。在解码器中，您可以将传入的 ByteBuf 转换为字符串，完成您的工作，然后将其转换回 ByteBuf，然后将其传递到管道中。

Netty、字符串和冲洗

Netty, Strings and flushing

java

proxy

netty