《Apache MINA 2.0 用户指南》第四章：会话

墨蓝 2023-10-16 21:17 51阅读 0赞

最近准备将Apache MINA 2.0 用户指南英文文档翻译给大家，但是我偶然一次百度，发现“[Defonds][]”这位大牛已经翻译大部分文档。

原文链接：[http://mina.apache.org/mina-project/userguide/ch11-ssl-filter/ch11-ssl-filter.html][http_mina.apache.org_mina-project_userguide_ch11-ssl-filter_ch11-ssl-filter.html]。

会话处于 MINA 的核心位置：每当一个客户端连接到服务器，一个新的会话会被创建，并会在客户端关掉连接前一直保存在内存中。  
 会话用于保存连接的持久信息，以及在请求处理过程中、会话的生命周期中服务器可能需要用到的任何信息。  
会话的状态  
 会话会有一个随着时间演变的状态：

*  已连接：会话已被创建并可用
 *  闲置：会话在至少一段时间 (这段时间是可配的) 内没有处理任何请求

读闲置：在一段时间内没有任何读操作  
 写闲置：在一段时间内没有任何写操作  
 同时闲置：在一段时间内既没有读操作也没有写操作

*  关闭中：会话正在关闭中 (还有正在清空的消息，清理尚未结束)
 *  已关闭：会话现在已被关闭，没有其他方法可以将其恢复。

以下状态图揭示了所有可能的状态及其转换：  
  
![session-state][]  
 配置  
 对于特定会话可以设置以下不同的参数：

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

另外还有一些其他配置，取决于你所用的传输类型 (参考 [《Apache MINA 2.0 用户指南》第六章：传输][Apache MINA 2.0] )。  
 管理用户定义的属性  
 有可能需要存储一些以后可能会用到的数据。这个使用每个会话关联到的专用数据结构来实现。这是一个键值对组合，它可以存储开发人员可能希望保存的任何类型的数据。  
 例如，如果你想跟踪会话创建以后用户已发送的请求次数，把它放进集合很容易：只需要创建将要关联到这个值的键即可。

**\[java\]** [view plain][] [copy][view plain] [print][view plain] [?][view plain] [![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

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

这样就有了将保存属性放进会话的方法：属性就是一个键值对，它可以从会话的容器中添加、删除以及读取。  
 容器在会话创建时会被自动创建，而在会话结束时会被清理。  
 定义容器  
 如上所述，容器是存储键值对的容器，默认情况下是一个 Map，但是也可以定义做其他的数据结构，如果你想处理长寿命周期的数据，或者避免将所有大数据都存储在内存：我们可以实现一个接口和一个工厂用于在会话建立时创建容器。  
 以下代码演示了会话初始化时容器的创建：

**\[java\]** [view plain][] [copy][view plain] [print][view plain] [?][view plain] [![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

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.  ...

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

**\[java\]** [view plain][] [copy][view plain] [print][view plain] [?][view plain] [![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

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() 方法：

**\[java\]** [view plain][] [copy][view plain] [print][view plain] [?][view plain] [![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

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

[Defonds]: http://my.csdn.net/defonds
[http_mina.apache.org_mina-project_userguide_ch11-ssl-filter_ch11-ssl-filter.html]: http://mina.apache.org/mina-project/userguide/ch11-ssl-filter/ch11-ssl-filter.html
[session-state]: https://img-blog.csdn.net/20140109134459937?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZGVmb25kcw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast
[Apache MINA 2.0]: http://blog.csdn.net/defonds/article/details/18074411
[view plain]: http://blog.csdn.net/defonds/article/details/18039127#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/149167
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/149167/fork