Saltar al contenido

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