Exemple File d'attente avec un automate - Historique des versions

Flfay : /* Code snippet du producteur */

2014-06-05T13:44:41Z

Code snippet du producteur

Syfre : a déplacé Exemple file d'attente avec un automate vers Exemple File d'attente avec un automate

2013-08-29T11:59:43Z

a déplacé Exemple file d'attente avec un automate vers Exemple File d'attente avec un automate

Syfre : /* Configuration de la file d'attente */

2013-04-29T08:31:08Z

Configuration de la file d'attente

Syfre le 11 avril 2013 à 14:41

2013-04-11T14:41:04Z

Syfre le 11 avril 2013 à 08:36

2013-04-11T08:36:52Z

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

2013-04-11T08:14:19Z

Configuration de la tâche d'automate

Syfre : /* Utilisation de plusieurs consommateurs */

2013-04-11T08:10:36Z

Utilisation de plusieurs consommateurs

Syfre : /* Exécution */

2013-04-11T08:08:41Z

Exécution

Syfre : /* Configuration de la file d'attente */

2013-04-11T08:05:59Z

Configuration de la file d'attente

Syfre : Page créée avec « TOC Dans cet exemple nous allons mettre en oeuvre le design pattern file d'attente en utilisant : * Une file d'attente stockée dans la base de données * Un automate ... »

2013-04-11T08:03:08Z

Page créée avec « __TOC__ Dans cet exemple nous allons mettre en oeuvre le design pattern file d'attente en utilisant : * Une file d'attente stockée dans la base de données * Un automate ... »

Nouvelle page

__TOC__
Dans cet exemple nous allons mettre en oeuvre le design pattern file d'attente en utilisant :
* Une file d'attente stockée dans la base de données
* Un automate pour consommer les messages de cette file d'attente (consommateur)
* Un code script pour générer les messages (producteur)
* Un processus de traitement pour traiter les messages

===Configuration de la file d'attente===
La file d'attente est configurée par un objet TdbmMessageQueue du référentiel:

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

* 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 un message dans la file est le suivant :

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

Il peut être directement exécuté à partir du concepteur de modèle.

Notez que :
* Ce code ne connait pas la configuration de la file, il peut fonctionner avec n'importe quel type de file.
* Il ne fait pas référence à TdbmStoredQueueMessage (ce qui serait propre à la configuration de la file) mais à TdbmQueueMessage qui est un type non persistant générique représentant un message.
* Il écrit le message en base par un Post sur le message, c'est une action générique indépendante du type de la file.
* Le message contient deux paramètres et un contenu binaire
* Il ni a pas besoin de déclarer une transaction.

===Code snippet du processus de traitement===
La classe traitant les messages est la suivante :

<source lang="delphi">
unit TestSYFREWF;
interface

Type
MyProcessus = Class(TitObject)
public
uneChaine: string;
unEntier: integer;
Procedure Execute;
end;

Implementation

{MyProcessus}

Procedure MyProcessus.Execute;
//Procedure Execute;
var aMsg:TdbmQueueMessage; idx:Integer;
begin
if Assigned(UserContext.TaskContext) then
begin
UserContext.TaskContext.AddMessage('MyProcessus.Execute');
if Assigned(UserContext.TaskContext.EventContext.receivedMsg) then
begin
aMsg := UserContext.TaskContext.EventContext.receivedMsg;
UserContext.TaskContext.AddMessage('Has a message');
for idx:=0 to aMsg.Count-1 do
begin
UserContext.TaskContext.AddMessage(aMsg.DisplayStrings[idx]);
end;
// simulate job
sleep(5000);
end
else UserContext.TaskContext.AddMessage('No message');
end
else showMessage('not in a task');
end;;
end.
</source>

Ce processus réalise :
* Vérifie qu'il s'exécute bien dans le contexte du tâche
* Trace dans les messages du contexte son exécution
* Récupère le message consommé (aMsg)
* Trace tous les paramètres du message dans messages du contexte
* Simule l'exécution d'un traitement.

Le processus sera exécuté par la tâche d'automate consommant les messages.

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

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

* L'évènement référence la file d'attente par son nom de paramétrage (DBQUEUE)
* L'intervalle de test est zéro (?)

'''Tâche :'''

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

Cet automate est configuré ainsi :
* L'évènement est de type File d'attente
* La tâche est de type traitement
* Les paramètres de la tâche référence le processus MyProcessus
* L'état suivant est -1

===Exécution===
'''Exécution du code producteur :'''

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

* On constate que ce code a créé un objet dans la classe TdbmStoredQueueMessage.
* Les paramètres du message sont stockés dans l'attribut Data
* Le contenu binaire est stocké dans l'attribut BinaryContent

'''Démarrage de l'automate :'''

On utilise une console SNMTP pour superviser l'exécution :

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

On constate que
* l'évènement DBQUEUE est déclenché.
* L'exécution de la tâche de traitement est réalisé.

La tâche de traitement génère une entrée dans le journal :

