SKUARCH

---

Requisitos

mina-core.2.0.4.jar
sfl4j-simple-1.6.2.jar
sfl4j-api-1.6.1.jar

Introducción

Apache mina es un framework que nos ayuda a realizar conexiones con redes, udp y tcp, tambien creo que puede hacer algo con el serial (aqui no se menciona) pero este tutorial es solo la introduccion a este framework.

Por que usar mina? por que te ayuda a desarrollar sockets rapidamente es extencible, ampliable y facil.




La imagen de arriba muestra la arquitectura de apache mina.

Programando un time server

Todo el codigo esta dentro del metodo main y utilizaremos un try-catch para controlar las excepciones, lo primero que se debe de hacer es un objecto del tipo IoAcaptor

Primero definiremos el puerto.

Para este tutorial utilizaremos el puerto 9123 y definiremos una variable miembro

private static final int PORT = 9123;

acceptor este objecto es el que se usa para recibir las conexiones de entrada. Con la clase NioSocketAcceptor se puede defiir un handler, el handler sera la clase que haga el trabajo del socket.

IoAcceptor acceptor = new NioSocketAcceptor();

Los siguiente es crear un filtro y agregarlo a la configuracion.

acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));

Ahora definiremos el handler, el handler es el que atendera las peticiones del cliente. Este handler esta separado en otra clase que hereda de IoHandlerAdapter

acceptor.setHandler( new TimeServerHandler() );

Definimos dos metodos mas el buffer y el tiempo de in idle.

acceptor.getSessionConfig().setReadBufferSize( 2048 );
acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );

Entonces asi tendremos la primer clase Main

package testmina;

import java.net.BindException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import org.apache.log4j.Logger;
import org.apache.log4j.PropertyConfigurator;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.SocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

/**
 *
 * @author skuarch
 */
public class Main {

    public static Logger logger = null;
    private static final int PORT = 9123;

    //==========================================================================
    public Main() {
        PropertyConfigurator.configure("log.properties");
        logger = Logger.getLogger(getClass());
    }

    //==========================================================================
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {

        new Main();

        try {

            //IoAcceptor acceptor = new NioSocketAcceptor();
            SocketAcceptor acceptor = new NioSocketAcceptor();
            acceptor.setReuseAddress( true );

            //acceptor.getFilterChain().addLast("logger", new LoggingFilter());
            acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));

            acceptor.setHandler(new TimeServerHandler());            
            acceptor.getSessionConfig().setReadBufferSize(2048);
            acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
            acceptor.bind(new InetSocketAddress(PORT));

            acceptor.setCloseOnDeactivation(true);           
                                   

        } catch (BindException be) {
            logger.error("error", be);
        } catch (Exception e) {
            logger.error("error", e);
        }

    } // end main
} // end class

Se utilizo testmina como paquete y el nombre de la clase es Main.

La clase TimeServerHandler

En esta clase de heredo de IoHandlerAdapter pero tambien se puede utilizar la interfaz IoHandler se sobre escriben los metodos exceptionCaught, messageReceived y sessionIdle

exceptionCaught

Este metodo es el encargado de las excepciones solo imprime el stack trace y cierra la conexion, esta es una buen practica.

messageReceived

Este es el metodo que recibe los datos del cliente y escribe la fecha actual, si el mensaje que se recibe es quit se cerrara la conexion.

sessionIdle

Este metodo es llamado segun se configuro en acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );. y solo imprime el numero de idles

La clase se veria de esta forma

import java.util.Date;

import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;

public class TimeServerHandler extends IoHandlerAdapter
{
    @Override
    public void exceptionCaught( IoSession session, Throwable cause ) throws Exception
    {
        cause.printStackTrace();
    }

    @Override
    public void messageReceived( IoSession session, Object message ) throws Exception
    {
        String str = message.toString();
        if( str.trim().equalsIgnoreCase("quit") ) {
            session.close();
            return;
        }

        Date date = new Date();
        session.write( date.toString() );
        System.out.println("Message written...");
    }

    @Override
    public void sessionIdle( IoSession session, IdleStatus status ) throws Exception
    {
        System.out.println( "IDLE " + session.getIdleCount( status ));
    }
}

Por ultimo para probar puedes utilizar telnet y el puerto, de esta forma

telnet localhost 9123

y dar entrer

Referencias

apache mina
video tutorial de apache mina
documentacion de apache mina
ejemplos de apache mina
ejemplo cliente servidor