View
143
Download
2
Category
Preview:
Citation preview
@xebiconfr #xebiconfr
Event Sourcing/CQRS Certains en parlent, nous les avons
implémentés!
Clément HELIOU
@c_heliou @xebiconfr #xebiconfr 2
@c_heliou
@c_heliou @xebiconfr #xebiconfr
L’Event SourcingEn bref
@c_heliou @xebiconfr #xebiconfr 4
« Capturer tous les changements d’état d’une application comme une séquence d’évènements »
Martin Fowler
@c_heliou @xebiconfr #xebiconfr 5
Date Débit Crédit
2016/05/14 100 €
2016/05/14 -20 €
2016/05/16 -30 €
2016/05/24 380 €
2016/06/01 -70 €
Total -120 € 480 €
Solde 360 €
@c_heliou @xebiconfr #xebiconfr 6
Pourquoi utiliser l’Event Sourcing?
Audit
Analyse/debugReprise dedonnées
Performance
@c_heliou @xebiconfr #xebiconfr 7
Application
Inspiré par J. Chassaing - http://thinkbeforecoding.com/post/2014/01/04/Event-Sourcing.-Draw-it
Commande
Fonction de Décision
@c_heliou @xebiconfr #xebiconfr 8
Fonction de décision (état courant + commande)
=> évènement(s)
@c_heliou @xebiconfr #xebiconfr 9
Application
Inspiré par J. Chassaing - http://thinkbeforecoding.com/post/2014/01/04/Event-Sourcing.-Draw-it
Fonction de Décision
Commande
Fonction d’évolution
Évènement(s)
Event store
@c_heliou @xebiconfr #xebiconfr 10
Fonction d’évolution (état courant + évènement)
=> nouvel étatPour chaque évènement émis par
la fonction de décision
@c_heliou @xebiconfr #xebiconfr 11
Application
Inspiré par J. Chassaing - http://thinkbeforecoding.com/post/2014/01/04/Event-Sourcing.-Draw-it
Évènement(s)Fonction de
Décision
Commande
Fonction d’évolution Event
store
Action
Effets de bord
@c_heliou @xebiconfr #xebiconfr
Contexte Au coeur des
salles de marché
@c_heliou @xebiconfr #xebiconfr 13
@c_heliou @xebiconfr #xebiconfr 14
http://www.les-terres-rares.com/platine-palladium-meme-famille-2-destins-differents/
@c_heliou @xebiconfr #xebiconfr 15
Couverture
Livraison physique
A l’échéance
@c_heliou @xebiconfr #xebiconfr 16
Client
Comptabilité
Trader Marché
Vendeur
Avant Multiplus
@c_heliou @xebiconfr #xebiconfr 17
Client
Comptabilité
Automatede prix
Marché
Multiplus
Avec Multiplus
Couverture
Limites
Marges
@c_heliou @xebiconfr #xebiconfr
L’EVENT SOURCINGchez Multiplus
@c_heliou @xebiconfr #xebiconfr 19
Application
Inspiré par J. Chassaing - http://thinkbeforecoding.com/post/2014/01/04/Event-Sourcing.-Draw-it
Fonction de Décision
RecevoirPrix {commande}
@c_heliou @xebiconfr #xebiconfr 20
Fonction de décision (état courant + commande)
=> évènement(s)
@c_heliou @xebiconfr #xebiconfr 21
Fonction de décision (état courant + RecevoirPrix)
=> PrixReçu
@c_heliou @xebiconfr #xebiconfr 22
Application
Inspiré par J. Chassaing - http://thinkbeforecoding.com/post/2014/01/04/Event-Sourcing.-Draw-it
Fonction de Décision
RecevoirPrix {commande}
Fonction d’évolution
PrixReçu{évènement}
@c_heliou @xebiconfr #xebiconfr 23
@c_heliou @xebiconfr #xebiconfr 24
Application
Inspiré par J. Chassaing - http://thinkbeforecoding.com/post/2014/01/04/Event-Sourcing.-Draw-it
Fonction de Décision
RecevoirPrix {commande}
Fonction d’évolution
PrixReçu{évènement}
Demande de prix
Réception de prix
PrixReçu{évènement}
TransférerPrix {action}
PrixTransféré {évènement}
@c_heliou @xebiconfr #xebiconfr 25
Application
PrixReçu{évènement}
PrixTransféré {évènement}
Bus d’évènements
PrixTransféréHandler {handler}
CLIENT
@c_heliou @xebiconfr #xebiconfr 26
Bus
Handler
HandlerEMS
thread pool
IUM thread
pool
EMS thread
pool
IUM thread
pool
Event loop
Commandes Évènements
Messages
Messages
@c_heliou @xebiconfr #xebiconfr 27
Bus
Handler
HandlerEMS
thread pool
IUM thread
pool
EMS thread
pool
IUM thread
pool
Event loop
Commandes Évènements
Messages
Messages
@c_heliou @xebiconfr #xebiconfr 28
C1 C2 C3
C1 = 10 ms C2 = 10 msC2 = 10 ms C2 = 10 + 10 ms
@c_heliou @xebiconfr #xebiconfr 29
Bus
Handler
HandlerEMS
thread pool
IUM thread
pool
EMS thread
pool
IUM thread
pool
Event loop
Commandes Évènements
Messages
Messages
@c_heliou @xebiconfr #xebiconfr 30
Bus
Handler
HandlerEMS
thread pool
IUM thread
pool
EMS thread
pool
IUM thread
pool
Event loop
CommandesÉvène
ments
Messages
Messages
Event loop
@c_heliou @xebiconfr #xebiconfr 31
Bus
Handler
HandlerEMS
thread pool
IUM thread
pool
EMS thread
pool
IUM thread
pool
Event loop
Commandes
Évènements
Messages
Messages
Event loop
Commandes
@c_heliou @xebiconfr #xebiconfr
Event sourcing ce que l’on a appris
@c_heliou @xebiconfr #xebiconfr 33
Vous pouvez (devez ?) faire sans framework
@c_heliou @xebiconfr #xebiconfr 34
Ne pas confondre Event sourcing et Command sourcing
@c_heliou @xebiconfr #xebiconfr 35
Application
Inspiré par J. Chassaing - http://thinkbeforecoding.com/post/2014/01/04/Event-Sourcing.-Draw-it
Évènement(s)Fonction de
Décision
Commande
Fonction d’évolution Event
store
Action
@c_heliou @xebiconfr #xebiconfr 36
Application
Inspiré par J. Chassaing - http://thinkbeforecoding.com/post/2014/01/04/Event-Sourcing.-Draw-it
Évènement(s)Fonction de
Décision
Commande
Fonction d’évolution Event
store
Action
@c_heliou @xebiconfr #xebiconfr 37
Recevoir prix {commande}
requêteId: 9387prix: 100€
Fonction de Décision
Fonction de Décision
Prix reçu{évènement}
requêteId: 9387prix: 100€marge: 0,10€
Recevoir prix {commande}
requêteId: 9387prix: 100€
Prix reçu{évènement}
requêteId: 9387prix: 100€marge: 0,20€
12/02/2016 - Marge 0,1%
01/07/2016 - Marge 0,2%
@c_heliou @xebiconfr #xebiconfr 38
Dénommer un évènement n’est pas chose Aisée.
« Anatomy of domain event » M. Praglowski - http://blog.arkency.com/2016/05/the-anatomy-of-domain-event/
@c_heliou @xebiconfr #xebiconfr
CQRS En bref
@c_heliou @xebiconfr #xebiconfr 40
Command Query Responsibility Segregation ?
@c_heliou @xebiconfr #xebiconfr 41
Pourquoi utiliser CQRS?
Maintenabilité
Performance des lectures
Intégration avec
l’Event Sourcing
@c_heliou @xebiconfr #xebiconfr
Contexte Monitorer
notre business
@c_heliou @xebiconfr #xebiconfr 43
Monitoring « Métier »
Contrôles basiquespar client, produit, etc.
Suivi temps-réel des transactions
@c_heliou @xebiconfr #xebiconfr
CQRS chez Multiplus
@c_heliou @xebiconfr #xebiconfr 45
Bus d’évènementsMultiplus
Handler
PUSH-API
Fonction de STOCKAGE
Fonction D’AGREGATION
Event store
Évènement
QUEUE EMS
WEB SOCKETVue CONSOLE
Vue
@c_heliou @xebiconfr #xebiconfr 46
PUSH-API
Fonction de STOCKAGE
Fonction D’AGREGATION
Event store
WEB SOCKET CONSOLE
Évènement{transaction #345}
Évènements {transaction #345}
Vue {transaction #345} Vue
{transaction #345}
@c_heliou @xebiconfr #xebiconfr 47
Fonction D’AGREGATION
ExécutionDemandée{transaction #345,idSéquence = 1}
ExécutionAcceptée{transaction #345,idSéquence = 2}
Fonction D’AGREGATION
Vue{transaction #345,
statut = TERMINÉE}
Vue{transaction #345,
statut = EN COURS}
@c_heliou @xebiconfr #xebiconfr 48
Fonction D’AGREGATION
ExécutionDemandée{transaction #345,idSéquence = 1}
ExécutionAcceptée{transaction #345,idSéquence = 2}
Fonction D’AGREGATION
Vue{transaction #345,
statut = TERMINÉE}
Vue{transaction #345,
statut = EN COURS}
Fonction D’AGREGATION
ExécutionAcceptée{transaction #345,idSéquence = 2}
Vue{transaction #345,
statut = TERMINÉE}
@c_heliou @xebiconfr #xebiconfr
CQRS ce que l’on a appris
@c_heliou @xebiconfr #xebiconfr 50
Il existe toujours un contrat, même s’il est implicite !
@c_heliou @xebiconfr #xebiconfr 51
Poser la 1ère pierre, à l’édifice CQRS !
Évènements d’intérêt
Évènements en mémoire
@c_heliou @xebiconfr #xebiconfr
CONCLUSION
@c_heliou @xebiconfr #xebiconfr 53
Ressources๏ Xebicon 15’ - CQRS + Event Sourcing: en direct !
๏ Back Day 15’ - Explorer les principes de l’event sourcing
๏ Thinkbe4coding #Eventsourcing
๏ KATA MixteR- https://github.com/devlyon/mixter- Kata explorant les principes de l’Event Sourcing/CQRS.
- https://www.youtube.com/watch?v=QGGZs0KqxZw- Live coding présentant les principes de l’Event Sourcing/CQRS.
- http://thinkbeforecoding.com/tag/Event%20Sourcing- L’un des auteurs français à suivre sur le sujet Event Sourcing/CQRS.
- http://www.xebia.tv/vod?videoId=S8566fyZHp0- Présentation plus large du projet Multiplus (DDD, BDD, Architecture hexagonale).
Recommended