MQTTで始めるIoTデバイスの作り方 第5回：部屋の明るさを「パブリッシュ」する：MQTTで始めるIoTデバイスづくり（5）（3/5 ページ）

» 2016年07月21日 07時00分 公開
[今岡通博，MONOist]
前のページへ 1|2|3|4|5 次のページへ

　次のリストが部屋の明るさをフォトセンサーで捉えて、MQTTのパブリッシュメッセージを定期的に送出するプログラムです。

  1. #include <SoftwareSerial.h>
  2. SoftwareSerial mySerial(10, 11); // RX, TX
  3. byte con[]={0x10,0x21,0x00,0x06,'M','Q','I','s','d','p',0x03,0x02,0x00,0x3c,0x00,0x13,'m','o','s','q','s','u','b','/','1','2','5','1','6','-','h','i','r','o','3'};
  4. byte pub[]={0x30,0x11,0x00,0x0b,'a','r','d','u','i','n','o','/','a','2','/','0','0','0','0'};
  5.  
  6. void getResponse(int j){
  7.   int i;
  8.   for (i=0;i<j;i++){
  9.       if (mySerial.available())
  10.          Serial.write(mySerial.read());
  11.       delay(1);
  12.     }
  13.   }
  14. void setup()
  15. {
  16.   int i,j;
  17.   Serial.begin(9600);
  18.   mySerial.begin(9600); 
  19.   while(!Serial);
  20.   mySerial.print("AT+RST\r\n");
  21.   getResponse(5000);
  22.   mySerial.print("AT+CIPSTART=\"TCP\",\"192.168.1.16\",1883\r\n");
  23.   getResponse(1000);
  24.   mySerial.print("AT+CIPSEND=35\r\n");
  25.   getResponse(1000);
  26.   for (i=0;i<35;i++)mySerial.write(con[i]);                  
  27.   getResponse(1000); 
  28. }
  29. void loop(){
  30.   int i,v,n;
  31.   mySerial.print("AT+CIPSEND=19\r\n");
  32.   getResponse(1000);  
  33.   v = analogRead(2);
  34.   n=int(v/1000);
  35.   pub[15]='0'+n;
  36.   v = v -(n*1000);
  37.   n=int(v/100);
  38.   pub[16]='0'+n;
  39.   v = v - (n*100);
  40.   n=int(v/10);
  41.   pub[17]='0'+n;
  42.   v = v - (n*10);
  43.   pub[18]='0'+v;
  44.   for (i=0;i<19;i++)mySerial.write(pub[i]); 
  45.   getResponse(1000);  
  46. }

関連キーワード

IoT | マイコン 関連 | Arduino | Wireshark | MQTT（Message Queue Telemetry Transport）

前のページへ 1|2|3|4|5 次のページへ

Copyright © ITmedia, Inc. All Rights Reserved.

TechFactory 驛｢譎擾ｽｸ蜴･�｡驛｢�ｧ�ｽ�､驛｢譎冗樟�ｽ�ｽ驛｢譎｢�ｽ�ｼ驛｢譏懶ｽｻ�｣�ｽ�ｽ髫ｴ�ｽ�ｽ�ｰ鬨ｾ�ｹ�つ€髫ｲ�ｽ�ｽ�ｽ�ｽ�ｽ�ｽ�ｱ