Publicar y recibir mensajes MQTT

Ahora necesita crear un nuevo cliente MQTT y conectarse a su agente de mensajería MQTT. Como se muestra en este tutorial, puede alojar un corredor público en HiveMQ o cualquier otro corredor de su elección. En un proyecto más serio, use un corredor diferente.

Manejarás todo esto en el constructor. Primero agregue esta definición de método a la PUBLIC SECTION de tu clase:

METHODS constructor.

Agregue la definición de datos de este objeto local al PRIVATE SECTION de su clase, lo necesitará en un minuto.

DATA: mo_mqtt_client TYPE REF TO if_mqtt_client.

El creador de URL lleva el agente de HiveMQ MQTT y el caso del controlador de eventos al modo de fábrica CREATE_BY_URL, que restaura un nuevo objeto Cliente MQTT MO_MQTT_CLIENT. Finalmente, se establece un vínculo con el agente de mensajería especificado.

Pegue el siguiente método en su aplicación de clase.

METHOD constructor.
  TRY.
      " create MQTT client
      cl_mqtt_client_manager=>create_by_url(
        EXPORTING
          i_url            = 'ws://broker.hivemq.com:8000/mqtt'
          i_event_handler  = me
        RECEIVING
          r_client        = mo_mqtt_client ).

      " establish the connection
      mo_mqtt_client->connect( ).
    CATCH cx_mqtt_error.
      " to do: error handling, e.g. write error log!
  ENDTRY.
ENDMETHOD.

Hecho

Inicie sesión para responder la pregunta

Deja un comentario

Tu dirección de correo electrónico no será publicada. Los campos obligatorios están marcados con *