基于解码消息设置netty响应编码

Question

我正在编写一个netty TCP服务器，它必须根据请求中的resseType值对响应进行编码，例如返回pro buf或JSON。建议的实现方法是什么？

我们的服务器有一个带有解码器、编码器和处理程序的管道。

pipeline.addLast(new RequestDecoder<Request>())
pipeline.addLast(new ResponseEncoder<Response>())
pipeline.addLast(new Handler<Request, Response>())

我考虑使用解码器将正确的编码器添加到管道中，如下所示

pipeline.addLast(new RequestDecoder<Request>())
pipeline.addLast(new ResponseEncoder<Response>())
pipeline.addLast(new Handler<Request, Response>())

class RequestDecoder<Request> {
  public void decode(...) {
    if (request.responseType().equals("protobuf")) {
      ch.pipeline().replace(ResponseEncoder.class, "protobuf", new ProtobufResponseEncoder<Response>());
    } else {
      ch.pipeline().replace(ResponseEncoder.class, "protobuf", new JsonResponseEncoder<Response>());
    }
  }
}

这似乎有效，但是否正确？ChannelHandler文档使我想到了这个设计。

可以随时添加或删除通道处理器，因为通道管道是线程安全的。例如，可以在将要交换敏感信息时插入加密处理程序，并在交换后将其删除。

通道可能是线程安全的，但通道会串行处理请求吗？如果不是，如果它在完成第一个请求之前启动第二个请求，那么第一个请求的响应是否会使用第二个请求的编码器？

或者，我可以用协议对象< code>RequestDecoder包装请求

Answer 1

通道可能是线程安全的，但是通道会串行处理请求吗？

Netty不理解通道上固有的请求/响应的概念，除非您添加了一个理解您的协议的处理程序。在您的情况下，它是您添加的编码器/解码器。Netty将从通道读取数据，并按照可用的顺序将其发送到管道上。除此之外的顺序由处理程序完成，例如：处理程序可以决定异步处理这些消息，然后乱序写入它们。

如果不是，如果它在完成第一个请求之前启动第二个请求，那么第一个请求的响应是否会使用第二个请求的编码器？

是的，如果请求/响应是相互分开的，则不应修改管道，假定它们是有序的。

对于您的情况，我建议让两个处理程序都在管道中，让它们有条件地处理消息，否则通过管道传递消息。或者，您可以有一个基于类型对消息进行编码的处理程序。