<pre>
Tâche : Tâche de traitement Traiter un msg de DBQUEUE
Société : Test SYFRE Workflow
Utilisateur: syfre
Base(s) : TestWorkFlowdup_7
Mode Soc. : Enchainer sur ces sociétés
Société(s) :
Début : 11/04/2013 09:39:19
Fin : 11/04/2013 09:39:24
Durée : 5 s
Fichiers : 0
Statut : 0 OK

MyProcessus.Execute
Has a message
MessageClassName="TStaticRegClass"
MessageDatetime="11/04/2013"
MessageUser="syfre"
MessageOID="000000000000000000E30001A0FF0008"
MessageID="166"
Topic="WSMQCOPY"
State="1"
OriginalUniqueID=""
idOTP="227"
ObjectClassLabel="Classe message stocké d'une file d'attente"
ObjectClassName="TDBMSTOREDQUEUEMESSAGE"
oid="000000000000000000E30001A0FF0008"
oiddbmQueue=""
oidShare=""
QueueName="WSMQCOPY"
queueTopic="WSMQCOPY"
ShareInfo=""
ShareInstanceInfo=""
ShareInstanceLevel="2"
ShareInstanceRequestedLevel="-1"
ShareLevel="0"
UniqueID="166"
UpdDate="11/04/2013"
UpdStamp="00017D6100000022"
UpdUser="syfre"
uneChaine="some text"
unEntier="1999"
</pre>

====Production de plusieurs messages====
On peut modifier le code du producteur pour générer plusieurs messages :

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

On constate les déclenchements de l'automate :

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

Chaque déclenchement est espacé d'environ 5 secondes qui correspondes au temps de traitement du processus.

====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}}

Une fois démarré chaque service exécute le même automate :

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

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

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

On constate que les messages ont été consommés par les deux services.

[[Category:File d'attente]]

@@ Ligne 15 : / Ligne 15 : @@
 * 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.
-{{tip|Cet exemple fonctionnerait identiquement avec une file d'attente WebSphereMQ ou ActiveMQ en changeant uniquement cet objet de configuration}}
+{{tip|Le topic associé à la queue permet de filtrer les objets de classe. Seul les objets ayant ce topic seront pris en compte, la classe peut donc être partagée par plusieurs files.}}
 ===Code snippet du producteur ===

← Version précédente		Version du 11 avril 2013 à 08:10
Ligne 248 :		Ligne 248 :

	{{#images:image7.png\|msgqueue/example1}}		{{#images:image7.png\|msgqueue/example1}}
		+
		+	{{tip\|Notez le nodeID propre à chaque instance du service}}

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

@@ Ligne 45 : / Ligne 45 : @@
 * Il écrit le message en base par un Post sur le message, c'est une action générique indépendante du type de la file.
 * Le message contient deux paramètres et un contenu binaire
-* Il ni a pas besoin de déclarer une transaction.
+* Il n y a pas besoin de déclarer une transaction.
 ===Code snippet du processus de traitement===

@@ Ligne 7 : / Ligne 7 : @@
 ===Configuration de la file d'attente===
-La file d'attente est configurée par un objet TdbmMessageQueue du référentiel:
+La file d'attente est configurée par un objet [[TdbmQueue]] du référentiel:
 {{#images:image1.png|msgqueue/example1}}

@@ Ligne 2 : / Ligne 2 : @@
 Dans cet exemple nous allons mettre en oeuvre le design pattern file d'attente en utilisant :
 * Une file d'attente stockée dans la base de données
 * Un code script pour générer les messages (producteur)
 * Un processus de traitement pour traiter les messages

@@ Ligne 104 : / Ligne 104 : @@
 * L'évènement référence la file d'attente par son nom de paramétrage (DBQUEUE)
-* L'intervalle de test est zéro (?)
+* L'intervalle de test est zéro ce qui indique qu'il ni a pas de délai entre les différents tests de cet évènement.
 '''Tâche :'''

@@ Ligne 180 : / Ligne 180 : @@
 unEntier="1999"
 </pre>
 ====Production de plusieurs messages====

Exemple File d'attente avec un automate - Historique des versions

Flfay : /* Code snippet du producteur */

Syfre : a déplacé Exemple file d'attente avec un automate vers Exemple File d'attente avec un automate

Syfre : /* Configuration de la file d'attente */

Syfre le 11 avril 2013 à 14:41

Syfre le 11 avril 2013 à 08:36

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

Syfre : /* Utilisation de plusieurs consommateurs */

Syfre : /* Exécution */

Syfre : /* Configuration de la file d'attente */

Syfre : Page créée avec « __TOC__ Dans cet exemple nous allons mettre en oeuvre le design pattern file d'attente en utilisant : * Une file d'attente stockée dans la base de données * Un automate ... »

Syfre : Page créée avec « TOC Dans cet exemple nous allons mettre en oeuvre le design pattern file d'attente en utilisant : * Une file d'attente stockée dans la base de données * Un automate ... »