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

← Version précédente	Version du 29 août 2013 à 11:58
(Aucune différence)

Syfre : /* Utilisation de plusieurs consommateurs */

2013-04-11T11:52:53Z

Utilisation de plusieurs consommateurs

← 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]]

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

2013-04-11T11:37:52Z

Configuration de la tâche d'automate

← Version précédente		Version du 11 avril 2013 à 11:37
Ligne 44 :		Ligne 44 :

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

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

	'''Tâche d'automate de copie :'''		'''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}}		{{#images:image3.png\|msgqueue/example2}}

Syfre le 11 avril 2013 à 11:37

2013-04-11T11:37:23Z

← Version précédente		Version du 11 avril 2013 à 11:37
Ligne 3 :		Ligne 3 :
	* Une file d'attente source gérée par un serveur activeMQ		* Une file d'attente source gérée par un serveur activeMQ
	* Une file d'attente destination stockée en base de données.		* Une file d'attente destination stockée en base de données.
			* Un automate pour exécuter une tâche de copie

	===Configuration des files d'attentes===		===Configuration des files d'attentes===

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]]

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 : 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 : 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... »