Part I - Basics 基础 - Chapter 4 - Session(会话)

优质
小牛编辑
131浏览
2023-12-01

Session(会话)是 MINA 的核心。每当一个客户端连接到服务器,一个新的会话会被创建,并会在客户端关掉连接前一直保存在内存中。

会话用于保存连接的持久信息,以及在请求处理过程中、会话的生命周期中服务器可能需要用到的任何信息。

会话的状态

会话会有一个随着时间演变的状态:

  • 已连接:会话已被创建并可用
  • 闲置:会话在至少一段时间 (这段时间是可配的) 内没有处理任何请求
    • 读闲置:在一段时间内没有任何读操作
    • 写闲置:在一段时间内没有任何写操作
    • 同时闲置:在一段时间内既没有读操作也没有写操作
  • 关闭中:会话正在关闭中 (还有正在清空的消息,清理尚未结束)
  • 已关闭:会话现在已被关闭,没有其他方法可以将其恢复。

以下状态图揭示了所有可能的状态及其转换:

Chapter 4 - Session(会话) - 图1

配置

对于特定会话可以设置以下不同的参数:

  • 接收缓冲大小
  • 发送缓冲大小
  • 空闲时间
  • 写超时时间

另外还有一些其他配置,取决于你所用的传输类型 (参考Chapter 6 - Transports)。

管理用户定义的属性

有可能需要存储一些以后可能会用到的数据。这个使用每个会话关联到的专用数据结构来实现。这是一个键值对组合,它可以存储开发人员可能希望保存的任何类型的数据。

例如,如果你想跟踪会话创建以后用户已发送的请求次数,把它放进集合很容易:只需要创建将要关联到这个值的键即可。

  1. ...
  2. int counterValue = session.getAttribute( "counter" );
  3. session.setAttribute( "counter", counterValue + 1 );
  4. ...

这样就有了将保存属性放进会话的方法:属性就是一个键值对,它可以从会话的容器中添加、删除以及读取。

容器在会话创建时会被自动创建,而在会话结束时会被清理。

定义容器

如上所述,容器是存储键值对的容器,默认情况下是一个 Map,但是也可以定义做其他的数据结构,如果你想处理长寿命周期的数据,或者避免将所有大数据都存储在内存:我们可以实现一个接口和一个工厂用于在会话建立时创建容器。

以下代码演示了会话初始化时容器的创建:

  1. protected final void initSession(IoSession session,
  2. IoFuture future, IoSessionInitializer sessionInitializer) {
  3. ...
  4. try {
  5. ((AbstractIoSession) session).setAttributeMap(session.getService()
  6. .getSessionDataStructureFactory().getAttributeMap(session));
  7. } catch (IoSessionInitializationException e) {
  8. throw e;
  9. } catch (Exception e) {
  10. throw new IoSessionInitializationException(
  11. "Failed to initialize an attributeMap.", e);
  12. }
  13. ...

如果我们想要定义其他类型的容器,这里是我们可以实现的工厂接口:

  1. public interface IoSessionDataStructureFactory {
  2. /**
  3. * Returns an {@link IoSessionAttributeMap} which is going to be associated
  4. * with the specified <tt>session</tt>. Please note that the returned
  5. * implementation must be thread-safe.
  6. */
  7. IoSessionAttributeMap getAttributeMap(IoSession session) throws Exception;
  8. }

过滤器链

每个会话会关联到一个过滤器链,在连入一个请求或者接收/发出消息时这个过滤器链将会对其处理。这些过滤器针对于每个每个单独的会话,在多数情况下,会为所有现有会话使用同一个过滤器链。

但是,也可以为单个会话动态修改过滤器链,比如为指定的会话的过滤器链添加一个日志过滤器。

统计

每个会话也会保持对会话处理结束的一些记录的跟踪:

  • 接收或发送的字节数
  • 接收或发送的消息数
  • 闲置状态
  • 吞吐量

以及其他一些有用的信息。

处理器

最后,并非最不重要的,每个会话会被附加到一个处理器,该处理器负责调度给你的应用的消息。这个处理器也会通过使用会话发送响应包,只需调用 write() 方法:

  1. ...
  2. session.write( <your message> );
  3. ...