Syfre : a déplacé Exemple copie entre files d'attente vers Exemple Copie entre files d'attente

2013-08-29T11:58:04Z

a déplacé Exemple copie entre files d'attente vers Exemple Copie entre files d'attente

Syfre : /* Utilisation de plusieurs consommateurs */

2013-04-11T11:52:53Z

Utilisation de plusieurs consommateurs

Syfre : /* Configuration de la tâche d'automate */

2013-04-11T11:37:52Z

Configuration de la tâche d'automate

Syfre le 11 avril 2013 à 11:37

2013-04-11T11:37:23Z

Syfre : Page créée avec « TOC Dans cet exemple nous allons montrer comment copier les messages d'une file d'attente à une autre en utilisant : * Une file d'attente source gérée par un serveu... »

2013-04-11T11:36:41Z

Page créée avec « __TOC__ Dans cet exemple nous allons montrer comment copier les messages d'une file d'attente à une autre en utilisant : * Une file d'attente source gérée par un serveu... »

Nouvelle page

__TOC__
Dans cet exemple nous allons montrer comment copier les messages d'une file d'attente à une autre en utilisant :
* Une file d'attente source gérée par un serveur activeMQ
* Une file d'attente destination stockée en base de données.

===Configuration des files d'attentes===
La file d'attente source est configurée ainsi :

