この質問ではHashedWheelTimer

Question

の1つのインスタンスを共有

Netty Comet Async request time out

それは、パイプラインの間HashedWheelTimerの1つのインスタンスを共有するために、私に示唆されました。

私の現在のコードは、私の知る限り、私はパイプラインの間HashedWheelTimerの1つのインスタンスを共有するが、IdleStateHandlerの新しいインスタンスを毎回作成するか見CAとしてこの

@Override 
    public ChannelPipeline getPipeline() throws Exception { 
    ChannelPipeline pipeline = Channels.pipeline(); 
    pipeline.addLast("decoder", new HttpRequestDecoder()); 
    pipeline.addLast("encoder", new HttpResponseEncoder()); 
    pipeline.addLast("handler", new HTTPRequestHandler()); 
    Timer timer = new HashedWheelTimer(); 
    pipeline.addLast("timeout", new IdleStateHandler(timer, 30, 30, 0)); 
    return pipeline; 

のように見えます。

間違っていますか？誰でもそれを正しく行う方法について私を助けることができますか？ IdleStateHandlerとHashedWheelTimerのインスタンスを静的にする必要がありますか？

Answer 1

間違っています。

このパイプラインでは、新しいチャンネルごとに独自のHashedWheelTimerインスタンスが作成されます。あなたが唯一のインスタンスとアプリケーション間で共有 それを作成するようにしてくださいネッティーHashedWheelTimerドキュメント

から

。 アプリケーションが応答しなくなるという一般的な間違いの1つは、すべての接続に対して新しいインスタンスを作成することです。

HashedWheelTimerインスタンスを静的に変更する必要があります。そのままIdleStateHandlerをそのまま使用してください。