The Message Queuing Telemetry Transport ( MQTT ) protocol defines a lightweight and simple and lightweight messaging protocol designed for limited devices and networks with low bandwidth, unreliable networks or high latency, or unreliable networks. The MQTT client uses publish and subscribe methods to communicate over a TCP connection with the MQTT message broker (hereinafter referred to as the MQTT server).
| Info |
|---|
MQTT AT commands are implemented according to MQTT version 3.1.1. |
| Note |
|---|
Secure MQTT is not supported |
1. Example: Unencrypted, unauthenticated
| Code Block | ||
|---|---|---|
| ||
# Translates a domain name into an IP address using an existing DNS. > AT+UDNSRN=0,"broker.emqx.io" < +UDNSRN: "3.82.39.163", "44.195.202.69" < OK # Enable URCs > AT+CEREG=2 < OK # Read network registration status > AT+CEREG? < +CEREG: 2,2 < OK # Read network registration status. Wait of +CEREG: 2,5... > AT+CEREG? < +CEREG: 2,5,"AB80","819965",9 < OK # Check the module connected to the network > AT+CGATT? < +CGATT: 1 < OK # Check to see if the PDP context has been activated. > AT+CGACT? < +CGACT: 1,1 < OK # Read IP address from module > AT+CGDCONT? < +CGDCONT: 1,"IP","vgesace.nb.iot","10.254.46.241",0,0,0,0,0,0 < OK # Set MQTT unique client ID. In the example IMEI from device > AT+UMQTT=0,"350857128129037" < +UMQTT: 0,1 < OK # Set MQTT local TCP port number > AT+UMQTT=1,1883 < +UMQTT: 1,1 < OK # Set remote MQTT server's name > AT+UMQTT=2,"broker.emqx.io" < +UMQTT: 2,1 < OK # Set remote MQTT server's IP address > AT+UMQTT=3,"44.195.202.69",1883 < +UMQTT: 3,1 < OK # Connect to the broker > AT+UMQTTC=1 < +UMQTTC: 1,1 < OK < +UUMQTTC: 1,0 """ Repeat the command "AT+UMQTTC=1" if the URC "+UUMQTTC: 1,0" does not arrive. """ # Subscribe to MQTT topic filter > AT+UMQTTC=4,0,"/exelonix/test" < +UMQTTC: 4,1 < OK < +UUMQTTC: 4,1,0,"/exelonix/test" # Publish MQTT message to topic name > AT+UMQTTC=2,0,0,"/exelonix/test","MQTT message" < +UMQTTC: 2,1 < OK # Wait of asynchronous notification (URC) of the reception of an MQTT message < +UUMQTTCM: 6,1 # Read MQTT messages received > AT+UMQTTC=6 < +UMQTTC: 6,1 < OK < +UUMQTTCM: 6,1 < Topic:/exelonix/test < Msg:MQTT message # Disconnect from the broker > AT+UMQTTC=0 < +UMQTTC: 0,1 < OK |
2. Example: Unencrypted, authenticated
| Code Block |
|---|
# Translates a domain name into an IP address using an existing DNS. > AT+UDNSRN=0,"test.mosquitto.org" < +UDNSRN: "91.121.93.94" < OK # Enable URCs > AT+CEREG=2 < OK # Read network registration status > AT+CEREG? < +CEREG: 2,2 < OK # Read network registration status. Wait of +CEREG: 2,5... > AT+CEREG? < +CEREG: 2,5,"A9F0","819901",7 < OK # Check the module connected to the network > AT+CGATT? < +CGATT: 1 < OK # Check to see if the PDP context has been activated. > AT+CGACT? < +CGACT: 1,1 < OK # Read IP address from module > AT+CGDCONT? < +CGDCONT: 1,"IP","vgesace.nb.iot","10.254.46.27",0,0,0,0,0,0 < OK # Set MQTT unique client ID. In the example IMEI from device AT+UMQTT=0,"350857128129037" +UMQTT: 0,1 OK # Set MQTT local TCP port number AT+UMQTT=1,1884 +UMQTT: 1,1 OK # Set remote MQTT server's name AT+UMQTT=2,"test.mosquitto.org" +UMQTT: 2,1 OK # Set remote MQTT server's IP address AT+UMQTT=3,"91.121.93.94",1884 +UMQTT: 3,1 OK # Set User name and password AT+UMQTT=4,"rw","readwrite" +UMQTT: 4,1 OK # Connect to the broker AT+UMQTTC=1 +UMQTTC: 1,1 OK +UUMQTTC: 1,0 """ Repeat the command "AT+UMQTTC=1" if the URC "+UUMQTTC: 1,0" does not arrive. """ # Subscribe to MQTT topic filter AT+UMQTTC=4,0,"/exelonix/test" +UMQTTC: 4,1 OK +UUMQTTC: 4,1,0,"/exelonix/test" # Publish MQTT message to topic name AT+UMQTTC=2,0,0,"/exelonix/test","MQTT message" +UMQTTC: 2,1 OK # Wait of asynchronous notification (URC) of the reception of an MQTT message +UUMQTTCM: 6,1 # Read MQTT messages received AT+UMQTTC=6 +UMQTTC: 6,1 OK +UUMQTTCM: 6,1 Topic:/exelonix/test Msg:MQTT message # Disconnect from the broker > AT+UMQTTC=0 < +UMQTTC: 0,1 < OK |