java - Netty 中的并发

Question

我正在实现 ChannelInboundHandlerAdapter 并且有一个关于并发的问题。是否有必要使其成为线程安全的？我的意思是我必须为每个客户的每个 session 存储一些状态。

public class Impl extends ChannelInboundHandlerAdapter{
    private List<Integer> someState;
    //

    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        int size = someState.size();  //Should I worry about memory consitency here?
        //...
    }
}

问题是，如果从请求到请求 channelRead 方法被不同的线程调用，我将不得不设置一些内存屏障。

有必要吗？还是 Netty 自己搞定？

Answer 1

对于 Netty 4.x

Well-defined thread model

3.x 中没有定义明确的线程模型，尽管在 3.5 中尝试修复它的不一致性。 4.0 定义了严格的线程模型，帮助用户编写 ChannelHandler 而不必过多担心线程安全。

• Netty 永远不会并发调用 ChannelHandler 的方法，除非 ChannelHandler 带有 @Sharable 注释。这与处理程序方法的类型无关 - 入站、出站或生命周期事件处理程序方法。
  • 用户不再需要同步入站或出站事件处理程序方法。
  • 4.0 不允许多次添加 ChannelHandler，除非使用 @Sharable 注释。
• 在 Netty 进行的每个 ChannelHandler 方法调用之间总是存在先行关系。
  • 用户不需要定义可变字段来保持处理程序的状态。
• 用户可以在向 ChannelPipeline 添加处理程序时指定 EventExecutor。
  • 如果指定，ChannelHandler 的处理程序方法始终由指定的 EventExecutor 调用。
  • 如果未指定，则处理程序方法始终由其关联的 Channel 注册到的 EventLoop 调用。
• 分配给处理程序或 channel 的 EventExecutor 和 EventLoop 始终是单线程的。
  • 处理程序方法将始终由同一线程调用。
  • 如果指定了多线程 EventExecutor 或 EventLoop，将首先选择其中一个线程，然后使用所选线程直到注销。
  • 如果同一管道中的两个处理程序分配有不同的 EventExecutors，它们将被同时调用。如果多个处理程序访问共享数据，即使共享数据仅由同一管道中的处理程序访问，用户也必须注意线程安全。
• 添加到 ChannelFuture 的 ChannelFutureListeners 始终由分配给 future 关联 Channel 的 EventLoop 线程调用。
• ChannelHandlerInvoker 可用于控制 Channel 事件的顺序。 DefaultChannelHandlerInvoker 立即执行来自 EventLoop 线程的事件，并将来自其他线程的事件作为 EventExecutor 上的 Runnable 对象执行。请参阅下面的示例，了解在从 EventLoop 线程和其他线程与 Channel 交互时可能产生的影响。

(强调是我的)