Cilia, un framework de médiation ouvert, léger, multi-personnalités PARTIE 4 : Cas d'usage SI

Groupe France Télécom Projet Cilia : collaboration LIG Adèle – Orange Labs/MAPS/MEP ― slide 1

Cilia,un framework de médiation

ouvert, léger, multi-personnalités

PARTIE 4 : Cas d'usage SI

Auteurs : LIG/Adèle – Orange Labs/MAPS/MEP

Workshop Cilia : 21 juin 2010


Plan Partie 1 : Médiation

Historique Technologies de médiation Cilia : génération OSGi et multi-personnalités

Partie 2 : Framework Cilia Modèle d'implantation Modèle de conception Médiation de données et médiation de service

Partie 3 : Processus logiciel Spécification d’architecture Spécification d’instances Déploiement

Partie 4 : Cas d'usage Interopérabilité dans un Système d’Information Remontée de données dans un Système Embarqué


Cas d'usage

Système d'InformationUC1 : Décomposition de messages et aggrégation de messages

Description et analyse

Spécification de l’architecture

Spécification des instances


UC1 : descriptionUne application de suivi de consommation envoie des messages à

destination de back-ends en charge de la facturation des communications fixe, mobile et internet


Requêtes et réponses Front-EndRequête FE :<SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/">

<SOAP-ENV:Header/><SOAP-ENV:Body>

<suiviconso-requete xmlns:SOAP-ENV="http://www.example.org/SuiviConso/"> <idclient>CLIENT-ID 00114</idclient>

<debut>15052010</debut><fin>15062010</fin><produit>fixe,mobile,internet</produit>

</suiviconso-requete></SOAP-ENV:Body></SOAP-ENV:Envelope>

Réponse FE :<SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/">

<SOAP-ENV:Header/><SOAP-ENV:Body> <suiviconso-reponse xmlns:SOAP-ENV="http://www.example.org/SuiviConso/">

<fixe>48</fixe><mobile>18</mobile><internet>17</internet><total>73</total>

</suiviconso-reponse></SOAP-ENV:Body></SOAP-ENV:Envelope>


Transformer : créer un message compositeRequête initiale du client (body) :<suiviconso-requete xmlns:SOAP-ENV="http://www.example.org/SuiviConso/"> <idclient>CLIENT-ID 00114</idclient>

<debut>15052010</debut><fin>15062010</fin><produit>fixe,mobile,internet</produit>

</suiviconso-requete>

Requête après transformation (body) :<suiviconso-requete produit="fixe" xmlns:SOAP-ENV="http://www.example.org/SuiviConso/">

<idclient>CLIENT-ID 00114</idclient><debut>15052010</debut><fin>15062010</fin>

</ suiviconso-requete><suiviconso-requete produit="mobile" xmlns:SOAP-ENV="http://www.example.org/SuiviConso/">


</ suiviconso-requete><suiviconso-requete produit="internet" xmlns:SOAP-ENV="http://www.example.org/SuiviConso/">




UC1 : analyse

2) Découper le contenu et créer n requêtes3) Router les messages par le contenu

6) Appeler un service (pour chaque BE)

4) Traduire le contenu d'une requête (pour chaque BE)

1) Créer une requête composite

7) Regrouper les réponses associées à une requête et créer une liste de n réponses8) Créer une réponse et y insérer une valeur calculée

1. Transform

2. Split

InternetMobileFixe

3. Translate

6. Aggregate

5) Transformer une requête (pour chaque BE)

5. InvokeS

4. Transform


Splitter : créer n requêtes

<suiviconso-requete produit="fixe" xmlns:SOAP-ENV="http://www.example.org/SuiviConso/">


</ suiviconso-requete>

<suiviconso-requete produit="mobile" xmlns:SOAP-ENV="http://www.example.org/SuiviConso/">


</ suiviconso-requete>

<suiviconso-requete produit="internet" xmlns:SOAP-ENV="http://www.example.org/SuiviConso/">



Pour chaque sous-message, ajouter dans header :

- correlation_id,

- nb total de messages,

- n°seq


Translator : traduire le contenuAvant traduction (exemple de FacturationInternet) :

<suiviconso-requete produit="internet" xmlns:SOAP-ENV="http://www.example.org/SuiviConso/">

<idclient>CLIENT-ID 00114</idclient>

<debut>15052010</debut><fin>15062010</fin></suiviconso-requete>

Après traduction :

<suiviconso-requete produit="internet" xmlns:SOAP-ENV="http://www.example.org/SuiviConsoInternet/">

<idclient>CLIENT-IDENT 00114</idclient>

<debut>15052010</debut><fin>15062010</fin></suiviconso-requete>

Information de contexte :

- correlation_id,


- n°seq


Transformer : supprimer un attributAvant transformation (exemple de FacturationInternet) :

<suiviconso-requete produit="internet" xmlns:SOAP-ENV="http://www.example.org/SuiviConsoInternet/">



Après transformation :

<suiviconso-requete xmlns:SOAP-ENV="http://www.example.org/SuiviConsoInternet/">

<idclient>CLIENT-IDENT 00114</idclient><debut>15052010</debut><fin>15062010</fin>


