LAGOM...Lagom sorgt für Implementierung für Service-Zugriff …inclusive „Service“ wie Circuit...

LAGOMDIE RICHTIGE DOSIS MICROSERVICE

Dr. Stefan Schlott und Armin Bauer ( )BeOne Stuttgart GmbH

ABOUT.TXTStefan Schlott, BeOne Stuttgart GmbH

Advisory Consultant, Architekt, Java-Entwickler, Scala-Enthusiast, Linux-Jünger

Begeistert für Skalierbarkeit, Security, Privacy - undandere skurile Techniken ;-)

ABOUT.TXTArmin Bauer, BeOne Stuttgart GmbH

Senior Consultant, Architekt, Java-Entwickler, OpenSource - Fan, …

Begeistert für Technologie, MaschinelleSprachverarbeitung und Software Engineering

WIR WOLLENMICROSERVICES!(UND ANDERE MODERNE

TECHNOLOGIEN)

ZUR ERINNERUNG: WELCHEERWARTUNGEN STELLEN WIR AN DIE

EIGENSCHAFTEN VONMICROSERVICES?

EIGENSCHAFTEN: GRÖSSE... sollte von einem Team gut zu bearbeiten sein... sollte als ganzes neu implementiert werden... sollte für neue Entwickler leicht zu verstehen sein

■■■

EIGENSCHAFTEN: DOMÄNEJeder Microservice bearbeitet einen abgetrennten Teil der DomäneJeder Microservice hat eine eigene Datenstruktur die er verwaltetDie Microservices kommunizieren um miteinander zumInformationsaustausch

■■■

UND WIE WAR DAS MIT REACTIVE?!

EIGENSCHAFTEN: REACTIVE SYSTEMSScalable

Resilient

Responsive

Message Driven

(siehe )Reactive Manifesto

WEITERE BUZZWORDSCQRSEvent SourcingAsynchronous

■■■

FÜR ALLES GIBT ES EINE LÖSUNG…

FERTIG, ODER?

WILLKOMMEN IM ZOO!

DER TECHNOLOGIE-ZOOWie reden die Systeme miteinander?

Austauschbarkeit?

Muss ich das jetzt alles ansprechen?

Was muss ich jetzt händisch machen?

Wie bringe ich das auf meiner Entwicklermaschine zum laufen?

Setupzeit für neue Teammember?

Wer administriert das denn jetzt alles?

WAS IST LAGOM UND WASWILL ES IN MEINEM TEAM?

WORTHERKUNFT

Schwedisch: Genau die richtige Menge

WAS BRINGT LAGOM MIT?Gemeinsamer Deckel und API über die Tools und TechnologienGeschmackvolle Vorauswahl an Technologien„Opinionated“ FrameworkGemeinsamer Start aller ServicesHot Code Reload

■■■■■

FÜR WEN IST LAGOM?Neue Microservice ProjekteRefactoring Tool für MonolithenJava API (und seit Lagom 1.3 auch eine Scala API)

■■■

BEISPIELPROJEKT:GESCHENKE-DOODLE

BESCHREIBUNGEs soll eine Software entwickelt werden, mit der mehrere Leute ein

gemeinsames Geschenk kaufen können

Der Initiator legt das Geschenk webbasiert anDie Mit-schenker können einen Betrag zum Geschenk dazugebenWenn das Ziel erreicht ist, erhält der Initiator eine Mail und weissnun, dass er das Geschenk kaufen kann

■■■

DOMÄNENMODELL UND ARCHITEKTUROrganize-Service: Verwaltung und Status der Geschenke

Contribute-Service: Entgegennehmen der einzelnen Beiträge

Mail-Service: Versand der Info-Mails

NA DANN MAL LOS.

DIE IMPLEMENTIERUNG DESGESCHENK-DOODLE

DEFINITION VON SERVICES

WAS GEHÖRT ZURSERVICEDEFINITION?

Definition der Methoden die der Service anbietetDefinition der Datenstruktur für Request und Response für denService

■■

BEISPIEL-SERVICEEin Java - Interface definiert die Methoden die der Service anbietet.

public interface OrganizeService extends Service { ServiceCall<NotUsed, PresentBaseInformation> getBaseInfo(String id); ServiceCall<PresentCreateRequest, PresentCreateResponse> organizePresent(); ServiceCall<NotUsed, PresentAdminInfo> getAdminInfo(String id);

@Override default Descriptor descriptor() { return Service.named("organizeservice").withCalls( Service.pathCall("/api/organize/create-present", this::organizePresent), Service.pathCall("/api/organize/admin/:id", this::getAdminInfo), Service.pathCall("/api/organize/get/:id", this::getBaseInfo) ).withAutoAcl(true); }}

WAS IST EIGENTLICH...Service.pathCall ... Mapping von Pfadelementen auf Methodenparametergenerics von ServiceCall ... Mapping von RequestBody auf ResponseBody TypNotUsed ... Bedeutet das es keinen Requestbody gibt.

■

■

■

Die verwendeten Typen sind einfache JSON-serialisierbare Objekte

ANGENEHM:Die gewählte Art von Abstraktion ist sehr weit von

HTTP als Transportschicht entfernt

DATENSTRUKTURAm gewohntesten als Beans mit Gettern und Settern, aber eleganter

wenn man es Immutable macht

@Immutable@JsonDeserializepublic class PresentAdminInfo { public final String organisator; public final String description; public final LocalDate deadline;

@JsonCreator public PresentAdminInfo(String orga, String description, LocalDate deadline) { this.organisator = orga; this.description = description; this.deadline = deadline; }}

IMPLEMENTIERUNG VONSERVICES

INTERFACEIMPLEMENTIEREN

Der Service implementiert zunächst das Interface

public class OrganizeServiceImpl implements OrganizeService { … @Override public ServiceCall<NotUsed, PresentBaseInformation> getBaseInfo(final String id) { return request -> persistentEntityRegistry.refFor(Present.class, id) .ask(GetPresentData.INSTANCE) .thenApplyAsync(PresentBaseInformation::of); } …}

DEPENDENCY INJECTIONMit Guice als Constructor Injection

public class OrganizeServiceImpl implements OrganizeService { private final PersistentEntityRegistry persistentEntityRegistry;

@Inject public OrganizeServiceImpl(PersistentEntityRegistry per) { persistentEntityRegistry = per; persistentEntityRegistry.register(Present.class); } …}

SERVICE REGISTRIERENpublic class OrganizeServiceModule extends AbstractModule implements ServiceGuiceSupport { @Override protected void configure() { bindServices(serviceBinding(OrganizeService.class, OrganizeServiceImpl.class)); }}

KONSUMIEREN VONSERVICES

BINDEN DES INTERFACESpublic class FrontendModule extends AbstractModule implements ServiceClientGuiceSupport { @Override protected void configure() { bindClient(OrganizeService.class); … }}

NUTZUNG DES INTERFACESAls Client: Interface per Injection anfordern

Lagom sorgt für Implementierung für Service-Zugriff

…inclusive „Service“ wie Circuit Breaker, etc.

CQRS IN A NUTSHELL

WAS IST EVENT SOURCINGDie alte Welt:

Es gibt eine Datenbank mit dem aktuellen Zustand, ein Objektmodellmit dem aktuellen Zustand und ein ORM, das die beiden abgleicht

Die neue Welt: Speichere nicht den Zustand der Objekte sondern Events, die

diesen Zustand verändern

WOZU?Es ist nachvollziehbar, durch welche Änderungen der aktuelle

Zustand zustande gekommen ist.

Es können inkrementelle Snapshots der Events erzeugt werden.

Zustandsänderungen sind leicht zwischen Instanzen zu syncen.

Sehr gute Performance-Charakteristik.

WIE IST ES IN LAGOMUMGESETZT?

Zu jeder Entity gibt es einen World-State.

Sendet man ein Command an eine Entity, so löst dieser einen Eventaus, der den World State verändert.

Die Events werden persistent gespeichert.

Der World State kann zu jedem Zeitpunkt rekonstruiert werden.

EINE PERSISTENT ENTITYDEFINIEREN

Entity besteht immer aus Commands, Events und einem World-State

