More Related Content
Viewers also liked (19)
More from Marc de Graauw (13)
Reliable messaging
- 1. Reliable MessagingMarc de Graauw
- 3. Betrouwbaar transportNetwerk is niet betrouwbaarHet is niet te garanderen dat twee partijen beide 100% zeker weten dat communicatie geslaagd isHet is wel te garanderen dat als de communicatie niet geslaagd is, tenminste een partij dat weetAanname: vroeg of laat is het netwerk weer beschikbaar
- 4. Eisen betrouwbaar transportIeder bericht wordt minimaal een keer afgeleverdIeder bericht wordt maximaal een keer afgeleverdBerichten worden afgeleverd in de volgorde waarin ze verzonden zijnAfgeleverde berichten worden bewaard
- 5. Het IssueTransport over HTTP is niet betrouwbaarGeen antwoord op een bericht:door timeout, netwerk down, server downniet zeker of het bericht al dan niet aangekomen en/of verwerkt is
- 6. HTTP Methods (RFC 2616)safe heeft geen neveneffecten op de serverHTTP: GETb.v.: opvragen informatieidempotentlaat server in zelfde staat na herhaling HTTP DELETE, PUTb.v. verwijderen recordniet-idempotentwijzigt serverHTTP POSTb.v. 100 aandelen kopen
- 8. ZenderOntvangerBerichtVerwerk berichtKopie van berichtOntvangstbevestiging
- 9. ZenderOntvangerVerwerk berichtBerichtOntvangstbevestigingNiet verwerkenKopie van berichtOntvangstbevestiging
- 10. Betrouwbare afleveringGegarandeerde afleveringberichtnummersontvangstbevestigingeventueel duplicaat zendenEenmalige afleveringduplicaatdetectieduplicaatverwijderingVolgordelijke afleveringoplopende berichtnummering
- 11. Eisen aan betrouwbaar transportEis 1: duplicaatdetectie is nodig voor niet-idempotente actiesEis 2: ontvangstbevestigingen zijn nodig bij niet-directe actiesOntwerprichtlijn: Geef bij iedere interactie aan of deze veilig en/of idempotent isOntwerprichtlijn: Ieder bericht waarop niet direct een (ander) antwoord komt, krijgt een ontvangstbevestigingOntwerprichtlijn: Idempotente berichten waarop het verwachte antwoord niet komt, worden herhaald met een nieuw bericht-id. Geen duplicaat dus, maar een nieuw berichtOntwerprichtlijn: De ontvanger hoeft voor idempotente berichten geen status (bericht-id en verzonden antwoord) te bewarenOntwerprichtlijn: Niet-idempotente berichten waarop het verwachte antwoord niet komt, worden herhaald met een duplicaat.
- 13. WS-ReliableMessagingApache Sandesha 2 ondersteund WS-RM 1.1 voor Axis2 Java en C++http://ws.apache.org/sandesha/sandesha2/index.htmlWSO2 bevat Sandesha2 en ondersteund daarmee ook WS-RM 1.1.Metro 3.0.1 (onderdeel van J2EE reference implementatie"glassfish") ondersteund in ieder geval WS-RM 1.1.https://metro.dev.java.net/Apache CXF ondersteund gezien de source alleen WS-RM 1.0.JBossWS vanaf versie 3.0.1: ondersteund 1.0 en 1.1.https://jira.jboss.org/jira/browse/JBWS-515http://jbossws.jboss.org/mediawiki/index.php?title=WS_Reliable_MessagingMicrosoft .Net ondersteund WS-RM 1.1 vanaf versie 3.5, Windows Communication Framework
- 16. Infra 1
- 19. WSRM patronen1-waybidirectionalanonymousveel berichten (atom. aanmelden)plaatjes
- 20. OntvangerZenderHL7v3 Query1. QueriesHL7v3 Antwoord2. Bericht zonderantwoordHL7v3 BerichtHL7v3 Accept AcknowledgementHL7v3 Bericht 3. Bericht metantwoordHL7v3 BerichtResponse (Accept or Reject)
- 21. ZIMGBZ 1CreateSequenceCreateSequenceResponseHL7v3 bericht 1 + AckRequestack 1TerminateSequenceTerminateSequenceResponse
- 22. ZIMGBZ 1CreateSequenceCreateSequenceResponseHL7v3 bericht 1HL7v3 bericht 2HL7v3 bericht 3HL7v3 bericht 4HL7v3 bericht 5 + AckRequestack 1..5TerminateSequenceTerminateSequenceResponse
- 23. ZIMGBZ 1CreateSequenceCreateSequenceResponseHL7v3 bericht 1HL7v3 bericht 2HL7v3 bericht 3HL7v3 bericht 4HL7v3 bericht 5 + AckRequestack 2..5HL7v3 bericht 1 + AckRequestack 1TerminateSequenceTerminateSequenceResponse
- 24. ZIMGBZ 1CreateSequenceCreateSequenceResponseHL7v3 bericht a1HL7v3 bericht a2HL7v3 bericht b1HL7v3 bericht a3HL7v3 bericht a4 + AckRequestHL7v3 bericht b2 + ackRequestack a1..a4ack b1..b2TerminateSequenceTerminateSequenceResponse
- 25. ZIMGBZ 1HTTP Request + HL7v3 bericht 1 HTTP Response + HL7v3 Accept Ack
- 26. ZIMGBZ 1CreateSequenceCreateSequenceResponseHTTP Request +HL7v3 bericht 1 + AckRequestHTTP Response + ack 1TerminateSequenceTerminateSequenceResponse
- 27. ZIMGBZ 1CreateSequenceCreateSequenceResponseHTTP Request +HL7v3 bericht 1 + AckRequestHTTP 200 OKHTTP Response +ack 1HTTP 200 OKTerminateSequenceTerminateSequenceResponse
- 28. Welke communicatiepatronen?anonymous one-way, one message, one ackanonymous one-way, many messages, many acksaddressed one-way, many messages, one ack?bidirectional – (nog) niet?alles anonymous?
- 30. businessdocumentbusinessdocumentEnvelopeHeaders:Web Service SenderWeb Service Receiverreliabilityreliability modulemessagingreliability modulemessagingsecuritysecurity modulesecurity modulePayload:transaction moduletransaction modulebusinessdocumentet ceteraet cetera
- 31. Scenario 1: Resending worksSenderReceiverMessageDuplicate MessageProcess MessageAcknowledgement
- 32. Scenario 2: Resending failsSenderReceiverMessageProcess MessageAcknowledgementDuplicate MessageProcess MessageAcknowledgement
- 33. Scenario 3: Reliable messagingSenderReceiverMessageProcess MessageAcknowledgementDuplicate MessageDiscard DuplicateAcknowledgement
- 34. Sender’sTransportModuleReceiver’sTransportModuleSender’sBusinessModuleReceiver’sBusinessModulePlace OrderOrderMessageTransport AckSubmit OrderAccept OrderAcceptMessageTransport AckSubmit Accept
- 35. GP’sTransportModulePharmacistsTransportModuleGP’sConsultationApplicationPharmacistsPrescriptionApplicationPrescriptionPrescriptionPrescriptionprescription.id=xprescription.id=xprescription.id=xAck prescriptionPrescriptionPrescriptionprescription.id=xPrescriptionprescription.id=xprescription.id=xErrorErrorErrorprescription.id=xalready existsprescription.id=xalready existsprescription.id=xalready exists