Paho MQTT Client example with W7500
Dependencies: DHT MQTTforLecture WIZnetInterface mbed-src
Fork of w7500-paho-mqtt by
Code
WIZwiki W7500 with paho mqtt client.
Import programw7500-paho-mqtt
Paho MQTT Client example with W7500
You have to change
You have to use your ethernet(network) information.
MQTTEthernet.h
uint8_t mac_addr[6] = {0x00, 0x08, 0xDC, 0x00, 0x00, 0x00}; // your mac address const char * ip_addr = "???.???.???.???"; // your ip const char * gw_addr = "???.???.???.???"; // your gateway const char * snmask = "???.???.???.???"; // your subnetmask
And you have to use your mqtt broker server information. Broker server ip address and port number listed bleow are available now. But I will close the mqtt broker server on July 15,2015.
main.cpp
char* hostname = "104.199.146.45"; int port = 1883;
Platform
WIZwiki W7500 [ https://developer.mbed.org/platforms/WIZwiki-W7500/ ]
Component
YWRobot Easy module shield [ where to buy ] (This is not mbed component)
Test software
PC
MQTT-FX - A JavaFX based MQTT Client [ Home page ]
Mobile(iPhone)
ZMQTT-UTILITY - MQTT Test utility|You can download from App store(iPhone).
Diff: main.cpp
- Revision:
- 7:a5ead1402704
- Parent:
- 3:36fd3cfad85a
- Child:
- 8:f837e0d255e8
--- a/main.cpp Tue Jun 04 16:07:06 2013 +0100 +++ b/main.cpp Mon May 04 22:47:02 2015 +0000 @@ -7,7 +7,7 @@ EthernetInterface eth; eth.init(); //Use DHCP eth.connect(); - printf("IP Address is %s\n", eth.getIPAddress()); + printf("\nServer IP Address is %s\n", eth.getIPAddress()); TCPSocketServer server; server.bind(ECHO_SERVER_PORT); @@ -25,6 +25,22 @@ int n = client.receive(buffer, sizeof(buffer)); if (n <= 0) break; + // print received message to terminal + buffer[n] = '\0'; + printf("Received message from Client :'%s'\n",buffer); + + // reverse the message + char temp; + for(int f = 0, l = n-1; f<l; f++,l--){ + temp = buffer[f]; + buffer[f] = buffer[l]; + buffer[l] = temp; + } + + // print reversed message to terminal + printf("Sending message to Client: '%s'\n",buffer); + + // Echo received message back to client client.send_all(buffer, n); if (n <= 0) break; }