import org.apache.mina.common.IoHandler; //导入依赖的package包/类
public static void main(String[] args) throws Exception{
	int port=9527;
	
	final IoAcceptor acceptor=new SocketAcceptor(Runtime.getRuntime().availableProcessors() + 1,
               							   Executors.newCachedThreadPool());
	acceptor.getFilterChain().addLast("stringserialize", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
	IoHandler handler=new IoHandlerAdapter(){

		public void messageReceived(IoSession session, Object message)
				throws Exception {
			if("quit".equalsIgnoreCase(message.toString())){
				acceptor.unbindAll();
				System.out.println("Server has been shutdown!");
				System.exit(0);
			}
			System.out.println("Message from client: "+message);
			session.write("Server response��"+message);
		}
		
	};
	acceptor.bind(new InetSocketAddress(port), handler);
	System.out.println("Server listen on port: "+port);
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
/**
 * Create a connection to federation listener.
 */
private static IoSession connectFederation (Router router,
                                            EwafURI uri,
                                            IoHandler listener)
{
  SocketConnector connector = new SocketConnector (1, router.executor ());
  SocketConnectorConfig connectorConfig = new SocketConnectorConfig ();
  
  connector.setWorkerTimeout (0);
  
  connectorConfig.setThreadModel (ThreadModel.MANUAL);
  connectorConfig.setConnectTimeout (20);
  
  connectorConfig.getFilterChain ().addLast   
    ("codec", FederationFrameCodec.FILTER);
  
  ConnectFuture future = 
    connector.connect (new InetSocketAddress (uri.host, uri.port),
                       listener, connectorConfig);
  
  future.join ();
  
  return future.getSession ();
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
@Override
protected void doStart() throws Exception {
    super.doStart();
    LOG.info("Binding to server address: {} using acceptor: {}", address, acceptor);
    IoHandler handler = new ReceiveHandler();
    if (protocol.equals("tcp") && clientMode) {
        ConnectFuture future = connector.connect(address, handler, getEndpoint().getConnectorConfig());
        future.join();
        session = future.getSession();
    } else {
        acceptor.bind(address, handler, getEndpoint().getAcceptorConfig());
    }
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
private void openConnection() {
    SocketAddress address = getEndpoint().getAddress();
    connector = getEndpoint().getConnector();
    if (LOG.isDebugEnabled()) {
        LOG.debug("Creating connector to address: {} using connector: {} timeout: {} millis.", new Object[]{address, connector, timeout});
    }
    IoHandler ioHandler = new ResponseHandler(getEndpoint());
    // connect and wait until the connection is established
    ConnectFuture future = connector.connect(address, ioHandler, getEndpoint().getConnectorConfig());
    future.join();
    session = future.getSession();
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
/**
 * Bind to a set of URI's. This can be used by plugins to bind to
 * network addresses using the same network setup as the router
 * would, including TLS parameters.
 * 
 * @param uris The URI's to listen to.
 * @param handler The IO handler.
 * @param baseFilters The IO filters used by all connection types.
 * @param authRequired Hosts matched by this filter must be
 *                successfully authenticated via TLS or will be
 *                refused access.
 * 
 * @throws IOException if an error occurred during binding.
 */
public void bind (Set<? extends ElvinURI> uris, IoHandler handler,
                  DefaultIoFilterChainBuilder baseFilters, 
                  Filter<InetAddress> authRequired) 
  throws IOException
{
  SocketAcceptorConfig defaultAcceptorConfig = 
    createAcceptorConfig 
      (createStandardFilters (baseFilters, authRequired));
  SocketAcceptorConfig secureAcceptorConfig = null; // lazy init'ed
  
  for (ElvinURI uri : uris)
  {
    SocketAcceptorConfig bindConfig;
    
    if (uri.isSecure ())
    {
      if (secureAcceptorConfig == null)
      {
        secureAcceptorConfig = 
          createAcceptorConfig 
            (createSecureFilters (baseFilters, authRequired, false));
      }
      
      bindConfig = secureAcceptorConfig;
    } else
    {
      bindConfig = defaultAcceptorConfig;
    }
    
    for (InetSocketAddress address : addressesFor (uri))
      acceptor.bind (address, handler, bindConfig);
  }
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
/**
 * Create a connection to federation listener.
 */
private static IoSession connectFederationTLS (Router router,
                                               EwafURI uri,
                                               IoHandler listener)
  throws Exception
{
  SocketConnector connector = new SocketConnector (1, router.executor ());
  SocketConnectorConfig connectorConfig = new SocketConnectorConfig ();
  
  connector.setWorkerTimeout (0);
  
  connectorConfig.setThreadModel (ThreadModel.MANUAL);
  connectorConfig.setConnectTimeout (20);
  
  SSLFilter filter = new SSLFilter (defaultSSLContext ());
  
  filter.setUseClientMode (true);
  
  connectorConfig.getFilterChain ().addFirst ("ssl", filter);   
  
  connectorConfig.getFilterChain ().addLast   
    ("codec", FederationFrameCodec.FILTER);
  
  ConnectFuture future = 
    connector.connect (new InetSocketAddress (uri.host, uri.port),
                       listener, connectorConfig);
  
  future.join ();
  
  return future.getSession ();
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
public void connect (IoHandler acceptorListener, IoHandler connectorListener)
  throws IOException
{
  InetSocketAddress remoteAddress = new InetSocketAddress ("127.0.0.1", 29170);
  
  acceptor.bind (remoteAddress, acceptorListener, acceptorConfig);
  
  ConnectFuture future = 
    connector.connect (remoteAddress, connectorListener, connectorConfig);
  
  future.join ();
  
  session = future.getSession ();
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
/**
 * Does nothing.
 * @return 
 */
@Override
public IoHandler getHandler() {
    return null;
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
public IoHandler getHandler() {
    return null;
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
@Override
public IoHandler getHandler() {
    return null;
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
public IoSession createClient(NioConfig cfg, IoHandler handler) throws IOException {
    SocketConnector sc = new SocketConnector();
    ConnectFuture cf = sc.connect(new InetSocketAddress("127.0.0.1", 2227), handler, cfg.configureSocketSessionConfig());
    cf.join();
    return cf.getSession();
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
@Override
public IoHandler getHandler() {
    return mock.getHandler();
}
 

import org.apache.mina.common.IoHandler; //导入依赖的package包/类
@Override
public IoHandler getHandler() {
    return null;  //To change body of implemented methods use File | Settings | File Templates.
}