Netty、Strings和flushing

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));

...这很好。

如果我添加一个新的LineBasedFrameDecoder（maxLen）ftp客户端将挂起等待服务器，因为代理已剥离CRLF，而服务器仍在等待。我可以通过告诉帧解码器不要删除分隔符来解决这个问题：newlinebasedFrameDecoder（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是一个出站通道适配器。它的目的是在编写时将字符串转换为ByteBuf，所以我不希望对入站数据调用encode。

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

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