SLiX : A protégé « ActiveMQ » ([edit=autoconfirmed] (infini) [move=autoconfirmed] (infini))

2012-05-15T12:14:40Z

A protégé « ActiveMQ » ([edit=autoconfirmed] (infini) [move=autoconfirmed] (infini))

← Version précédente

Version du 15 mai 2012 à 12:14

SLiX : /* Active MQ */

2012-03-27T12:38:41Z

Active MQ

← Version précédente		Version du 27 mars 2012 à 12:38
Ligne 97 :		Ligne 97 :
	'''Note''': Les tables seront créées automatiquement au lancement d'un serveur ActiveMQ		'''Note''': Les tables seront créées automatiquement au lancement d'un serveur ActiveMQ

-	==== ~~Active MQ~~ ====	+	==== ActiveMQ ====

-	Sur chaque futur serveur du cluster, suivre la procédure d'installation ''de base''.	+	Sur chaque futur serveur du cluster, suivre la procédure d'installation ''de base''; voir [[ActiveMQ#Installation]]
-	* voir [[ActiveMQ#Installation]]	+

	==== Connecteur JDBC ====		==== Connecteur JDBC ====

SLiX : Page créée avec « {| align="right" | TOC |} [http://activemq.apache.org/ Apache ActiveMQ] est ''courtier de messages'' distribué sous licence libre. == Installation == Procédure d'ins... »

2012-03-27T12:37:08Z

Page créée avec « {| align="right" | __TOC__ |} [http://activemq.apache.org/ Apache ActiveMQ] est ''courtier de messages'' distribué sous licence libre. == Installation == Procédure d'ins... »

Nouvelle page

{| align="right"
| __TOC__
|}
[http://activemq.apache.org/ Apache ActiveMQ] est ''courtier de messages'' distribué sous licence libre.

== Installation ==

Procédure d'installation basique permettant d'avoir un serveur autonome, ou pouvant servir de base pour un mode cluster.

=== Installation sur RHEL 6 ===

* Installer Java:
# yum install java-1.6.0-sun

* Créer un utilisateur ''activemq'':
# groupadd -g 92 activemq && useradd -u 92 -g 92 -m activemq

* Désarchiver:
# cd /opt
# tar zxvf ~/apache-activemq-5.5.1-bin.tar.gz

* Attribuer les droits:
# chown -R activemq.activemq /opt/apache-activemq-5.5.1/

* Créer un lien symbolique:
# ln -s apache-activemq-5.5.1 activemq

* Faire un lien du script de démarrage/arrêt en tant que script d'init:
# ln -s /opt/activemq/bin/activemq /etc/init.d/activemq

* Editer le script et ajouter au début les lignes ''chkconfig'' et ''description'' suivantes pour le rendre compatible avec ''chkconfig'':
# '''vi /etc/init.d/activemq'''
#!/bin/sh
# chkconfig: 2345 92 8
# description: Apache ActiveMQ server
(...)

* Activer le service:
# chkconfig --add activemq

* Vérifier:
# '''ls -l /etc/rc*.d/*activemq'''
lrwxrwxrwx 1 root root 18 15 mars 14:10 /etc/rc0.d/K08activemq -> ../init.d/activemq
lrwxrwxrwx 1 root root 18 15 mars 14:10 /etc/rc1.d/K08activemq -> ../init.d/activemq
lrwxrwxrwx 1 root root 18 15 mars 14:10 /etc/rc2.d/S92activemq -> ../init.d/activemq
lrwxrwxrwx 1 root root 18 15 mars 14:10 /etc/rc3.d/S92activemq -> ../init.d/activemq
lrwxrwxrwx 1 root root 18 15 mars 14:10 /etc/rc4.d/S92activemq -> ../init.d/activemq
lrwxrwxrwx 1 root root 18 15 mars 14:10 /etc/rc5.d/S92activemq -> ../init.d/activemq
lrwxrwxrwx 1 root root 18 15 mars 14:10 /etc/rc6.d/K08activemq -> ../init.d/activemq

* Créer un fichier de configuration et spécifier l'utilisateur avec lequel doit être lancé le service:
# '''vi /etc/default/activemq'''
ACTIVEMQ_USER="activemq"

* Démarrer le service:
# '''service activemq start'''
INFO: Loading '/etc/default/activemq'
INFO: Using java '/usr/bin/java'
INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
INFO: changing to user 'activemq' to invoke java
INFO: pidfile created : '/opt/activemq/data/activemq.pid' (pid '16665')

== Cluster Master/Slave JDBC sur RHEL 6==

=== Principe ===

Dans ce mode de clustering, un seul serveur est actif à un moment donné, et un ou plusieurs serveurs sont en attente de prendre son rôle.

Pour garantir cela, chaque serveur qui démarre se connecte à la base de données via JDBC et tente d'obtenir un verrou, avec une requête du genre:

<syntaxhighlight lang="mysql">
SELECT * FROM ACTIVEMQ_LOCK FOR UPDATE
</syntaxhighlight>

Celui qui obtient le verrou (normalement le 1er arrivé) continue son démarrage et fourni le service. Les autres se retrouvent à attendre le verrou.

Si le serveur actif subit un incident (perte de connexion JDBC, plantage, ...), un des autres serveurs obtient immédiatement le verrou et devient le serveur actif.

Avec cette configuration les clients doivent se connecter en utilisant la couche ''failover'', exemple:

failover:(tcp://srv01:61616,tcp://srv02:61616)

=== Procédure ===

==== Base de données ====

Se connecter au serveur MySQL et:

* Créer un schéma:
mysql> '''create database activemq;'''
Query OK, 1 row affected (0.00 sec)

* Créer un utilisateur ayant les permissions nécessaires:
mysql> '''grant all privileges on activemq.* to 'activemq'@'%' identified by '<PASSWORD>';'''
Query OK, 0 rows affected (0.03 sec)

'''Note''': Les tables seront créées automatiquement au lancement d'un serveur ActiveMQ

==== Active MQ ====

Sur chaque futur serveur du cluster, suivre la procédure d'installation ''de base''.
* voir [[ActiveMQ#Installation]]

==== Connecteur JDBC ====

Télécharger le connecteur JDBC MySQL:
* http://www.mysql.com/downloads/connector/j/

Puis sur chaque serveur ActiveMQ du cluster:

* Installer le connecteur JDBC/MySQL dans le répertoire lib/ d'ActiveMQ, exemple:
# '''cp mysql-connector-java-5.1.13-bin.jar /opt/activemq/lib/'''

==== Configuration ====
Sur chaque serveur ActiveMQ du cluster:

* Arrêter le service ActiveMQ:
# '''service activemq stop'''
INFO: Loading '/etc/default/activemq'
INFO: Using java '/usr/bin/java'
INFO: changing to user 'activemq' to invoke java
INFO: Waiting at least 30 seconds for regular process termination of pid '8867' :
Java Runtime: Sun Microsystems Inc. 1.6.0_31 /usr/lib/jvm/java-1.6.0-sun-1.6.0.31.x86_64/jre
Heap sizes: current=251264k free=249951k max=251264k
JVM args: -Xms256M -Xmx256M -Dorg.apache.activemq.UseDedicatedTaskRunner=true -Djava.util.logging.config.file=logging.properties -Dactivemq.classpath=/opt/activemq/conf; -Dactivemq.home=/opt/activemq -Dactivemq.base=/opt/activemq
ACTIVEMQ_HOME: /opt/activemq
ACTIVEMQ_BASE: /opt/activemq
Connecting to pid: 8867
Stopping broker: srv01
. FINISHED

* Editer le fichier de configuration et effectuer les actions suivantes ('''Attention''': L'ordre des sections est important !):
# '''vim conf/activemq.xml'''

* Changer le nom du broker par un identifiant unique (par exemple le nom d'hôte):
<syntaxhighlight lang="xml">
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.base}/data" destroyApplicationContextOnStop="true">
</syntaxhighlight>
devient
<syntaxhighlight lang="xml">
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="srv01" dataDirectory="${activemq.base}/data" destroyApplicationContextOnStop="true">
</syntaxhighlight>

* Remplacer le ''persistentAdapter'':
<syntaxhighlight lang="xml">
<persistenceAdapter>
<kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>
</syntaxhighlight>
devient:
<syntaxhighlight lang="xml">
<persistenceAdapter>
<jdbcPersistenceAdapter dataSource="activemq-ds"/>
</persistenceAdapter>
</syntaxhighlight>

* Ajouter la source de données JDBC MySQL correspondant au schéma créé (en dehors de la section ''broker'', après '''</broker>'''):

<syntaxhighlight lang="xml">
<bean id="activemq-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://<DB_SERVER>/activemq?relaxAutoCommit=true"/>
<property name="username" value="activemq"/>
<property name="password" value="<PASSWORD>"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
</syntaxhighlight>

* Démarrer le service ActiveMQ:
# '''service activemq start'''
INFO: Loading '/etc/default/activemq'
INFO: Using java '/usr/bin/java'
INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
INFO: changing to user 'activemq' to invoke java
INFO: pidfile created : '/opt/activemq/data/activemq.pid' (pid '12870')

=== Références ===

* http://activemq.apache.org/jdbc-master-slave.html
* http://activemq.apache.org/failover-transport-reference.html
* http://blog.octo.com/creer-un-cluster-activemq-hautement-disponible/

[[Catégorie:Applications]]

ActiveMQ - Historique des versions

SLiX : A protégé « ActiveMQ » ([edit=autoconfirmed] (infini) [move=autoconfirmed] (infini))

SLiX : /* Active MQ */

SLiX : Page créée avec « {| align="right" | __TOC__ |} [http://activemq.apache.org/ Apache ActiveMQ] est ''courtier de messages'' distribué sous licence libre. == Installation == Procédure d'ins... »

SLiX : Page créée avec « {| align="right" | TOC |} [http://activemq.apache.org/ Apache ActiveMQ] est ''courtier de messages'' distribué sous licence libre. == Installation == Procédure d'ins... »