Information de contexte :

- correlation_id,


- n°seq


Appeler un WS Réponse de FacturationFixe :

<SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"><SOAP-ENV:Header/><SOAP-ENV:Body>

<suiviconso-reponseFixe xmlns:SOAP-ENV="http://www.example.org/suiviconsoFixe/"> <conso>48</conso>

</suiviconso-reponseFixe> </SOAP-ENV:Body>

</SOAP-ENV:Envelope>

Réponse de FacturationMobile :…

<suiviconso-reponseMobile xmlns:SOAP-ENV="http://www.example.org/suiviconsoMobile/"> <conso>18</conso>

</suiviconso-reponseMobile>

Réponse de FacturationInternet :…

<suiviconso-reponseInternet xmlns:SOAP-ENV="http://www.example.org/suiviconsoInternet/"> <conso>17</conso>

</suiviconso-reponseInternet>


Aggregator : créer une réponse

<SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/">

<SOAP-ENV:Header/><SOAP-ENV:Body> <suiviconso-reponse xmlns:SOAP-ENV="http://www.example.org/SuiviConso/">

<fixe>48</fixe>

<mobile>18</mobile>

<internet>17</internet>

<total>73</total>

</suiviconso-reponse></SOAP-ENV:Body></SOAP-ENV:Envelope>


Cas d'usage






Architecture

Catégories de médiateurs identifiésTransform, Split, Translate, InvokeS, Aggregate

Types de médiateur identifiés pour le cas d'usage Types spécifiques :

- FacturationFixe, FacturationMobile, FacturationInternet

- UC1Aggregator

Types de la bibliothèque Cilia :

- XsltTransformer,

- XmlSplitter,

- Translator


Transformer

Scheduler = synchronisationBut : transmettre sans délai le message à la partie "traitement métier"

"immediate-scheduler" de la bibliothèque Cilia

Processor = traitement métierBut : modifier la structure d'un message

POJO "XsltTransformerProcessor"

Dispatcher = routageBut : router un message vers le composant destinataire

"multicast-dispatcher" de la bibliothèque Cilia

Cilia compendium : XsltTransformer


Spécification de Transformer

<mediator-component category="Transform"

name="XsltTransformer">

<processor classname="XsltTransformerProcessor"> <property name="xslt-file" field="filepath" /> </processor> <scheduler name="immediate-scheduler" /> <dispatcher name="multicast-dispatcher" />

</mediator-component>

Cilia compendium : XsltTransformer


Splitter



Processor = traitement métierBut : découper le contenu sur expression et créer des messages

POJO "XmlSplitterProcessor"

Dispatcher = routageBut : insérer un numéro de séquence et le nombre total de destinataires dans le header des messages, router les messages par le contenu vers les destinataires

"content-based-dispatcher-with-correlation" de la bibliothèque Cilia

Cilia compendium : XmlSplitterWithCorrelation


Spécification de Splitter

<mediator-component category="Split"

name="XmlSplitterWithCorrelation">

<processor classname="XmlSplitterProcessor"> <property name="separator" field="expression" /> </processor> <scheduler name="immediate-scheduler" /> <dispatcher name="content-based-dispatcher-with-correlation" />


Cilia compendium : XmlSplitterWithCorrelation


Translator

Scheduler = synchronisationBut : transmettre sans délai le message à la partie "traitement métier""immediate-scheduler" de la bibliothèque Cilia

Processor = traitement métierBut : traduire des éléments du contenu d'un message en utilisant un dictionnaire local au médiateur (paramètre)POJO TranslatorProcessor

Dispatcher = routageBut : router un message vers le composant destinataire"multicast-dispatcher" de la bibliothèque Cilia

Cilia compendium : Translator


Spécification de Translator

<mediator-component category="Translate" name="Translator">

<processor classname="TranslatorProcessor"> <property name="dictionary" field="dictionary" /> </processor> <scheduler name="immediate-scheduler" />

<dispatcher name="multicast-dispatcher" />


Cilia compendium : Translator


FacturationInternet



Processor = traitement métierBut : transmettre la requête au service InternetBilling et récupérer la réponse

POJO développé pour le projet UC1 – utilisation de CXF

public class FacturationInternetProcessor {…}

Dispatcher = routageBut : router un message vers le composant destinataire


UC1 projet : FacturationInternet


Spécification de FacturationInternet

<mediator-component category ="InvokeS"

name = "FacturationInternet">

<processor classname ="FacturationInternetProcessor" >

<proxy value ="uc1-cxf-proxy" /> </processor>

<scheduler name="immediate-scheduler" /><dispatcher name="multicast-dispatcher" />

</mediator-component >

UC1 projet : FacturationInternet


POJO FacturationInternetProcessor

public class FacturationInternet {

private FacturationInternetService service;

public Data process(Data data)

{

String content = (String) data.getContent();

String responseContent = service.getConsommation(content);

data.setContent(responseContent);

return data;

}

}


Aggregator

Scheduler : synchronisationBut : regrouper les messages sur identifiant de corrélation, puis transmettre la liste des messages corrélés au processor

