RxMQTTnet

rxmqttnet

MQTTNETプロジェクトの拡張、サブスクリプションを観測可能性に変換し、観察可能なストリームから公開します。

クライアントを作成します

工場を使用してください

MQTTnet.Extensions.External.RxMQTT.Client.MqttFactoryExtensionsでMQTTnet.MqttFactoryを使用します。

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

オプションを作成します

マネージドクライアントオプションを使用します

クライアントを開始します

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

購読する

rxクライアントに接続し、拡張機能を使用してメッセージを処理することにより、 IObservable<MqttApplicationMessageReceivedEventArgs>を取得します。

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

サブスクリプションを処分してサブスクリプションを終了します。

 subscription . Dispose ( ) ;

公開

観測可能から

MqttApplicationMessage sの観測可能なシーケンスを作成し、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 ( ) ; 

単一のメッセージ

MQTTクライアントパブリッシュメソッドを使用します。