您的位置:首页 > 其它

MINA 心跳协议

2012-05-09 13:09 357 查看
MINA本身自带了对心跳协议的支持,可以对心跳做出细致的配置,昨天仔细研究了一下MINA的API文档,翻译了一下其中心跳的内容(翻译的不好请大家见谅),做了一个测试例子。和需要用到MINA此功能的同行一起探讨一下。

写道
这个IoFilter 对IoEventType. SESSION_IDLE状态发出保持连接的请求,同时发回保持连接请求的响应。

这个过滤器要和IoSessionConfig.setIdleTime(IdleStatus, int)方法配制使用

这个过滤器会自动校正IdleStatus的idleTime。 (例如IdleStatus.READER_IDLE状态和 IdleStatus.WRITER_IDLE状态.) 改变IdleStatus的idleTime会让过滤器出现一些无法预计的行为。请注意任何IoFilter 和 IoHandler绑定了KeepAliveFilter后都不会得到任何的IoEventType.SESSION_IDLE响应,除非你调用 setForwardEvent(boolean)方法,传参true。

实现KeepAliveMessageFactory

如果要使用这个过滤器,你需要提供一些KeepAliveMessageFactory的实现:确定接收到,或者发出的都是心跳消息,或者重新构造一条新的信条消息。

NameDescriptionImplementation
Active

活跃型
你希望当读取者空闲时发送心跳消息。一旦请求发出,对心跳的响应必须在keepAliveRequestTimeout seconds 的时间内. 接收。否则,指定的KeepAliveRequestTimeoutHandler 类会被调用。如果心跳请求被接收到,它的响应当然会被回复。Both KeepAliveMessageFactory.getRequest(IoSession) and

KeepAliveMessageFactory.getResponse(IoSession, Object)

must return a non-null.

Semi-active

半活跃型
你希望当读取者空闲时发送心跳消息。然而,你实质上并不在意它是否会得到响应。如果心跳请求被接收,同时他会把回应发回来。Both KeepAliveMessageFactory.getRequest(IoSession) and

KeepAliveMessageFactory.getResponse(IoSession, Object)

must return a non-null,

and the timeoutHandler property should be set to KeepAliveRequestTimeoutHandler.NOOP , KeepAliveRequestTimeoutHandler.LOG or

the custom KeepAliveRequestTimeoutHandler implementation

that doesn't affect the session state nor throw an exception.

Passive

被动型
你并不想自己发送心跳请求,但是如果由心跳请求被接收到还是会发响应回去。KeepAliveMessageFactory.getRequest(IoSession) must return null and KeepAliveMessageFactory.getResponse(IoSession, Object) must return a non-null.
Deaf Speaker

聋子型
当读取者空闲时你希望发出心跳请求,但是你并不希望得到任何反馈。KeepAliveMessageFactory.getRequest(IoSession) must return a non-null, KeepAliveMessageFactory.getResponse(IoSession, Object) must return null and the timeoutHandler must be set to KeepAliveRequestTimeoutHandler.DEAF_SPEAKER .
Silent Listener

沉默监听型
你不想发出心跳请求,同时你并不想收到任何回应。Both KeepAliveMessageFactory.getRequest(IoSession) and KeepAliveMessageFactory.getResponse(IoSession, Object) must return null.
写道
请注意你务必正确实现 KeepAliveMessageFactory.isRequest(IoSession, Object) and KeepAliveMessageFactory.isResponse(IoSession, Object)中任何一个你选择实现的方法.

Handling timeout处理超时

KeepAliveFilter 在没有收到心跳消息的响应时,会报告给的KeepAliveRequestTimeoutHandler。默认的处理是 KeepAliveRequestTimeoutHandler.CLOSE,但是你可以调整预设值为:KeepAliveRequestTimeoutHandler.NOOP, KeepAliveRequestTimeoutHandler.LOG或 KeepAliveRequestTimeoutHandler.EXCEPTION,你也可以实现个人的处理类。

特别的 handler: KeepAliveRequestTimeoutHandler.DEAF_SPEAKER

KeepAliveRequestTimeoutHandler.DEAF_SPEAKER 是一个特定的处理方法,专门应对于前面提及过的“deaf speaker”模式。在设置KeepAliveRequestTimeoutHandler.DEAF_SPEAKER的timeoutHandler 时需要停止回应的过滤器,从此去除超时的侦测。

以上是MINA的 心跳包API,从文档中可以得知MINA的心跳主要是依赖KeepAliveMessageFactory,和KeepAliveRequestTimeoutHandler的实现。。

附上自己测试的代码。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: