NServiceBus

-

 NServicebus = abstraction over een service bus broker.. voorkeur masstransit

 endpoint configuration = basis, geef je naam, gewoon logische naam, bijv "Sales".

 endpoint serialization -> welke serializer moet gebruikt worden

 endpoint transport = medium dat de messages transporteert (memory, azure service bus, rabbitmq, etc). LearningTransport is een memory implementation. Dus de berichten gaan nu via het geheugen.

 endpointInstance =  Endpoint.start(endpointConfiguration) 

    -> start de service, een background service 

Nservicebus kent 3 soortenm messages

1. command: 1 of meerdere senders, altijd 1 receiver. Doel is om een plek iets te laten doen. naming is dan: PlaceOrder, DoSomething

2. event: pub sub scenario: 1 sender, meerdere receivers. Doel: laat de wereld weten dat er iets is gebeurt: OrderPlaced, UserLoggedIn

3. message: voor alle overige berichten, bijv een reply op een request/response

public class ExampleCommand : ICommend

{}

later in code te gebruiken om te versturen:

var command = new ExampleCommand()

// SendLocal gebruik je niet in productie, alleen voor dev en demo 

await endpointInstance.SendLocal(command)

Command handler:

public class ExampleCommandHandler : IHandleMessages<ExampleCommand>

{

}

IMessageSession kan je injecteren in je classes als je iets wilt publiseren (pub sub / events)

messageSession.Send(<instantie van ICommand>);

Als je iets probeert te senden bij een command, maar er is geen ontvanger gedefinieerd, krijg je een exception

Dit los je op door:

1.  routing te specificeren  / configureren: Welke type command wordt door welke endpointconfiguratie afgehandeld

   routing.RouteToEndpoint(typeof(ExampleCommand), "Sales")

2.  een handler te maken

   -> erevn van IHandleMessages<ExampleCommand>

Bij het publishen van een event (pub/sub) heb je geen routing nodig 

Reacties

Een reactie posten

Populaire posts van deze blog

IIS: Application pool recycling vs IIS Reset

-
Om het verschil tussen IIS Reset en Application pool recycling uit te leggen, eerst even een stukje uitlog over hoe IIS werkt. IIS kent drie hoofdcomponenten: 1. Http.sys Dit is een kernelcomponent wat betekent dat het geen onderdeel is van de user mode processen, zoals de W3WP.Exe. Een kernelcomponent gebruikt nooit virtueel geheugen van user processen. Het is geisoleerd en gescheiden. Http.sys heeft drie belangrijke rollen: (client) connection management; Routing requests van browsers. Dit houdt in dat http.sys er voor zorgt dat de requests bij de juiste application pool queue terecht komen. Beheren van de response cache. 2. Worker processen Worker processen zijn de application pools en elke application pool en voor elke application pool wordt een instantie van W3WP.exe opgestart. Een application pool handelt alle content af zoals html bestanden, afbeeldingen, scripts, css bestanden, maar ook dynamische content zoals ASP.NET applicaties. Om deze reden is de stat...
Meer lezen

Hoofdstuk 2 - Les 2

-
Om naar een tekstbestand te schrijven maak dan gebruik van TestReader of StreamReader: TextReader tr = File.Open(@"C:\myfile.txt"); Console.WriteLine(tr.ReadToEnd()); tr.Close(); Om met binaire bestanden te werken maak dan gebruik van BinaryWriter en BinaryReader: FileStream fs = new FileStream("data.txt", FileMode.Create); BinaryWriter bw = new BinaryWriter(fs); for(int i = 0; i { bw.Write((int)i); } bw.Close(); fs.Close(); fs = new FileStream("data.txt", FileMode.Read); BinaryReader br = new BinaryReader(fs); for(int i = 0; i { Console.WriteLine(r.ReadInt32()); } br.Close(); fs.Close(); Met de MemoryStream wordt niet naar een bestand geschreven, maar naar het geheugen, waarna het vervolgens naar een bestand oid kan worden geschreven. Ook kan gebruik gemaakt worden van de compressed streams, zoals GZipStream. Isolated storage is een prive bestandssysteem dat wordt beheerd door het .NET Framework. Om hier naar toe te schrijven zijn geen speciale stream...
Meer lezen

Totstandkoming estimated en actual query plans Sql Server

-
Als een query wordt aangeboden aan SQL Server, worden er een aantal stappen uitgevoerd: Parsing De query wordt geparsed. Dit houdt in dat wordt bekeken of de query correct geschreven is. De uitkomst hiervan is een parse tree (of query tree of sequence tree). De parse tree representeert de logische stappen die nodig zijn om de query uit te voeren. DML of DDL Als de query een Data Manupilation Language (DML) statement is, dan wordt deze geoptimaliseerd. Als het een Data Definition Language query is, dan niet. Dit omdat een DDL altijd statement bevatten die gaan over de DB structuur en er is altijd maar 1 juiste manier om bijv. een tabel aan te maken. Algebrizer Als de T-sql een DML statement is en hij is door de parser heen gekomen, dan wordt de parse tree doorgegeven aan de algebrizer. De algebrizer achterhaalt alle namen van de gemoeide objecten, tabellen en kolommen. Hij identificeert ook alle data types, zoals int, varchar(50), etc.. Tevens bepaalt hij ook de aggregates, zoa...
Meer lezen