apache mina 与 SEDA

在apache mina创建之初作者就开始讨论SEDA在mina中的应用。在mina官网中也配置mina的线程模型时,也提及SEDA。那让我们看看SEDA在apache mina中的应用吧。

1 -通过队列queue把服务分成多个stages.

1.1 每一个阶段执行请求过程中的一个部分。1.2 阶段内部通过事件驱动,特别是非阻塞模型。1.3 用队列来区分边界

2 每一个阶段包含一个线程池来驱动阶段的执行.

2.1 每一个阶段中的线程池不会暴露给应用程序 2.2 根据需要动态控制线程池

3 最好的区分事件和线程

3.1 根据事件流来明确来明确编程逻辑

接下来,我们以apache mina的服务器端来分析SEDA架构在mina中是如何应用的？

在apache mina服务器端通过把整个应该程序划分为4个阶段。

Acceptor阶段 ----->newSessions 队列---->Processor 阶段--->IoFilterChain 队列-->ExecutorFilter阶段-->--->waitingSessions 队列--->业务处理阶段

紧接着我们把每一阶段具体实现来分析一下：

1 -Acceptor阶段。

    /*** This class is called by the startupAcceptor() method and is* placed into a NamePreservingRunnable class.* It's a thread accepting incoming connections from clients.* The loop is stopped when all the bound handlers are unbound.*/private class Acceptor implements Runnable {public void run() {}
}

    /** A Session queue containing the newly created sessions */private final Queue<S> newSessions = new ConcurrentLinkedQueue<S>();

    public final void add(S session) {if (disposed || disposing) {throw new IllegalStateException("Already disposed.");}// Adds the session to the newSession queue and starts the workernewSessions.add(session);startupProcessor();}

Acceptor阶段是接收新socket进来,然后把IoSession加入到newSessions队列中。通过startupProcessor()方法来启动下一个阶段线程。

在Acceptor阶段是通过Acceptor 线程来驱动事件的。当int selected = select(); 事件发生时,表示新socket的来临。

2 -Processor 阶段。

    /*** The main loop. This is the place in charge to poll the Selector, and to* process the active sessions. It's done in* - handle the newly created sessions* -*/private class Processor implements Runnable {public void run() {}
}

    /** A queue used to store the sessions to be removed */private final Queue<S> removingSessions = new ConcurrentLinkedQueue<S>();/** A queue used to store the sessions to be flushed */private final Queue<S> flushingSessions = new ConcurrentLinkedQueue<S>();

Processor 阶段主要处理Socket的输入输出流。在这个阶段涉及到removingSessions队列和flushingSessions 队列。

已读取数据为例,在IoFilterChain过滤链中,触发messageReceived事件来驱动。

3 -ExecutorFilter 阶段。

当ExecutorFilter接收到messageReceived 事件时,会把消息分发到OrderedThreadPoolExecutor线程池中。

    private class Worker implements Runnable {private volatile long completedTaskCount;private Thread thread;public void run() {}
}

    /** A queue used to store the available sessions */private final BlockingQueue<IoSession> waitingSessions = new LinkedBlockingQueue<IoSession>();

该阶段由Worker线程来驱动事件。在该阶段中waitingSessions 队列来区分边界。

4-业务处理阶段。

在最后阶段,为应用程序处理阶段。该阶段可以定义业务处理的线程。在Fix协议中定义一个IoSession一个线程来处理的。

1 队列主要负责进入控制策略

2-队列分割执行边界

3-明确事件分发,支持监控

apache mina 与 SEDA相关推荐

Apache Mina开发手册
作者:chszs,转载需注明.博客主页:http://blog.csdn.net/chszs 一.介绍 Apache Mina是一个网络应用框架,简化用户开发高性能.高可扩展性的网络应用程序的难度.M ...
Apache MiNa 2 学习笔记
http://blog.csdn.net/cgwcgw_/article/details/18402769 http://download.csdn.net/detail/xiaozhu_1986/2 ...
Apache mina,Netty的起源和历史
Genesis of MINA by Trustin Lee 文章来自:Apache mina http://mina.apache.org/mina-project/road-map. ...
Apache Mina 介绍
为什么80%的码农都做不了架构师?>>> 1.MINA 框架简介下图为本人根据对MINA的简要理解,所画出来的框架简图: Apache MINA 是一个网络应用框架,有助于用 ...
java Mina sftp_java – 使用Apache Mina作为模拟/内存SFTP服务器进行单元测试
我正在解决如何使用Apache Mina的麻烦.他们的文档对我无能为力的大脑来说有一点不足.我已经看到了有用的起始代码 Java SFTP server library? 我无法想像的是如何使用它.我 ...
搭建Apache Mina框架并实现Server与Client端的简单消息传递
http://www.himigame.com/apache-mina/831.html :(作者新浪微博: @李华明Himi ) 转载自[黑米GameDev街区] 原文链接: http://www. ...
使用 Apache MINA 开发高性能网络应用程序
http://www.ibm.com/developerworks/cn/opensource/os-cn-apmina/ Apache MINA(Multipurpose Infrastructur ...
Apache MiNa 实现多人聊天室
Apache MiNa 实现多人聊天室开发环境: System:Windows JavaSDK:1.6 IDE:eclipse.MyEclipse 6.6 开发依赖库: Jdk1.4+.mina-c ...
Apache Mina Demo
Mina主要是作为服务器端底层框架来实现数据处理,它的实现很简单,如下例所示: view plaincopy to clipboardprint? package com.gftech.mytool. ...

apache mina 与 SEDA

apache mina 与 SEDA相关推荐

最新文章

热门文章