Netty IdleStateHandler出现问题 - 我测试了错误的方法吗？

我有一个玩具Netty服务器，并试图发送心跳消息给客户端，当他们的频道没有发生任何事情时。我正在通过telnet到服务器，写信息然后不发送任何东西来测试这个，但是我没有听到任何信息！Netty IdleStateHandler出现问题 - 我测试了错误的方法吗？

控制台：

>>telnet localhost 6969 
Trying 127.0.0.1... 
Connected to localhost. 
Escape character is '^]'. 
>>foo 
Did you say 'foo'?

MyPipelineFactory.java

public class MyPipelineFactory implements ChannelPipelineFactory { 
    private final Timer timer; 
    private static final ChannelHandler stringDecoder = new StringDecoder(); 
    private static final ChannelHandler stringEncoder = new StringEncoder(); 
    private final ChannelHandler idleStateHandler; 

    public MyPipelineFactory(Timer t) { 
     this.timer = t; 
     this.idleStateHandler = new IdleStateHandler(timer, 5, 5, 5); 
    } 

    public ChannelPipeline getPipeline() { 
     // create default pipeline from static method 
     ChannelPipeline pipeline = Channels.pipeline(); 
     pipeline.addLast("idleStateHandler", this.idleStateHandler); // heartbeat 
     pipeline.addLast("framer", new DelimiterBasedFrameDecoder(1024, Delimiters.lineDelimiter())); 
     //pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024,0,1)); // get header from message 
     pipeline.addLast("stringDecoder", stringDecoder); 
     pipeline.addLast("stringEncoder", stringEncoder); 
     pipeline.addLast("ServerHandler", new ServerHandler()); // goes at the end 

     return pipeline; 
    } 
}

HeartbeatHandler.java

public class HeartbeatHandler extends IdleStateAwareChannelHandler { 

    @Override 
    public void channelIdle(ChannelHandlerContext ctx, IdleStateEvent e) { 
     if (e.getState() == IdleState.READER_IDLE) { 
      System.out.println("Reader idle, closing channel"); 
      //e.getChannel().close(); 
      e.getChannel().write("heartbeat-reader_idle"); 
     } 
     else if (e.getState() == IdleState.WRITER_IDLE) { 
      System.out.println("Writer idle, sending heartbeat"); 
      e.getChannel().write("heartbeat-writer_idle"); 
     } 
     else if (e.getState() == IdleState.ALL_IDLE) { 
      System.out.println("All idle, sending heartbeat"); 
      e.getChannel().write("heartbeat-all_idle"); 
     } 
    } 
}

修正：

我忘了有HeartbeatHandler，它需要IdleStateHandler（这部分对我来说并不明显）。这样可行。

public class MyPipelineFactory implements ChannelPipelineFactory { 
    private final Timer timer; 
    private static final ChannelHandler stringDecoder = new StringDecoder(); 
    private static final ChannelHandler stringEncoder = new StringEncoder(); 
    private final ChannelHandler idleStateHandler; 
    private final ChannelHandler heartbeatHandler; 

    public MyPipelineFactory(Timer t) { 
     this.timer = t; 
     this.idleStateHandler = new IdleStateHandler(timer, 5, 5, 5); 
     this.heartbeatHandler = new HeartbeatHandler(); 
    } 

    public ChannelPipeline getPipeline() { 
     // create default pipeline from static method 
     ChannelPipeline pipeline = Channels.pipeline(); 
     pipeline.addLast("idleStateHandler", this.idleStateHandler); 
     pipeline.addLast("heartbeatHandler", this.heartbeatHandler); // heartbeat 
     pipeline.addLast("framer", new DelimiterBasedFrameDecoder(1024, Delimiters.lineDelimiter())); 
     //pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024,0,1)); // get header from message 
     pipeline.addLast("stringDecoder", stringDecoder); 
     pipeline.addLast("stringEncoder", stringEncoder); 
     pipeline.addLast("ServerHandler", new ServerHandler()); // goes at the end 

     return pipeline; 
    } 
}

来源

2012-02-15 nflacco

您错过了在ChannelPipeline中添加HeartbeatHandler。您需要将IdleStateHandler 和 HeartbeatHandler添加到ChannelPipeline以使其工作。

来源

2012-02-15 09:13:34

啊，从文档中我并不清楚，我需要两个。再次感谢 – nflacco 2012-02-15 16:34:57

是否可以在3.5.9中不再需要HeartbeatHandler？ – 2012-10-31 08:46:50

您仍然需要 – 2012-10-31 17:55:15

Norman的回答是一个非常有用的，但我想指出另一件事情：idleStateHandler和heartbeatHandler应该是通道特定的，所以在PipeLineFactory中，您不应该将这两个处理程序构造为私有成员，但需要在getPipeline（）方法中创建新的。您还可以通过频道图保存构建的频道，如果您需要发布频道，最好还是停止计时器以释放资源。

来源

2013-09-14 17:45:12 user2659647

因为IdleStateHandler是可共享的我不认为你需要为每个管道创建一个新的实例。 – WorM 2017-12-12 15:36:55

Netty IdleStateHandler出现问题 - 我测试了错误的方法吗？

回答

相关问题