RxMQTTnet

rxmqttnet

MQTTNET 프로젝트로의 확장으로 구독을 관측부로 변환하고 관찰 가능한 스트림에서 게시합니다.

클라이언트를 만듭니다

공장을 사용하십시오

MQTTnet.MqttFactory MQTTnet.Extensions.External.RxMQTT.Client.MqttFactoryExtensions 와 함께 사용하십시오.

 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 클라이언트 게시 방법을 사용하십시오.