java - 确定 session 是否空闲并用 Mina 刷新解码器？

Question

我将 Apache Camel 与 Apache Mina 结合使用来建立 TCP 服务器。我在代码中使用特定的协议(protocol)解码器。在此解码器中，我正在等待获取 X 字节数，然后再将它们发送到下游路由。

我想实现一些能够理解 session 空闲或关闭的东西，然后将我们已经到达下游的字节发送到路由(如果我们没有得到总的X也没关系)字节)。我已经尝试实现一个 IoFilterAdapter 重写方法 sessionIdle() 但我不知道如何使用它。

Answer 1

重写 sessionIdle() 方法基本上用于在达到 session 空闲时间时关闭(或根据需要配置) session 。

您可以通过重写 sessionOpened() 方法在处理程序类中设置空闲时间(或通过扩展 IoFilterAdapter )。像这样的事情应该可以完成工作:

@Override
public void sessionOpened(final IoSession session) throws Exception
{
    session.getConfig().setIdleTime(IdleStatus.BOTH_IDLE, this.idleTimeOut);
}

您还可以使用 IdleStatus 类中定义的其他空闲状态。本质上有以下几种状态:

public static final IdleStatus READER_IDLE = new IdleStatus("reader idle");
public static final IdleStatus WRITER_IDLE = new IdleStatus("writer idle");
public static final IdleStatus BOTH_IDLE = new IdleStatus("both idle");