{{#images:image1.png|msgqueue/example2}}

* Le nom de paramétrage de la file est AMQ
* Le type de la file est ActiveMQ ce qui indique une file d'attente gérée par uns serveur ActiveMQ
* La chaine de connexion référence le serveur ActiveMQ s'exécutant sur le serveur merlin et indique le nom de file sur ce serveur.

La file destination est configurée ainsi :

{{#images:image2.png|msgqueue/example2}}

* Le nom de paramétrage de la file est DBQUEUE
* Le type de la file est DatabaseMQ ce qui indique qu'il s'agit d'une file gérée en base de données
* L'attribut QueueConnextionInfos indique le nom de la classe dans laquelle seront stockés les messages, il s'agit de la classe générique permettant de stocker n'importe quel message.

===Code snippet du producteur===
Le code générant le message dans la file activeMQ est le suivant :

<source lang="delphi">
var msg:TdbmQueueMessage; idx:Integer;
begin
for idx:=1 to 1 do
begin
msg := TdbmQueueMessage.Create;
msg.QueueName := 'AMQ';
msg.AddParameter('uneChaine','some text');
msg.AddParameter('unEntier',1999);
msg.BinaryContent.LoadFromFile('c:\image.jpg');
msg.Post;
end;
end;
</source>

===Configuration de la tâche d'automate===
'''Evènement file d'attente :'''

{{#images:image4.png|msgqueue/example2}}

'''Tâche d'automate de copie :'''

* L'évènement référence la file d'attente par son nom de paramétrage (AMQ)

{{#images:image3.png|msgqueue/example2}}

* L'évènement déclencheur est un évènement file d'attente.
* La tâche exécutée est une tâche de copie.
* La configuration de la tâche de copie indique la file source et la file destination.

{{tip|Du fait que l'évènement est du type file d'attente la configuration de la file source n'est pas utilisée}}

===Exécution===
L'exécution du code du producteur crée un message dans la file d'attente ActiveMQ :

{{#images:image5.png|msgqueue/example2}}

Démarrage de l'automate :

{{#images:image6.png|msgqueue/example2}}

On constate que l'automate est déclenchée et exécute la tâche de copie

Le message a été copié dans la file destination :

{{#images:image7.png|msgqueue/example2}}

====Traitement du message copié====
Pour traiter le message copié nous utilisant un second automate :

{{#images:image8.png|msgqueue/example2}}

Cet automate est déclenchée par évènement file d'attente configuré sur la file destination.

Les deux automates sont exécutés simultanément.

Exécutons :

{{#images:image9.png|msgqueue/example2}}

On constate que :
* Le premier automate copie le message de la file source vers la file destination.
* Le second automate consomme le message de la file destination.

Le compte rendu de la tâche d'exécution :

<pre>
Tâche : Tâche de traitement testprocessusautomate
Société : Test SYFRE Workflow
Utilisateur: syfre
Base(s) : TestWorkFlowdup_7
Mode Soc. : Enchaîner sur ces sociétés
Société(s) :
Début : 11/04/2013 13:26:14
Fin : 11/04/2013 13:26:19
Durée : 5 s
Fichiers : 0
Statut : 0 OK

MyProcessus.Execute
Has a message
MessageClassName="TStaticRegClass"
MessageDatetime="11/04/2013"
MessageUser="syfre"
MessageOID="000000000000000000E30001A1180021"
MessageID="179"
Topic="WSMQCOPY"
State="1"
OriginalUniqueID="ID:MERLIN-49884-1359131319255-2:115:-1:1:3"
idOTP="227"
ObjectClassLabel="Classe message stocké d'une file d'attente"
ObjectClassName="TDBMSTOREDQUEUEMESSAGE"
oid="000000000000000000E30001A1180021"
oiddbmQueue=""
oidShare=""
QueueName="WSMQCOPY"
queueTopic="WSMQCOPY"
ShareInfo=""
ShareInstanceInfo=""
ShareInstanceLevel="2"
ShareInstanceRequestedLevel="-1"
ShareLevel="0"
UniqueID="179"
UpdDate="11/04/2013"
UpdStamp="00017D7A0000002D"
UpdUser="syfre"
id="ID:MERLIN-49884-1359131319255-2:115:-1:1:3"
msgDestination="/queue/queue/QUEUE1"
msgReceiptId=""
msgCorrelationId=""
msgReplyTo=""
msgType=""
msgGroupId=""
msgGroupSeq="0"
msgPriority="4"
uneChaine="some text"
unEntier="1999"
OriginalQueueName="AMQ"
</pre>

La tâche d'exécution effectue un dump des paramètres de la tâche, on retrouve les valeurs des paramètres du message d'origine.

====Utilisation de plusieurs consommateurs====

Il est possible de démarrer plusieurs services sur le même automate pour mettre en oeuvre plusieurs consommateurs :

<pre>
[\SOFTWARE\Sage\Ligne 1000\Administration\IPC\SYFRE1]
ipcMode=ipcTCP
tcpPort=8091
section=SYFRE

[\SOFTWARE\Sage\Ligne 1000\Administration\IPC\SYFRE2]
ipcMode=ipcTCP
tcpPort=8092
section=SYFRE

[\SOFTWARE\Sage\Ligne 1000\Administration\Servers\SYFRE]
Master Profil=dbMasterTahoe
Server Societies=Test SYFRE Workflow
Server Application=Test-SYFRE-WorkFlow
Server User=syfre
Server Password=
Public Folder=C:\Mes documents\Server\
IPC Started=0
BP Started=0
Automate Name=SYFRE
Automate Started=1
DEBUGGER Started=0
DEBUGGER Users=syfre,toto,titi
SESSIONS profil=CONFIG_SESSION_1
SOAP Profil=CONFIG_SOAP_1
SNMP Profil=CONFIG_SNMP_1
SMTP Profil=CONFIG_SMTP_1
PROCESS Profil=CONFIG_PROCESS_1
--HTTP Profil=CONFIG_HTTP_INTERNAL
</pre>

{{tip|Les services ne démarre pas de serveur HTTP}}

Lorsque l'on crée plusieurs messages dans la file d'attente :

{{#images:image10.png|msgqueue/example2}}

On constate que les deux services ont consommés les deux files.

[[Category:File d'attente]]

← Version précédente		Version du 11 avril 2013 à 11:52
Ligne 190 :		Ligne 190 :

	On constate que les deux services ont consommés les deux files.		On constate que les deux services ont consommés les deux files.
		+
		+	'''Au vue de cette log on peut se demander pourquoi les copies et les traitements ne sont pas entrelacés ?'''
		+
		+	La raison est liée à la façon dont sont exécutées les tâches :
		+
		+	Dans cet exemple :
		+	* Chaque automate n'exécute qu'une tâche à la fois
		+	* Les messages sont générés en rafale par un producteur très rapide.
		+
		+	L'exécution est réalisée ainsi :
		+	* L'évènement file d'attente se déclenche
		+	* Tant qu'il existe des messages dans la file la tâche est exécutée
		+	* Le délai de boucle du serveur d'automate est appliqué
		+
		+	Du fait qu'il existe une boucle interne "Tant qu'il existe des messages" les automates consomment la totalité des messages avant de tester l'évènement suivant.
		+
		+	Si on ralentit le producteur, par exemple avec un slip(2000) dans la boucle on constate que les exécutions vont s'entrelacer :
		+
		+	{{#images:image11.png\|msgqueue/example2}}

	[[Category:File d'attente]]		[[Category:File d'attente]]

@@ Ligne 45 : / Ligne 45 : @@
 {{#images:image4.png|msgqueue/example2}}
-'''Tâche d'automate de copie :'''
+L'évènement référence la file d'attente par son nom de paramétrage (AMQ)
-* L'évènement référence la file d'attente par son nom de paramétrage (AMQ)
+'''Tâche d'automate de copie :'''
 {{#images:image3.png|msgqueue/example2}}

@@ Ligne 3 : / Ligne 3 : @@
 * Une file d'attente source gérée par un serveur activeMQ
 * Une file d'attente destination stockée en base de données.
 ===Configuration des files d'attentes===

Exemple Copie entre files d'attente - Historique des versions

Syfre : a déplacé Exemple copie entre files d'attente vers Exemple Copie entre files d'attente

Syfre : /* Utilisation de plusieurs consommateurs */

Syfre : /* Configuration de la tâche d'automate */

Syfre le 11 avril 2013 à 11:37

Syfre : Page créée avec « __TOC__ Dans cet exemple nous allons montrer comment copier les messages d'une file d'attente à une autre en utilisant : * Une file d'attente source gérée par un serveu... »

Syfre : Page créée avec « TOC Dans cet exemple nous allons montrer comment copier les messages d'une file d'attente à une autre en utilisant : * Une file d'attente source gérée par un serveu... »