上一篇博客 Apache MINA (3) NioSocketAcceptor初始化 了解了NioSocketAcceptor的初始化过程，完成了初始化，Acceptor线程被阻塞，处于等待客户端请求到达的状态，通过进一步研究源代码了解Mina处理请求的过程。

当有客户端的请求到达时selector.select()被唤醒

?

if (selected > 0) {
                        // We have some connection request, let's process 
                        // them here. 
                        processHandles(selectedHandles());
                    }

?

?processHandles(selectedHandles())负责处理所有接收到的请求，首先调用了NioSocketAcceptor的accept方法，接受来自客户端的请求，并初始化一个NioSocketSession，并将SocketChannel绑定到NioSession中，指定了处理该NioSession的NioProcesser,IoServices,IoFilterChain等，最后执行

?

session.getProcessor().add(session);?

?

把session交给SimpleIoProcessorPool处理。

?

?

上一篇博客中介绍了SimpleIoProcessorPool的初始化，他初始化了一个无界线程池this.executor = Executors.newCachedThreadPool();并定义了一个cpu+1个NioProcessor绑定到这个executor中，每个NioProcessor中初始化了一个Selector，提供Nio相关的具体实现，如select(),read(),write()等方法

?

SimpleIoProcessorPool的add(S session)方法首先指定一个处理session的NioProcessor；其中getProcessor(session)，该方法会先从session的attributeMap中找有没有指定好的Processor，如果没有，根据sessionId和cpu+1取模取到一个NioProcessor放到attributeMap中。

processor = pool[Math.abs((int) session.getId()) % pool.length];
session.setAttributeIfAbsent(PROCESSOR, processor);

private final Queue<S> newSessions = new ConcurrentLinkedQueue<S>();

executor.execute(new NamePreservingRunnable(processor, threadName));

IoBuffer buf = IoBuffer.allocate(bufferSize);

filterChain.fireMessageReceived(buf);

chain.addLast("myChain", new ProtocolCodecFilter(new TextLineCodecFactory())); 

Queue<Object> messageQueue = getMessageQueue();
            
            while (!messageQueue.isEmpty()) {
                nextFilter.messageReceived(session, messageQueue.poll());
            }

@Override
	public void messageReceived(IoSession session, Object message)
			throws Exception {

		String str = (String)message;

        // 打印客户端
		System.out.println("receive client message : [ " + str +" ]");

		// 回写消息给客户端
		session.write(count.incrementAndGet());

	}