gs fan / Mbed 2 deprecated GSwifiInterface_HelloMQTT

Sample MQTT program - simple send and receive (MQ Telemetry Transport) for GainSpan Wi-Fi module

Dependencies:   C12832 GSwifiInterface MQTT mbed-rtos mbed

Fork of HelloMQTT by MQTT

mbedのMQTTグループで保守されているMQTTライブラリを GainSpan Wi-Fi モジュールへ対応させたサンプルです。

MQTT (MQ Telemetry Transport) とは、IoTやM2M向け デバイス間通信のためのプロトコルです。

MQTTサーバーには http://iot.eclipse.org/ のサンドボックスを使います。 送信したメッセージをエコーバックしてくるだけの動作をします。

mbed Application Board を使う場合は次の行のコメントアウトを外すとLCDへ表示するようになる。

#define MBED_APPLICATION_BOARD

GainSpanモジュールの接続ピンについては次の行で指定する。

    gs = new GSwifiInterface(p9, p10, NC, NC, p30, NC, 9600); //tx, rx, cts, rts, reset, alarm, baud

Wi-Fiアクセスポイントは次の行で指定する。

#define SEC  GSwifi::SEC_WPA_PSK
#define SSID "SSID"
#define PASS "PASSPHRASE"

Diff: main.cpp

Revision:
16:fd155e824a80
Parent:
12:086a9314e8a5
--- a/main.cpp	Fri Aug 01 23:46:08 2014 +0000
+++ b/main.cpp	Thu Oct 02 03:26:56 2014 +0000
@@ -23,22 +23,43 @@
   system libraries.
  
  */
+/*
+ * Supported for GsinSpan Wi-Fi Module.
+ * Modified by gsfan
+ *   src: http://developer.mbed.org/teams/mqtt/code/HelloMQTT/
+ */
+
+#include "mbed.h"
+#include "GSwifiInterface.h"
+
+//#define MBED_APPLICATION_BOARD
+
+#define SEC  GSwifi::SEC_WPA_PSK
+#define SSID "SSID"
+#define PASS "PASSPHRASE"
 
 
+#ifdef MBED_APPLICATION_BOARD
 #include "C12832.h"
 C12832 lcd(p5, p7, p6, p8, p11);
+#else
+#define lcd pc
+#endif
 
-#include "MQTTEthernet.h"
+#include "MQTTGSwifi.h"
 #include "MQTTClient.h"
 
 int arrivedcount = 0;
-
+GSwifiInterface *gs;
+Serial pc(USBTX, USBRX);
 
 void messageArrived(MQTT::MessageData& md)
 {
     MQTT::Message &message = md.message;
+#ifdef MBED_APPLICATION_BOARD
     lcd.cls();
     lcd.locate(0,3);
+#endif
     printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\n", message.qos, message.retained, message.dup, message.id);
     printf("Payload %.*s\n", message.payloadlen, (char*)message.payload);
     ++arrivedcount;
@@ -48,14 +69,23 @@
 
 int main(int argc, char* argv[])
 {   
-    MQTTEthernet ipstack = MQTTEthernet();
+    pc.baud(115200);
+//    gs = new GSwifiInterface(p13, p14, p12, P0_22, p21, NC, 115200); //tx, rx, cts, rts, reset, alarm, baud
+    gs = new GSwifiInterface(p9, p10, NC, NC, p30, NC, 9600); //tx, rx, cts, rts, reset, alarm, baud
+    wait_ms(200);
+    lcd.printf("Connecting...\n");
+    gs->init(); //Use DHCP
+    if (gs->connect(SEC, SSID, PASS)) return -1; // join the network
+    lcd.printf("IP Address is %s\n", gs->getIPAddress());
+
+    MQTTGSwifi ipstack = MQTTGSwifi(gs);
     float version = 0.47;
     char* topic = "mbed-sample";
     
     lcd.printf("Version is %f\n", version);
     printf("Version is %f\n", version);
               
-    MQTT::Client<MQTTEthernet, Countdown> client = MQTT::Client<MQTTEthernet, Countdown>(ipstack);
+    MQTT::Client<MQTTGSwifi, Countdown> client = MQTT::Client<MQTTGSwifi, Countdown>(ipstack);
     
     char* hostname = "m2m.eclipse.org";
     int port = 1883;
@@ -124,8 +154,10 @@
     
     ipstack.disconnect();
     
+#ifdef MBED_APPLICATION_BOARD
     lcd.cls();
     lcd.locate(0,3);
+#endif
     lcd.printf("Version %.2f: finish %d msgs\n", version, arrivedcount);
     printf("Finishing with %d messages received\n", arrivedcount);