"correlation-scheduler" de la bibliothèque Cilia

Processor : traitement métierBut : créer un message unique et y insérer une valeur calculée

POJO développé pour le projet UC1

public class UC1AggregatorProcessor implements IProcessor {…}

Dispatcher : routageBut : router les messages vers le composant destinataire


UC1 projet : UC1Aggregator


Spécification de Aggregator

UC1 projet : UC1Aggregator

<mediator-component category="Aggregate"

name = "UC1Aggregator">

<processor classname ="UC1AggregatorProcessor" /> <scheduler name="correlation-scheduler" />

<dispatcher name="multicast-dispatcher" />

</mediator-component >


POJO UC1AggregatorProcessorpublic class UC1AggregatorProcessor implements IProcessor{ public List process(List dataSet) { String fixe = "0",mobile = "0",internet = "0"; int total = 0; Document document = null; for(int i=0;i<dataSet.size();i++){ document = getDocumentFromData((Data)dataSet.get(i)); if (isDocumentFromMobile(document)) mobile = getConsommation(document); else if (isDocumentFromInternet(document)) internet = getConsommation(document); else if (isDocumentFromFixe(document)) fixe = getConsommation(document); } //calcul du total total=Integer.valueOf(mobile)+Integer.valueOf(fixe)+Integer.valueOf(internet); Data data = (Data) ((Data) dataSet.get(0)).clone(); data.setContent(buildReponse(fixe, mobile, internet, total)); //composition de la réponse List returnList= Collections.singletonList(data); return returnList; }}


Cas d'usage





Déploiement


Instances

Chaîne ou graphe de médiationSpécification des instances des types identifiés

Spécification séparée des liaisons (binding)


Exemple de deux instances de Transformer

Première occurrence de Transformer dans la chaîne de médiation : créer une requête composite<mediator-instance type="XsltTransformer" id="xslttransformer-1" >

<processor><property name="xslt-file" value="trans-1.xslt" />

</processor></mediator-instance>

Deuxième occurrence de Transformer dans la chaîne de médiation : supprimer un attribut<mediator-instance type="XsltTransformer" id="xslttransformer-2" >

<processor><property name="xslt-file" value="trans-2.xslt" />

</processor></mediator-instance>


Une instance de Splitter

<mediator-instance type= "XmlSplitterWithCorrelation"id="xmlsplitterwithcorrelation-1"><processor>

<property name="separator" value="//suiviconso-requete" /></processor><dispatcher>

<property name="language" value="xpath" /> <property name="condition"> <property name="//suiviconso-requete[@produit='fixe']"

value="fixe" /> <property name="// suiviconso-requete[@produit='mobile']"

value="mobile" /> <property name="// suiviconso-requete[@produit='internet']"

value="internet" /> </property>

</dispatcher></mediator-instance>


Trois instances de Translator<mediator-instance type="Translator" id="translator-1">

<processor> <property name=“dictionary">

<item key=“SuiviConso" value=“SuiviConsoFixe"/></property></processor>

</ mediator-instance >

<mediator-instance type="Translator" id="translator-2"><processor>

<property name=“dictionary"> <item key=“SuiviConso" value=“SuiviConsoMobile"/></property></processor>


<mediator-instance type="Translator" id="translator-3"><processor>

<property name=“dictionary"> <item key="CLIENT-ID" value="CLIENT-IDENT"/> <item key=“SuiviConso" value=“SuiviConsoInternet"/></property></processor>


FacturationFixe

FacturationMobile

FacturationInternet


Trois instances pour appeler un WS

FacturationFixe : <mediator-instance type="FacturationFixe "

id="facturationfixe-1"/>

FacturationMobile : <mediator-instance type="FacturationMobile "

id="facturationmobile-1"/>

FacturationInternet : <mediator-instance type="FacturationInternet "

id="facturationinternet-1"/>


Une instance de UC1Aggregator

<mediator-instance type="UC1Aggregator"

id="uc1aggregator-1"/>


Spécification des liaisons<bindings>

…

<binding from="xslttransformer-1”

to="xmlsplitterwithcorrelation-1”/>

<binding from="xmlsplitterwithcorrelation-1:fixe“

to="translator-1" />

<binding from="xmlsplitterwithcorrelation-1:mobile“


<binding from="xmlsplitterwithcorrelation-1:internet“


…

</bindings>


Liaison avec le premier médiateur

<binding to="xslttransformer-1">

<property name="topic" value="splitaggregate/input"/>

</binding>

Front End

Chain ProxyPremier médiateur (xslttransformer-1)

dernier médiateur

topic= splitaggregate/inputLe composant chain-proxy est un gestionnaire de requête qui sert aussi de façade pour l’accès à la passerelle

sender.send(data);…public void notifyData(Data data){…}

Gestionnaire de RQ/R


Communication vers l’extérieur

La chaîne de médiation communique avec des services externes en utilisant des technologies d’importation de services (ROSE, DOSGi-CXF, …)

Cette solution permet d’avoir des médiateurs uniquement dédiés au code métier

Documents

Cilia, un framework de médiation ouvert, léger, multi-personnalités PARTIE 4 : Cas d'usage SI