public class Present extends PersistentEntity< PresentCommand, PresentEvent, PresentWorldState> {

@Override public Behavior initialBehavior( final Optional<PresentWorldState> snapshotState) { final BehaviorBuilder builder = newBehaviorBuilder( snapshotState .orElse(new PresentWorldState(null, null, null, null, null))); // Command Handler: … // Event Handler: … // Readonly Commands: … return builder.build(); }}

REAGIEREN AUF READONLY-COMMANDS

Ein Readonly Command ändert den Worldstate nicht

// Readonly Commands: get Present Databuilder.setReadOnlyCommandHandler(GetPresentData.class, (cmd, ctx) -> ctx.reply(state()));

state() ... gibt den aktuellen World-State des Objekts zurück

REAGIEREN AUF ANDERECOMMANDS

Ein Command ändert den Worldstate durch Aufrufen eines Events:

// Command Handler: Neues Geschenk erzeugenbuilder.setCommandHandler(CreatePresent.class, (cmd, ctx) -> { final PresentCreatedEvent event = new PresentCreatedEvent(cmd.id, cmd.organisatorName, cmd.organisatorMail, cmd.deadline, cmd.description); return ctx.thenPersist(event, evt -> ctx.reply(state()));});

Auch hier stünde für ändernde Events der World-State mit state()zur Verfügung.

REAGIEREN AUF EVENTSEin Event ersetzt den World-State durch einen anderen. Der World-

State an sich ist Immutable.

Vorteile: Keine Nebenläufigkeit, nur Zustandsübergänge

builder.setEventHandler( PresentCreatedEvent.class, event -> new PresentWorldState(event.id, event.organisatorName, event.organisatorMail, event.deadline, event.description));

MESSAGE QUEUE / EVENTS

ABGRENZUNGBisher:

Ein Service der Daten braucht, die einem anderen Service gehörenfragt diesen an. User erlebt die Antwort synchron.

Neu:

Ein Service dem Daten gehören stellt diese einem anderen zurdurch einen Message Broker Verfügung.

(Publish / Subscribe Pattern)

ANWENDUNGSBEISPIELContribute-Service: Interessiert an jedem Einzelbeitrag (wer wieviel)

Organize-Service: Interessiert an Gesamtsumme (kommt dasGeschenk zustande?)

→ Entkopplung durch Messages

RÜCKBLENDE: PUB/SUBPublisher senden Nachrichten an Kanäle (Topics). Topics sind

meistens als Warteschlangen definiert

Subscriber holen die Nachrichten aus den Topics ab, verarbeitensie und schicken ggf. neue Nachrichten oder Antworten

Nachrichten werden aus dem Topic gelöscht, wenn…

…eine vorgegebene Zeit die sie bestehen sollen abgelaufen ist…eine eingestellte Anzahl Subscriber sie entfangen hat…ein Subscriber sie bearbeitet und explizit gelöscht hat

■■■

EIGENSCHAFTEN: PUB/SUBlose KopplungSkalierbarkeitSemantik nicht flexibelZustellung der Nachricht kann unter Umständen nicht garantiertwerden

■■■■

DEFINITION IM SERVICEDie Definition eines solchen Service-Listeners erfolgt analog zu der

von Web-Aufrufen:

public interface ContributeService extends Service { (…)

@Override default Descriptor descriptor() { return named("contributeservice").withCalls( (…) ).publishing( topic("contributions", this::contributionsTopic) ).withAutoAcl(true); }

Topic contributionsTopic();}

PUBLISHBeispielsweise auf Events aus dem CQRS hören um zu publishen.

public Topic contributionsTopic() { return TopicProducer.singleStreamWithOffset(offset -> persistentEntityRegistry .eventStream(ContribEvent.EVENT_TAG, offset) .map(this::convertEvent) );}

SUBSCRIBERegistrieren als Subscriber, sodass wenn eine Nachricht eingeht

eine Aktion ausgeführt wird.

contributeService.contributionsTopic() .subscribe() .atLeastOnce(Flow.fromFunction((contributionEvent) -> { // Handle event return Done.getInstance(); }));

UNTERSTÜTZTE BROKERLagom schreibt nicht einen Broker vor, unterstützt werden

Beispielsweise:

Google Cloud Pub/SubKafkaRabbitMQ

■■■

DINGE DIE WIRAUSGELASSEN HABEN...

SERVICE DISCOVERY UNDDEPLOYMENT

Lightbend bietet ConductR an, was sich um scaling und servicediscovery kümmert.

Es gibt ein Plugin für Consul als Service Discovery und der Serviceläuft auch in einem Docker Container.

DIE ANDEREN ARBEITEN ABER MITFRAMEWORK X...

Der Vorteil von Microservices ist, dass jeder Service mit deroptimalen Technologie arbeiten kann

Daher ist es in Lagom vorgesehen, auch andere Serviceskonsumieren zu können

ICH BRAUCHE DIESE LIBRARY GANZDRINGEND...

Libraries generell integrierbar, zB via Dependency Injection.

Vorsicht: Requests sollten nicht blockieren.

ICH HAB ABER SCHON EINE SERVICEDISCOVERY...

Prinzipiell steht nichts im Wege eine andere Art von ServiceDiscovery zu benutzen

UNSER FAZITSehr mächtiges Framework

Deckt mit generischer API quasi alle Aspekte modernerMicroservice-Entwicklung ab

Sehr angenehm: Kurze Setup-Zeit für Entwickler-Maschinen, Code-Reloading

Gefühlt (noch?) etwas schwierig, wenn man vom Standardwegabweichen will (Beispiel: Message Queues)

…aber: Noch jung, da dürfen wir noch mehr erwarten!

http://www.beone-group.com/

Twitter:

Armin BauerDr. Stefan Schlottstefan.schlott@beone-group.com

@_skyrarmin.bauer@beone-group.com

BILDQUELLEN

by Microsoft■ Lagom Wortherkunft■ CQRS pattern