QsMessaging Download – Download des QsMessaging Quellcodes

QsMessaging

Andere Kategorien

1.0.0

Herunterladen

QsMessaging

QsMessaging ist eine .NET 8-Bibliothek zum Senden und Empfangen von Nachrichten zwischen Diensten oder Komponenten Ihrer Anwendung mithilfe von RabbitMQ . Es unterstützt horizontale Skalierbarkeit, sodass mehrere Instanzen desselben Dienstes Nachrichten effizient verarbeiten können.
Verfügbar auf NuGet für eine nahtlose Integration:

Eine einfache, skalierbare Messaging-Lösung für verteilte Systeme.

Installation

Installieren Sie das Paket mit dem folgenden Befehl:

dotnet add package QsMessaging

Registrierung der Bibliothek

Die Registrierung der Bibliothek ist einfach. Fügen Sie die folgenden zwei Codezeilen zu Ihrer Program.cs hinzu:

 // Add QsMessaging (use the default configuration)...
builder . Services . AddQsMessaging ( options => { } ) ;

.. .
await host . UseQsMessaging ( ) ;

Standardkonfiguration

RabbitMQ

Host: localhost
Benutzername: guest
Passwort: guest
Port: 5672

Verwendung

Senden von Nachrichten

Vertrag

Definieren Sie einen Nachrichtenvertrag:

 public class RegularMessageContract
{
    public required string MyTextMessage { get ; set ; } 
}

Senden einer Nachricht

Integrieren Sie IQsMessaging in Ihre Klasse:

 public YourClass ( IQsMessaging qsMessaging ) { }

Verwenden Sie es dann, um eine Nachricht zu senden:

 await qsMessaging . SendMessageAsync ( new RegularMessageContract { MyTextMessage = "My message." } ) ;

Umgang mit Nachrichten

Um die Nachricht zu verarbeiten, erstellen Sie einen Handler:

 public class RegularMessageContractHandler : IQsMessageHandler < RegularMessageContract >
{
    public Task < bool > Consumer ( RegularMessageContract contractModel )
    {
        // Process the message here
        return Task . FromResult ( true ) ;
    }
}

Anfrage-/Antwortmuster

Sie können das Request/Response- Muster auch verwenden, um eine Anfrage zu senden und auf eine Antwort zu warten. Dies ist nützlich, wenn Sie zwischen Diensten kommunizieren müssen und eine Antwort erwarten.

Anfrage-/Antwortvertrag

Definieren Sie die Anfrage- und Antwortverträge:

 public class MyRequestContract
{
    public required string RequestMessage { get ; set ; }
}

public class MyResponseContract
{
    public required string ResponseMessage { get ; set ; }
}

Senden einer Anfrage und Empfangen einer Antwort

Um eine Anfrage zu senden und auf eine Antwort zu warten, verwenden Sie RequestResponse<TRequest, TResponse> :

 public class MyService
{
    private readonly IQsMessaging _qsMessaging ;

    public MyService ( IQsMessaging qsMessaging )
    {
        _qsMessaging = qsMessaging ;
    }

    public async Task < MyResponseContract > SendRequestAsync ( MyRequestContract request )
    {
        var response = await _qsMessaging . SendRequestResponseAsync < MyRequestContract , MyResponseContract > ( request ) ;
        return response ;
    }
}

Bearbeitung von Anfragen

Um Anfragen zu verarbeiten, implementieren Sie die Schnittstelle IQsRequestResponseHandler<TRequest, TResponse> :

 public class MyRequestHandler : IQsRequestResponseHandler < MyRequestContract , MyResponseContract >
{
    public Task < MyResponseContract > Handle ( MyRequestContract request )
    {
        // Process the request and create a response
        return Task . FromResult ( new MyResponseContract { ResponseMessage = "Response to: " + request . RequestMessage } ) ;
    }
}