RxMQTTnet

Rxmqttnet

Eine Erweiterung des MQTTNET -Projekts, um die Abonnements in Observable umzuwandeln und aus einem beobachtbaren Stream zu veröffentlichen.

Einen Kunden erstellen

Verwenden Sie die Fabrik

Verwenden Sie die MQTTnet.MqttFactory mit den MQTTnet.Extensions.External.RxMQTT.Client.MqttFactoryExtensions .

 var client = new MqttFactory ( ) . CreateRxMqttClient ( ) ; 

Erstellen Sie die Optionen

Verwenden Sie die verwalteten Kundenoptionen

Starten Sie den Kunden

 await client . StartAsync ( options ) . ConfigureAwait ( false ) ;

Abonnieren

Holen Sie sich eine IObservable<MqttApplicationMessageReceivedEventArgs> , indem Sie eine Verbindung zum RX -Client herstellen und Erweiterungen verwenden, um die Nachricht zu verarbeiten:

 var subscription = rxMqttClinet
    . Connect ( "RxClientTest/#" )
    . SelectPayload ( )
    . Subscribe ( Console . WriteLine ) ;

Beenden Sie das Abonnement, indem Sie das Abonnement entstellen.

 subscription . Dispose ( ) ;

Veröffentlichen

Von beobachtbar

Erstellen Sie eine beobachtbare Sequenz von MqttApplicationMessage S und veröffentlichen Sie diese über den RX -Client.

 Observable . Interval ( TimeSpan . FromMilliseconds ( 1000 ) )
    . Select ( i => new MqttApplicationMessageBuilder ( )
        . WithTopic ( "RxClientTest" )
        . WithPayload ( "Time: " + DateTime . Now . ToLongTimeString ( ) )
        . WithQualityOfServiceLevel ( MqttQualityOfServiceLevel . ExactlyOnce )
        . WithRetainFlag ( )
        . Build ( ) )
    . PublishOn ( mqttClient )
    . Subscribe ( ) ; 

Einzelne Nachricht

Verwenden Sie die MQTT Client Publish -Methode.