RxMQTTnet

Rxmqttnet

Una extensión al proyecto MQTTNet, para transformar las suscripciones en observables y publicar desde una secuencia observable.

Crear un cliente

Usa la fábrica

Use la MQTTnet.MqttFactory con MQTTnet.Extensions.External.RxMQTT.Client.MqttFactoryExtensions .

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

Crea las opciones

Utilice las opciones de cliente administrado

Iniciar el cliente

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

Suscribir

Obtenga un IObservable<MqttApplicationMessageReceivedEventArgs> conectándose al cliente RX y use extensiones para procesar el mensaje:

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

Finalice la suscripción eliminando la suscripción.

 subscription . Dispose ( ) ;

Publicar

De observable

Cree una secuencia observable de MqttApplicationMessage S y publíquelos a través del cliente RX.

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

Mensaje único

Use el método de publicación de clientes MQTT.