深入解析Apache Mina源码(1)——Mina的过滤器机制实现

• 一个Apache MINA使用案例源代码
• java mina 源码解析_深入解析Apache Mina源码(1)——Mina的过滤器机制实现
• java mina 长连接池_深入解析Apache Mina源码(3)——Mina的线程池模型
• 深入解析Apache Mina源码(2)——Mina的事件模型
• 【端午节礼物大放送】深入解析Apache Mina源码(3)——Mina的线程池模型

package com.lifanghu.chain;

/**
 * @author lifh
 * @mail wslfh2005@163.com
 * @since 2012-6-12 下午11:20:18
 * @name com.lifanghu.chain.Iphone.java
 * @version 1.0
 */

public class Iphone {

    private String state = "我是一台苹果机器；";

    public String getState() {
        return state;
    }

    public void setState(String state) {
        this.state = state;
    }

}

package com.lifanghu.chain;



/**
 * @author  lifh
 * @mail    wslfh2005@163.com
 * @since   2012-6-12 下午11:23:36
 * @name    com.lifanghu.chain.IWorker.java
 * @version 1.0
 */

public interface IWorker {

    /**
     * 处理方法
     * @param iphone
     * @author lifh
     */
    void handleIphone(Iphone iphone);
    /**
     * 设置下一个处理者
     * @param worker
     * @author lifh
     */
    void setNext(IWorker worker);
}

package com.lifanghu.chain;

/**
 * @author lifh
 * @mail wslfh2005@163.com
 * @since 2012-6-12 下午11:29:46
 * @name com.lifanghu.chain.Worker1.java
 * @version 1.0
 */

public class Worker1 implements IWorker {

    private IWorker next;

    public void handleIphone(Iphone iphone) {
        iphone.setState(iphone.getState() + "我被装了一个黑色的后盖；");
        if (next != null)
            next.handleIphone(iphone);
    }

    public void setNext(IWorker worker) {
        this.next = worker;

    }

}
package com.lifanghu.chain;

/**
 * @author lifh
 * @mail wslfh2005@163.com
 * @since 2012-6-12 下午11:34:32
 * @name com.lifanghu.chain.Worker2.java
 * @version 1.0
 */

public class Worker2 implements IWorker {

    private IWorker next;

    public void handleIphone(Iphone iphone) {
        iphone.setState(iphone.getState() + "我被装了一块电池；");
        if (next != null)
            next.handleIphone(iphone);
    }

    public void setNext(IWorker worker) {
        this.next = worker;
    }
}
package com.lifanghu.chain;

/**
 * @author lifh
 * @mail wslfh2005@163.com
 * @since 2012-6-12 下午11:34:32
 * @name com.lifanghu.chain.Worker3.java
 * @version 1.0
 */

public class Worker3 implements IWorker {

    private IWorker next;

    public void handleIphone(Iphone iphone) {
        iphone.setState(iphone.getState() + "我现在是一台完整的Iphone了。");
        if (next != null)
            next.handleIphone(iphone);
    }

    public void setNext(IWorker worker) {
        this.next = worker;
    }
}

package com.lifanghu.chain;

/**
 * @author lifh
 * @mail wslfh2005@163.com
 * @since 2012-6-12 下午11:37:27
 * @name com.lifanghu.chain.Client.java
 * @version 1.0
 */

public class Client {

    public static void main(String[] args) {
        IWorker worker1 = new Worker1();
        IWorker worker2 = new Worker2();
        IWorker worker3 = new Worker3();

        worker1.setNext(worker2);
        worker2.setNext(worker3);
        Iphone iphone = new Iphone();
        worker1.handleIphone(iphone);

        System.out.println(iphone.getState());
    }
}

//消息接收到以后NextFilter的实现会把消息传递给nextEntry去处理。
public void messageReceived(IoSession session, Object message) {
    Entry nextEntry = EntryImpl.this.nextEntry;
    callNextMessageReceived(nextEntry, session, message);
}

private void callNextMessageReceived(Entry entry, IoSession session,
        Object message) {
    try {
        IoFilter filter = entry.getFilter();
        NextFilter nextFilter = entry.getNextFilter();
        //本过滤器进行数据处理，完成后再把消息传向下个过滤器
        filter.messageReceived(nextFilter, session,
                message);
    } catch (Throwable e) {
        fireExceptionCaught(e);
    }
}

@Override
public void messageReceived(NextFilter nextFilter, IoSession session, Object message) throws Exception {
    AbstractIoSession s = (AbstractIoSession) session;
    if (!(message instanceof IoBuffer)) {
        s.increaseReadMessages(System.currentTimeMillis());
    } else if (!((IoBuffer) message).hasRemaining()) {
        s.increaseReadMessages(System.currentTimeMillis());
    }

    try {
        // 最后一个filter会进入到handler进行消息处理。
        session.getHandler().messageReceived(s, message);
    } finally {
        if (s.getConfig().isUseReadOperation()) {
            s.offerReadFuture(message);
        }
    }
}