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

优质

小牛编辑

132浏览

2023-12-01

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

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

会话的状态

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

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

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

Chapter 4 - Session(会话) - 图1

配置

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

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

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

管理用户定义的属性

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

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

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

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

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

定义容器

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

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

protected final void initSession(IoSession session,
        IoFuture future, IoSessionInitializer sessionInitializer) {
    ...
    try {
        ((AbstractIoSession) session).setAttributeMap(session.getService()
                .getSessionDataStructureFactory().getAttributeMap(session));
    } catch (IoSessionInitializationException e) {
        throw e;
    } catch (Exception e) {
        throw new IoSessionInitializationException(
                "Failed to initialize an attributeMap.", e);
    }
    ...

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

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

过滤器链

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

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

统计

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

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

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

处理器

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

...
session.write( <your message> );
...