Apache ActiveMQ
En este artículo veremos las características de ActiveMQ, un intermediario de mensajes entre diferentes aplicaciones o sistemas, se describen algunos de los escenarios donde puede ser interesante su uso. Claro está, veremos cómo se instala, cómo se configura y un ejemplo de funcionamiento.
Características principales
- Es Código Open Source.
- Actúa como mediador de mensajes entre aplicaciones emisoras y receptoras.
- Proporciona comunicación asíncrona entre aplicaciones.
- Pese a ser una implementación de la especificación JMS (Java Message Service), proporciona una gran cantidad de APIs para diferentes lenguajes como PHP, C/C++, .Net, Ruby, etc.
- Soporta diferentes protocolos de conexión como HTTP, TCP, SSL, etc.
- Tiene una GUI de administración.
Instalación
La instalación de Apache ActiveMQ es sencilla.Primero debemos descargar el software de: http://activemq.apache.org/download.html. Una vez descargado el fichero, debemos seguir los siguientes pasos:
- Descomprimir la distribución descargada en el directorio deseado.
- Para entornos Unix: tar zxvf apache-activemq-X.X.X-bin.tar.gz
- Comprobar que el script de arranque de la aplicación tiene permisos de ejecución. Entramos en el directorio bin que se encuentra dentro de la carpeta de instalación, y asignamos al script "activemq" permisos de ejecución. chmod 755 activemq
- Arrancamos Apache ActiveMQ de la siguiente forma: directorio_instalacion_activemq]/bin/activemq start
- También podemos "parar" la aplicación, "reiniciarla" o comprobar su "estado" con: stop, restart o status.
- Para comprobar que nuestro intermediario de mensajes ha arrancado correctamente: netstat -an|grep 61616, donde 61616 es el puerto por defecto.
También podemos acceder a la consola de administración en http://localhost:8161/admin/
Para que puedas acceder:
Para que puedas acceder:
- Usuario: admin
- Password: admin
Configuración
La configuración del ActiveMQ se encuentra en un fichero activemq.xml localizado en el directorio [directorio_instalacion_activemq]/conf/. No obstante, se puede cambiar el fichero de configuración con el que arrancar ActiveMQ de la siguiente forma:
[directorio_instalacion_activemq]/bin/activemq start xbean:[nombre_del_fichero_configuracion].xml
A continuación destacamos cada una de las propiedades principales:
Transport Connector
Define la conexión con el "broker" de mensajería. Se configura en el tag transportConnectors (dentrodel tag broker) de activemq.xml de la siguiente forma:
Se pueden definir varios tipos de conexiones dependiendo del protocolo de transporte (ver lista completa en http://activemq.apache.org/configuring-transports.html).... ...
A continuación se muestran dos ejemplos por VM y TCP:
- VM Transport permite la conexión con un cliente Java que corra bajo la misma JVM. Se define de la siguiente forma: vm://nombre_del_broker?transportOptions, donde:
- nombre_del_broker: es el atributo brokerName del tag broker del activemq.xml
- transportOptions: distintas opciones de la comunicación. Se puede ver la lista de opciones en http://activemq.apache.org/vm-transport-reference.html
... ...
- TCP Transport permite la conexión entre el cliente y el gestor de mensajería mediante protocolo TCP. Se define de la siguiente forma: tcp://nombre_o_ip_de_la_maquina:puerto?options, donde:
- nombre_o_ip_de_la_maquina: máquina o IP donde reside ActiveMQ
- puerto: puerto de la máquina donde escucha ActiveMQ (por defecto suele ser el 61616)
- options: opciones de la conexión. Se puede ver la lista entera de opciones en http://activemq.apache.org/tcp-transport-reference.html
... ...
http://www.adictosaltrabajo.com/tutoriales/tutoriales.php?pagina=ActiveMQ
Persistencia de mensajes
Define la manera de persistir los mensajes en caso de que sea necesario (ver especificación JMS). En este artículo hablaremos de dos tipos: con KahaDB y con JDBC.Persistencia con KahaDB:
KahaDB es un sistema de almacenamiento propio de ActiveMQ diseñado específicamente para las necesidades de un intermediario de mensajes. Proporciona un rendimiento muy alto. Más que cualquier base de datos relacional. Es un sistema de almacenamiento en ficheros combinado con una caché en memoria.
A continuación un ejemplo de configuración de broker con persistencia en KahaDB, donde:
- directory: directorio donde se almacenará la información.
- maxDataFileLength: máximo número de bytes que tendrán los ficheros que compondrán KahaDB.
... ...
Persistencia con JDBC:
ActiveMQ tiene soporte para poder almacenar mensajes en la mayoría de bases de datos.
... ...
Importante: es necesario añadir el driver JDBC de conexión de cualquier base de datos al classpath de ActiveMQ, para ello basta con copiarlo en el directorio [directorio_instalacion_activemq]/lib/
Más información sobre persistencia de mensajes en http://activemq.apache.org/persistence.html.
Control de flujo
Existe un problema muy típico en ActiveMQ cuando se usan mensajes no persistentes (almacenados en memoria) y es que el buffer de almacenamiento termine con toda la RAM. Para solucionar esto existe un sistema de control de flujo, mediante el cual, es posible limitar el número de mensajes en memoria de uno o varios productores de mensajes no persistentes.
A continuación un ejemplo de configuración:
... ...
El valor del atributo queue igual a >, significa que este control de flujo se aplicará a cualquier cola de mensajes. Podríamos aplicar distintas políticas de control de flujo según el nombre de la cola. Ejemplo:
- queue="TEST.FOO" : para todos los mensajes de la cola TEST.FOO
- queue="TEST.>" : para todos los mensajes de las colas que comiencen por TEST.
Más info sobre control de flujo en http://activemq.apache.org/producer-flow-control.html
Uso del sistema
Es posible realizar una configuración más genérica de determinadas partes del sistema como puede ser el uso de memoria o el límite de almacenamiento físico o temporal.
Aquí vemos ejemplo:
....... ...
Nótese que el límite de almacenamiento no influye en bases de datos externas aunque sí en KahaDB.
No hay comentarios:
Publicar un comentario